db.h

Go to the documentation of this file.

 
#ifndef CSILK_DB_H
#define CSILK_DB_H
 
#include <stddef.h>
#include <stdint.h>
 
#include "csilk/csilk.h"
 
typedef struct {
    uint64_t queries_total;     
    uint64_t execs_total;       
    uint64_t errors_total;      
    uint64_t duration_us_total; 
} csilk_db_stats_t;
 
void csilk_db_get_stats(csilk_db_stats_t* stats);
 
typedef struct csilk_db_driver_s csilk_db_driver_t;
 
typedef struct csilk_db_pool_s {
    csilk_db_driver_t* driver; 
    void* connection;      
    uv_mutex_t mutex;      
} csilk_db_pool_t;
 
typedef struct {
    char** values; 
    int count;     
} csilk_db_row_t;
 
typedef struct {
    csilk_db_row_t** rows; 
    char** column_names;   
    int row_count;         
    int column_count;      
} csilk_db_result_t;
 
struct csilk_db_driver_s {
    const char* name; 
    int (*connect)(csilk_db_pool_t* pool, const char* dsn);
 
    int (*disconnect)(csilk_db_pool_t* pool);
 
    int (*query)(csilk_db_pool_t* pool, const char* sql, csilk_db_result_t* result);
 
    int (*exec)(csilk_db_pool_t* pool, const char* sql);
 
    int (*transaction_begin)(csilk_db_pool_t* pool);
 
    int (*transaction_commit)(csilk_db_pool_t* pool);
 
    int (*transaction_rollback)(csilk_db_pool_t* pool);
 
    void (*free_result)(csilk_db_result_t* result);
};
 
csilk_db_pool_t* csilk_db_pool_new(const char* driver_name, const char* dsn);
 
void csilk_db_pool_free(csilk_db_pool_t* pool);
 
cJSON* csilk_db_query_json(csilk_db_pool_t* pool, const char* sql);
 
int csilk_db_exec(csilk_db_pool_t* pool, const char* sql);
 
cJSON* csilk_db_query_param_json(csilk_db_pool_t* pool, const char* sql, const char** params);
 
int csilk_db_register_driver(const char* name, csilk_db_driver_t* driver);
 
csilk_db_driver_t* csilk_db_get_driver(const char* name);
 
void csilk_db_sqlite_init(void);
 
#ifdef HAS_MYSQL
void csilk_db_mysql_init(void);
#endif
 
#ifdef HAS_POSTGRES
void csilk_db_postgres_init(void);
#endif
 
#ifdef HAS_MONGODB
void csilk_db_mongodb_init(void);
#endif
 
#ifdef HAS_REDIS
void csilk_db_redis_init(void);
#endif
 
void csilk_db_init(void);
 
#endif /* CSILK_DB_H */