driver-pgsql.c revision 840a3701b7a0f7fadd17738998c33790a8dfad2d
e59faf65ce864fe95dc00f5d52b8323cdbd0608aTimo Sirainen/* Copyright (c) 2004-2007 Dovecot authors, see the included COPYING file */
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen#include "lib.h"
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen#include "array.h"
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen#include "ioloop.h"
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen#include "ioloop-internal.h" /* kind of dirty, but it should be fine.. */
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen#include "sql-api-private.h"
0371406d952fe51367c7be91703e5634b7d9d225Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen#ifdef BUILD_PGSQL
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen#include <stdlib.h>
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen#include <time.h>
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen#include <libpq-fe.h>
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen#define QUERY_TIMEOUT_SECS 6
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
22627da0fb77c1d0d9a8e8bc485ef5540b6f2e69Timo Sirainenstruct pgsql_db {
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen struct sql_db api;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen pool_t pool;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen char *connect_string;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen PGconn *pg;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct io *io;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen enum io_condition io_dir;
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen struct pgsql_queue *queue, **queue_tail;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen struct timeout *queue_to;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen struct ioloop *ioloop;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen struct sql_result *sync_result;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen char *error;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen time_t last_connect;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen unsigned int connecting:1;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen unsigned int connected:1;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen unsigned int querying:1;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen unsigned int query_finished:1;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen};
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstruct pgsql_binary_value {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen unsigned char *value;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen size_t size;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen};
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstruct pgsql_result {
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct sql_result api;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen PGresult *pgres;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen unsigned int rownum, rows;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen unsigned int fields_count;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen const char **fields;
68f0dfb4b2815ecbc1bd8d8a68adcfd577ec55aeTimo Sirainen const char **values;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen ARRAY_DEFINE(binary_values, struct pgsql_binary_value);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen sql_query_callback_t *callback;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen void *context;
9c2b0eb659540b9db8dd3a8a6a2515921fbe8eebTimo Sirainen};
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainenstruct pgsql_queue {
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen struct pgsql_queue *next;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen time_t created;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen char *query;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen struct pgsql_result *result;
f4c0b1874b0533bcf2df1d28d584ff02cfdae3faTimo Sirainen};
f4c0b1874b0533bcf2df1d28d584ff02cfdae3faTimo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainenstruct pgsql_transaction_context {
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen struct sql_transaction_context ctx;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
0db5b158a00c08955bdacc99b1e2cd1ec07f4311Timo Sirainen sql_commit_callback_t *callback;
0db5b158a00c08955bdacc99b1e2cd1ec07f4311Timo Sirainen void *context;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
d16b506f5540e3407d256bda35624b38a5ecf88fTimo Sirainen const char *error;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen unsigned int opened:1;
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen unsigned int failed:1;
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen};
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainenextern struct sql_db driver_pgsql_db;
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainenextern struct sql_result driver_pgsql_result;
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainenstatic void queue_send_next(struct pgsql_db *db);
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainenstatic void result_finish(struct pgsql_result *result);
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainenstatic void driver_pgsql_close(struct pgsql_db *db)
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen{
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen if (db->io != NULL)
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen io_remove(&db->io);
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen db->io_dir = 0;
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen PQfinish(db->pg);
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen db->pg = NULL;
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->connecting = FALSE;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->connected = FALSE;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->querying = FALSE;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
407caeb5d0c8a6b158e2caef48dd909011d40340Timo Sirainenstatic const char *last_error(struct pgsql_db *db)
407caeb5d0c8a6b158e2caef48dd909011d40340Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen const char *msg;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen size_t len;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen msg = PQerrorMessage(db->pg);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (msg == NULL)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen return "(no error set)";
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen
a54fa00087ba926a3d966a8449d8d7579e89911cTimo Sirainen /* Error message should contain trailing \n, we don't want it */
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen len = strlen(msg);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen return len == 0 || msg[len-1] != '\n' ? msg :
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen t_strndup(msg, len-1);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic void connect_callback(struct pgsql_db *db)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen enum io_condition io_dir = 0;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen int ret;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen while ((ret = PQconnectPoll(db->pg)) == PGRES_POLLING_ACTIVE)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen ;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen switch (ret) {
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen case PGRES_POLLING_READING:
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen io_dir = IO_READ;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen break;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen case PGRES_POLLING_WRITING:
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen io_dir = IO_WRITE;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen break;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen case PGRES_POLLING_OK:
2cfe9983ce7a6280636ee12beccc2e865111967bTimo Sirainen i_info("pgsql: Connected to %s", PQdb(db->pg));
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->connecting = FALSE;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->connected = TRUE;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen break;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen case PGRES_POLLING_FAILED:
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen i_error("pgsql: Connect failed to %s: %s",
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen PQdb(db->pg), last_error(db));
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen driver_pgsql_close(db);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen }
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (db->io_dir != io_dir) {
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (db->io != NULL)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen io_remove(&db->io);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->io = io_dir == 0 ? NULL :
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen io_add(PQsocket(db->pg), io_dir, connect_callback, db);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->io_dir = io_dir;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen }
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (db->connected && db->queue != NULL)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen queue_send_next(db);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic int driver_pgsql_connect(struct sql_db *_db)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_db *db = (struct pgsql_db *)_db;
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen time_t now;
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen /* don't try reconnecting more than once a second */
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen now = time(NULL);
d16b506f5540e3407d256bda35624b38a5ecf88fTimo Sirainen if (db->connecting || db->last_connect == now)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen return db->connected ? 1 : (db->connecting ? 0 : -1);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen db->last_connect = now;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen db->pg = PQconnectStart(db->connect_string);
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen if (db->pg == NULL)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen i_fatal("pgsql: PQconnectStart() failed (out of memory)");
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (PQstatus(db->pg) == CONNECTION_BAD) {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen i_error("pgsql: Connect failed to %s: %s",
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen PQdb(db->pg), last_error(db));
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_close(db);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen return -1;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen } else {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen /* nonblocking connecting begins. */
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen db->io = io_add(PQsocket(db->pg), IO_WRITE,
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen connect_callback, db);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen db->io_dir = IO_WRITE;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen db->connecting = TRUE;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen return 0;
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen }
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic struct sql_db *driver_pgsql_init_v(const char *connect_string)
a0b89f3b1df99b3a32f44623f13ad1893118825bTimo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_db *db;
a0b89f3b1df99b3a32f44623f13ad1893118825bTimo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen i_assert(connect_string != NULL);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db = i_new(struct pgsql_db, 1);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->connect_string = i_strdup(connect_string);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->api = driver_pgsql_db;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->queue_tail = &db->queue;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return &db->api;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic void driver_pgsql_deinit_v(struct sql_db *_db)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
a0b89f3b1df99b3a32f44623f13ad1893118825bTimo Sirainen struct pgsql_db *db = (struct pgsql_db *)_db;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen while (db->queue != NULL) {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen struct pgsql_queue *next = db->queue->next;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen result_finish(db->queue->result);
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen i_free(db->queue->query);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen i_free(db->queue);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen db->queue = next;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (db->queue_to != 0)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen timeout_remove(&db->queue_to);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_close(db);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen i_free(db->error);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen i_free(db->connect_string);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen array_free(&_db->module_contexts);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen i_free(db);
9349a0afffad990e45d3ad33081e1d2d9e68a753Timo Sirainen}
9349a0afffad990e45d3ad33081e1d2d9e68a753Timo Sirainen
9349a0afffad990e45d3ad33081e1d2d9e68a753Timo Sirainenstatic enum sql_db_flags
4c9c55e15f35474f53f11659e796c63b1c34e884Timo Sirainendriver_pgsql_get_flags(struct sql_db *db ATTR_UNUSED)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen{
4c9c55e15f35474f53f11659e796c63b1c34e884Timo Sirainen return 0;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
a94936bafd127680184da114c6a177b37ff656e5Timo Sirainenstatic void consume_results(struct pgsql_db *db)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen do {
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (!PQconsumeInput(db->pg))
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen break;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (PQisBusy(db->pg))
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen return;
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen } while (PQgetResult(db->pg) != NULL);
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen io_remove(&db->io);
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen db->querying = FALSE;
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen if (db->queue != NULL && db->connected)
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen queue_send_next(db);
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic void driver_pgsql_result_free(struct sql_result *_result)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
a94936bafd127680184da114c6a177b37ff656e5Timo Sirainen struct pgsql_db *db = (struct pgsql_db *)_result->db;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_result *result = (struct pgsql_result *)_result;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (result->api.callback)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen return;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
d16b506f5540e3407d256bda35624b38a5ecf88fTimo Sirainen if (result->pgres != NULL) {
4c9c55e15f35474f53f11659e796c63b1c34e884Timo Sirainen PQclear(result->pgres);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen /* we'll have to read the rest of the results as well */
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen i_assert(db->io == NULL);
22627da0fb77c1d0d9a8e8bc485ef5540b6f2e69Timo Sirainen db->io = io_add(PQsocket(db->pg), IO_READ,
3e28b527dd6048a40684afd29cff0ee008fc0014Timo Sirainen consume_results, db);
3e28b527dd6048a40684afd29cff0ee008fc0014Timo Sirainen db->io_dir = IO_READ;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen consume_results(db);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen } else {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen db->querying = FALSE;
ccffb125d94adff0ad776de5a96e22f864d6fb0aTimo Sirainen }
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (array_is_created(&result->binary_values)) {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen struct pgsql_binary_value *values;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen unsigned int i, count;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen values = array_get_modifiable(&result->binary_values, &count);
ccffb125d94adff0ad776de5a96e22f864d6fb0aTimo Sirainen for (i = 0; i < count; i++)
ccffb125d94adff0ad776de5a96e22f864d6fb0aTimo Sirainen PQfreemem(values[i].value);
2cfe9983ce7a6280636ee12beccc2e865111967bTimo Sirainen array_free(&result->binary_values);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen }
c44f402f17f9a58ead24ac0083945cae86fb172bTimo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen i_free(result->fields);
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen i_free(result->values);
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen i_free(result);
c44f402f17f9a58ead24ac0083945cae86fb172bTimo Sirainen
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen if (db->queue != NULL && !db->querying && db->connected)
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen queue_send_next(db);
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen}
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic void result_finish(struct pgsql_result *result)
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen{
c44f402f17f9a58ead24ac0083945cae86fb172bTimo Sirainen struct pgsql_db *db = (struct pgsql_db *)result->api.db;
c44f402f17f9a58ead24ac0083945cae86fb172bTimo Sirainen bool free_result = TRUE;
c44f402f17f9a58ead24ac0083945cae86fb172bTimo Sirainen
c44f402f17f9a58ead24ac0083945cae86fb172bTimo Sirainen if (result->callback != NULL) {
c44f402f17f9a58ead24ac0083945cae86fb172bTimo Sirainen result->api.callback = TRUE;
c44f402f17f9a58ead24ac0083945cae86fb172bTimo Sirainen t_push();
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen result->callback(&result->api, result->context);
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen t_pop();
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen result->api.callback = FALSE;
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen free_result = db->sync_result != &result->api;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (free_result)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen driver_pgsql_result_free(&result->api);
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (PQstatus(db->pg) == CONNECTION_BAD) {
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen /* disconnected */
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen driver_pgsql_close(db);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen}
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainenstatic void get_result(struct pgsql_result *result)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen{
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen struct pgsql_db *db = (struct pgsql_db *)result->api.db;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (!PQconsumeInput(db->pg)) {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen db->connected = FALSE;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen result_finish(result);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen return;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen }
a1aaf11831cab8346d6d0dc702e37b3f1d95eb43Timo Sirainen
a1aaf11831cab8346d6d0dc702e37b3f1d95eb43Timo Sirainen if (PQisBusy(db->pg)) {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (db->io == NULL) {
a1aaf11831cab8346d6d0dc702e37b3f1d95eb43Timo Sirainen db->io = io_add(PQsocket(db->pg), IO_READ,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen get_result, result);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->io_dir = IO_READ;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen }
c44f402f17f9a58ead24ac0083945cae86fb172bTimo Sirainen return;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (db->io != NULL)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen io_remove(&db->io);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen result->pgres = PQgetResult(db->pg);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen result_finish(result);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic void flush_callback(struct pgsql_result *result)
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen{
e20e638805c4bd54e039891a3e92760b1dfa189aTimo Sirainen struct pgsql_db *db = (struct pgsql_db *)result->api.db;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen int ret;
e20e638805c4bd54e039891a3e92760b1dfa189aTimo Sirainen
e20e638805c4bd54e039891a3e92760b1dfa189aTimo Sirainen ret = PQflush(db->pg);
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen if (ret > 0)
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen return;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen io_remove(&db->io);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (ret < 0) {
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->connected = FALSE;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen result_finish(result);
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen } else {
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen /* all flushed */
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen get_result(result);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen}
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainenstatic void send_query(struct pgsql_result *result, const char *query)
68f0dfb4b2815ecbc1bd8d8a68adcfd577ec55aeTimo Sirainen{
e958a3c4573058f17999f0083a34080ca35e34d8Timo Sirainen struct pgsql_db *db = (struct pgsql_db *)result->api.db;
e958a3c4573058f17999f0083a34080ca35e34d8Timo Sirainen int ret;
e958a3c4573058f17999f0083a34080ca35e34d8Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen i_assert(db->io == NULL);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen i_assert(!db->querying);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen i_assert(db->connected);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (!PQsendQuery(db->pg, query)) {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen db->connected = FALSE;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen result_finish(result);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen return;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen ret = PQflush(db->pg);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (ret < 0) {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen db->connected = FALSE;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen result_finish(result);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen return;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen db->querying = TRUE;
68f0dfb4b2815ecbc1bd8d8a68adcfd577ec55aeTimo Sirainen if (ret > 0) {
68f0dfb4b2815ecbc1bd8d8a68adcfd577ec55aeTimo Sirainen /* write blocks */
3656c91dcb8336814bebd4500e81c3dde25233e6Timo Sirainen db->io = io_add(PQsocket(db->pg), IO_WRITE,
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen flush_callback, result);
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen db->io_dir = IO_WRITE;
2cfe9983ce7a6280636ee12beccc2e865111967bTimo Sirainen } else {
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen get_result(result);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen }
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainenstatic struct pgsql_queue *queue_unlink_first(struct pgsql_db *db)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_queue *queue;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen queue = db->queue;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->queue = queue->next;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen if (db->queue == NULL)
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen db->queue_tail = &db->queue;
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen return queue;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic void queue_send_next(struct pgsql_db *db)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_queue *queue;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen queue = queue_unlink_first(db);
2cfe9983ce7a6280636ee12beccc2e865111967bTimo Sirainen send_query(queue->result, queue->query);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen i_free(queue->query);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen i_free(queue);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainenstatic void queue_abort_next(struct pgsql_db *db)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen struct pgsql_queue *queue;
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen queue = queue_unlink_first(db);
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen queue->result->callback(&sql_not_connected_result,
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen queue->result->context);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen i_free(queue->result);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen i_free(queue->query);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen i_free(queue);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic void queue_drop_timed_out_queries(struct pgsql_db *db)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen while (db->queue != NULL &&
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->queue->created + QUERY_TIMEOUT_SECS < ioloop_time)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen queue_abort_next(db);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen}
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainenstatic void queue_timeout(struct pgsql_db *db)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen{
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (db->querying)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen return;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (!db->connected) {
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen queue_drop_timed_out_queries(db);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen driver_pgsql_connect(&db->api);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen return;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (db->queue != NULL)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen queue_send_next(db);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (db->queue == NULL)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen timeout_remove(&db->queue_to);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen}
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainenstatic void
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainendriver_pgsql_queue_query(struct pgsql_result *result, const char *query)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_db *db = (struct pgsql_db *)result->api.db;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_queue *queue;
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen queue = i_new(struct pgsql_queue, 1);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen queue->created = time(NULL);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen queue->query = i_strdup(query);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen queue->result = result;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen *db->queue_tail = queue;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->queue_tail = &queue->next;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (db->queue_to == NULL)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->queue_to = timeout_add(5000, queue_timeout, db);
13a8c553f293349248b161ff851743498916e26eTimo Sirainen}
13a8c553f293349248b161ff851743498916e26eTimo Sirainen
24ce0c343cefe54af841871fa39dbc3464028b06Timo Sirainenstatic void do_query(struct pgsql_result *result, const char *query)
24ce0c343cefe54af841871fa39dbc3464028b06Timo Sirainen{
24ce0c343cefe54af841871fa39dbc3464028b06Timo Sirainen struct pgsql_db *db = (struct pgsql_db *)result->api.db;
24ce0c343cefe54af841871fa39dbc3464028b06Timo Sirainen
24ce0c343cefe54af841871fa39dbc3464028b06Timo Sirainen if (db->querying) {
24ce0c343cefe54af841871fa39dbc3464028b06Timo Sirainen /* only one query at a time */
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_queue_query(result, query);
9fcf7b79236b0045f7709718f7b65ada516565e7Timo Sirainen return;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
9fcf7b79236b0045f7709718f7b65ada516565e7Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (!db->connected) {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen /* try connecting again */
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_connect(&db->api);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_queue_query(result, query);
24ce0c343cefe54af841871fa39dbc3464028b06Timo Sirainen return;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (db->queue == NULL)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen send_query(result, query);
24ce0c343cefe54af841871fa39dbc3464028b06Timo Sirainen else {
24ce0c343cefe54af841871fa39dbc3464028b06Timo Sirainen /* there's already queries queued, send them first */
24ce0c343cefe54af841871fa39dbc3464028b06Timo Sirainen driver_pgsql_queue_query(result, query);
24ce0c343cefe54af841871fa39dbc3464028b06Timo Sirainen queue_send_next(db);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen}
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainenstatic void exec_callback(struct sql_result *result,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen void *context ATTR_UNUSED)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen{
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen struct pgsql_db *db = (struct pgsql_db *)result->db;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen i_error("pgsql: sql_exec() failed: %s", last_error(db));
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic const char *
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainendriver_pgsql_escape_string(struct sql_db *_db, const char *string)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_db *db = (struct pgsql_db *)_db;
3656c91dcb8336814bebd4500e81c3dde25233e6Timo Sirainen size_t len = strlen(string);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen char *to;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen#ifdef HAVE_PQESCAPE_STRING_CONN
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (!db->connected) {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen /* try connecting again */
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen (void)driver_pgsql_connect(&db->api);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen }
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen to = t_buffer_get(len * 2 + 1);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen len = PQescapeStringConn(db->pg, to, string, len, NULL);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen#else
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen to = t_buffer_get(len * 2 + 1);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen len = PQescapeString(to, string, len);
3656c91dcb8336814bebd4500e81c3dde25233e6Timo Sirainen#endif
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen t_buffer_alloc(len + 1);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return to;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic void driver_pgsql_exec(struct sql_db *db, const char *query)
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen{
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen struct pgsql_result *result;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen result = i_new(struct pgsql_result, 1);
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen result->api = driver_pgsql_result;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen result->api.db = db;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen result->callback = exec_callback;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen do_query(result, query);
36c4702131e5a04984ad5d07cf5d8d5c633d43c3Timo Sirainen}
36c4702131e5a04984ad5d07cf5d8d5c633d43c3Timo Sirainen
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainenstatic void driver_pgsql_query(struct sql_db *db, const char *query,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen sql_query_callback_t *callback, void *context)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen{
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen struct pgsql_result *result;
5fe06fea9fee0f5e4e9cb49f6866877223f78b85Timo Sirainen
5fe06fea9fee0f5e4e9cb49f6866877223f78b85Timo Sirainen result = i_new(struct pgsql_result, 1);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen result->api = driver_pgsql_result;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen result->api.db = db;
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen result->callback = callback;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen result->context = context;
36c4702131e5a04984ad5d07cf5d8d5c633d43c3Timo Sirainen
ab1b9a793d57a60c230a41f65f1a25d52c026233Timo Sirainen do_query(result, query);
36c4702131e5a04984ad5d07cf5d8d5c633d43c3Timo Sirainen}
36c4702131e5a04984ad5d07cf5d8d5c633d43c3Timo Sirainen
36c4702131e5a04984ad5d07cf5d8d5c633d43c3Timo Sirainenstatic void pgsql_query_s_callback(struct sql_result *result, void *context)
36c4702131e5a04984ad5d07cf5d8d5c633d43c3Timo Sirainen{
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen struct pgsql_db *db = context;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
36c4702131e5a04984ad5d07cf5d8d5c633d43c3Timo Sirainen db->query_finished = TRUE;
36c4702131e5a04984ad5d07cf5d8d5c633d43c3Timo Sirainen db->sync_result = result;
36c4702131e5a04984ad5d07cf5d8d5c633d43c3Timo Sirainen io_loop_stop(db->ioloop);
36c4702131e5a04984ad5d07cf5d8d5c633d43c3Timo Sirainen}
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainenstatic struct sql_result *
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainendriver_pgsql_query_s(struct sql_db *_db, const char *query)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen{
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen struct pgsql_db *db = (struct pgsql_db *)_db;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen struct io old_io;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (db->io == NULL)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen db->ioloop = io_loop_create();
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen else {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen /* have to move our existing I/O handler to new I/O loop */
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen old_io = *db->io;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen io_remove(&db->io);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
840a3701b7a0f7fadd17738998c33790a8dfad2dTimo Sirainen db->ioloop = io_loop_create();
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen db->io = io_add(PQsocket(db->pg), old_io.condition,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen old_io.callback, old_io.context);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen db->query_finished = FALSE;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_query(_db, query, pgsql_query_s_callback, db);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (!db->query_finished) {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (db->connected || db->connecting)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen io_loop_run(db->ioloop);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen else
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen queue_abort_next(db);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (db->io != NULL) {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen i_assert(db->sync_result == &sql_not_connected_result);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen io_remove(&db->io);
f6e301cb2060c4367d8145e2bf5d553ba87ceb34Timo Sirainen }
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen if (db->queue_to != NULL)
06f537a8e0b399222cc2a7755015ef3963525fd2Timo Sirainen timeout_remove(&db->queue_to);
06f537a8e0b399222cc2a7755015ef3963525fd2Timo Sirainen }
06f537a8e0b399222cc2a7755015ef3963525fd2Timo Sirainen io_loop_destroy(&db->ioloop);
06f537a8e0b399222cc2a7755015ef3963525fd2Timo Sirainen
06f537a8e0b399222cc2a7755015ef3963525fd2Timo Sirainen i_assert(db->io == NULL);
06f537a8e0b399222cc2a7755015ef3963525fd2Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen return db->sync_result;
06f537a8e0b399222cc2a7755015ef3963525fd2Timo Sirainen}
06f537a8e0b399222cc2a7755015ef3963525fd2Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainenstatic int driver_pgsql_result_next_row(struct sql_result *_result)
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen{
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen struct pgsql_result *result = (struct pgsql_result *)_result;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen struct pgsql_db *db = (struct pgsql_db *)_result->db;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (result->rows != 0) {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen /* second time we're here */
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen return ++result->rownum < result->rows;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (result->pgres == NULL)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen return -1;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen switch (PQresultStatus(result->pgres)) {
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen case PGRES_COMMAND_OK:
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen /* no rows returned */
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return 0;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen case PGRES_TUPLES_OK:
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen result->rows = PQntuples(result->pgres);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return result->rows > 0;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen case PGRES_EMPTY_QUERY:
26cdaf7097427fa90343260fa236af12ab93cca3Timo Sirainen case PGRES_NONFATAL_ERROR:
26cdaf7097427fa90343260fa236af12ab93cca3Timo Sirainen /* nonfatal error */
26cdaf7097427fa90343260fa236af12ab93cca3Timo Sirainen return -1;
26cdaf7097427fa90343260fa236af12ab93cca3Timo Sirainen default:
26cdaf7097427fa90343260fa236af12ab93cca3Timo Sirainen /* treat as fatal error */
26cdaf7097427fa90343260fa236af12ab93cca3Timo Sirainen db->connected = FALSE;
26cdaf7097427fa90343260fa236af12ab93cca3Timo Sirainen return -1;
26cdaf7097427fa90343260fa236af12ab93cca3Timo Sirainen }
26cdaf7097427fa90343260fa236af12ab93cca3Timo Sirainen}
26cdaf7097427fa90343260fa236af12ab93cca3Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic void driver_pgsql_result_fetch_fields(struct pgsql_result *result)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen unsigned int i;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (result->fields != NULL)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen return;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen /* @UNSAFE */
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen result->fields_count = PQnfields(result->pgres);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen result->fields = i_new(const char *, result->fields_count);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen for (i = 0; i < result->fields_count; i++)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen result->fields[i] = PQfname(result->pgres, i);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic unsigned int
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainendriver_pgsql_result_get_fields_count(struct sql_result *_result)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen struct pgsql_result *result = (struct pgsql_result *)_result;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen driver_pgsql_result_fetch_fields(result);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return result->fields_count;
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen}
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic const char *
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainendriver_pgsql_result_get_field_name(struct sql_result *_result, unsigned int idx)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_result *result = (struct pgsql_result *)_result;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen driver_pgsql_result_fetch_fields(result);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen i_assert(idx < result->fields_count);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return result->fields[idx];
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic int driver_pgsql_result_find_field(struct sql_result *_result,
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen const char *field_name)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_result *result = (struct pgsql_result *)_result;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen unsigned int i;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen driver_pgsql_result_fetch_fields(result);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen for (i = 0; i < result->fields_count; i++) {
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (strcmp(result->fields[i], field_name) == 0)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return i;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen }
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return -1;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic const char *
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainendriver_pgsql_result_get_field_value(struct sql_result *_result,
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen unsigned int idx)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_result *result = (struct pgsql_result *)_result;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (PQgetisnull(result->pgres, result->rownum, idx))
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return NULL;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return PQgetvalue(result->pgres, result->rownum, idx);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic const unsigned char *
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainendriver_pgsql_result_get_field_value_binary(struct sql_result *_result,
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen unsigned int idx, size_t *size_r)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_result *result = (struct pgsql_result *)_result;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen const char *value;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_binary_value *binary_value;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (PQgetisnull(result->pgres, result->rownum, idx)) {
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen *size_r = 0;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return NULL;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen }
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen value = PQgetvalue(result->pgres, result->rownum, idx);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (!array_is_created(&result->binary_values))
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen i_array_init(&result->binary_values, idx + 1);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen binary_value = array_idx_modifiable(&result->binary_values, idx);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (binary_value->value == NULL) {
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen binary_value->value =
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen PQunescapeBytea((const unsigned char *)value,
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen &binary_value->size);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen }
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen *size_r = binary_value->size;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return binary_value->value;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen}
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainenstatic const char *
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainendriver_pgsql_result_find_field_value(struct sql_result *result,
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen const char *field_name)
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen{
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen int idx;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen idx = driver_pgsql_result_find_field(result, field_name);
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen if (idx < 0)
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen return NULL;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen return driver_pgsql_result_get_field_value(result, idx);
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen}
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainenstatic const char *const *
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainendriver_pgsql_result_get_values(struct sql_result *_result)
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen{
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen struct pgsql_result *result = (struct pgsql_result *)_result;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen unsigned int i;
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen if (result->values == NULL) {
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen driver_pgsql_result_fetch_fields(result);
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen result->values = i_new(const char *, result->fields_count);
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen }
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen /* @UNSAFE */
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen for (i = 0; i < result->fields_count; i++) {
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen result->values[i] =
1ac19c5c2b66a12f5598792aad15114ee3eb62e2Timo Sirainen driver_pgsql_result_get_field_value(_result, i);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen }
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return result->values;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic const char *driver_pgsql_result_get_error(struct sql_result *_result)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_result *result = (struct pgsql_result *)_result;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_db *db = (struct pgsql_db *)_result->db;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen const char *msg;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen size_t len;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen msg = PQresultErrorMessage(result->pgres);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen if (msg == NULL)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return "(no error set)";
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen /* Error message should contain trailing \n, we don't want it */
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen len = strlen(msg);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen i_free(db->error);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen db->error = len == 0 || msg[len-1] != '\n' ?
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen i_strdup(msg) : i_strndup(msg, len-1);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return db->error;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainenstatic struct sql_transaction_context *
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainendriver_pgsql_transaction_begin(struct sql_db *db)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_transaction_context *ctx;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen ctx = i_new(struct pgsql_transaction_context, 1);
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen ctx->ctx.db = db;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen return &ctx->ctx;
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen}
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainenstatic void
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainentransaction_commit_callback(struct sql_result *result, void *context)
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen{
6c2c5f20760b06bfb4a40b0ee2ef5ab016bc41f0Timo Sirainen struct pgsql_transaction_context *ctx =
9672bb2a11c37c275d695451accd824da5c9e485Timo Sirainen (struct pgsql_transaction_context *)context;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen if (sql_result_next_row(result) < 0)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen ctx->callback(sql_result_get_error(result), ctx->context);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen else
9672bb2a11c37c275d695451accd824da5c9e485Timo Sirainen ctx->callback(NULL, ctx->context);
9672bb2a11c37c275d695451accd824da5c9e485Timo Sirainen}
9672bb2a11c37c275d695451accd824da5c9e485Timo Sirainen
9672bb2a11c37c275d695451accd824da5c9e485Timo Sirainenstatic void
9672bb2a11c37c275d695451accd824da5c9e485Timo Sirainendriver_pgsql_transaction_commit(struct sql_transaction_context *_ctx,
9672bb2a11c37c275d695451accd824da5c9e485Timo Sirainen sql_commit_callback_t *callback, void *context)
9672bb2a11c37c275d695451accd824da5c9e485Timo Sirainen{
9672bb2a11c37c275d695451accd824da5c9e485Timo Sirainen struct pgsql_transaction_context *ctx =
9672bb2a11c37c275d695451accd824da5c9e485Timo Sirainen (struct pgsql_transaction_context *)_ctx;
9672bb2a11c37c275d695451accd824da5c9e485Timo Sirainen
9672bb2a11c37c275d695451accd824da5c9e485Timo Sirainen if (ctx->failed) {
9672bb2a11c37c275d695451accd824da5c9e485Timo Sirainen callback(ctx->error, context);
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen if (ctx->opened)
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen sql_exec(_ctx->db, "ROLLBACK");
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen i_free(ctx);
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen return;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen }
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen if (!ctx->opened) {
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen /* nothing done */
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen ctx->callback(NULL, ctx->context);
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen return;
9c2b0eb659540b9db8dd3a8a6a2515921fbe8eebTimo Sirainen }
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen ctx->callback = callback;
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen ctx->context = context;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen sql_query(_ctx->db, "COMMIT", transaction_commit_callback, ctx);
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen}
9c2b0eb659540b9db8dd3a8a6a2515921fbe8eebTimo Sirainen
9c2b0eb659540b9db8dd3a8a6a2515921fbe8eebTimo Sirainenstatic int
9c2b0eb659540b9db8dd3a8a6a2515921fbe8eebTimo Sirainendriver_pgsql_transaction_commit_s(struct sql_transaction_context *_ctx,
9c2b0eb659540b9db8dd3a8a6a2515921fbe8eebTimo Sirainen const char **error_r)
9c2b0eb659540b9db8dd3a8a6a2515921fbe8eebTimo Sirainen{
9c2b0eb659540b9db8dd3a8a6a2515921fbe8eebTimo Sirainen struct pgsql_transaction_context *ctx =
9c2b0eb659540b9db8dd3a8a6a2515921fbe8eebTimo Sirainen (struct pgsql_transaction_context *)_ctx;
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen struct sql_result *result;
9c2b0eb659540b9db8dd3a8a6a2515921fbe8eebTimo Sirainen
9c2b0eb659540b9db8dd3a8a6a2515921fbe8eebTimo Sirainen if (ctx->failed) {
9c2b0eb659540b9db8dd3a8a6a2515921fbe8eebTimo Sirainen *error_r = ctx->error;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen if (!ctx->opened)
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen sql_exec(_ctx->db, "ROLLBACK");
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen } else if (!ctx->opened)
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen *error_r = NULL;
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen else {
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen result = sql_query_s(_ctx->db, "COMMIT");
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen if (sql_result_next_row(result) < 0)
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen *error_r = sql_result_get_error(result);
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen else
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen *error_r = NULL;
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen sql_result_free(result);
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen }
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen i_free(ctx);
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen return *error_r == NULL ? 0 : -1;
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen}
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainenstatic void
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainendriver_pgsql_transaction_rollback(struct sql_transaction_context *_ctx)
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen{
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen struct pgsql_transaction_context *ctx =
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen (struct pgsql_transaction_context *)_ctx;
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen if (ctx->opened)
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen sql_exec(_ctx->db, "ROLLBACK");
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen i_free(ctx);
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen}
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainenstatic void
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainentransaction_update_callback(struct sql_result *result,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen struct pgsql_transaction_context *ctx)
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen{
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen if (sql_result_next_row(result) < 0) {
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen ctx->failed = TRUE;
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen ctx->error = sql_result_get_error(result);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen}
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainenstatic void
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainendriver_pgsql_update(struct sql_transaction_context *_ctx, const char *query)
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen{
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen struct pgsql_transaction_context *ctx =
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen (struct pgsql_transaction_context *)_ctx;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen if (ctx->failed)
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen return;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen if (!ctx->opened) {
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen ctx->opened = TRUE;
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen sql_query(_ctx->db, "BEGIN", transaction_update_callback, ctx);
f4c0b1874b0533bcf2df1d28d584ff02cfdae3faTimo Sirainen }
f4c0b1874b0533bcf2df1d28d584ff02cfdae3faTimo Sirainen
f4c0b1874b0533bcf2df1d28d584ff02cfdae3faTimo Sirainen sql_query(_ctx->db, query, transaction_update_callback, ctx);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen}
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainenstruct sql_db driver_pgsql_db = {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen "pgsql",
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen MEMBER(v) {
f4c0b1874b0533bcf2df1d28d584ff02cfdae3faTimo Sirainen driver_pgsql_init_v,
f4c0b1874b0533bcf2df1d28d584ff02cfdae3faTimo Sirainen driver_pgsql_deinit_v,
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen driver_pgsql_get_flags,
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen driver_pgsql_connect,
bfdf0fd7b6186f64cbdcbf1cb2bf9c42a9007b77Timo Sirainen driver_pgsql_escape_string,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_exec,
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen driver_pgsql_query,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_query_s,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_transaction_begin,
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen driver_pgsql_transaction_commit,
892b3cbf0eba9ba455448adcf71864a409345c6dTimo Sirainen driver_pgsql_transaction_commit_s,
28cddf411c475eb8bb84b4023398bb12346ce5adTimo Sirainen driver_pgsql_transaction_rollback,
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen
dc9de21d4375faeedbe5b7e941502ac578650da9Timo Sirainen driver_pgsql_update
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen};
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainenstruct sql_result driver_pgsql_result = {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen MEMBER(v) {
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_result_free,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_result_next_row,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_result_get_fields_count,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_result_get_field_name,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_result_find_field,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_result_get_field_value,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_result_get_field_value_binary,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_result_find_field_value,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_result_get_values,
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen driver_pgsql_result_get_error
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen }
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen};
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainenvoid driver_pgsql_init(void);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainenvoid driver_pgsql_deinit(void);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainenvoid driver_pgsql_init(void)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen{
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen sql_driver_register(&driver_pgsql_db);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen}
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainenvoid driver_pgsql_deinit(void)
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen{
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen sql_driver_unregister(&driver_pgsql_db);
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen}
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen#endif
6b2738c39a868ff9291867138c55029fc40cf105Timo Sirainen