#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <values.h>
#include "sqlitehandler.h"
Defines | |
| #define | DOCONNECT |
| #define | MAX_LINE_LEN 1024 |
| #define | SQLERROR |
Functions | |
| aw_sqlitehandler_t * | aw_create_sqlitehandler (const aw_sqlite_cinfo_t *cinfo, const byte_t *sql, const byte_t *desc, aw_db_cevents_t *cevents, u_int32_t nregexs, const aw_db_regex_t *regexs, u_int32_t ncounters, const aw_db_counter_t *counters, int32_t(*regevent)(aw_handler_t *h, aw_address_t *eventid, u_int32_t index), int32_t(*regmaskevent)(aw_handler_t *h, aw_address_t *eventid, u_int32_t index), const aw_alarm_sched_t *sched, aw_logger_t *elogger) |
| Create a sqlite handler. | |
| void | aw_free_sqlitehandler (aw_sqlitehandler_t *mh) |
| Free handler and all associated resources. | |
| aw_handler_t * | aw_wire_sqlitehandler (aw_wire_mkhandler_args_t *args) |
| Create a sqlitehandler using "wire". See header doc for keyword documentation. | |
|
|
Value: {\
db_connect(mh); \
\
if ( mh->state.connected != 1 ) { \
aw_log(args->h->logger, AW_ERROR_LOG_LEVEL, "sqlitehandler could not connect to %s: %s", \
mh->cinfo.db, \
sqlite3_errmsg(mh->state.conn)); \
closedb=1; \
goto done; \
}/* end if */ \
}
|
|
|
|
|
|
Value: {\
aw_log(args->h->logger, AW_ERROR_LOG_LEVEL, "sqlitehandler sql cmd error: %s for %s", \
sqlite3_errmsg(mh->state.conn), line); \
if (pStmt != NULL) sqlite3_finalize(pStmt); \
pStmt = NULL; \
closedb=1; \
/* return connection to pool */ \
db_disconnect(mh,closedb);\
/* try reconnect */\
DOCONNECT; \
}
|
|
||||||||||||||||||||||||||||||||||||||||||||||||||||
|
Create a sqlite handler. aw_create_sqlitehandler
|
|
|
Free handler and all associated resources. aw_free_sqlitehandler
|
|
|
Create a sqlitehandler using "wire". See header doc for keyword documentation. aw_wire_sqlitehandler |