dovecot/core-2.2: src/lib-sql/sql-api.c annotate

annotate src/lib-sql/sql-api.c @ 11261:1c8cc349ef55 HEAD

lib-sql: Use generic sql connection pooling code for mysql/pgsql. It's possible to give multiple host settings to do load balancing / HA. If one host is down, another one is tried. All queries are automatically retried in another host if they fail in first one. Since PostgreSQL support async queries, Dovecot can create multiple connections to the database as needed, so it can do lookups in parallel. The number of connections can be changed with maxconns=n in connect_query, the default is 5.

author	Timo Sirainen <tss@iki.fi>
date	Tue, 04 May 2010 17:55:23 +0300
parents	260e190306b0
children	11538925cbbb

rev	line source
10582 615eef3139c2 Updated copyright notices to include year 2010. Timo Sirainen <tss@iki.fi> parents: 10410 diff changeset	1 /* Copyright (c) 2004-2010 Dovecot authors, see the included COPYING file */
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	2
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	3 #include "lib.h"
3943 cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	4 #include "array.h"
11261 1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	5 #include "ioloop.h"
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	6 #include "sql-api-private.h"
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	7
5496 72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	8 #include <stdlib.h>
11261 1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	9 #include <time.h>
5496 72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	10
6478 1e07f47e5e1e Added sql_db_module_register for module_contexts users. Timo Sirainen <tss@iki.fi> parents: 6476 diff changeset	11 struct sql_db_module_register sql_db_module_register = { 0 };
4451 1a35d53c18fc Array API redesigned to work using unions. It now provides type safety Timo Sirainen <tss@iki.fi> parents: 4294 diff changeset	12 ARRAY_TYPE(sql_drivers) sql_drivers;
3943 cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	13
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	14 void sql_drivers_init(void)
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	15 {
4596 bf4e98a0de3f Replaced ARRAY_CREATE() macro with [ipt]_array_init() macros. The macro Timo Sirainen <tss@iki.fi> parents: 4594 diff changeset	16 i_array_init(&sql_drivers, 8);
3943 cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	17 }
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	18
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	19 void sql_drivers_deinit(void)
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	20 {
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	21 array_free(&sql_drivers);
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	22 }
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	23
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	24 void sql_driver_register(const struct sql_db *driver)
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	25 {
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	26 array_append(&sql_drivers, &driver, 1);
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	27 }
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	28
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	29 void sql_driver_unregister(const struct sql_db *driver)
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	30 {
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	31 const struct sql_db const drivers;
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	32 unsigned int i, count;
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	33
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	34 drivers = array_get(&sql_drivers, &count);
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	35 for (i = 0; i < count; i++) {
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	36 if (drivers[i] == driver) {
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	37 array_delete(&sql_drivers, i, 1);
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	38 break;
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	39 }
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	40 }
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	41 }
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	42
11261 1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	43 static const struct sql_db sql_find_driver(const char name)
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	44 {
3943 cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	45 const struct sql_db const drivers;
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	46 unsigned int i, count;
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	47
3943 cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	48 drivers = array_get(&sql_drivers, &count);
cbe5c6772e0d Added support for dynamically building SQL drivers. Timo Sirainen <tss@iki.fi> parents: 3919 diff changeset	49 for (i = 0; i < count; i++) {
11261 1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	50 if (strcmp(drivers[i]->name, name) == 0)
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	51 return drivers[i];
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	52 }
11261 1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	53 return NULL;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	54 }
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	55
11261 1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	56 struct sql_db sql_init(const char db_driver, const char *connect_string)
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	57 {
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	58 const struct sql_db *driver;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	59 struct sql_db *db;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	60
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	61 i_assert(connect_string != NULL);
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	62
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	63 driver = sql_find_driver(db_driver);
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	64 if (driver == NULL)
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	65 i_fatal("Unknown database driver '%s'", db_driver);
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	66
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	67 if ((driver->flags & SQL_DB_FLAG_POOLED) == 0)
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	68 db = driver->v.init(connect_string);
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	69 else
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	70 db = driver_sqlpool_init(connect_string, driver);
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	71 i_array_init(&db->module_contexts, 5);
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	72 return db;
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	73 }
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	74
6474 46c3e1ee196f Added module_contexts to struct sql_db. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	75 void sql_deinit(struct sql_db **_db)
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	76 {
6474 46c3e1ee196f Added module_contexts to struct sql_db. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	77 struct sql_db db = _db;
46c3e1ee196f Added module_contexts to struct sql_db. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	78
46c3e1ee196f Added module_contexts to struct sql_db. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	79 *_db = NULL;
11261 1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	80
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	81 if (db->to_reconnect != NULL)
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	82 timeout_remove(&db->to_reconnect);
6474 46c3e1ee196f Added module_contexts to struct sql_db. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	83 db->v.deinit(db);
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	84 }
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	85
3421 c624ffa9e6f0 Added sql_connect() to do explicit connecting. sql_init() no longer does. Timo Sirainen <tss@iki.fi> parents: 3163 diff changeset	86 enum sql_db_flags sql_get_flags(struct sql_db *db)
c624ffa9e6f0 Added sql_connect() to do explicit connecting. sql_init() no longer does. Timo Sirainen <tss@iki.fi> parents: 3163 diff changeset	87 {
11261 1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	88 return db->flags;
3421 c624ffa9e6f0 Added sql_connect() to do explicit connecting. sql_init() no longer does. Timo Sirainen <tss@iki.fi> parents: 3163 diff changeset	89 }
c624ffa9e6f0 Added sql_connect() to do explicit connecting. sql_init() no longer does. Timo Sirainen <tss@iki.fi> parents: 3163 diff changeset	90
c624ffa9e6f0 Added sql_connect() to do explicit connecting. sql_init() no longer does. Timo Sirainen <tss@iki.fi> parents: 3163 diff changeset	91 int sql_connect(struct sql_db *db)
c624ffa9e6f0 Added sql_connect() to do explicit connecting. sql_init() no longer does. Timo Sirainen <tss@iki.fi> parents: 3163 diff changeset	92 {
11261 1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	93 time_t now;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	94
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	95 switch (db->state) {
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	96 case SQL_DB_STATE_DISCONNECTED:
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	97 break;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	98 case SQL_DB_STATE_CONNECTING:
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	99 return 0;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	100 default:
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	101 return 1;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	102 }
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	103
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	104 /* don't try reconnecting more than once a second */
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	105 now = time(NULL);
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	106 if (db->last_connect_try + (time_t)db->connect_delay > now)
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	107 return -1;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	108 db->last_connect_try = now;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	109
6474 46c3e1ee196f Added module_contexts to struct sql_db. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	110 return db->v.connect(db);
3421 c624ffa9e6f0 Added sql_connect() to do explicit connecting. sql_init() no longer does. Timo Sirainen <tss@iki.fi> parents: 3163 diff changeset	111 }
c624ffa9e6f0 Added sql_connect() to do explicit connecting. sql_init() no longer does. Timo Sirainen <tss@iki.fi> parents: 3163 diff changeset	112
11261 1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	113 void sql_disconnect(struct sql_db *db)
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	114 {
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	115 if (db->to_reconnect != NULL)
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	116 timeout_remove(&db->to_reconnect);
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	117 db->v.disconnect(db);
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	118 }
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	119
4458 3e196acd60b7 sql_escape_string() should return const char , not char . Timo Sirainen <tss@iki.fi> parents: 4451 diff changeset	120 const char sql_escape_string(struct sql_db db, const char *string)
4294 1a98cb709395 Added sql_escape_string() Timo Sirainen <tss@iki.fi> parents: 3943 diff changeset	121 {
6474 46c3e1ee196f Added module_contexts to struct sql_db. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	122 return db->v.escape_string(db, string);
4294 1a98cb709395 Added sql_escape_string() Timo Sirainen <tss@iki.fi> parents: 3943 diff changeset	123 }
1a98cb709395 Added sql_escape_string() Timo Sirainen <tss@iki.fi> parents: 3943 diff changeset	124
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	125 void sql_exec(struct sql_db db, const char query)
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	126 {
6474 46c3e1ee196f Added module_contexts to struct sql_db. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	127 db->v.exec(db, query);
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	128 }
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	129
4903 204d7edc7cdc Added context parameter type safety checks for most callback APIs. Timo Sirainen <tss@iki.fi> parents: 4596 diff changeset	130 #undef sql_query
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	131 void sql_query(struct sql_db db, const char query,
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	132 sql_query_callback_t callback, void context)
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	133 {
6474 46c3e1ee196f Added module_contexts to struct sql_db. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	134 db->v.query(db, query, callback, context);
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	135 }
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	136
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	137 struct sql_result sql_query_s(struct sql_db db, const char *query)
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	138 {
6474 46c3e1ee196f Added module_contexts to struct sql_db. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	139 return db->v.query_s(db, query);
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	140 }
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	141
9270 f9ebd72a73e8 SQL API change: SQL results can be now refed/unrefed. Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	142 void sql_result_ref(struct sql_result *result)
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	143 {
9270 f9ebd72a73e8 SQL API change: SQL results can be now refed/unrefed. Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	144 result->refcount++;
f9ebd72a73e8 SQL API change: SQL results can be now refed/unrefed. Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	145 }
f9ebd72a73e8 SQL API change: SQL results can be now refed/unrefed. Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	146
f9ebd72a73e8 SQL API change: SQL results can be now refed/unrefed. Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	147 void sql_result_unref(struct sql_result *result)
f9ebd72a73e8 SQL API change: SQL results can be now refed/unrefed. Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	148 {
f9ebd72a73e8 SQL API change: SQL results can be now refed/unrefed. Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	149 i_assert(result->refcount > 0);
f9ebd72a73e8 SQL API change: SQL results can be now refed/unrefed. Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	150 if (--result->refcount > 0)
f9ebd72a73e8 SQL API change: SQL results can be now refed/unrefed. Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	151 return;
f9ebd72a73e8 SQL API change: SQL results can be now refed/unrefed. Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	152
5496 72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	153 i_free(result->map);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	154 result->v.free(result);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	155 }
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	156
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	157 static const struct sql_field_def *
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	158 sql_field_def_find(const struct sql_field_def fields, const char name)
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	159 {
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	160 unsigned int i;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	161
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	162 for (i = 0; fields[i].name != NULL; i++) {
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	163 if (strcasecmp(fields[i].name, name) == 0)
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	164 return &fields[i];
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	165 }
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	166 return NULL;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	167 }
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	168
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	169 static void
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	170 sql_result_build_map(struct sql_result *result,
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	171 const struct sql_field_def *fields, size_t dest_size)
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	172 {
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	173 const struct sql_field_def *def;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	174 const char *name;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	175 unsigned int i, count, field_size = 0;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	176
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	177 count = sql_result_get_fields_count(result);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	178
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	179 result->map_size = count;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	180 result->map = i_new(struct sql_field_map, result->map_size);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	181 for (i = 0; i < count; i++) {
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	182 name = sql_result_get_field_name(result, i);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	183 def = sql_field_def_find(fields, name);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	184 if (def != NULL) {
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	185 result->map[i].type = def->type;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	186 result->map[i].offset = def->offset;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	187 switch (def->type) {
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	188 case SQL_TYPE_STR:
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	189 field_size = sizeof(const char *);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	190 break;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	191 case SQL_TYPE_UINT:
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	192 field_size = sizeof(unsigned int);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	193 break;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	194 case SQL_TYPE_ULLONG:
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	195 field_size = sizeof(unsigned long long);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	196 break;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	197 case SQL_TYPE_BOOL:
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	198 field_size = sizeof(bool);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	199 break;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	200 }
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	201 i_assert(def->offset + field_size <= dest_size);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	202 } else {
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	203 result->map[i].offset = (size_t)-1;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	204 }
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	205 }
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	206 }
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	207
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	208 void sql_result_setup_fetch(struct sql_result *result,
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	209 const struct sql_field_def *fields,
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	210 void *dest, size_t dest_size)
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	211 {
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	212 if (result->map == NULL)
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	213 sql_result_build_map(result, fields, dest_size);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	214 result->fetch_dest = dest;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	215 result->fetch_dest_size = dest_size;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	216 }
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	217
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	218 static void sql_result_fetch(struct sql_result *result)
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	219 {
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	220 unsigned int i, count;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	221 const char *value;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	222 void *ptr;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	223
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	224 memset(result->fetch_dest, 0, result->fetch_dest_size);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	225 count = result->map_size;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	226 for (i = 0; i < count; i++) {
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	227 if (result->map[i].offset == (size_t)-1)
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	228 continue;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	229
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	230 value = sql_result_get_field_value(result, i);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	231 ptr = STRUCT_MEMBER_P(result->fetch_dest,
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	232 result->map[i].offset);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	233
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	234 switch (result->map[i].type) {
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	235 case SQL_TYPE_STR: {
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	236 ((const char *)ptr) = value;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	237 break;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	238 }
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	239 case SQL_TYPE_UINT: {
11086 260e190306b0 Started using str_to_() functions instead of libc's ones. Timo Sirainen <tss@iki.fi>* parents: 10582 diff changeset	240 if (value != NULL &&
260e190306b0 Started using str_to_() functions instead of libc's ones. Timo Sirainen <tss@iki.fi>* parents: 10582 diff changeset	241 str_to_uint(value, (unsigned int *)ptr) < 0)
260e190306b0 Started using str_to_() functions instead of libc's ones. Timo Sirainen <tss@iki.fi>* parents: 10582 diff changeset	242 i_error("sql: Value not uint: %s", value);
5496 72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	243 break;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	244 }
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	245 case SQL_TYPE_ULLONG: {
11086 260e190306b0 Started using str_to_() functions instead of libc's ones. Timo Sirainen <tss@iki.fi>* parents: 10582 diff changeset	246 if (value != NULL &&
260e190306b0 Started using str_to_() functions instead of libc's ones. Timo Sirainen <tss@iki.fi>* parents: 10582 diff changeset	247 str_to_ullong(value, (unsigned long long *)ptr) < 0)
260e190306b0 Started using str_to_() functions instead of libc's ones. Timo Sirainen <tss@iki.fi>* parents: 10582 diff changeset	248 i_error("sql: Value not ullong: %s", value);
5496 72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	249 break;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	250 }
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	251 case SQL_TYPE_BOOL: {
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	252 if (value != NULL && (value == 't' \|\| value == '1'))
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	253 ((bool )ptr) = TRUE;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	254 break;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	255 }
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	256 }
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	257 }
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	258 }
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	259
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	260 int sql_result_next_row(struct sql_result *result)
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	261 {
5496 72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	262 int ret;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	263
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	264 if ((ret = result->v.next_row(result)) <= 0)
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	265 return ret;
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	266
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	267 if (result->fetch_dest != NULL)
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	268 sql_result_fetch(result);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	269 return 1;
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	270 }
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	271
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	272 unsigned int sql_result_get_fields_count(struct sql_result *result)
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	273 {
5496 72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	274 return result->v.get_fields_count(result);
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	275 }
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	276
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	277 const char sql_result_get_field_name(struct sql_result result,
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	278 unsigned int idx)
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	279 {
5496 72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	280 return result->v.get_field_name(result, idx);
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	281 }
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	282
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	283 int sql_result_find_field(struct sql_result result, const char field_name)
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	284 {
5496 72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	285 return result->v.find_field(result, field_name);
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	286 }
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	287
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	288 const char sql_result_get_field_value(struct sql_result result,
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	289 unsigned int idx)
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	290 {
5496 72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	291 return result->v.get_field_value(result, idx);
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	292 }
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	293
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	294 const unsigned char *
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	295 sql_result_get_field_value_binary(struct sql_result *result,
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	296 unsigned int idx, size_t *size_r)
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	297 {
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	298 return result->v.get_field_value_binary(result, idx, size_r);
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	299 }
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	300
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	301 const char sql_result_find_field_value(struct sql_result result,
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	302 const char *field_name)
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	303 {
5496 72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	304 return result->v.find_field_value(result, field_name);
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	305 }
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	306
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	307 const char const sql_result_get_values(struct sql_result *result)
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	308 {
5496 72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	309 return result->v.get_values(result);
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	310 }
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	311
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	312 const char sql_result_get_error(struct sql_result result)
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	313 {
5496 72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	314 return result->v.get_error(result);
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	315 }
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	316
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	317 static void
6411 6a64e64fa3a3 Renamed __attr___ to ATTR_. Renamed __attrs_used__ to ATTRS_DEFINED. Timo Sirainen <tss@iki.fi> parents: 5496 diff changeset	318 sql_result_not_connected_free(struct sql_result *result ATTR_UNUSED)
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	319 {
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	320 }
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	321
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	322 static int
6411 6a64e64fa3a3 Renamed __attr___ to ATTR_. Renamed __attrs_used__ to ATTRS_DEFINED. Timo Sirainen <tss@iki.fi> parents: 5496 diff changeset	323 sql_result_not_connected_next_row(struct sql_result *result ATTR_UNUSED)
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	324 {
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	325 return -1;
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	326 }
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	327
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	328 static const char *
6411 6a64e64fa3a3 Renamed __attr___ to ATTR_. Renamed __attrs_used__ to ATTRS_DEFINED. Timo Sirainen <tss@iki.fi> parents: 5496 diff changeset	329 sql_result_not_connected_get_error(struct sql_result *result ATTR_UNUSED)
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	330 {
11261 1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	331 return SQL_ERRSTR_NOT_CONNECTED;
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	332 }
3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	333
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	334 struct sql_transaction_context sql_transaction_begin(struct sql_db db)
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	335 {
6474 46c3e1ee196f Added module_contexts to struct sql_db. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	336 return db->v.transaction_begin(db);
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	337 }
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	338
4903 204d7edc7cdc Added context parameter type safety checks for most callback APIs. Timo Sirainen <tss@iki.fi> parents: 4596 diff changeset	339 #undef sql_transaction_commit
3879 928229f8b3e6 deinit, unref, destroy, close, free, etc. functions now take a pointer to Timo Sirainen <tss@iki.fi> parents: 3736 diff changeset	340 void sql_transaction_commit(struct sql_transaction_context **_ctx,
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	341 sql_commit_callback_t callback, void context)
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	342 {
3879 928229f8b3e6 deinit, unref, destroy, close, free, etc. functions now take a pointer to Timo Sirainen <tss@iki.fi> parents: 3736 diff changeset	343 struct sql_transaction_context ctx = _ctx;
928229f8b3e6 deinit, unref, destroy, close, free, etc. functions now take a pointer to Timo Sirainen <tss@iki.fi> parents: 3736 diff changeset	344
928229f8b3e6 deinit, unref, destroy, close, free, etc. functions now take a pointer to Timo Sirainen <tss@iki.fi> parents: 3736 diff changeset	345 *_ctx = NULL;
6474 46c3e1ee196f Added module_contexts to struct sql_db. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	346 ctx->db->v.transaction_commit(ctx, callback, context);
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	347 }
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	348
3879 928229f8b3e6 deinit, unref, destroy, close, free, etc. functions now take a pointer to Timo Sirainen <tss@iki.fi> parents: 3736 diff changeset	349 int sql_transaction_commit_s(struct sql_transaction_context **_ctx,
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	350 const char **error_r)
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	351 {
3879 928229f8b3e6 deinit, unref, destroy, close, free, etc. functions now take a pointer to Timo Sirainen <tss@iki.fi> parents: 3736 diff changeset	352 struct sql_transaction_context ctx = _ctx;
928229f8b3e6 deinit, unref, destroy, close, free, etc. functions now take a pointer to Timo Sirainen <tss@iki.fi> parents: 3736 diff changeset	353
928229f8b3e6 deinit, unref, destroy, close, free, etc. functions now take a pointer to Timo Sirainen <tss@iki.fi> parents: 3736 diff changeset	354 *_ctx = NULL;
6474 46c3e1ee196f Added module_contexts to struct sql_db. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	355 return ctx->db->v.transaction_commit_s(ctx, error_r);
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	356 }
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	357
3879 928229f8b3e6 deinit, unref, destroy, close, free, etc. functions now take a pointer to Timo Sirainen <tss@iki.fi> parents: 3736 diff changeset	358 void sql_transaction_rollback(struct sql_transaction_context **_ctx)
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	359 {
3879 928229f8b3e6 deinit, unref, destroy, close, free, etc. functions now take a pointer to Timo Sirainen <tss@iki.fi> parents: 3736 diff changeset	360 struct sql_transaction_context ctx = _ctx;
928229f8b3e6 deinit, unref, destroy, close, free, etc. functions now take a pointer to Timo Sirainen <tss@iki.fi> parents: 3736 diff changeset	361
928229f8b3e6 deinit, unref, destroy, close, free, etc. functions now take a pointer to Timo Sirainen <tss@iki.fi> parents: 3736 diff changeset	362 *_ctx = NULL;
6474 46c3e1ee196f Added module_contexts to struct sql_db. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	363 ctx->db->v.transaction_rollback(ctx);
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	364 }
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	365
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	366 void sql_update(struct sql_transaction_context ctx, const char query)
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	367 {
9888 551c273f4844 lib-sql: Added sql_update_get_rows(). Timo Sirainen <tss@iki.fi> parents: 9270 diff changeset	368 sql_update_get_rows(ctx, query, NULL);
551c273f4844 lib-sql: Added sql_update_get_rows(). Timo Sirainen <tss@iki.fi> parents: 9270 diff changeset	369 }
551c273f4844 lib-sql: Added sql_update_get_rows(). Timo Sirainen <tss@iki.fi> parents: 9270 diff changeset	370
551c273f4844 lib-sql: Added sql_update_get_rows(). Timo Sirainen <tss@iki.fi> parents: 9270 diff changeset	371 void sql_update_get_rows(struct sql_transaction_context ctx, const char query,
551c273f4844 lib-sql: Added sql_update_get_rows(). Timo Sirainen <tss@iki.fi> parents: 9270 diff changeset	372 unsigned int *affected_rows)
551c273f4844 lib-sql: Added sql_update_get_rows(). Timo Sirainen <tss@iki.fi> parents: 9270 diff changeset	373 {
551c273f4844 lib-sql: Added sql_update_get_rows(). Timo Sirainen <tss@iki.fi> parents: 9270 diff changeset	374 ctx->db->v.update(ctx, query, affected_rows);
3736 3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	375 }
3dd0ab18d8da Added support for transactions and synchronous SQL queries. Timo Sirainen <tss@iki.fi> parents: 3421 diff changeset	376
11261 1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	377 void sql_db_set_state(struct sql_db *db, enum sql_db_state state)
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	378 {
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	379 enum sql_db_state old_state = db->state;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	380
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	381 if (db->state == state)
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	382 return;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	383
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	384 db->state = state;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	385 if (db->state_change_callback != NULL) {
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	386 db->state_change_callback(db, old_state,
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	387 db->state_change_context);
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	388 }
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	389 }
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	390
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	391 void sql_transaction_add_query(struct sql_transaction_context *ctx, pool_t pool,
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	392 const char query, unsigned int affected_rows)
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	393 {
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	394 struct sql_transaction_query *tquery;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	395
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	396 tquery = p_new(pool, struct sql_transaction_query, 1);
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	397 tquery->trans = ctx;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	398 tquery->query = p_strdup(pool, query);
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	399 tquery->affected_rows = affected_rows;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	400
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	401 if (ctx->head == NULL)
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	402 ctx->head = tquery;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	403 else
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	404 ctx->tail->next = tquery;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	405 ctx->tail = tquery;
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	406 }
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	407
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	408 struct sql_result sql_not_connected_result = {
10410 b757dab45756 Removed MEMBER() macro. Require C99 style struct initializer. Timo Sirainen <tss@iki.fi> parents: 9888 diff changeset	409 .v = {
5496 72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	410 sql_result_not_connected_free,
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	411 sql_result_not_connected_next_row,
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	412 NULL, NULL, NULL, NULL, NULL, NULL, NULL,
72ee0521dfaf Added sql_result_setup_fetch() which makes it easier to fetch rows into Timo Sirainen <tss@iki.fi> parents: 4903 diff changeset	413 sql_result_not_connected_get_error
11261 1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	414 },
1c8cc349ef55 lib-sql: Use generic sql connection pooling code for mysql/pgsql. Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	415 .failed_try_retry = TRUE
2754 3c3ac12be307 Created generic asynchronous SQL API and implemented MySQL and PostgreSQL Timo Sirainen <tss@iki.fi> parents: diff changeset	416 };

Mercurial > dovecot > core-2.2

annotate src/lib-sql/sql-api.c @ 11261:1c8cc349ef55 HEAD