db/db7/pool_8h_source.html

#ifndef __CWIST_DB_POOL_H__

#define __CWIST_DB_POOL_H__


#include <cwist/core/db/sql.h>

#include <cwist/sys/err/cwist_err.h>

#include <cjson/cJSON.h>

#include <stddef.h>


#ifdef __cplusplus

extern "C" {

#endif


typedef struct cwist_db_pool cwist_db_pool_t;


cwist_db_pool_t *cwist_db_pool_create(const char *path, size_t max_conns);


void cwist_db_pool_destroy(cwist_db_pool_t *pool);


bool cwist_db_pool_destroy_timeout(cwist_db_pool_t *pool, int timeout_ms);


cwist_db *cwist_db_pool_acquire(cwist_db_pool_t *pool);


cwist_db *cwist_db_pool_acquire_timeout(cwist_db_pool_t *pool, int timeout_ms);


void cwist_db_pool_release(cwist_db_pool_t *pool, cwist_db *conn);


size_t cwist_db_pool_in_use(cwist_db_pool_t *pool);


cwist_error_t cwist_db_pool_exec(cwist_db_pool_t *pool, const char *sql);


cwist_error_t cwist_db_pool_query(cwist_db_pool_t *pool, const char *sql, cJSON **result);


#ifdef __cplusplus

}

#endif


#endif /* __CWIST_DB_POOL_H__ */

sql.h
Database operations wrapper (SQLite3).

cwist_db_pool_acquire
cwist_db * cwist_db_pool_acquire(cwist_db_pool_t *pool)
Acquire a connection from the pool. Blocks until one is available.
Definition pool.c:157

cwist_db_pool_exec
cwist_error_t cwist_db_pool_exec(cwist_db_pool_t *pool, const char *sql)
Execute a non-query using a pooled connection.
Definition pool.c:265

cwist_db_pool_acquire_timeout
cwist_db * cwist_db_pool_acquire_timeout(cwist_db_pool_t *pool, int timeout_ms)
Lease a pooled connection, waiting at most timeout_ms.
Definition pool.c:171

cwist_db_pool_release
void cwist_db_pool_release(cwist_db_pool_t *pool, cwist_db *conn)
Return a connection to the pool.
Definition pool.c:189

cwist_db_pool_create
cwist_db_pool_t * cwist_db_pool_create(const char *path, size_t max_conns)
Create a pool of SQLite connections.
Definition pool.c:93

cwist_db_pool_destroy_timeout
bool cwist_db_pool_destroy_timeout(cwist_db_pool_t *pool, int timeout_ms)
Close a pool, waiting up to timeout_ms for leased connections.
Definition pool.c:222

cwist_db_pool_destroy
void cwist_db_pool_destroy(cwist_db_pool_t *pool)
Destroy the pool and close all connections.
Definition pool.c:256

cwist_db_pool_query
cwist_error_t cwist_db_pool_query(cwist_db_pool_t *pool, const char *sql, cJSON **result)
Execute a query using a pooled connection.
Definition pool.c:279

cwist_db_pool_t
struct cwist_db_pool cwist_db_pool_t
Opaque database connection pool handle.
Definition pool.h:21

cwist_db_pool_in_use
size_t cwist_db_pool_in_use(cwist_db_pool_t *pool)
Count connections currently leased from the pool.
Definition pool.c:206

cwist_db
Wrapper for Database Operations. Currently uses SQLite3.
Definition sql.h:21

cwist_error_t
Integrated error structure used throughout the system.
Definition cwist_err.h:72

cwist_err.h
Unified error code and type definitions for the CWIST system layer.