当前位置：首页 > 数据库 > 正文

C 怎么连接数据库

admin
数据库
2025-08-01
5

语言连接数据库可用ODBC/ADO接口或特定驱动（如MySQL Connector），通过API

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

准备工作

选择数据库类型

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

安装驱动库

不同数据库对应的C语言接口库如下表所示：

|————–|——————–|———————————|—————————-|

C 怎么连接数据库第1张

注意：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：依次检查以下项目：

确保MySQL服务正在运行（终端执行systemctl status mysql）；
验证监听端口是否匹配（默认3306，可通过netstat -tulnp | grep mysql查看）；
检查防火墙设置是否阻止了该端口（使用ufw allow 3306/tcp开放权限）；
确认配置文件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()将返回完整诊断信息。