ToB企服应用市场:ToB评测及商务社交产业平台

标题: 【MySQL】MySQL库 [打印本页]
作者: 花瓣小跑    时间: 2024-7-26 06:13
标题: 【MySQL】MySQL库
一、mysql connect

要利用C语言毗连 mysql，需要利用 mysql 官网提供的库，大家可以去官网下载。
由于我们从前在我们的 Linux 中已经安装了有关 MySQL 的安装包，它会默认帮我们安装了链接 MySQL 的头文件和库，我们可以检察一下：


此中 include 包罗所有的方法声明， lib64 包罗所有的方法实现（打包成库）。
假如大家在安装的时候没有这些头文件和库，可以实行如下指令安装：
  1.                                 sudo yum install mysql-devel
复制代码
安装好以后，我们可以通过 mysql_get_client_info() 接口函数，来验证我们是否引入乐成：
  1.                                 #include <iostream>
  2.                                 #include <mysql/mysql.h>
  3.                                
  4.                                 int main()
  5.                                 {
  6.                                     std::cout <<  mysql_get_client_info() << std::endl;
  7.                                     return 0;
  8.                                 }
复制代码
效果如下：

如上，我们就乐成引入了。
二、mysql 接口先容

我们可以检察 MySQL5.7 的接口文档先容。
1. 初始化 mysql_init()

想要利用库，必须先进行初始化，其函数为 mysql_init()，其在官方文档中的定义如下：
  1.                                 MYSQL *mysql_init(MYSQL *mysql);
复制代码
它的返回值是一个 MySQL* 的对象，我们可以这样初始化：
  1.                                 MYSQL* fp = mysql_init(nullptr);
复制代码
2. 链接数据库 mysql_real_connect()

初始化完毕之后，必须先链接数据库，在进行后续操作。（mysql 网络部门是基于 TCP/IP 的），其在官方文档的定义如下：
  1.                         MYSQL *mysql_real_connect(MYSQL *mysql, const char *host,
  2.                                         const char *user,
  3.                                         const char *passwd,
  4.                                         const char *db,
  5.                                         unsigned int port,
  6.                                         const char *unix_socket,
  7.                                         unsigned long clientflag);
复制代码
此中 mysql 为我们初始化返回的对象；host 为需要链接的主机；user 为用户名；passwd 为用户密码；db 为利用的数据库名称；port 为端标语；背面两个参数不紧张，我们可以设置为 nullptr 和 0。
而返回值假如乐成是一个对象，否则就是空，接下来我们就可以利用这个接口了，比方以下代码，我们将函数中的参数在全局中用对应的名字定义了，所以直接传进去即可：
  1.                                 int main()
  2.                                 {
  3.                                     MYSQL* my = mysql_init(nullptr);
  4.                                     if(my == nullptr) return -1;
  5.                                
  6.                                     if(mysql_real_connect(my, host, user, passwd, db, port, nullptr, 0) == nullptr) return -1;
  7.                                
  8.                                     return 0;
  9.                                 }
复制代码
假如 nullptr 报错，修改一下 g++ 选项即可：
  1.                                 g++ -o test test.cpp -std=c++11 -l mysqlclient -L /lib64/mysql
复制代码
建立好链接之后，获取英文没有题目，假如获取中文是乱码，是由于原始默认是 latin1，我们可以通过接口设置链接的默认字符集是 utf8，如下：
  1.                                 mysql_set_character_set(my, "utf8");
复制代码
3. 实行 mysql 命令 mysql_query()

我们检察文档中的先容：


  1.                                 int mysql_query(MYSQL *mysql, const char *stmt_str);
复制代码
此中返回值0为乐成，非0则是失败；第一个参数上面已经先容过，第二个参数为要实行的 sql 语句。我们先在库中创建一张表，如下：

接下来我们利用接口插入数据：
  1.                                 int main()
  2.                                 {
  3.                                     MYSQL* my = mysql_init(nullptr);
  4.                                     if(my == nullptr) return -1;
  5.                                
  6.                                     if(mysql_real_connect(my, host, user, passwd, db, port, nullptr, 0) == nullptr) return -1;
  7.                                
  8.                                     mysql_set_character_set(my, "utf8");
  9.                                
  10.                                     if(mysql_query(my, "insert into for_test values(1,'James')") != 0) return -1;
  11.                                     else std::cout << "query success" << std::endl;
  12.                                
  13.                                     return 0;
  14.                                 }
复制代码
运行效果如下：

接下来检察数据库中的表数据：

假如我们利用 mysql_query() 检察表数据呢？我们可以尝试一下：
  1.                                 int main()
  2.                                 {
  3.                                     MYSQL* my = mysql_init(nullptr);
  4.                                     if(my == nullptr) return -1;
  5.                                
  6.                                     if(mysql_real_connect(my, host, user, passwd, db, port, nullptr, 0) == nullptr) return -1;
  7.                                
  8.                                     mysql_set_character_set(my, "utf8");
  9.                                
  10.                                     if(mysql_query(my, "select * from for_test") != 0) return -1;
  11.                                     else std::cout << "query success" << std::endl;
  12.                                
  13.                                     return 0;
  14.                                 }
复制代码

我们看到，运行之后虽然乐成了，但是什么都没有显示出来，这是因为 sql 假如是查询语句，我们还要读取数据！
4. 获取实行效果 mysql_store_result()

实在 my 中会存放每次读取到的效果，但是这个效果还需要我们再次提取出来，所以假如 mysql_query 返回乐成，那么我们就通过 mysql_store_result 这个函数来读取效果。原型如下：

  1.                                 MYSQL_RES *mysql_store_result(MYSQL *mysql);
复制代码
该函数会调用 MYSQL 变量中的 st_mysql_methods 中的 read_rows 函数指针来获取查询的效果。同时该函数会返回 MYSQL_RES 这样一个变量，该变量主要用于生存查询的效果。同时该函数 malloc 了一片内存空间来存储查询过来的数据，所以我们肯定要记得 free(result)，不然是肯定会造成内存泄漏的。 实行完 mysql_store_result 以后，实在数据都已经在 MYSQL_RES 变量中了。下面的 api 基本就是读取 MYSQL_RES* 中的数据：

此中 my_ulonglong 就是 unsigned long long，如下图：


mysql_fetch_fields 可以获取列的属性，此中获取列属性中的列名只需要指定 name 即可，如下：
  1.                            // 属性
  2.                             MYSQL_FIELD *field_array = mysql_fetch_fields(res);
  3.                             for(int i = 0; i < fields; i++)
  4.                             {
  5.                                 std::cout << field_array[i].name << "\t";
  6.                             }
  7.                             std::cout << std::endl;
复制代码

我们该怎么明白读取这个数据呢？起首需要知道，mysql 将所有的数据读取出来的时候全部都看成字符串。
其次我们在 select * from for_test 的时候，显示出来的是一个表格的形状，所以我们就可以给它进行按行按列分割，如下图：

实在我们可以把这个返回的 MYSQL_ROW  变量看作是一个 char** 的指针，如下图：

更紧张的是，返回的这个 MYSQL_ROW  的变量可以像迭代器一样利用，我们不需要手动进行迭代，它会帮我们自己迭代，比方：
  1.                             // 内容
  2.                             for(int i = 0; i < rows; i++)
  3.                             {
  4.                                 MYSQL_ROW line = mysql_fetch_row(res);
  5.                                 for(int j = 0; j < fields; j++)
  6.                                 {
  7.                                     std::cout << line[j] << "\t";
  8.                                 }
  9.                                 std::cout << std::endl;
  10.                             }
复制代码
5. 释放空间

我们上面开发的空间我们最后也要释放掉，就是 char** 这段空间，接口为：

我们在最后直接调用即可，参数就是我们上面的 res.
5. 关闭 mysql 链接 mysql_close()

  1.                                 void mysql_close(MYSQL *mysql);
复制代码
关闭链接我们直接调用以上方法即可，参数就是我们初始化的返回值。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4