C语言如何一步步连接MySQL数据库并执行SQL语句？

在C语言中连接MySQL数据库是一项基础且重要的技能,它使得C程序能够与强大的关系型数据库进行交互，实现数据的持久化存储与高效检索，这一过程主要依赖于MySQL官方提供的C API（应用程序编程接口），即libmysqlclient库，下面将详细介绍从环境准备到代码实现的完整流程。

环境准备与库安装

在编写代码之前,必须确保开发环境已经就绪，这包括一个正在运行的MySQL服务器、一个C语言编译器（如GCC），以及最关键的MySQL C Connector开发库。

• Linux系统：通常可以使用包管理器轻松安装，在基于Debian或Ubuntu的系统上，可以执行命令 sudo apt-get install libmysqlclient-dev，在基于Red Hat或CentOS的系统上，则可以使用 sudo yum install mysql-devel。
• Windows系统：需要从MySQL官方网站下载适用于Windows的MySQL C Connector安装包或ZIP压缩文件，安装后，需要将包含头文件（mysql.h等）的include目录和包含库文件（libmysql.lib）的lib目录路径配置到编译器的搜索路径中。

核心连接步骤

连接MySQL数据库的过程可以分解为几个关键步骤,每一步都对应着特定的API函数调用。

初始化连接句柄

需要定义一个MYSQL类型的指针，并使用mysql_init()函数对其进行初始化，这个句柄将作为后续所有数据库操作的载体。

MYSQL *conn;
conn = mysql_init(NULL);
if (conn == NULL) {
    // 处理初始化失败
    fprintf(stderr, "mysql_init() failedn");
    exit(1);
}

建立实际连接

初始化完成后,使用mysql_real_connect()函数尝试与MySQL服务器建立连接，这是整个流程的核心函数，其参数包含了连接所需的所有信息。

if (mysql_real_connect(conn, "host", "user", "password", "database", port, unix_socket, client_flag) == NULL) {
    // 处理连接失败
    fprintf(stderr, "mysql_real_connect() failed: %sn", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

参数说明如下：

• conn: 已初始化的连接句柄。
• host: MySQL服务器地址，如”localhost”或IP地址。
• user: 数据库用户名。
• password: 对应的密码。
• database: 要连接的数据库名称。
• port: MySQL服务端口号，通常为0表示使用默认端口3306。
• unix_socket: 通常为NULL。
• client_flag: 通常为0。

执行SQL查询

连接成功后,便可以使用mysql_query()函数执行SQL语句，该函数接受一个SQL查询字符串作为参数。

const char *sql_query = "SELECT id, name FROM users";
if (mysql_query(conn, sql_query)) {
    // 处理查询失败
    fprintf(stderr, "mysql_query() failed: %sn", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}

处理查询结果

对于SELECT等会返回结果的查询，需要使用mysql_store_result()将结果集从服务器获取到客户端，然后通过循环遍历每一行数据。

MYSQL_RES *result = mysql_store_result(conn);
if (result == NULL) {
    // 处理获取结果失败
    fprintf(stderr, "mysql_store_result() failed: %sn", mysql_error(conn));
    mysql_close(conn);
    exit(1);
}
int num_fields = mysql_num_fields(result);
MYSQL_ROW row;
while ((row = mysql_fetch_row(result))) {
    for(int i = 0; i < num_fields; i++) {
        printf("%s ", row[i] ? row[i] : "NULL");
    }
    printf("n");
}

关闭连接与释放资源

操作完成后,必须释放结果集占用的内存，并关闭数据库连接，以避免资源泄漏。

mysql_free_result(result);
mysql_close(conn);

编译与运行

编写完C代码后,编译时需要链接MySQL客户端库，使用mysql_config工具可以方便地获取所需的编译和链接选项。

gcc your_program.c -o your_program $(mysql_config --cflags --libs)

这个命令会自动包含正确的头文件路径和链接-lmysqlclient库。

为了更清晰地理解核心函数,下表小编总结了它们的主要用途：

函数名	主要功能
mysql_init()	初始化一个MYSQL连接句柄。
mysql_real_connect()	与MySQL服务器建立连接。
mysql_query()	执行一条SQL查询语句。
mysql_store_result()	获取查询的完整结果集。
mysql_fetch_row()	从结果集中获取下一行数据。
mysql_error()	返回最近一次MySQL函数调用的错误信息。
mysql_close()	关闭服务器连接并释放句柄。
mysql_free_result()	释放结果集占用的内存。

---

相关问答FAQs

问题1：连接MySQL时，程序提示“Can’t connect to local MySQL server through socket”，这是什么原因？

解答：这个错误通常意味着C程序无法通过Unix套接字文件（在Linux/macOS上）或命名管道（在Windows上）找到本地MySQL服务，常见原因包括：MySQL服务未启动；套接字文件路径不正确（my.cnf配置文件中指定）；或程序尝试连接的主机名是localhost，但MySQL配置为仅允许TCP/IP连接，可以尝试将连接主机从"localhost"改为"127.0.0.1"，强制使用TCP/IP连接，或者检查MySQL服务状态和配置文件。

问题2：除了mysql_real_connect，还有其他方式设置连接参数吗？

解答：是的，在调用mysql_real_connect之前，可以使用mysql_options函数来设置多种连接选项，例如设置超时时间、启用SSL加密、设置默认字符集等，这种方式提供了更灵活的配置能力，设置连接超时的代码如下：
unsigned int timeout = 5;
mysql_options(conn, MYSQL_OPT_CONNECT_TIMEOUT, &timeout);
这样可以在建立连接前对连接行为进行更细致的控制。