C语言如何连接数据库？详细步骤与代码示例解析

在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 <mysql.h>
#include <stdio.h>
#include <stdlib.h>

stdio.h和stdlib.h主要用于标准输入输出及内存管理函数，确保程序能正确处理错误信息和动态分配资源。

初始化连接句柄

连接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()释放。

常见问题与注意事项

1. 字符集问题：连接时可通过mysql_options()设置字符集，避免乱码：

   mysql_options(conn, MYSQL_SET_CHARSET_NAME, "utf8mb4");  

2. 连接超时：可通过mysql_options()设置连接超时时间（单位：秒）：

   unsigned int timeout = 30;  
   mysql_options(conn, MYSQL_OPT_CONNECT_TIMEOUT, &timeout);  

3. 预处理语句：为提高性能和安全性，建议使用mysql_stmt_prepare()等函数预处理SQL语句，防止SQL注入攻击。

---

相关问答FAQs

Q1：C语言连接MySQL时出现“Can’t connect to MySQL server on ‘localhost’ (10061)”错误，如何解决？
A：该错误通常表示MySQL服务未启动或网络连接问题，可检查以下内容：

1. 确认MySQL服务是否运行（Windows可通过任务管理器，Linux通过systemctl status mysql）；
2. 检查防火墙是否阻止了3306端口；
3. 验证连接参数（如用户名、密码）是否正确，或尝试使用mysql -u username -p命令手动登录数据库排查问题。

Q2：如何在C程序中安全地处理用户输入，防止SQL注入？
A：避免直接拼接SQL字符串，采用以下方法：

1. 使用预处理语句（Prepared Statements）：通过mysql_stmt_prepare()、mysql_stmt_bind_param()等函数绑定参数，让数据库引擎自动处理输入数据；
2. 对输入数据进行转义：使用mysql_real_escape_string()函数对特殊字符（如单引号、双引号）进行转义，但预处理语句更安全高效；
3. 严格验证输入类型和范围,例如对数字输入使用atoi()或strtol()转换，确保数据符合预期格式。