]> jfr.im git - irc/quakenet/newserv.git/blame_incremental - dbapi/dbapi.h
DBAPI2: add support for stored procedures
[irc/quakenet/newserv.git] / dbapi / dbapi.h
... / ...
CommitLineData
1#ifndef __DBAPI_H
2#define __DBAPI_H
3
4#ifndef DBAPI2_ADAPTER
5#include "../config.h"
6#endif
7
8#define DB_NULLIDENTIFIER 0
9#define DB_CREATE 1
10#define DB_CALL 2
11
12#ifdef DBAPI_OVERRIDE
13#undef USE_DBAPI_PGSQL
14#undef USE_DBAPI_SQLITE
15#endif
16
17#ifndef BUILDING_DBAPI
18
19#if defined(USE_DBAPI_PGSQL) || defined(DBAPI_OVERRIDE_PGSQL)
20
21#include "../pqsql/pqsql.h"
22
23typedef PQModuleIdentifier DBModuleIdentifier;
24typedef PGconn DBConn;
25typedef PQQueryHandler DBQueryHandler;
26typedef PQResult DBResult;
27
28#define dbconnected() pqconnected()
29#define dbgetid() pqgetid()
30#define dbfreeid(x) pqfreeid(x)
31
32#define dbattach(schema) pqcreateschema(schema)
33#define dbdetach(schema)
34#define dbescapestring(buf, src, len) PQescapeString(buf, src, len)
35#define dbloadtable(tablename, init, data, fini) pqloadtable(tablename, init, data, fini, NULL);
36#define dbloadtable_tag(tablename, init, data, fini, tag) pqloadtable(tablename, init, data, fini, tag);
37
38#define dbasyncqueryf(id, handler, tag, flags, format, ...) pqasyncqueryf(id, handler, tag, flags, format , ##__VA_ARGS__)
39#define dbquerysuccessful(x) pqquerysuccessful(x)
40#define dbgetresult(conn) pqgetresult(conn)
41#define dbnumfields(x) PQnfields(x->result)
42
43#define dbfetchrow(result) pqfetchrow(result)
44#define dbgetvalue(result, column) pqgetvalue(result, column)
45
46#define dbclear(result) pqclear(result)
47#define dbcall(id, handler, tag, function, ...) pqasyncqueryf(id, handler, tag, (handler) == NULL ? DB_CALL : 0, "SELECT %s(%s)", function , ##__VA_ARGS__)
48
49#endif /* DBAPI_PGSQL */
50
51#if defined(USE_DBAPI_SQLITE) || defined(DBAPI_OVERRIDE_SQLITE)
52
53#include "../sqlite/sqlite.h"
54
55typedef SQLiteModuleIdentifier DBModuleIdentifier;
56typedef SQLiteConn DBConn;
57typedef SQLiteQueryHandler DBQueryHandler;
58typedef SQLiteResult DBResult;
59
60#define dbconnected() sqliteconnected()
61#define dbgetid() sqlitegetid()
62#define dbfreeid(x) sqlitefreeid(x)
63
64#define dbattach(schema) sqliteattach((schema))
65#define dbdetach(schema) sqlitedetach((schema))
66#define dbescapestring(buf, src, len) sqliteescapestring(buf, (char *)(src), len)
67#define dbloadtable(tablename, init, data, fini) sqliteloadtable(tablename, init, data, fini, NULL);
68#define dbloadtable_tag(tablename, init, data, fini, tag) sqliteloadtable(tablename, init, data, fini, tag);
69
70#define dbasyncqueryf(id, handler, tag, flags, format, ...) sqliteasyncqueryf(id, handler, tag, flags, format , ##__VA_ARGS__)
71#define dbquerysuccessful(x) sqlitequerysuccessful(x)
72#define dbgetresult(conn) sqlitegetresult(conn)
73#define dbnumfields(x) sqlite3_column_count(x->r)
74
75#define dbfetchrow(result) sqlitefetchrow(result)
76#define dbgetvalue(result, column) sqlitegetvalue(result, column)
77
78#define dbclear(result) sqliteclear(result)
79
80#define dbcall(...) abort() /* HA */
81
82#endif /* DBAPI_SQLITE */
83
84#endif /* BUILDING_DBAPI */
85
86#define dbasyncqueryi(identifier, handler, tag, format, ...) dbasyncqueryf(identifier, handler, tag, 0, format , ##__VA_ARGS__)
87#define dbasyncquery(handler, tag, format, ...) dbasyncqueryf(DB_NULLIDENTIFIER, handler, tag, 0, format , ##__VA_ARGS__)
88#define dbcreatequery(format, ...) dbasyncqueryf(DB_NULLIDENTIFIER, NULL, NULL, DB_CREATE, format , ##__VA_ARGS__)
89#define dbquery(format, ...) dbasyncqueryf(DB_NULLIDENTIFIER, NULL, NULL, 0, format , ##__VA_ARGS__)
90
91#endif /* __DBAPI_H */