#include <stdio.h>
#include "evpq.h"
#include "lib/log.h"
#define CONNINFO_DEFAULT "dbname=test"
#define QUERY_DEFAULT "SELECT a, b FROM foo"
void cb_connected (struct evpq_conn *conn, void *arg) {
INFO("[evpq_test] connected");
if (evpq_query(conn, QUERY_DEFAULT))
FATAL("evpq_query");
}
void cb_result (struct evpq_conn *conn, PGresult *result, void *arg) {
INFO("[evpq_test] result: %s", PQresStatus(PQresultStatus(result)));
// fatal error?
if (PQresultStatus(result) != PGRES_TUPLES_OK)
FATAL("error: %s", PQresultErrorMessage(result));
// dump it to stdout
PQprintOpt popt = {
.header = 1,
.align = 1,
.standard = 0,
.html3 = 0,
.expanded = 1,
.pager = 0,
.fieldSep = "|",
.tableOpt = NULL,
.caption = NULL,
.fieldName = NULL,
};
PQprint(stdout, result, &popt);
// don't care about the result anymore
PQclear(result);
}
void cb_done (struct evpq_conn *conn, void *arg) {
INFO("[evpq_test] done");
}
void cb_failure (struct evpq_conn *conn, void *arg) {
INFO("[evpq_test] failure");
INFO("\t%s", evpq_error_message(conn));
FATAL("exiting");
}
int main (int argc, char **argv) {
struct event_base *ev_base = NULL;
struct evpq_conn *conn = NULL;
const char *conninfo = CONNINFO_DEFAULT;
struct evpq_callback_info cb_info = {
.fn_connected = cb_connected,
.fn_result = cb_result,
.fn_done = cb_done,
.fn_failure = cb_failure,
};
// initialize libevent
if ((ev_base = event_base_new()) == NULL)
ERROR("event_base_new");
// establish the evpq connection
if ((conn = evpq_connect(ev_base, conninfo, cb_info, NULL)) == NULL)
ERROR("evpq_connect");
// run libevent
INFO("running libevent loop");
if (event_base_dispatch(ev_base))
ERROR("event_base_dispatch");
// clean shutdown
error:
if (ev_base)
event_base_free(ev_base);
}