MySQL 权限管理与 C/C++ 客户端开发实战

flush privileges;

回收权限则使用 revoke：

revoke 权限列表 on 库名.* from '用户名'@'主机名';

使用 C 语言链接访问库

C++ 原理相同，此处以 C 语言为例演示底层对接流程。

1. 环境准备

推荐通过包管理器安装开发库，Ubuntu 下执行：

sudo apt update && sudo apt install libmysqlclient-dev

安装完成后，头文件通常位于 /usr/include/mysql 目录下，包含 mysql.h。

编译时需告知编译器头文件和库文件路径，否则无法找到符号定义。

2. 核心接口学习

操作 MySQL 主要依赖 libmysqlclient 提供的 API，以下是关键步骤。

初始化连接句柄

MYSQL *my = mysql_init(NULL);
if (my == NULL) {
    printf("Init failed: %s\n", mysql_error(my));
}

设置字符集

避免乱码的关键一步，推荐使用 utf8mb4：

mysql_options(my, MYSQL_SET_CHARSET_NAME, "utf8mb4");

建立连接

调用 mysql_real_connect 传入服务器地址、账号、密码等信息：

mysql_real_connect(my, "localhost", "newuser", "123456", "testdb", 3306, NULL, 0);

参数说明：

• host: 服务器地址，本地可用 localhost 或 127.0.0.1。
• port: 端口号，默认 3306。
• unix_socket: Unix/Linux 下本地连接填 NULL。
• client_flag: 连接标志，默认 0 即可。

关闭连接

使用完毕后务必释放资源：

mysql_close(my);

3. 数据操作与结果集处理

执行增删改查使用 mysql_query，返回 0 表示成功：

int result = mysql_query(my, "INSERT INTO student VALUES (...)");

对于 SELECT 查询，需要获取结果集指针并遍历：

MYSQL_RES *result_set = mysql_store_result(my);

注意：mysql_store_result 会将结果全部加载到内存，大数据量场景下需注意性能。获取行数与列数：

my_ulonglong row_count = mysql_num_rows(result_set);
unsigned int col_count = mysql_num_fields(result_set);

获取列名结构体数组：

MYSQL_FIELD *fields = mysql_fetch_fields(result_set);

逐行读取数据：

MYSQL_ROW row;
while ((row = mysql_fetch_row(result_set)) != NULL) {
    // 遍历每一列
    for (unsigned int i = 0; i < col_count; i++) {
        printf("%s\t", row[i]);
    }
    printf("\n");
}

最后释放结果集：

mysql_free_result(result_set);

4. 完整代码示例

整合上述步骤，一个完整的 C 语言查询示例如下：

#include <stdio.h>
#include <mysql.h>

int main() {
    // 初始化
    MYSQL *my = mysql_init(NULL);
    if (my == NULL) {
        printf("Init failed: %s\n", mysql_error(my));
        return 1;
    }

    // 设置字符集
    mysql_options(my, MYSQL_SET_CHARSET_NAME, "utf8mb4");

    // 连接数据库
    if (!mysql_real_connect(my, "localhost", "newuser", "123456", "hello", 3306, NULL, 0)) {
        printf("Connect failed: %s\n", mysql_error(my));
        mysql_close(my);
        return 1;
    }

    // 执行查询
    const char *sql = "select * from student";
    if (mysql_query(my, sql)) {
        printf("Query failed: %s\n", mysql_error(my));
        mysql_close(my);
        return 1;
    }

    // 获取结果集
    MYSQL_RES *result = mysql_store_result(my);
    my_ulonglong row_count = mysql_num_rows(result);
    unsigned int col_count = mysql_num_fields(result);

    // 打印列名
    MYSQL_FIELD *fields = mysql_fetch_fields(result);
    for (unsigned int i = 0; i < col_count; i++) {
        printf("%s\t", fields[i].name);
    }
    printf("\n");

    // 打印数据
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(result)) != NULL) {
        for (unsigned int i = 0; i < col_count; i++) {
            printf("%s\t", row[i]);
        }
        printf("\n");
    }

    // 清理资源
    mysql_free_result(result);
    mysql_close(my);
    return 0;
}

编译时请确保链接 -lmysqlclient 库。实际开发中建议增加错误处理逻辑和异常捕获机制，确保程序健壮性。