1

     2

#include <event2/event.h>

     3

     4

#include "evsql.h"

     5

#include "lib/log.h"

     6

#include "lib/signals.h"

     7

#include "lib/misc.h"

     8

     9

#define CONNINFO_DEFAULT "dbname=dbfs port=5433"

    10

    11

void db_results (struct evsql_result *result, void *arg) {

    12

    uint32_t val;

    13

    14

    static struct evsql_result_info result_info = {

    15

        0, {

    16

            {   EVSQL_FMT_BINARY,   EVSQL_TYPE_UINT32   },

    17

            {   0,                  0                   }

    18

        }

    19

    };

    20

    21

    22

}

    23

    24

void do_query (struct evsql *db) {

    25

    struct evsql_query *query = NULL;

    26

    27

    static struct evsql_query_info query_info = {

    28

        .sql    = "SELECT $1::int4 + 5",

    29

    30

        .params = {

    31

            {   EVSQL_FMT_BINARY,   EVSQL_TYPE_UINT32   },

    32

            {   0,                  0                   }

    33

        }

    34

    };

    35

    36

    // query

    37

    assert((query = evsql_query_exec(db, NULL, &query_info, (uint32_t) 4, db_results, NULL)) != NULL);

    38

}

    39

    40

int main (char argc, char **argv) {

    41

    struct event_base *ev_base = NULL;

    42

    struct signals *signals = NULL;

    43

    struct evsql *db = NULL;

    44

    45

    const char *db_conninfo;

    46

    47

    // parse args

    48

    db_conninfo = CONNINFO_DEFAULT;

    49

    50

    // init libevent

    51

    if ((ev_base = event_base_new()) == NULL)

    52

        ERROR("event_base_new");

    53

    54

    // setup signals

    55

    if ((signals = signals_default(ev_base)) == NULL)

    56

        ERROR("signals_default");

    57

    58

    // setup evsql

    59

    if ((db = evsql_new_pq(ev_base, db_conninfo, NULL, NULL)) == NULL)

    60

        ERROR("evsql_new_pq");

    61

    62

    // run libevent

    63

    INFO("running libevent loop");

    64

    65

    if (event_base_dispatch(ev_base))

    66

        PERROR("event_base_dispatch");

    67

    68

    // clean shutdown

    69

    70

error :

    71

    if (db) {

    72

        /* evsql_close(db); */

    73

    }

    74

    75

    if (signals)

    76

        signals_free(signals);

    77

    78

    if (ev_base)

    79

        event_base_free(ev_base);

    80

    81

}

    82