afsql.c File Reference

#include "afsql.h"
#include "logqueue.h"
#include "template/templates.h"
#include "messages.h"
#include "string-list.h"
#include "str-format.h"
#include "seqnum.h"
#include "stats/stats-registry.h"
#include "apphook.h"
#include "mainloop-worker.h"
#include "str-utils.h"
#include <string.h>
#include <errno.h>
#include "compat/openssl_support.h"
#include <openssl/evp.h>

Include dependency graph for afsql.c:

Macros
#define	MAX_FAILED_ATTEMPTS   3

Functions
void	afsql_dd_add_dbd_option (LogDriver *s, const gchar *name, const gchar *value)
void	afsql_dd_add_dbd_option_numeric (LogDriver *s, const gchar *name, gint value)
void	afsql_dd_set_dbi_driver_dir (LogDriver *s, const gchar *dbi_driver_dir)
void	afsql_dd_set_quote_char (LogDriver *s, const gchar *quote_str)
void	afsql_dd_set_type (LogDriver *s, const gchar *type)
void	afsql_dd_set_host (LogDriver *s, const gchar *host)
void	afsql_dd_set_port (LogDriver *s, const gchar *port)
void	afsql_dd_set_user (LogDriver *s, const gchar *user)
void	afsql_dd_set_password (LogDriver *s, const gchar *password)
void	afsql_dd_set_database (LogDriver *s, const gchar *database)
void	afsql_dd_set_table (LogDriver *s, LogTemplate *table_template)
void	afsql_dd_set_columns (LogDriver *s, GList *columns)
void	afsql_dd_set_indexes (LogDriver *s, GList *indexes)
void	afsql_dd_set_values (LogDriver *s, GList *values)
void	afsql_dd_set_null_value (LogDriver *s, const gchar *null)
void	afsql_dd_set_ignore_tns_config (LogDriver *s, const gboolean ignore_tns_config)
void	afsql_dd_set_session_statements (LogDriver *s, GList *session_statements)
void	afsql_dd_set_create_statement_append (LogDriver *s, const gchar *create_statement_append)
LogDriver *	afsql_dd_new (GlobalConfig *cfg)
gboolean	afsql_dd_process_flag (LogDriver *driver, const gchar *flag)

Variables
CfgFlagHandler	afsql_dd_flag_handlers []

Macro Definition Documentation

MAX_FAILED_ATTEMPTS

#define MAX_FAILED_ATTEMPTS   3

Function Documentation

afsql_dd_add_dbd_option()

void afsql_dd_add_dbd_option	(	LogDriver *	s,
		const gchar *	name,
		const gchar *	value
	)

afsql_dd_add_dbd_option_numeric()

void afsql_dd_add_dbd_option_numeric	(	LogDriver *	s,
		const gchar *	name,
		gint	value
	)

afsql_dd_new()

LogDriver* afsql_dd_new

(

GlobalConfig *

cfg

)

afsql_dd_process_flag()

gboolean afsql_dd_process_flag	(	LogDriver *	driver,
		const gchar *	flag
	)

afsql_dd_set_columns()

void afsql_dd_set_columns	(	LogDriver *	s,
		GList *	columns
	)

afsql_dd_set_create_statement_append()

void afsql_dd_set_create_statement_append	(	LogDriver *	s,
		const gchar *	create_statement_append
	)

afsql_dd_set_database()

void afsql_dd_set_database	(	LogDriver *	s,
		const gchar *	database
	)

afsql_dd_set_dbi_driver_dir()

void afsql_dd_set_dbi_driver_dir	(	LogDriver *	s,
		const gchar *	dbi_driver_dir
	)

afsql_dd_set_host()

void afsql_dd_set_host	(	LogDriver *	s,
		const gchar *	host
	)

afsql_dd_set_ignore_tns_config()

void afsql_dd_set_ignore_tns_config	(	LogDriver *	s,
		const gboolean	ignore_tns_config
	)

afsql_dd_set_indexes()

void afsql_dd_set_indexes	(	LogDriver *	s,
		GList *	indexes
	)

afsql_dd_set_null_value()

void afsql_dd_set_null_value	(	LogDriver *	s,
		const gchar *	null
	)

afsql_dd_set_password()

void afsql_dd_set_password	(	LogDriver *	s,
		const gchar *	password
	)

afsql_dd_set_port()

void afsql_dd_set_port	(	LogDriver *	s,
		const gchar *	port
	)

afsql_dd_set_quote_char()

void afsql_dd_set_quote_char	(	LogDriver *	s,
		const gchar *	quote_str
	)

afsql_dd_set_session_statements()

void afsql_dd_set_session_statements	(	LogDriver *	s,
		GList *	session_statements
	)

afsql_dd_set_table()

void afsql_dd_set_table	(	LogDriver *	s,
		LogTemplate *	table_template
	)

afsql_dd_set_type()

void afsql_dd_set_type	(	LogDriver *	s,
		const gchar *	type
	)

afsql_dd_set_user()

void afsql_dd_set_user	(	LogDriver *	s,
		const gchar *	user
	)

afsql_dd_set_values()

void afsql_dd_set_values	(	LogDriver *	s,
		GList *	values
	)

Variable Documentation

afsql_dd_flag_handlers

CfgFlagHandler afsql_dd_flag_handlers[]

Initial value:

=
{
  { "explicit-commits",   CFH_SET, offsetof(LogThreadedDestDriver, flags), AFSQL_DDF_EXPLICIT_COMMITS },
  { "dont-create-tables", CFH_SET, offsetof(LogThreadedDestDriver, flags), AFSQL_DDF_DONT_CREATE_TABLES },
  { NULL },
}