如何在C项目中全局复用MySQL连接？求可行实现方案

这个需求完全可行，下面是几种实用的实现方案，适配不同场景：

1. 全局变量方案（最简单直接） #

这种方式适合单线程或并发极低的小型项目，实现成本最低。

• 核心逻辑：在公共头文件声明MYSQL*类型的全局变量，在指定初始化函数中完成连接创建，其他文件通过包含头文件直接访问。
• 代码示例：
  公共头文件 mysql_global.h：

  #ifndef MYSQL_GLOBAL_H
  #define MYSQL_GLOBAL_H
  
  #include <mysql/mysql.h>
  
  // 声明全局MySQL连接句柄
  extern MYSQL* g_mysql_conn;
  
  // 初始化连接的函数
  int init_mysql_conn(const char* host, const char* user, const char* pass, const char* db);
  // 关闭连接的函数
  void close_mysql_conn(void);
  
  #endif
  

  实现文件 mysql_global.c：

  #include "mysql_global.h"
  
  // 定义全局变量
  MYSQL* g_mysql_conn = NULL;
  
  int init_mysql_conn(const char* host, const char* user, const char* pass, const char* db) {
      g_mysql_conn = mysql_init(NULL);
      if (!g_mysql_conn) return -1;
  
      if (!mysql_real_connect(g_mysql_conn, host, user, pass, db, 0, NULL, 0)) {
          mysql_close(g_mysql_conn);
          g_mysql_conn = NULL;
          return -2;
      }
      return 0;
  }
  
  void close_mysql_conn(void) {
      if (g_mysql_conn) {
          mysql_close(g_mysql_conn);
          g_mysql_conn = NULL;
      }
  }
  

  其他文件中使用：

  #include "mysql_global.h"
  
  void process_data(void) {
      if (!g_mysql_conn) {
          // 处理未初始化的异常情况
          return;
      }
      // 执行SQL操作
      if (mysql_query(g_mysql_conn, "UPDATE user SET status=1 WHERE id=1") != 0) {
          // 处理SQL错误
      }
  }
  

• 注意点：
  • 必须在程序入口（比如main函数）先调用init_mysql_conn完成初始化，再使用连接。
  • 多线程环境下不能直接用单个全局连接（MySQL客户端库不是线程安全的），必须加互斥锁包裹所有连接操作，否则会出现数据混乱或崩溃。

2. 单例模式实现（更可控的全局访问） #

这种方式比全局变量更安全，避免外部误修改连接句柄，同时保证连接只初始化一次。

• 核心逻辑：通过封装的函数获取连接实例，内部用静态变量存储连接，加锁保证初始化的原子性。
• 代码示例：
  头文件 mysql_singleton.h：

  #ifndef MYSQL_SINGLETON_H
  #define MYSQL_SINGLETON_H
  
  #include <mysql/mysql.h>
  
  // 获取MySQL连接实例（未初始化时自动创建）
  MYSQL* mysql_get_conn(const char* host, const char* user, const char* pass, const char* db);
  // 释放连接实例
  void mysql_release_conn(void);
  
  #endif
  

  实现文件 mysql_singleton.c：

  #include "mysql_singleton.h"
  #include <pthread.h>
  
  static MYSQL* s_mysql_conn = NULL;
  static pthread_mutex_t s_conn_mutex = PTHREAD_MUTEX_INITIALIZER;
  
  MYSQL* mysql_get_conn(const char* host, const char* user, const char* pass, const char* db) {
      pthread_mutex_lock(&s_conn_mutex);
      if (!s_mysql_conn) {
          s_mysql_conn = mysql_init(NULL);
          if (s_mysql_conn) {
              if (!mysql_real_connect(s_mysql_conn, host, user, pass, db, 0, NULL, 0)) {
                  mysql_close(s_mysql_conn);
                  s_mysql_conn = NULL;
              }
          }
      }
      pthread_mutex_unlock(&s_conn_mutex);
      return s_mysql_conn;
  }
  
  void mysql_release_conn(void) {
      pthread_mutex_lock(&s_conn_mutex);
      if (s_mysql_conn) {
          mysql_close(s_mysql_conn);
          s_mysql_conn = NULL;
      }
      pthread_mutex_unlock(&s_conn_mutex);
      pthread_mutex_destroy(&s_conn_mutex);
  }
  

• 优势：
  • 隐藏了连接的内部细节，外部只能通过函数获取/释放，降低误操作风险。
  • 加锁后多线程环境下能安全初始化，但执行SQL时仍需额外加锁（因为单个MySQL连接不能并发执行操作）。

3. 多线程高并发场景的优化方案 #

如果项目是多线程高并发的，单连接加锁会成为性能瓶颈，此时应该用连接池：

• 核心逻辑：预先创建多个MySQL连接存入连接池，线程需要时从池里取空闲连接，用完归还。
• 实现思路：可以自己封装简单的连接池（用链表或数组存储连接，加锁管理空闲/使用状态），也可以基于现有库扩展。

方案选择建议 #

• 单线程/低并发项目：优先用全局变量方案，实现最快。
• 多线程低并发项目：单例模式加操作锁，能满足需求。
• 多线程高并发项目：必须使用连接池，才能保证性能和稳定性。

内容的提问来源于stack exchange，提问作者Ivo