24、MySQL数据库连接管理：连接参数配置、连接池实现、超时设置、SSL连接

数据库连接管理，说白了就是让你的C程序跟MySQL之间建立一条稳定、高效、安全的“管道”。我见过太多新手直接写死连接参数，结果线上环境一换IP就崩。也见过老项目因为没做连接池，高并发时数据库直接被拖垮。今天咱们就把这块彻底讲透。

24.1 连接参数配置：别写死，要灵活

我个人习惯把连接参数放在配置文件里，而不是硬编码在代码中。你想想看，开发环境、测试环境、生产环境的数据库地址都不一样，每次改代码多麻烦。

MySQL C API 的 mysql_real_connect() 函数支持这些关键参数：

参数	说明	我的建议
host	主机地址	不要用localhost，用127.0.0.1或具体IP
user	用户名	最小权限原则，别用root
passwd	密码	加密存储，别明文
db	数据库名	连接时指定，避免跨库操作
port	端口号	默认3306，但生产环境建议改掉
unix_socket	Unix套接字	本地连接用这个更快
client_flag	客户端标志	常用CLIENT_MULTI_STATEMENTS等

// 我的推荐做法：从配置文件读取
typedef struct {
    char host[64];
    int  port;
    char user[32];
    char passwd[64];
    char dbname[64];
} DBConfig;

DBConfig load_config(const char* path) {
    DBConfig cfg = {"127.0.0.1", 3306, "app_user", "", "mydb"};
    // 实际项目用iniparser或json-c解析
    // 这里简化演示
    FILE* fp = fopen(path, "r");
    if (fp) {
        fscanf(fp, "host=%s\nport=%d\nuser=%s\npasswd=%s\ndb=%s",
               cfg.host, &cfg.port, cfg.user, cfg.passwd, cfg.dbname);
        fclose(fp);
    }
    return cfg;
}

MYSQL* connect_db(DBConfig* cfg) {
    MYSQL* conn = mysql_init(NULL);
    if (!mysql_real_connect(conn, cfg->host, cfg->user,
                            cfg->passwd, cfg->dbname,
                            cfg->port, NULL, 0)) {
        fprintf(stderr, "连接失败: %s\n", mysql_error(conn));
        mysql_close(conn);
        return NULL;
    }
    return conn;
}

24.2 连接池实现：别频繁创建销毁

每次请求都创建新连接，用完就关——这是最糟糕的做法。我在项目中遇到过，一个简单的查询接口，因为频繁创建连接，响应时间从5ms飙升到200ms。连接池就是为了解决这个问题。

连接池的核心思想：预先创建一批连接，用的时候借，用完归还。C语言实现一个轻量级连接池，我一般这样设计：

#define POOL_SIZE 10
#define MAX_IDLE_TIME 300  // 5分钟

typedef struct {
    MYSQL* conn;
    time_t last_used;
    int    in_use;
} PoolEntry;

typedef struct {
    PoolEntry entries[POOL_SIZE];
    int       count;
    pthread_mutex_t lock;
    pthread_cond_t  cond;
} ConnectionPool;

// 初始化连接池
ConnectionPool* pool_init(DBConfig* cfg) {
    ConnectionPool* pool = calloc(1, sizeof(ConnectionPool));
    pthread_mutex_init(&pool->lock, NULL);
    pthread_cond_init(&pool->cond, NULL);

    for (int i = 0; i < POOL_SIZE; i++) {
        pool->entries[i].conn = connect_db(cfg);
        pool->entries[i].last_used = time(NULL);
        pool->entries[i].in_use = 0;
        pool->count++;
    }
    return pool;
}

// 从连接池获取连接
MYSQL* pool_get_conn(ConnectionPool* pool) {
    pthread_mutex_lock(&pool->lock);

    while (1) {
        for (int i = 0; i < pool->count; i++) {
            if (!pool->entries[i].in_use) {
                // 检查连接是否还活着
                if (mysql_ping(pool->entries[i].conn) != 0) {
                    // 连接断了，重新连接
                    // 实际项目需要重连逻辑
                    continue;
                }
                pool->entries[i].in_use = 1;
                pool->entries[i].last_used = time(NULL);
                pthread_mutex_unlock(&pool->lock);
                return pool->entries[i].conn;
            }
        }
        // 所有连接都在用，等待
        pthread_cond_wait(&pool->cond, &pool->lock);
    }
}

// 归还连接
void pool_return_conn(ConnectionPool* pool, MYSQL* conn) {
    pthread_mutex_lock(&pool->lock);
    for (int i = 0; i < pool->count; i++) {
        if (pool->entries[i].conn == conn) {
            pool->entries[i].in_use = 0;
            pool->entries[i].last_used = time(NULL);
            pthread_cond_signal(&pool->cond);
            break;
        }
    }
    pthread_mutex_unlock(&pool->lock);
}

24.3 超时设置：别让程序死等

网络不稳定、数据库负载高、死锁——这些情况都会导致连接卡死。没有超时机制，你的程序就会像“死机”一样。MySQL C API 提供了几个关键超时参数：

MYSQL* conn = mysql_init(NULL);

// 连接超时：5秒
unsigned int timeout = 5;
mysql_options(conn, MYSQL_OPT_CONNECT_TIMEOUT, &timeout);

// 读写超时：10秒
mysql_options(conn, MYSQL_OPT_READ_TIMEOUT, &timeout);
mysql_options(conn, MYSQL_OPT_WRITE_TIMEOUT, &timeout);

// 交互超时：30秒（针对长时间查询）
timeout = 30;
mysql_options(conn, MYSQL_OPT_INTERACTIVE_TIMEOUT, &timeout);

// 重连设置：自动重连
my_bool reconnect = 1;
mysql_options(conn, MYSQL_OPT_RECONNECT, &reconnect);

嗯，这里要注意：MYSQL_OPT_RECONNECT 在 MySQL 8.0 之后默认关闭了。为什么？因为自动重连在某些场景下会导致事务状态丢失。我个人建议：自己实现重连逻辑，而不是依赖自动重连。

24.4 SSL连接：数据加密是底线

明文传输密码？这在公网上等于裸奔。SSL/TLS 加密是保护数据传输安全的标配。MySQL C API 支持 SSL 连接，配置起来也不复杂：

MYSQL* conn = mysql_init(NULL);

// 设置SSL参数
mysql_ssl_set(conn,
    "/path/to/client-key.pem",   // 客户端私钥
    "/path/to/client-cert.pem",  // 客户端证书
    "/path/to/ca-cert.pem",     // CA证书
    NULL,                        // 证书颁发机构目录
    NULL);                       // 加密方式

// 强制使用SSL连接
unsigned int ssl_mode = SSL_MODE_REQUIRED;
mysql_options(conn, MYSQL_OPT_SSL_MODE, &ssl_mode);

// 连接时验证
if (!mysql_real_connect(conn, host, user, passwd, db, port, NULL, 0)) {
    fprintf(stderr, "SSL连接失败: %s\n", mysql_error(conn));
    return NULL;
}

// 检查是否真的用了SSL
if (mysql_get_ssl_cipher(conn)) {
    printf("SSL加密方式: %s\n", mysql_get_ssl_cipher(conn));
} else {
    printf("警告：未使用SSL加密！\n");
}

你想想看，如果数据库在内网，是不是就不用SSL了？不一定。我见过不少内网攻击案例，比如ARP欺骗、中间人攻击。我的原则是：只要数据经过网络，就加密。内网可以用性能更好的TLS 1.3，开销其实很小。

24.5 知识体系总览

下面这张图总结了MySQL连接管理的核心知识点，我把它画成了一张流程图，方便你理解整体脉络：

这张图把四个核心模块串起来了。从连接参数配置开始，到连接池复用连接，再到超时保护防止卡死，最后用SSL加密保证安全——这就是一个完整的连接管理体系。

---