db_engine.h

Go to the documentation of this file.

#pragma once
#include <common/xroad_xml.h>
 
#ifdef __cplusplus
extern "C"
{
#endif
 
typedef struct db_engine_s db_engine_t;
 
typedef struct
{
   void * ctx;
   void (*on_data)(db_engine_t* db, void* ctx, const char* data);
} db_notification_t;
 
typedef struct
{
   uint64_t exec_time_usec;
   int64_t  queue_size;
} db_query_stat_t;
 
typedef struct
{
   void * ctx;
   void (*on_data)(db_engine_t* db, void* ctx, const void* result);
   void (*on_success)(db_engine_t* db, void* ctx, db_query_stat_t stat); // fired when qeury execution has been completed succesfully
   void (*on_failed)(db_engine_t* db, void* ctx, db_query_stat_t stat); // fired if something went wrong with query
} db_result_callback_t;
 
typedef struct
{
   void * ctx;
   void (*on_connected)(db_engine_t*, void*);       
   void (*on_disconnected)(db_engine_t*, void*);    
} db_callback_t;
 
typedef enum
{
   db_mysql = 1,
   db_pgsql = 2
} db_type_t;
 
db_engine_t* db_engine_create(xroad_xml_tag_t cfg, db_callback_t cb);
 
db_engine_t* db_engine_create_ex(xroad_str_t uri, xroad_str_t encoding, bool async, db_callback_t cb);
 
void db_engine_destroy(db_engine_t * e);
 
xroad_errno_t db_engine_start(db_engine_t* e);
 
void db_engine_stop(db_engine_t* e);
 
xroad_errno_t db_engine_send(db_engine_t* e, xroad_str_t q);
 
xroad_errno_t db_engine_query(db_engine_t* e, xroad_str_t q, db_result_callback_t cb);
 
xroad_errno_t db_engine_query_bypass(db_engine_t* e, xroad_str_t q, db_result_callback_t cb);
 
xroad_errno_t db_engine_query_ex(db_engine_t* e, xroad_str_t q, bool queue_bypass, db_result_callback_t cb);
 
xroad_errno_t db_engine_subscribe(db_engine_t* e, xroad_str_t q, db_notification_t cb);
 
xroad_errno_t db_engine_unsubscribe(db_engine_t* e, xroad_str_t q, db_notification_t cb);
 
db_type_t db_engine_get_type(db_engine_t* e);
 
bool db_engine_is_busy(db_engine_t* e);
 
uint32_t db_engine_get_queue_size(db_engine_t* e);
 
#ifdef __cplusplus
}
#endif