在C语言中添加数据库连接是许多应用程序开发的核心环节,尤其是在需要持久化存储数据时，以MySQL数据库为例，整个过程涉及环境配置、库引入、连接建立、数据操作及资源释放等关键步骤，以下将详细拆解这一流程，确保开发者能够清晰掌握并实际应用。
开发环境准备 在开始编码前,需确保系统已安装必要的开发工具和数据库依赖，对于MySQL数据库，官方提供了C语言连接库——MySQL Connector/C，开发者需从MySQL官网下载对应版本的库文件（如libmysqlclient），并将其路径添加到编译器的链接选项中，以Linux系统为例，可通过sudo apt-get install libmysqlclient-dev命令快速安装；Windows环境下则需手动配置包含目录和库目录，或在IDE（如Visual Studio）中设置相应的链接器选项，确保MySQL服务已启动，并创建具有相应权限的数据库用户及测试用数据库。
引入必要的头文件 在C源文件中,需包含MySQL连接库提供的头文件mysql.h，该头文件定义了所有与MySQL交互所需的数据类型、函数结构和常量。
#include
#include
#include
初始化连接句柄 连接MySQL数据库前,需创建一个MYSQL结构体实例，该实例将存储连接状态、配置信息及通信句柄，通过mysql_init()函数完成初始化：
MYSQL *conn;
conn = mysql_init(NULL);
if (conn == NULL) {
fprintf(stderr, "mysql_init() failedn");
exit(1);
} 若返回NULL，通常表示内存分配失败，需检查系统资源或错误日志。
建立数据库连接 使用mysql_real_connect()函数建立与MySQL服务器的实际连接，该函数需指定服务器地址、用户名、密码、数据库名等关键参数：
conn = mysql_real_connect(conn, "localhost", "username", "password",
"database_name", 3306, NULL, 0);
if (conn == NULL) {
fprintf(stderr, "mysql_real_connect() failed: %sn", mysql_error(conn));
mysql_close(conn);
exit(1);
} 参数说明： "localhost"：服务器地址，本地连接通常为localhost或0.0.1； "username"：数据库用户名； "password"：用户密码； "database_name"：要连接的数据库名； 3306：MySQL默认端口号，若使用自定义端口需修改； 最后两个参数通常设为NULL和0，表示使用默认协议和 flags。
连接失败时，mysql_error()函数可返回具体的错误信息，便于调试。 执行SQL语句 连接成功后,可通过mysql_query()或mysql_real_query()函数执行SQL语句，前者适用于无结果集的查询（如INSERT、UPDATE），后者可处理包含二进制数据的查询，以执行查询为例：
if (mysql_query(conn, "SELECT id, name FROM users")) {
fprintf(stderr, "SELECT failed: %sn", mysql_error(conn));
exit(1);
} 对于返回结果集的查询,需使用mysql_store_result()或mysql_use_result()获取结果集对象：
MYSQL_RES *result = mysql_store_result(conn);
if (result == NULL) {
if (mysql_field_count(conn) == 0) {
// 无结果集的查询（如INSERT成功）
printf("%d rows affectedn", (int)mysql_affected_rows(conn));
} else {
fprintf(stderr, "mysql_store_result() failedn");
exit(1);
}
} else {
// 处理结果集
MYSQL_ROW row;
MYSQL_FIELD *field;
unsigned int num_fields = mysql_num_fields(result);
unsigned int num_rows = mysql_num_rows(result);
printf("Total rows: %dn", num_rows);
// 打印列名
while ((field = mysql_fetch_field(result))) {
printf("%-15s", field->name);
}
printf("n");
// 遍历每一行数据
while ((row = mysql_fetch_row(result))) {
for (unsigned int i = 0; i < num_fields; i++) {
printf("%-15s", row[i] ? row[i] : "NULL");
}
printf("n");
}
mysql_free_result(result); // 释放结果集内存
} mysql_fetch_row()逐行获取数据，mysql_fetch_field()获取列信息，使用后必须通过mysql_free_result()释放内存，避免内存泄漏。
处理事务与错误 对于需要保证数据一致性的操作（如银行转账），需使用事务控制，通过以下步骤实现：
mysql_query(conn, "START TRANSACTION");
if (mysql_query(conn, "UPDATE accounts SET balance = balance - 100 WHERE id = 1") ||
mysql_query(conn, "UPDATE accounts SET balance = balance + 100 WHERE id = 2")) {
fprintf(stderr, "Transaction failed: %sn", mysql_error(conn));
mysql_query(conn, "ROLLBACK"); // 回滚事务
} else {
mysql_query(conn, "COMMIT"); // 提交事务
} 事务执行过程中若发生错误,需立即调用ROLLBACK撤销操作，否则通过COMMIT确认更改。
关闭连接与资源释放 程序结束或连接不再需要时,必须关闭连接并释放相关资源：
mysql_close(conn); mysql_close()会释放连接句柄占用的内存，并通知服务器关闭连接，若使用了动态分配的结果集或预处理语句，需在关闭前通过mysql_free_result()或mysql_stmt_free()释放。
常见问题与注意事项 字符集问题：连接时可通过mysql_options()设置字符集，避免乱码：
mysql_options(conn, MYSQL_SET_CHARSET_NAME, "utf8mb4"); 连接超时：可通过mysql_options()设置连接超时时间（单位：秒）：
unsigned int timeout = 30;
mysql_options(conn, MYSQL_OPT_CONNECT_TIMEOUT, &timeout); 预处理语句：为提高性能和安全性，建议使用mysql_stmt_prepare()等函数预处理SQL语句，防止SQL注入攻击。 相关问答FAQs Q1：C语言连接MySQL时出现“Can’t connect to MySQL server on ‘localhost’ (10061)”错误，如何解决？A：该错误通常表示MySQL服务未启动或网络连接问题，可检查以下内容：
确认MySQL服务是否运行（Windows可通过任务管理器，Linux通过systemctl status mysql）； 检查防火墙是否阻止了3306端口； 验证连接参数（如用户名、密码）是否正确，或尝试使用mysql -u username -p命令手动登录数据库排查问题。 Q2：如何在C程序中安全地处理用户输入，防止SQL注入？A：避免直接拼接SQL字符串，采用以下方法：
使用预处理语句（Prepared Statements）：通过mysql_stmt_prepare()、mysql_stmt_bind_param()等函数绑定参数，让数据库引擎自动处理输入数据； 对输入数据进行转义：使用mysql_real_escape_string()函数对特殊字符（如单引号、双引号）进行转义，但预处理语句更安全高效； 严格验证输入类型和范围,例如对数字输入使用atoi()或strtol()转换，确保数据符合预期格式。 【版权声明】：本站所有内容均来自网络，若无意侵犯到您的权利，请及时与我们联系将尽快删除相关内容!