1 #ifndef EVSQL_INTERNAL_H

     2 #define EVSQL_INTERNAL_H

     3 

     4 #include <sys/queue.h>

     5 

     6 #include "evsql.h"

     7 

     8 /*

     9  * The engine type

    10  */

    11 enum evsql_type {

    12     EVSQL_EVPQ,     // evpq

    13 };

    14 

    15 /*

    16  * Contains the type, engine configuration, list of connections and waiting query queue.

    17  */

    18 struct evsql {

    19     // what event_base to use

    20     struct event_base *ev_base;

    21 

    22     // what engine we use

    23     enum evsql_type type;

    24 

    25     // callbacks

    26     evsql_error_cb error_fn;

    27     void *cb_arg;

    28     

    29     // engine-specific connection configuration

    30     union {

    31         const char *evpq;

    32     } engine_conf;

    33 

    34     // list of connections that are open

    35     LIST_HEAD(evsql_conn_list, evsql_conn) conn_list;

    36    

    37     // list of queries running or waiting to run

    38     TAILQ_HEAD(evsql_query_queue, evsql_query) query_queue;

    39 };

    40 

    41 /*

    42  * A single connection to the server.

    43  *

    44  * Contains the engine connection, may have a transaction associated, and may have a query associated.

    45  */

    46 struct evsql_conn {

    47     // evsql we belong to

    48     struct evsql *evsql;

    49 

    50     // engine-specific connection info

    51     union {

    52         struct evpq_conn *evpq;

    53     } engine;

    54 

    55     // our position in the conn list

    56     LIST_ENTRY(evsql_conn) entry;

    57 

    58     // are we running a transaction?

    59     struct evsql_trans *trans;

    60 

    61     // are we running a transactionless query?

    62     struct evsql_query *query;

    63 };

    64 

    65 /*

    66  * A single transaction.

    67  *

    68  * Has a connection associated and possibly a query (which will also be associated with the connection)

    69  */

    70 struct evsql_trans {

    71     // our evsql_conn/evsql

    72     //struct evsql *evsql;

    73     struct evsql_conn *conn;

    74     

    75     // callbacks

    76     evsql_trans_error_cb error_fn;

    77     evsql_trans_ready_cb ready_fn;

    78     void *cb_arg;

    79 

    80     // the transaction type

    81     enum evsql_trans_type type;

    82 

    83     // our current query

    84     struct evsql_query *query;

    85 

    86 };

    87 

    88 /*

    89  * A single query.

    90  *

    91  * Has the info needed to exec the query (as these may be queued), and the callback/result info.

    92  */

    93 struct evsql_query {

    94     // the actual SQL query, this may or may not be ours, see _evsql_query_exec

    95     char *command;

    96     

    97     // possible query params

    98     struct evsql_query_param_info {

    99         int count;

   100 

   101         Oid *types;

   102         const char **values;

   103         int *lengths;

   104         int *formats;

   105 

   106         int result_format;

   107     } params;

   108 

   109     // our callback

   110     evsql_query_cb cb_fn;

   111     void *cb_arg;

   112 

   113     // our position in the query list

   114     TAILQ_ENTRY(evsql_query) entry;

   115 

   116     // the result

   117     union {

   118         PGresult *evpq;

   119     } result;

   120 };

   121 

   122 // maximum length for a 'BEGIN TRANSACTION ...' query

   123 #define EVSQL_QUERY_BEGIN_BUF 512

   124 

   125 #endif /* EVSQL_INTERNAL_H */