MySQL 的 C 语言接口

﹏ヽ暗。殇╰゛Y 2023-10-16 14:01 48阅读 0赞

1. mysql\_init

MYSQL \*mysql\_init(MYSQL \*mysql);

mysql\_init函数的作用：创建一个 MYSQL 对象（该对象用于连接数据库）。

mysql\_init函数的参数：

① mysql：MYSQL 结构体指针，一般设置为 NULL 。

mysql\_init函数的返回值：

① 成功，返回一个指向 MYSQL 对象的指针。

② 失败，返回 NULL 。

**MYSQL 对象的定义如下：**

*typedef struct st\_mysql*

*\{*

*NET net; /\* Communication parameters \*/*

*unsigned char \*connector\_fd; /\* ConnectorFd for SSL \*/*

*char \*host,\*user,\*passwd,\*unix\_socket,\*server\_version,\*host\_info;*

*char \*info, \*db;*

*struct charset\_info\_st \*charset;*

*MYSQL\_FIELD \*fields;*

*MEM\_ROOT field\_alloc;*

*my\_ulonglong affected\_rows;*

*my\_ulonglong insert\_id; /\* id if insert on table with NEXTNR \*/*

*my\_ulonglong extra\_info; /\* Not used \*/*

*unsigned long thread\_id; /\* Id for connection in server \*/*

*unsigned long packet\_length;*

*unsigned int port;*

*unsigned long client\_flag,server\_capabilities;*

*unsigned int protocol\_version;*

*unsigned int field\_count;*

*unsigned int server\_status;*

*unsigned int server\_language;*

*unsigned int warning\_count;*

*struct st\_mysql\_options options;*

*enum mysql\_status status;*

*my\_bool free\_me; /\* If free in mysql\_close \*/*

*my\_bool reconnect; /\* set to 1 if automatic reconnect \*/*

*/\* session-wide random string \*/*

*char scramble\[SCRAMBLE\_LENGTH+1\];*

*my\_bool unused1;*

*void \*unused2, \*unused3, \*unused4, \*unused5;*

*LIST \*stmts; /\* list of all statements \*/*

*const struct st\_mysql\_methods \*methods;*

*void \*thd;*

*/\**

*Points to boolean flag in MYSQL\_RES or MYSQL\_STMT. We set this flag*

*from mysql\_stmt\_close if close had to cancel result set of this object.*

*\*/*

*my\_bool \*unbuffered\_fetch\_owner;*

*/\* needed for embedded server - no net buffer to store the 'info' \*/*

*char \*info\_buffer;*

*void \*extension;*

*\} MYSQL;*

MYSQL 对象里有很多连接基本参数，它也包含了一个叫 st\_mysql\_methods 的结构体变量，该变量里面保存着很多函数指针，这些函数指针将会在数据库连接成功以后的各种数据操作中被调用。

2. 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 clientflag);

mysql\_real\_connect函数的作用：连接数据库。

mysql\_real\_connect函数的参数：

① mysql：MYSQL 对象指针。

② host：要连接的 MySQL 服务器的 IP 地址。

③ user：用户名，以哪个用户身份连接。

④ passwd：用户密码。

⑤ db：要连接的数据库。

⑥ port：要连接的 MySQL 服务器的端口号。

⑦ unix\_socket：通常设置为 NULL 。

⑧ clientflag：通常设置为 0 。

mysql\_real\_connect函数的返回值：

① 成功，返回一个指向 MYSQL 对象的指针，与第一个参数 mysql 的值相同。

② 失败，返回 NULL 。

3. mysql\_close

void mysql\_close(MYSQL \*sock);

mysql\_close函数的作用：关闭数据库连接。

mysql\_close函数的参数：

① sock：MYSQL 对象指针。

mysql\_close函数的返回值：无。

4. mysql\_set\_character\_set

在连接数据库之后，需要先统一客户端和服务器的编码格式，避免在数据交互的过程中出现乱码。  
int mysql\_set\_character\_set(MYSQL \*mysql, const char \*csname);

mysql\_set\_character\_set函数的作用：设置编码格式。

mysql\_set\_character\_set函数的参数：

① mysql：MYSQL 对象指针。

② csname：要设置成哪种字符集。

mysql\_set\_character\_set函数的返回值：

① 成功，为 0 。

② 失败，为非 0 。

5. mysql\_query  
int mysql\_query(MYSQL \*mysql, const char \*q);

mysql\_query函数的作用：下发 SQL 请求。

mysql\_query函数的参数：

① mysql：MYSQL 对象指针。

② q：要执行的 SQL 语句（语句结尾可以不带分号）。

mysql\_query函数的返回值：

① 成功，为 0 。

② 失败，为非 0 。

6. mysql\_store\_result  
MYSQL\_RES \*mysql\_store\_result(MYSQL \*mysql);

mysql\_store\_result函数的作用：获取查询结果。

mysql\_store\_result函数的参数：

① mysql：MYSQL 对象指针。

mysql\_store\_result函数的返回值：

① 成功，返回一个指向 MYSQL\_RES 对象的指针。

② 失败，返回 NULL 。

该函数会调用 MYSQL 变量中的 st\_mysql\_methods 中对应的函数指针来获取查询结果。

该函数会 malloc 出一个 MYSQL\_RES 结构体变量，将获取到的查询结果保存到该变量中，最后返回该变量的指针。

由于 MYSQL\_RES 的内存空间是 malloc 出来的，所以在使用完之后一定要记得调用 free 函数(mysql\_free\_result函数)来释放对应的内存空间，否则会造成内存泄漏。

执行完mysql\_store\_result以后，其实要查询的数据都已经在 MYSQL\_RES 变量中了，下面的函数基本就是读取 MYSQL\_RES 中的数据，参数都是 MYSQL\_RES 对象指针：

// 获取结果的行数

my\_ulonglong mysql\_num\_rows(MYSQL\_RES \*res);

// 获取结果的列数

unsigned int mysql\_num\_fields(MYSQL\_RES \*res);

// 获取结果的列属性

MYSQL\_FIELD \*mysql\_fetch\_fields(MYSQL\_RES \*res);

// 获取结果中的一行记录

MYSQL\_ROW mysql\_fetch\_row(MYSQL\_RES \*result);

关于mysql\_fetch\_row函数的返回值 MYSQL\_ROW：

MYSQL\_ROW，即结果中的一行记录，对应着多个列信息，实际上就是一个字符串数组，因此，MYSQL\_ROW 类型，本质就是 char\*\* 类型，其定义如下：

typedef char \*\*MYSQL\_ROW; /\* return data as array of strings \*/

7.mysql\_free\_result()

void mysql\_free\_result(MYSQL\_RES \*result);

作用：用于释放前面 mysql\_store\_result 分配的内存。

三、使用示例

1.连接数据库和关闭数据库连接

\#include <stdio.h>

\#include <winsock.h>

\#include <mysql.h>

const char host\[\] = "127.0.0.1"; // MySQL所在机器的ip

const int port = 0; // MySQL所在机器的端口

const char db\[\] = "test"; // 数据库名

const char user\[\] = "root"; // 用户名

const char passwd\[\] = "test123"; // 用户密码

int main()

//1、获取MySQL实例（相当于创建了一个MySQL句柄）

MYSQL\* ms = mysql\_init(nullptr);

//2、连接数据库

if(mysql\_real\_connect(ms, host, user, passwd, db, port, nullptr, 0) == nullptr) \{

printf("数据库连接失败!\\n");

return 1;

printf("数据库连接成功!\\n");

//3、访问数据库

//4、关闭数据库连接

mysql\_close(ms);

printf("数据库连接关闭成功!\\n");

return 0;

2.访问数据库

mysql\_query：

*\#include <stdio.h>*

*\#include <winsock.h>*

*\#include <mysql.h>*

*const char host\[\] = "127.0.0.1"; // MySQL所在机器的ip*

*const int port = 0; // MySQL所在机器的端口*

*const char db\[\] = "test"; // 数据库名*

*const char user\[\] = "root"; // 用户名*

*const char passwd\[\] = "test123"; // 用户密码*

*int main()*

*\{*

*//1、获取MySQL实例（相当于创建了一个MySQL句柄）*

*MYSQL\* ms = mysql\_init(nullptr);*

*//2、连接数据库*

*if(mysql\_real\_connect(ms, host, user, passwd, db, port, nullptr, 0) == nullptr) \{*

*printf("数据库连接失败!\\n");*

*return 1;*

*\}*

*//设置连接的编码格式*

*mysql\_set\_character\_set(ms, "utf8");*

*printf("数据库连接成功!\\n");*

*//3. 访问数据库*

*//3.1 select 其实是最不好处理的！select sql执行完只是第一步，还需要对数据进一步解析*

*char sql\[\] = "select \* from orderitems;";*

*int code = mysql\_query(ms, sql);*

*if(code != 0)\{*

*printf("execute: %s failed\\n", sql);*

*return 2;*

*\}*

*printf("execute: %s success\\n", sql);*

*//3.2 解析数据 -- 获取行号和列号*

*MYSQL\_RES \*result = mysql\_store\_result(ms);*

*int rows = mysql\_num\_rows(result);*

*int cols = mysql\_num\_fields(result);*

*printf("行数：%d，列数：%d\\n", rows, cols);*

*//3.3 解析数据 -- 获取表中列名 -- 一般不用，仅仅是为了测试代码的完整性*

*MYSQL\_FIELD \*fields = mysql\_fetch\_fields(result);*

*for(int i = 0; i < cols; i++)\{*

*printf("%s\\t", fields\[i\].name);*

*\}*

*printf("\\n");*

*//3.4 解析数据 -- 获取表中的数据 -- 重要*

*for(int i = 0; i < rows; i++)\{*

*MYSQL\_ROW line = mysql\_fetch\_row(result); // 获取完整的一行记录（默认从前往后）*

*for(int j = 0; j < cols; j++)\{*

*printf("%s\\t", line\[j\]); // 将一行记录内部的多列字符串依次打印*

*\}*

*printf("\\n");*

*\}*

*mysql\_free\_result(result); // 释放内存空间*

*//4、关闭数据库连接*

*mysql\_close(ms);*

*printf("数据库连接关闭成功!\\n");*

*return 0;*

*\}*

*\#include <stdio.h>*

*\#include <winsock.h>*

*\#include <mysql.h>*

*const char host\[\] = "127.0.0.1"; // MySQL所在机器的ip*

*const int port = 0; // MySQL所在机器的端口*

*const char db\[\] = "test"; // 数据库名*

*const char user\[\] = "root"; // 用户名*

*const char passwd\[\] = "test123"; // 用户密码*

*// 查询表的内容*

*int select(MYSQL\* ms)*

*\{*

*//3.1 select 其实是最不好处理的！select sql执行完只是第一步，还需要对数据进一步解析*

*char sql\[\] = "select \* from man;";*

*int code = mysql\_query(ms, sql);*

*if(code != 0)\{*

*printf("execute: %s failed\\n", sql);*

*return 2;*

*\}*

*printf("execute: %s success\\n", sql);*

*//3.2 解析数据 -- 获取行号和列号*

*MYSQL\_RES \*result = mysql\_store\_result(ms);*

*int rows = mysql\_num\_rows(result);*

*int cols = mysql\_num\_fields(result);*

*printf("行数：%d，列数：%d\\n", rows, cols);*

*//3.3 解析数据 -- 获取表中列名 -- 一般不用，仅仅是为了测试代码的完整性*

*MYSQL\_FIELD \*fields = mysql\_fetch\_fields(result);*

*for(int i = 0; i < cols; i++)\{*

*printf("%s\\t", fields\[i\].name);*

*\}*

*printf("\\n");*

*//3.4 解析数据 -- 获取表中的数据 -- 重要*

*for(int i = 0; i < rows; i++)\{*

*MYSQL\_ROW line = mysql\_fetch\_row(result); // 获取完整的一行记录（默认从前往后）*

*for(int j = 0; j < cols; j++)\{*

*printf("%s\\t", line\[j\]); // 将一行记录内部的多列字符串依次打印*

*\}*

*printf("\\n");*

*\}*

*mysql\_free\_result(result); // 释放内存空间*

*return 0;*

*\}*

*int main()*

*\{*

*//1、获取MySQL实例（相当于创建了一个MySQL句柄）*

*MYSQL\* ms = mysql\_init(nullptr);*

*//2、连接数据库*

*if(mysql\_real\_connect(ms, host, user, passwd, db, port, nullptr, 0) == nullptr) \{*

*printf("数据库连接失败!\\n");*

*return 1;*

*\}*

*//设置连接的编码格式*

*mysql\_set\_character\_set(ms, "gb2312");*

*printf("数据库连接成功!\\n");*

*//3. 访问数据库*

*select(ms);*

*// insert 操作*

*char sql\_insert\[\] = "insert into man values (\\'小刚\\', 19);";*

*int res = mysql\_query(ms, sql\_insert);*

*if(res != 0)\{*

*printf("execute: %s failed\\n", sql\_insert);*

*return 2;*

*\}*

*printf("execute: %s success\\n", sql\_insert);*

*select(ms);*

*//4、关闭数据库连接*

*mysql\_close(ms);*

*printf("数据库连接关闭成功!\\n");*

*return 0;*

*\}*

![5b712ba4c80f4ca0950cc4e182148463.png][]

*\#include <stdio.h>*

*\#include <winsock.h>*

*\#include <mysql.h>*

*const char host\[\] = "127.0.0.1"; // MySQL所在机器的ip*

*const int port = 0; // MySQL所在机器的端口*

*const char db\[\] = "test"; // 数据库名*

*const char user\[\] = "root"; // 用户名*

*const char passwd\[\] = "test123"; // 用户密码*

*// 查询表的内容*

*int select(MYSQL\* ms)*

*\{*

*//3.1 select 其实是最不好处理的！select sql执行完只是第一步，还需要对数据进一步解析*

*char sql\[\] = "select \* from man;";*

*int code = mysql\_query(ms, sql);*

*if(code != 0)\{*

*printf("execute: %s failed\\n", sql);*

*return 2;*

*\}*

*printf("execute: %s success\\n", sql);*

*//3.2 解析数据 -- 获取行号和列号*

*MYSQL\_RES \*result = mysql\_store\_result(ms);*

*int rows = mysql\_num\_rows(result);*

*int cols = mysql\_num\_fields(result);*

*printf("行数：%d，列数：%d\\n", rows, cols);*

*//3.3 解析数据 -- 获取表中列名 -- 一般不用，仅仅是为了测试代码的完整性*

*MYSQL\_FIELD \*fields = mysql\_fetch\_fields(result);*

*for(int i = 0; i < cols; i++)\{*

*printf("%s\\t", fields\[i\].name);*

*\}*

*printf("\\n");*

*//3.4 解析数据 -- 获取表中的数据 -- 重要*

*for(int i = 0; i < rows; i++)\{*

*MYSQL\_ROW line = mysql\_fetch\_row(result); // 获取完整的一行记录（默认从前往后）*

*for(int j = 0; j < cols; j++)\{*

*printf("%s\\t", line\[j\]); // 将一行记录内部的多列字符串依次打印*

*\}*

*printf("\\n");*

*\}*

*mysql\_free\_result(result); // 释放内存空间*

*return 0;*

*\}*

*int main()*

*\{*

*//1、获取MySQL实例（相当于创建了一个MySQL句柄）*

*MYSQL\* ms = mysql\_init(nullptr);*

*//2、连接数据库*

*if(mysql\_real\_connect(ms, host, user, passwd, db, port, nullptr, 0) == nullptr) \{*

*printf("数据库连接失败!\\n");*

*return 1;*

*\}*

*//设置连接的编码格式*

*mysql\_set\_character\_set(ms, "gb2312");*

*printf("数据库连接成功!\\n");*

*//3. 访问数据库*

*select(ms);*

*// delete 操作*

*char sql\_delete\[\] = "delete from man where name=\\'小刚\\'";*

*int res = mysql\_query(ms, sql\_delete);*

*if(res != 0)\{*

*printf("execute: %s failed\\n", sql\_delete);*

*return 2;*

*\}*

*printf("execute: %s success\\n", sql\_delete);*

*select(ms);*

*//4、关闭数据库连接*

*mysql\_close(ms);*

*printf("数据库连接关闭成功!\\n");*

*return 0;*

*\}*

![1eb70a40fb8b4893b5da2fb79457c5b9.png][]

*\#include <stdio.h>*

*\#include <winsock.h>*

*\#include <mysql.h>*

*const char host\[\] = "127.0.0.1"; // MySQL所在机器的ip*

*const int port = 0; // MySQL所在机器的端口*

*const char db\[\] = "test"; // 数据库名*

*const char user\[\] = "root"; // 用户名*

*const char passwd\[\] = "test123"; // 用户密码*

*// 查询表的内容*

*int select(MYSQL\* ms)*

*\{*

*//3.1 select 其实是最不好处理的！select sql执行完只是第一步，还需要对数据进一步解析*

*char sql\[\] = "select \* from man;";*

*int code = mysql\_query(ms, sql);*

*if(code != 0)\{*

*printf("execute: %s failed\\n", sql);*

*return 2;*

*\}*

*printf("execute: %s success\\n", sql);*

*//3.2 解析数据 -- 获取行号和列号*

*MYSQL\_RES \*result = mysql\_store\_result(ms);*

*int rows = mysql\_num\_rows(result);*

*int cols = mysql\_num\_fields(result);*

*printf("行数：%d，列数：%d\\n", rows, cols);*

*//3.3 解析数据 -- 获取表中列名 -- 一般不用，仅仅是为了测试代码的完整性*

*MYSQL\_FIELD \*fields = mysql\_fetch\_fields(result);*

*for(int i = 0; i < cols; i++)\{*

*printf("%s\\t", fields\[i\].name);*

*\}*

*printf("\\n");*

*//3.4 解析数据 -- 获取表中的数据 -- 重要*

*for(int i = 0; i < rows; i++)\{*

*MYSQL\_ROW line = mysql\_fetch\_row(result); // 获取完整的一行记录（默认从前往后）*

*for(int j = 0; j < cols; j++)\{*

*printf("%s\\t", line\[j\]); // 将一行记录内部的多列字符串依次打印*

*\}*

*printf("\\n");*

*\}*

*mysql\_free\_result(result); // 释放内存空间*

*return 0;*

*\}*

*int main()*

*\{*

*//1、获取MySQL实例（相当于创建了一个MySQL句柄）*

*MYSQL\* ms = mysql\_init(nullptr);*

*//2、连接数据库*

*if(mysql\_real\_connect(ms, host, user, passwd, db, port, nullptr, 0) == nullptr) \{*

*printf("数据库连接失败!\\n");*

*return 1;*

*\}*

*//设置连接的编码格式*

*mysql\_set\_character\_set(ms, "gb2312");*

*printf("数据库连接成功!\\n");*

*//3. 访问数据库*

*select(ms);*

*// update 操作*

*char sql\_update\[\] = "update man set age = 20 where name=\\'小明\\'";*

*int res = mysql\_query(ms, sql\_update);*

*if(res != 0)\{*

*printf("execute: %s failed\\n", sql\_update);*

*return 2;*

*\}*

*printf("execute: %s success\\n", sql\_update);*

*select(ms);*

*//4、关闭数据库连接*

*mysql\_close(ms);*

*printf("数据库连接关闭成功!\\n");*

*return 0;*

*\}*

![997e7273f51e410288836b0d6371cd81.png][]

*  执行 update 操作：
 *  执行 delete 操作：
 *  执行 insert 操作：
 *  执行 select 操作：

[5b712ba4c80f4ca0950cc4e182148463.png]: https://img-blog.csdnimg.cn/5b712ba4c80f4ca0950cc4e182148463.png
[1eb70a40fb8b4893b5da2fb79457c5b9.png]: https://img-blog.csdnimg.cn/1eb70a40fb8b4893b5da2fb79457c5b9.png
[997e7273f51e410288836b0d6371cd81.png]: https://img-blog.csdnimg.cn/997e7273f51e410288836b0d6371cd81.png