X-Git-Url: https://jfr.im/git/irc/quakenet/newserv.git/blobdiff_plain/664aeff392777d5887852b6f91fda7449b098aab..c33a5aa269a9ae7bb419857cc1b0e17c1d70e21e:/pqsql/pqsql.h

diff --git a/pqsql/pqsql.h b/pqsql/pqsql.h
index 3f92e595..6f885e2e 100644
--- a/pqsql/pqsql.h
+++ b/pqsql/pqsql.h
@@ -3,16 +3,39 @@
 
 #include <libpq-fe.h>
 
-#define QH_CREATE 0x01
+#define PQ_ERRORMSG_LENGTH 1024
 
+#define QH_ALREADYFIRED 1
+
+typedef struct PQResult {
+  PGresult *result;
+  int row;
+  int rows;
+} PQResult;
+
+typedef int PQModuleIdentifier;
 typedef void (*PQQueryHandler)(PGconn *, void *);
 
-void pqasyncqueryf(PQQueryHandler handler, void *tag, int flags, char *format, ...);
+void pqloadtable(char *tablename, PQQueryHandler init, PQQueryHandler data, PQQueryHandler fini, void *tag);
 
-#define pqasyncquery(handler, tag, format, ...) pqasyncqueryf(handler, tag, 0, format , ##__VA_ARGS__)
-#define pqcreatequery(format, ...) pqasyncqueryf(NULL, NULL, QH_CREATE, format , ##__VA_ARGS__)
-#define pqquery(format, ...) pqasyncquery(NULL, NULL, format , ##__VA_ARGS__)
+void pqasyncqueryf(PQModuleIdentifier identifier, PQQueryHandler handler, void *tag, int flags, char *format, ...) __attribute__ ((format (printf, 5, 6)));
+#define pqasyncqueryi(identifier, handler, tag, format, ...) pqasyncqueryf(identifier, handler, tag, 0, format , ##__VA_ARGS__)
+#define pqasyncquery(handler, tag, format, ...) pqasyncqueryf(DB_NULLIDENTIFIER, handler, tag, 0, format , ##__VA_ARGS__)
+#define pqcreatequery(format, ...) pqasyncqueryf(DB_NULLIDENTIFIER, NULL, NULL, DB_CREATE, format , ##__VA_ARGS__)
+#define pqquery(format, ...) pqasyncqueryf(DB_NULLIDENTIFIER, NULL, NULL, 0, format , ##__VA_ARGS__)
 
 int pqconnected(void);
 
+PQModuleIdentifier pqgetid(void);
+void pqfreeid(PQModuleIdentifier identifier);
+
+#define pqquerysuccessful(x) (x && (PQresultStatus(x->result) == PGRES_TUPLES_OK))
+
+PQResult *pqgetresult(PGconn *c);
+int pqfetchrow(PQResult *res);
+char *pqgetvalue(PQResult *res, int column);
+void pqclear(PQResult *res);
+
+#define pqcreateschema(schema) pqcreatequery("CREATE SCHEMA %s;", schema)
+
 #endif