C 怎么连接数据库

是C语言连接数据库的详细指南,涵盖主流数据库（如MySQL、PostgreSQL、SQLite）及ODBC通用方案：

准备工作

选择数据库类型

• MySQL：适合Web应用开发，社区支持丰富；
• PostgreSQL：支持复杂事务和高并发场景；
• SQLite：轻量级嵌入式数据库，无需独立服务进程；
• 通用方案（ODBC）：跨平台兼容多种数据库系统。

安装驱动库

不同数据库对应的C语言接口库如下表所示：
| 数据库 | 驱动库名称 | 安装命令（Linux示例） | 官网下载链接 |
|————–|——————–|———————————|—————————-|
| MySQL | libmysqlclient | sudo apt install libmysqlclient-dev | MySQL官方文档 |
| PostgreSQL | libpq | sudo apt install postgresql-libpq-dev | PostgreSQL官网 |
| SQLite | sqlite3 | sudo apt install sqlite3 | SQLite官网 |
| ODBC兼容库 | unixODBC/iodbc | sudo apt install unixodbc | OpenGroup ODBC标准组织 |

注意：Windows用户需将驱动DLL路径添加到系统环境变量PATH中，并配置开发工具（如Visual Studio）的包含目录与库文件路径。

---

核心实现步骤（以MySQL为例）

包含头文件并初始化对象

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
MYSQL conn = mysql_init(NULL); // 创建MYSQL结构体实例
if (conn == NULL) {
    fprintf(stderr, "初始化失败: %sn", mysql_error(conn));
    exit(EXIT_FAILURE);
}

关键点：mysql_init()会分配内存空间用于存储连接状态信息，若返回NULL，说明内存不足或库加载异常。

建立实际连接

const char server = "localhost";
const char user = "root";
const char password = "your_password";
const char database = "testdb";
unsigned int port = 3306;
if (!mysql_real_connect(conn, server, user, password, database, port, NULL, 0)) {
    fprintf(stderr, "连接错误: %sn", mysql_error(conn));
    mysql_close(conn); // 确保释放资源
    exit(EXIT_FAILURE);
}

参数解析：最后一个参数标志位通常设为0（默认模式），支持CLIENT_MULTI_STATEMENTS等特性时可调整该值。

执行SQL语句

// 示例：查询所有用户数据
if (mysql_query(conn, "SELECT  FROM users")) {
    fprintf(stderr, "执行失败: %sn", mysql_error(conn));
    mysql_close(conn);
    exit(EXIT_FAILURE);
}
// 获取结果集
MYSQL_RES result = mysql_store_result(conn);
if (result == NULL) { // 非SELECT类操作可能返回NULL
    fprintf(stderr, "无结果集生成: %sn", mysql_error(conn));
    mysql_close(conn);
    exit(EXIT_FAILURE);
}

区别处理：对于INSERT/UPDATE/DELETE等非查询操作，应使用mysql_affected_rows()获取受影响行数而非调用mysql_store_result()。

遍历与解析结果

MYSQL_ROW row;
while ((row = mysql_fetch_row(result))) { // 逐行读取数据
    for (int i = 0; i < mysql_num_fields(result); i++) {
        printf("%st", row[i] ? row[i] : "NULL"); // 处理空字段
    }
    putchar('n');
}
mysql_free_result(result); // 必须显式释放内存

安全提示：直接拼接用户输入到SQL语句会导致注入破绽！建议改用预处理语句（见下文）。

高级特性应用

• 事务控制：通过禁用自动提交实现原子性操作：

  mysql_autocommit(conn, 0); // 关闭自动提交
  if (!mysql_query(conn, "START TRANSACTION")) { / 错误处理 / }
  // ...多条相关SQL操作...
  mysql_commit(conn);         // 成功时提交
  // or rollback on error: mysql_rollback(conn);
  mysql_autocommit(conn, 1);   // 恢复默认模式

• 预编译语句防注入：先编译后绑定参数，避免动态拼接SQL字符串：

  STMT stmt = mysql_prepare(conn, "INSERT INTO logs VALUES(?)", strlen("..."));
  if (stmt) {
      MYSQL_BIND bindParam; // 设置绑定类型及地址
      mysql_bind_param(stmt, &bindParam);
      mysql_execute(stmt);
      mysql_stmt_close(stmt);
  }

---

其他数据库适配对照表

功能点	MySQL	PostgreSQL	SQLite
初始化句柄	MYSQL = mysql_init()	PGconn = PQsetdbLogin()	sqlite3 = sqlite_open()
执行查询	mysql_query()	PQexec()	sqlite3_exec()
获取结果	mysql_store_result()	PQgetResult()	sqlite3_get_table()
错误信息获取	mysql_error()	PQerrorMessage()	sqlite3_errmsg()
关闭连接	mysql_close()	PQfinish()	sqlite3_close()

---

常见问题排查手册

Q1: “Can’t connect to MySQL server on ‘localhost’ (10061)”如何解决？

A：依次检查以下项目：

1. 确保MySQL服务正在运行（终端执行systemctl status mysql）；
2. 验证监听端口是否匹配（默认3306，可通过netstat -tulnp | grep mysql查看）；
3. 检查防火墙设置是否阻止了该端口（使用ufw allow 3306/tcp开放权限）；
4. 确认配置文件my.cnf中的bind-address未被错误设置为IP而非0.0.1。

Q2: SQL语句执行失败但看不到具体错误原因怎么办？

A：强制启用详细日志输出：

unsigned long clientFlags = mysql_get_client_info(); // 获取当前客户端标志位
mysql_options(conn, MYSQL_OPT_RECONNECT, &reconnect_enable); // 开启重连机制
mysql_options(conn, MYSQL_OPT_FOUND_ROWS, &found_rows);      // 精确计数模式
// 然后再次执行原SQL语句，此时mysql_error()将返回完整诊断信息。

补充技巧：对于批量插入操作，建议使用LOAD DATA INFILE替代循环调用INSERT语句，性能提升显著。

---

性能优化建议

1. 连接复用：避免频繁创建/销毁连接，可采用连接池设计模式；
2. 索引策略：对高频查询字段建立B+树索引，减少全表扫描开销；
3. 批量操作：将多个INSERT合并为单条多值语句（如INSERT INTO tbl VALUES (...), (...)）；
4. 内存管理：及时调用mysql_free_result()释放结果集，防止