CentOS下的C连接MySQL数据库

《CentOS下的C连接MySQL数据库》

在Linux系统开发中，CentOS作为稳定的服务器操作系统被广泛使用，而MySQL则是开源数据库中的佼佼者。通过C语言直接操作MySQL数据库，既能发挥C语言的高效性，又能满足对数据库底层控制的精细化需求。本文将详细介绍在CentOS环境下，如何使用C语言编程实现与MySQL数据库的连接、查询、插入及错误处理等核心操作，涵盖从环境配置到实际代码编写的完整流程。

一、环境准备与依赖安装

在CentOS中操作MySQL数据库前，需确保系统已安装MySQL服务端及C语言开发环境，并安装MySQL的C语言开发库。

1.1 安装MySQL服务端

CentOS 7/8默认使用MariaDB作为MySQL的替代品，但可通过官方仓库安装MySQL社区版：

# 添加MySQL官方YUM仓库
sudo rpm -Uvh https://dev.mysql.com/get/mysql80-community-release-el7-3.noarch.rpm

# 安装MySQL服务器
sudo yum install mysql-community-server

# 启动MySQL服务
sudo systemctl start mysqld
sudo systemctl enable mysqld

安装完成后，通过`mysql_secure_installation`脚本设置root密码并移除匿名用户。

1.2 安装MySQL C开发库

MySQL官方提供了C语言连接库`libmysqlclient`，需通过以下命令安装：

sudo yum install mysql-devel  # CentOS 7
# 或
sudo dnf install mysql-devel  # CentOS 8

该库包含头文件`mysql.h`及动态链接库`libmysqlclient.so`，是C程序连接MySQL的基础。

1.3 验证开发环境

检查头文件和库文件是否安装成功：

# 查找mysql.h路径
find /usr -name "mysql.h"

# 查找libmysqlclient.so路径
find /usr -name "libmysqlclient.so*"

典型路径为`/usr/include/mysql/mysql.h`和`/usr/lib64/libmysqlclient.so`。

二、C程序连接MySQL的核心步骤

使用C语言操作MySQL需遵循以下流程：初始化连接、建立连接、执行SQL、处理结果、释放资源。

2.1 初始化连接句柄

通过`mysql_init()`函数创建`MYSQL`结构体指针，该结构体存储连接信息：

#include 
#include 

int main() {
    MYSQL *conn;
    conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "mysql_init() failed\n");
        return 1;
    }
    // 其他操作...
    mysql_close(conn);
    return 0;
}

2.2 建立数据库连接

使用`mysql_real_connect()`函数连接MySQL服务器，需指定主机、用户、密码、数据库名及端口：

MYSQL *conn = mysql_init(NULL);
if (!mysql_real_connect(conn, "localhost", "root", "password", 
                       "testdb", 3306, NULL, 0)) {
    fprintf(stderr, "Connection error: %s\n", mysql_error(conn));
    mysql_close(conn);
    return 1;
}

参数说明：

• 第2参数：服务器地址（localhost或IP）
• 第3参数：用户名
• 第4参数：密码
• 第5参数：数据库名（可为NULL，连接后通过`mysql_select_db()`选择）
• 第6参数：端口号（默认3306）
• 第7参数：Unix套接字文件路径（本地连接可为NULL）
• 第8参数：客户端标志（通常为0）

2.3 执行SQL语句

通过`mysql_query()`执行非SELECT语句（如INSERT、UPDATE、DELETE），返回0表示成功：

if (mysql_query(conn, "INSERT INTO users (name, age) VALUES ('Alice', 25)")) {
    fprintf(stderr, "INSERT failed: %s\n", mysql_error(conn));
}

对于SELECT查询，需使用`mysql_store_result()`或`mysql_use_result()`获取结果集：

if (mysql_query(conn, "SELECT id, name FROM users")) {
    fprintf(stderr, "SELECT failed: %s\n", mysql_error(conn));
} else {
    MYSQL_RES *result = mysql_store_result(conn);
    if (result == NULL) {
        fprintf(stderr, "mysql_store_result() failed: %s\n", mysql_error(conn));
    } else {
        MYSQL_ROW row;
        while ((row = mysql_fetch_row(result))) {
            printf("ID: %s, Name: %s\n", row[0], row[1]);
        }
        mysql_free_result(result);
    }
}

2.4 错误处理机制

MySQL C API提供了`mysql_error()`和`mysql_errno()`函数获取错误信息：

if (!mysql_query(conn, "INVALID SQL")) {
    // 成功分支
} else {
    fprintf(stderr, "Error [%d]: %s\n", 
            mysql_errno(conn), mysql_error(conn));
}

三、完整示例代码

以下是一个完整的C程序，演示连接MySQL、创建表、插入数据及查询操作：

#include 
#include 
#include 

int main() {
    MYSQL *conn;
    conn = mysql_init(NULL);
    
    if (!mysql_real_connect(conn, "localhost", "root", "yourpassword", 
                           "testdb", 3306, NULL, 0)) {
        fprintf(stderr, "Connection failed: %s\n", mysql_error(conn));
        exit(1);
    }
    
    // 创建表
    if (mysql_query(conn, "CREATE TABLE IF NOT EXISTS employees ("
                          "id INT AUTO_INCREMENT PRIMARY KEY, "
                          "name VARCHAR(50), "
                          "salary DECIMAL(10,2))")) {
        fprintf(stderr, "CREATE TABLE failed: %s\n", mysql_error(conn));
    }
    
    // 插入数据
    const char *insert_sql = "INSERT INTO employees (name, salary) VALUES ('John', 5000.00)";
    if (mysql_query(conn, insert_sql)) {
        fprintf(stderr, "INSERT failed: %s\n", mysql_error(conn));
    }
    
    // 查询数据
    if (mysql_query(conn, "SELECT * FROM employees")) {
        fprintf(stderr, "SELECT failed: %s\n", mysql_error(conn));
    } else {
        MYSQL_RES *result = mysql_store_result(conn);
        if (result == NULL) {
            fprintf(stderr, "Result retrieval failed: %s\n", mysql_error(conn));
        } else {
            MYSQL_ROW row;
            int num_fields = mysql_num_fields(result);
            while ((row = mysql_fetch_row(result))) {
                for (int i = 0; i 

四、编译与运行

编译时需链接`mysqlclient`库，使用`-lmysqlclient`选项：

gcc mysql_demo.c -o mysql_demo -I/usr/include/mysql -lmysqlclient

运行程序前确保MySQL服务已启动，且用户权限正确：

./mysql_demo

五、常见问题与解决方案

5.1 连接失败问题

若出现`Can't connect to MySQL server`错误，检查：

• MySQL服务是否运行：`systemctl status mysqld`
• 防火墙是否放行3306端口：`sudo firewall-cmd --list-ports`
• 用户权限是否正确：登录MySQL后执行`SELECT host, user FROM mysql.user;`

5.2 库文件缺失问题

若编译时报`libmysqlclient.so not found`，通过`ldconfig`更新链接库缓存：

sudo ldconfig

或手动指定库路径：

gcc mysql_demo.c -o mysql_demo -L/usr/lib64/mysql -lmysqlclient

5.3 中文乱码问题

在连接后执行`SET NAMES utf8mb4`确保字符集正确：

mysql_query(conn, "SET NAMES utf8mb4");

六、性能优化建议

1. 使用连接池：频繁创建/销毁连接开销大，可实现简单的连接池管理

2. 预处理语句：对重复执行的SQL使用`mysql_stmt_init()`等函数

3. 批量操作：通过`MULTI_INSERT`语法减少网络往返

4. 结果集缓存：大数据量查询时考虑分页处理

关键词：CentOS、C语言、MySQL连接、数据库编程、MySQL C API、Linux开发、SQL操作、错误处理、编译链接、性能优化

简介：本文详细介绍了在CentOS系统下使用C语言连接MySQL数据库的完整流程，包括环境配置、连接建立、SQL执行、结果处理及错误管理，提供了可运行的示例代码和常见问题解决方案，适合Linux开发者及数据库管理员参考。

《CentOS下的C连接MySQL数据库.doc》

将本文的Word文档下载到电脑，方便收藏和打印

推荐度：

点击下载文档