当前位置：首页 > news >正文

MySQL C API高效编程：C语言实现数据库操作的深入解析

news 2025/5/8 2:19:52

知识点【MySQL C API】

1、头文件及MYSQL * 句柄

//头文件
#include <mysql/mysql.h>

1、MYSQL

MYSQL是一个结构体，封装了与数据库连接相关的所有状态，配置和数据。

2、MYSQL *的本质

类似于 FILE*，代表一个与数据库连接的通道，所有对数据库的操作都依赖于这个句柄

每个MYSQL* 句柄都对应一个独立的数据库连接，不能在多线程间共享（每个线程创建独立的句柄）

3、生命周期

从 init 到 close

4、MYSQL结构体内部管理的内容

大致了解就可以无需刻意背诵

5、MYSQL *作用

一个程序可以同时连接多个MySQL服务器，每个连接需要独立的MYSQL *句柄区分操作目标。

2、mysql_init()

**MYSQL *mysql_init(MYSQL *mysql)**

函数功能

初始化一个MYSQL对象，用于后续数据库连接操作

参数

mysql：指向MYSQL结构体的指针。

如果传入NULL，系统会自动分配并返回一个新对象。

返回值

成功：返回初始化后的MYSQL * 句柄

失败：NULL（如内存不足）

3、mysql_real_connect()

**MYSQL *mysql_real_connect(MYSQL *mysql, const char *host, const char *user, const char *passwd, const char *db, unsigned int port, const char *unix_socket, unsigned long client_flag)**

函数功能

建立于MYSQL服务器的实际连接

参数

mysql：有mysql_init初始化的MYSQL对象

host：主机名或者IP地址，如果是NULL，”localhost“，”127.0.0.1”被视为与本地主机连接

user：登陆用户名

passwd：登陆密码

db：默认连接的数据库名（可选）

port：服务器端口号（0表示默认端口3306）

unix_socket：套接字或命名管道（通常为NULL）

client_flag：连接标志

返回值

成功：返回传入的MYSQL *句柄

失败：NULL，可通过mysql_error(mysql)获取错误信息。

4、mysql_real_query()

**int mysql_real_query(MYSQL *mysql, const char *stmt_str, unsigned long length)**

函数功能

执行SQL查询（支持二进制数据）

参数

mysql：已连接的 MYSQL 对象

stmt_str：SQL语句字符串（不要以；结尾）

length：语句长度（使用strlen(stmt_str)计算）

返回值

成功：0

失败：返回非0值，需要用mysql_error(mysql)检查错误

5、mysql_store_result()

**MYSQL_RES *mysql_store_result(MYSQL *mysql)**

函数功能

从服务器获取完整的查询结果集并存储到客户端内存中

参数

mysql：已成功执行查询的MYSQL对象

返回值

成功：MYSQL_RES结果集指针

失败：返回NULL，使用mysql_error(mysql)检错

补充

适用于小型结果集，需要手动调用mysql_free_result()释放内存。

6、mysql_num_fields()

**unsigned int mysql_num_fields(MYSQL_RES *result)**

函数功能

获取结果集中的列数

参数

result：mysql_store_result 或者 mysql_use_result 返回的结果集

返回值

列数

7、mysql_num_rows()

**my_ulonglong mysql_num_rows(MYSQL_RES *result)**

函数功能

获取结果集中的行数（仅对 mysql_store_result 有效）

参数

result：my_result_result 返回的结果集

返回值

行数

补充

如果使用 mysql_use_result 需要遍历所有行才能得到准确行数

8、mysql_fetch_field()

**MYSQL_FIELD *mysql_fetch_field(MYSQL_RES *result)**

函数功能

获取结果集中列的元数据（列名，类型，长度等）

参数

return：结果集指针

返回值

成功：返回MYSQL_FIELD结构体指针

失败：无更多列：NULL

补充

内部会自动指向下一列，无需手动操作

MYSQL_FIELD结构体

typedef struct st_mysql_field
{char *name;// 列名（如 "id"）char *org_name;// 原始列名（若使用别名时）char *table;// 所属表名char *org_table;// 原始表名（若使用别名时）char *db;// 所属数据库名char *catalog;// 目录名（通常为空）char *def;// 列的默认值unsigned long length;// 列的定义长度（如 VARCHAR(255) → 255）unsigned long max_length;// 结果集中实际最大长度（需调用 mysql_store_result 后有效）unsigned int name_length;unsigned int org_name_length;unsigned int table_length;unsigned int org_table_length;unsigned int db_length;unsigned int catalog_length;unsigned int def_length;unsigned int flags;// 列的标志（如 NOT_NULL_FLAG）unsigned int decimals;// 小数位数（如 DECIMAL(10,2) → 2）unsigned int charsetnr;// 字符集编号enum enum_field_types type;// 列的数据类型（如 MYSQL_TYPE_INT、MYSQL_TYPE_STRING）
} MYSQL_FIELD;

9、mysql_fetch_row()

**MYSQL_ROW mysql_fetch_row(MYSQL_RES *result)**

typedef char **MYSQL_ROW; *// 例如：row[0] 是第一列的值*

函数功能

从结果集中逐行获取数据

参数

result：结果集指针

返回值

成功：返回MYSQL_ROW类型（字符串数组）

失败：无更多行，NULL

补充

内部会自动指向下一行，无需手动操作

10、mysql_free_result()

**void mysql_free_result(MYSQL_RES *result)**

函数功能

释放mysql_store_result 分配的 结果集的内存

参数

result：带释放的结果集指针

返回值

无

11、mysql_close()

**void mysql_close(MYSQL *mysql)**

函数功能

关闭数据库连接，并释放MYSQL对象内存

参数

mysql：已连接的MYSQL

返回值

无

补充

不能重复关闭句柄

可以加上防二次关闭的逻辑

if(mysql != NULL )
{mysql_close(mysql);mysql = NULL;
}

自动清理未释放的结果集：

如果忘记调用mysql_free_result()，mysql_close()会隐式释放结果集，但是显示释放更加直观，更加安全。

综合案例

1、函数补充 mysql_set_character_set

int mysql_set_character_set(MYSQL *mysql, const char *csname);

函数功能

设置 MySQL 客户端连接（MYSQL* 句柄）的字符集，确保客户端与服务器之间的数据传输使用指定编码。

参数

mysql：已成功连接的MYSQL *句柄

csname：字符集名称字符串

"utf8mb4"：支持 Unicode 4 字节字符（如 Emoji）。
"gbk"：中文编码。
"binary"：二进制数据。

返回值

成功：0

失败：非0

****以下是不进行编码指定的，向数据库中插入中文（小明）的现象。

2、编译要求

最后需要加上 -lmysqlclient

类似于我们在线程中添加的-lpthread

l是library（库）的意思

注意

• mysql_store_result() 的作用是获取 上一个查询 的结果集。

代码展示

#include <mysql/mysql.h>
#include <stdio.h>
#include <string.h>int main(int argc, char const *argv[])
{//初始化MYSQL * conn = mysql_init(NULL);//错误1 这里参数应是NULLif(conn == NULL){perror("mysql_init");exit(1);}//连接数据库if(!mysql_real_connect(conn,NULL,"root","","person",3306,NULL,0)){fprintf(stderr,"%s\\n",mysql_error(conn));if(conn != NULL){mysql_close(conn);conn = NULL;}exit(1);}mysql_set_character_set(conn, "utf8mb4");//请求char *arr_query1 = "select num,name from new_stu";char *arr_query2 = "insert into new_stu values(109,'小明',18)";unsigned len_query1 = strlen(arr_query1);unsigned len_query2 = strlen(arr_query2);if(mysql_real_query(conn,arr_query1,len_query1)){fprintf(stderr,"%s\\n",mysql_error(conn));if(conn != NULL){mysql_close(conn);conn = NULL;}exit(1);}//获取数据集MYSQL_RES * result = NULL; if(!(result = mysql_store_result(conn))){fprintf(stderr,"%s\\n",mysql_error(conn));if(conn != NULL){mysql_close(conn);conn = NULL;}exit(1);}//遍历数据库行数 列数unsigned int len_column = mysql_num_fields(result);my_ulonglong len_row = mysql_num_rows(result);printf("column == %u,row == %llu\\n",len_column,len_row);//遍历数据库的数据if(len_row != 0){//遍历列的属性MYSQL_FIELD *filed = NULL;while(filed = mysql_fetch_field(result)){printf("%-10s",filed->name);}printf("\\n");//遍历行数据MYSQL_ROW row = NULL;while(row = mysql_fetch_row(result)){for (size_t i = 0; i < len_column; i++){printf("%-10s",row[i]);}printf("\\n");}}else{//无数据printf("No data on database!\\n");}//注意这里 这里我们在这里插入 而不是紧跟着mysql_real_query(conn,arr_query1,len_query1)插入//让大家更好地理解 结果集的存在 和 mysql_store_result 的逻辑if(mysql_real_query(conn,arr_query2,len_query2)){fprintf(stderr,"%s\\n",mysql_error(conn));if(conn != NULL){mysql_close(conn);conn = NULL;}exit(1);}//关闭数据集mysql_free_result(result);//关闭句柄if(conn != NULL){mysql_close(conn);conn = NULL;}return 0;
}