sql-api-private.h revision bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77
c25356d5978632df6203437e1953bcb29e0c736fTimo Sirainen#ifndef SQL_API_PRIVATE_H
c25356d5978632df6203437e1953bcb29e0c736fTimo Sirainen#define SQL_API_PRIVATE_H
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen#include "sql-api.h"
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainen#include "module-context.h"
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainenstruct sql_db_module_register {
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainen unsigned int id;
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainen};
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainen
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainenunion sql_db_module_context {
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainen struct sql_db_module_register *reg;
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainen};
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainenextern struct sql_db_module_register sql_db_module_register;
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainen
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainenstruct sql_db_vfuncs {
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct sql_db *(*init)(const char *connect_string);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen void (*deinit)(struct sql_db *db);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
ccffb125d94adff0ad776de5a96e22f864d6fb0aTimo Sirainen enum sql_db_flags (*get_flags)(struct sql_db *db);
ccffb125d94adff0ad776de5a96e22f864d6fb0aTimo Sirainen
a0b89f3b1df99b3a32f44623f13ad1893118825bTimo Sirainen int (*connect)(struct sql_db *db);
13a8c553f293349248b161ff851743498916e26eTimo Sirainen const char *(*escape_string)(struct sql_db *db, const char *string);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen void (*exec)(struct sql_db *db, const char *query);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen void (*query)(struct sql_db *db, const char *query,
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen sql_query_callback_t *callback, void *context);
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen struct sql_result *(*query_s)(struct sql_db *db, const char *query);
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen struct sql_transaction_context *(*transaction_begin)(struct sql_db *db);
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen void (*transaction_commit)(struct sql_transaction_context *ctx,
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen sql_commit_callback_t *callback,
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen void *context);
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen int (*transaction_commit_s)(struct sql_transaction_context *ctx,
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen const char **error_r);
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen void (*transaction_rollback)(struct sql_transaction_context *ctx);
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen void (*update)(struct sql_transaction_context *ctx, const char *query,
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen unsigned int *affected_rows);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen};
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainenstruct sql_db {
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainen const char *name;
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainen struct sql_db_vfuncs v;
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainen ARRAY_DEFINE(module_contexts, union sql_db_module_context *);
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainen};
0ae010139a1bb3b29fbf117c5da1a6a6c6b7b5a0Timo Sirainen
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainenstruct sql_result_vfuncs {
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen void (*free)(struct sql_result *result);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen int (*next_row)(struct sql_result *result);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen unsigned int (*get_fields_count)(struct sql_result *result);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen const char *(*get_field_name)(struct sql_result *result,
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen unsigned int idx);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen int (*find_field)(struct sql_result *result, const char *field_name);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen const char *(*get_field_value)(struct sql_result *result,
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen unsigned int idx);
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen const unsigned char *
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen (*get_field_value_binary)(struct sql_result *result,
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen unsigned int idx,
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen size_t *size_r);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen const char *(*find_field_value)(struct sql_result *result,
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen const char *field_name);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen const char *const *(*get_values)(struct sql_result *result);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen const char *(*get_error)(struct sql_result *result);
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen};
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainenstruct sql_field_map {
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen enum sql_field_type type;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen size_t offset;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen};
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainenstruct sql_result {
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen struct sql_result_vfuncs v;
3656c91dcb8336814bebd4500e81c3dde25233e6Timo Sirainen int refcount;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen struct sql_db *db;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen const struct sql_field_def *fields;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen unsigned int map_size;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen struct sql_field_map *map;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen void *fetch_dest;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen size_t fetch_dest_size;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen unsigned int callback:1;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen};
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainenstruct sql_transaction_context {
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen struct sql_db *db;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen};
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
8d80659e504ffb34bb0c6a633184fece35751b18Timo SirainenARRAY_DEFINE_TYPE(sql_drivers, const struct sql_db *);
8d80659e504ffb34bb0c6a633184fece35751b18Timo Sirainen
8d80659e504ffb34bb0c6a633184fece35751b18Timo Sirainenextern ARRAY_TYPE(sql_drivers) sql_drivers;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenextern struct sql_result sql_not_connected_result;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen#endif