sql_pool.h

来自「类似apache2.0的多线程技术,目的在于解决网络服务器在并发客户数很大的情况」· C头文件 代码 · 共 51 行

#include <pthread.h>
#include <semaphore.h>

#include <mysql/mysql.h>

#define MAX_WAIT_NUM    1024

#define BUSY    0
#define IDLE    1
#define FLUSH   2

struct queue_mem {
    struct wait_struct *in;
    struct wait_struct *out;
    sem_t sem_in;
    sem_t sem_out;
};

/*
 * 数据库连接池的参数
 */
struct sql_par {
    char *host;     // mysql主机地址
    int num;        // 连接数目
};

/*
 * 数据库连接结构
 */
struct sql_struct {
    MYSQL sql;
    int status;     // 连接状态
    sem_t sem;      // 加锁本结构
};

/*
 * 等待队列结构
 */
struct wait_struct {
    struct sql_struct *ptr; // 唤醒时将指向获得的mysql连接。
    sem_t sem;      // 加锁 + 睡眠唤醒机制
};

int init_sql_pool(void *ptr);

MYSQL *get_sql_connection();

int ret_sql_connection(MYSQL *sql);

int free_sql_pool();