MySQL·C/C++访问数据库

没腿的鸟  金牌会员 | 7 天前 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 809|帖子 809|积分 2427

目录
准备工作
测试是否安装成功
C/C++语言访问
官方文档
接口介绍利用
mysql_init()
mysql_close() 
增补1：makefile编写
mysql_real_connect() 
测试1：编译链接
mysql_query()
测试2：SQL语句测试
改 
增
删
查
错误1：SQL语句错误
错误2：编码错误
mysql_set_character_set()
测试3：编码错误测试
查询的后序处置处罚
mysql_store_result()
mysql_num_rows() 
mysql_num_fields()
测试4：行列获取测试
mysql_fetch_row()
测试5：读取数据测试
mysql_fetch_fields()
测试6：读取数据测试
mysql_free_result()
增补2：事务
全部的测试代码

准备工作

起首我们创建一个用户 参考上文MySQL·用户管理-CSDN博客


赋予权限

登入与权限测试

方法一：动静态链接 
C库下载
   链接：MySQL :: MySQL Community Downloads
  

找到C版本支持的第三方库下载对应版本即可
方法二：yum源直接安装
参考下文： 
   MySQL卸载、安装、登入与配置_yum 卸载mysql-CSDN博客
  曾经安装过了，就不再演示了 


假如还是没有可以尝试直接安装
  1. yum install mysql-devel
复制代码
假如是一起看过来的话，可能你们的yum源必要更新了，我利用的源现在是有一些是无法访问的，但是到现在还没有什么影响，以是为了防止出现意外，就继续利用了。具体错误如下


测试是否安装成功

这是一个返回MySQL版本的一个函数，我们可以用它来做测试 
  1. #include <iostream>
  2. #include <mysql/mysql.h>
  4. int main()
  5. {
  6.     std::cout << "mysql client version: " << mysql_get_client_info() << std::endl;
  7.     return 0;
  8. }
复制代码
 直接编译是无法成功的，我们必要指定动态库


只指明库名也是无法成功的，我们还必要添加路径

  1. g++ -o mytest test.cc -L/lib64/mysql/ -lmysqlclient
复制代码
如许我们发现编译成功了，而且成功返回了MySQL的版本号

没有找到可以是由于这个的指明是无法找到，必要重新配置环境

你可能必要把环境添加到这里面来 

通常环境下，MySQL的安装程序会自动配置好所需的环境变量和库路径，你可能不必要手动进行这些操作。
解决方法可以参考下面这里的答复

假如在头文件中不指明文件夹的话，则必要在编译指令中添加文件夹
  1. #include <iostream>
  2. #include <mysql.h>
  4. int main()
  5. {
  6.     std::cout << "mysql client version: " << mysql_get_client_info() << std::endl;
  7.     return 0;
  8. }
复制代码
直接编译会报错 

添加大 -I 选项 

C/C++语言访问

官方文档

   MySQL :: MySQL Documentation
  找到C的，对应版本 
 
   官方接口 ：MySQL :: MySQL 5.7 C API Developer Guide :: 4 C API Function Reference
  

接口介绍利用

mysql_init()

MySQL :: MySQL 5.7 C API Developer Guide :: 5.4.37 mysql_init()
创建一个mysql类的布局体

MySQL类里面就是一些信息

mysql_close() 

MySQL :: MySQL 5.7 C API Developer Guide :: 5.4.5 mysql_close()
关闭释放这个句柄 

创建而且关闭 
  1. #include <iostream>
  2. #include <mysql/mysql.h>
  4. int main()
  5. {
  6.     // std::cout << "mysql client version: " << mysql_get_client_info() << std::endl;
  8.     // 创建一个mysql句柄
  9.     MYSQL *my = mysql_init(nullptr);
  10.     if(nullptr == my)
  11.     {
  12.         std::cerr << "init MySQL error" << std::endl;
  13.         return 1;
  14.     }
  16.     // 关闭释放该句柄
  17.     mysql_close(my);
  18.     return 0;
  19. }
复制代码
 
编译测试 

增补1：makefile编写

  1. mytest:test.cc
  2.         g++ -o $@ $^ -std=c++11 -L/lib64/mysql -lmysqlclient
  3. .PHONY:clean
  4. clean:
  5.         rm -f mytest
  6. #上面的原式 g++ -o mytest test.cc -std=c++11 -L/lib64/mysql -lmysqlclient
  7. #其中$@ $^表示自动变量,前者表示目标项,后者表示全部依赖项,$<表示第一个依赖项
复制代码
mysql_real_connect() 

MySQL :: MySQL 5.7 C API Developer Guide :: 5.4.54 mysql_real_connect() 
链接数据库 

  1. #include <iostream>
  2. #include <string>
  3. #include <mysql/mysql.h>
  5. // const std::string host = "127.0.0.1";
  6. const std::string host = "localhost";   // 使用本地回环也可以
  7. const std::string user = "connector";
  8. const std::string passwd = "123456";
  9. const std::string db = "conn";
  10. const unsigned int port = 8080;
  12. int main()
  13. {
  14.     // std::cout << "mysql client version: " << mysql_get_client_info() << std::endl;
  16.     // 创建一个mysql句柄
  17.     MYSQL *my = mysql_init(nullptr);
  18.     if(nullptr == my)
  19.     {
  20.         std::cerr << "init MySQL error" << std::endl;
  21.         return 1;
  22.     }
  23.     if(mysql_real_connect(my, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr)
  24.     {
  25.         std::cerr << "connect MySQL error" << std::endl;
  26.         return 2;
  27.     }
  28.     std::cout << "connnect success" << std::endl;
  29.     // 关闭释放该句柄
  30.     mysql_close(my);
  31.     return 0;
  32. }
复制代码
 
测试1：编译链接

  
为了方便演示，我们先创建一张表
  1. create table user(
  2.     id bigint primary key auto_increment,
  3.     name varchar(32) not null,
  4.     age int not null,
  5.     telphone varchar(32) unique
  6.     );
复制代码

显然这里是没有什么题目标
我们可以通过下面这条SQL语句检察当前链接的用户信息 
  1. show processlist;
复制代码
 
我们对代码进行修改，让它不要这么快退出，让我们看到链接的信息
  1. #include <iostream>
  2. #include <unistd.h>
  3. #include <string>
  4. #include <mysql/mysql.h>
  6. // const std::string host = "127.0.0.1";
  7. const std::string host = "localhost";   // 使用本地回环也可以
  8. const std::string user = "connector";
  9. const std::string passwd = "123456";
  10. const std::string db = "conn";
  11. const unsigned int port = 8080;
  13. int main()
  14. {
  15.     // std::cout << "mysql client version: " << mysql_get_client_info() << std::endl;
  17.     // 创建一个mysql句柄
  18.     MYSQL *my = mysql_init(nullptr);
  19.     if(nullptr == my)
  20.     {
  21.         std::cerr << "init MySQL error" << std::endl;
  22.         return 1;
  23.     }
  24.     if(mysql_real_connect(my, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr)
  25.     {
  26.         std::cerr << "connect MySQL error" << std::endl;
  27.         return 2;
  28.     }
  29.     sleep(10);
  30.     std::cout << "connnect success" << std::endl;
  31.     // 关闭释放该句柄
  32.     mysql_close(my);
  33.     return 0;
  34. }
复制代码
这一次我们看到了 

显然现在没有出现什么错误
mysql_query()

MySQL :: MySQL 5.7 C API Developer Guide :: 5.4.53 mysql_query()
下达指令 


  1. #include <iostream>
  2. #include <unistd.h>
  3. #include <string>
  4. #include <mysql/mysql.h>
  6. // const std::string host = "127.0.0.1";
  7. const std::string host = "localhost";   // 使用本地回环也可以
  8. const std::string user = "connector";
  9. const std::string passwd = "123456";
  10. const std::string db = "conn";
  11. const unsigned int port = 8080;
  13. int main()
  14. {
  15.     // std::cout << "mysql client version: " << mysql_get_client_info() << std::endl;
  17.     // 创建一个mysql句柄
  18.     MYSQL *my = mysql_init(nullptr);
  19.     if(nullptr == my)
  20.     {
  21.         std::cerr << "init MySQL error" << std::endl;
  22.         return 1;
  23.     }
  24.     if(mysql_real_connect(my, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr)
  25.     {
  26.         std::cerr << "connect MySQL error" << std::endl;
  27.         return 2;
  28.     }
  29.     std::string sql;
  30.     while(true)
  31.     {
  32.         std::cout << "MySQL>>> ";
  33.         if(!std::getline(std::cin, sql) || sql == "quit")
  34.         {
  35.             std::cout << "bye bye" << std::endl;
  36.             break;
  37.         }
  38.         int n = mysql_query(my, sql.c_str());
  39.         if(n == 0)
  40.         {
  41.             std::cout << sql << " success: " << n << std::endl;
  42.         }
  43.         else
  44.         {
  45.             std::cerr << sql << " failed: " << n << std::endl;
  46.         }
  47.     }
  48.     // sleep(10);
  49.     // std::cout << "connnect success" << std::endl;
  50.     // 关闭释放该句柄
  51.     mysql_close(my);
  52.     return 0;
  53. }
复制代码
 
测试2：SQL语句测试


改 

不外实在我们并不必要这么麻烦去写一个MySQL的客户端，我们只必要利用即可
  1. #include <iostream>
  2. #include <unistd.h>
  3. #include <string>
  4. #include <mysql/mysql.h>
  6. // const std::string host = "127.0.0.1";
  7. const std::string host = "localhost";   // 使用本地回环也可以
  8. const std::string user = "connector";
  9. const std::string passwd = "123456";
  10. const std::string db = "conn";
  11. const unsigned int port = 8080;
  13. int main()
  14. {
  15.     // std::cout << "mysql client version: " << mysql_get_client_info() << std::endl;
  17.     // 创建一个mysql句柄
  18.     MYSQL *my = mysql_init(nullptr);
  19.     if(nullptr == my)
  20.     {
  21.         std::cerr << "init MySQL error" << std::endl;
  22.         return 1;
  23.     }
  24.     if(mysql_real_connect(my, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr)
  25.     {
  26.         std::cerr << "connect MySQL error" << std::endl;
  27.         return 2;
  28.     }
  29.     std::string sql = "update user set name='Jimmy' where id=2";
  30.     int n = mysql_query(my, sql.c_str());
  31.     if(n == 0) std::cout << sql << " success: " << n << std::endl;
  32.     else std::cerr << sql << " failed: " << n << std::endl;
  33.     /*
  34.     // 其实我们并不需要这么麻烦去写一个MySQL的客户端，我们只需要使用即可
  35.     std::string sql;
  36.     while(true)
  37.     {
  38.         std::cout << "MySQL>>> ";
  39.         if(!std::getline(std::cin, sql) || sql == "quit")
  40.         {
  41.             std::cout << "bye bye" << std::endl;
  42.             break;
  43.         }
  44.         int n = mysql_query(my, sql.c_str());
  45.         if(n == 0)
  46.         {
  47.             std::cout << sql << " success: " << n << std::endl;
  48.         }
  49.         else
  50.         {
  51.             std::cerr << sql << " failed: " << n << std::endl;
  52.         }
  53.     }
  54.     */
  55.     // sleep(10);
  56.     // std::cout << "connnect success" << std::endl;
  57.     // 关闭释放该句柄
  58.     mysql_close(my);
  59.     return 0;
  60. }
复制代码

显然这里是没有出现什么错误的，我们能够利用语言来实现对数据的控制
下面进行增删改查测试
  1. #include <iostream>
  2. #include <unistd.h>
  3. #include <string>
  4. #include <mysql/mysql.h>
  6. // const std::string host = "127.0.0.1";
  7. const std::string host = "localhost";   // 使用本地回环也可以
  8. const std::string user = "connector";
  9. const std::string passwd = "123456";
  10. const std::string db = "conn";
  11. const unsigned int port = 8080;
  13. int main()
  14. {
  15.     // std::cout << "mysql client version: " << mysql_get_client_info() << std::endl;
  17.     // 创建一个mysql句柄
  18.     MYSQL *my = mysql_init(nullptr);
  19.     if(nullptr == my)
  20.     {
  21.         std::cerr << "init MySQL error" << std::endl;
  22.         return 1;
  23.     }
  24.     if(mysql_real_connect(my, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr)
  25.     {
  26.         std::cerr << "connect MySQL error" << std::endl;
  27.         return 2;
  28.     }
  29.     // std::string sql = "update user set name='Jimmy' where id=2"; // 改
  30.     // std::string sql = "insert into user (name, age, telphone) values ('peter', 19, '987654321')";
  31.     // std::string sql = "delete from user where id=1";
  32.     std::string sql = "select * from user";
  34.     int n = mysql_query(my, sql.c_str());
  35.     if(n == 0) std::cout << sql << " success: " << n << std::endl;
  36.     else std::cerr << sql << " failed: " << n << std::endl;
  37.     /*
  38.     // 其实我们并不需要这么麻烦去写一个MySQL的客户端，我们只需要使用即可
  39.     std::string sql;
  40.     while(true)
  41.     {
  42.         std::cout << "MySQL>>> ";
  43.         if(!std::getline(std::cin, sql) || sql == "quit")
  44.         {
  45.             std::cout << "bye bye" << std::endl;
  46.             break;
  47.         }
  48.         int n = mysql_query(my, sql.c_str());
  49.         if(n == 0)
  50.         {
  51.             std::cout << sql << " success: " << n << std::endl;
  52.         }
  53.         else
  54.         {
  55.             std::cerr << sql << " failed: " << n << std::endl;
  56.         }
  57.     }
  58.     */
  59.     // sleep(10);
  60.     // std::cout << "connnect success" << std::endl;
  61.     // 关闭释放该句柄
  62.     mysql_close(my);
  63.     return 0;
  64. }
复制代码
增


删


查

我们会发现查这个操作是无法进行的，由于查是这四种操作最欠好处置处罚的，由于这个消息并不是让服务端去表现，在利用的时候，我们肯定是要让用户去看到这个查的消息，这个我们在后面进行详细介绍


 
错误1：SQL语句错误

从这里看到，当用户传递的SQL语句不正确的时候，MySQL的服务端是不会进行处置处罚的，当然这也是我们可以预料到的，由于MySQL包管对数据的操作，只要是成功的，就一定是正确的SQL语句，反之假如失败的，就一定是错误的语句

错误2：编码错误

我们可以看到，这里插入中文的话，是会出现乱码的，但是我们知道的，在一开始我们就已经配置好了MySQL的编码格式，那么为什么这里还是会出现呢？

如下我们配置里面是利用的utf8的

        这实在是由于编码的不同等导致的，建立好链接之后，获取英文没有题目，假如获取中文是乱码：设置链接的默认字符集是utf8，原始默认是latin1
mysql_set_character_set()

MySQL :: MySQL 5.7 C API Developer Guide :: 5.4.69 mysql_set_character_set()
设置编码格式
测试3：编码错误测试

  1. #include <iostream>
  2. #include <unistd.h>
  3. #include <string>
  4. #include <mysql/mysql.h>
  6. // const std::string host = "127.0.0.1";
  7. const std::string host = "localhost";   // 使用本地回环也可以
  8. const std::string user = "connector";
  9. const std::string passwd = "123456";
  10. const std::string db = "conn";
  11. const unsigned int port = 8080;
  13. int main()
  14. {
  15.     // std::cout << "mysql client version: " << mysql_get_client_info() << std::endl;
  17.     // 创建一个mysql句柄
  18.     MYSQL *my = mysql_init(nullptr);
  19.     if(nullptr == my)
  20.     {
  21.         std::cerr << "init MySQL error" << std::endl;
  22.         return 1;
  23.     }
  24.     if(mysql_real_connect(my, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr)
  25.     {
  26.         std::cerr << "connect MySQL error" << std::endl;
  27.         return 2;
  28.     }
  29.     mysql_set_character_set(my, "utf8");
  31.     // std::string sql = "update user set name='Jimmy' where id=2"; // 改
  32.     // std::string sql = "insert into user (name, age, telphone) values ('peter', 19, '987654321')";
  33.     // std::string sql = "delete from user where id=1";
  34.     // std::string sql = "select * from user";
  35.     std::string sql = "insert into user (name, age, telphone) values ('张三', 19, '666666666')";
  37.     int n = mysql_query(my, sql.c_str());
  38.     if(n == 0) std::cout << sql << " success: " << n << std::endl;
  39.     else std::cerr << sql << " failed: " << n << std::endl;
  40.     /*
  41.     // 其实我们并不需要这么麻烦去写一个MySQL的客户端，我们只需要使用即可
  42.     std::string sql;
  43.     while(true)
  44.     {
  45.         std::cout << "MySQL>>> ";
  46.         if(!std::getline(std::cin, sql) || sql == "quit")
  47.         {
  48.             std::cout << "bye bye" << std::endl;
  49.             break;
  50.         }
  51.         int n = mysql_query(my, sql.c_str());
  52.         if(n == 0)
  53.         {
  54.             std::cout << sql << " success: " << n << std::endl;
  55.         }
  56.         else
  57.         {
  58.             std::cerr << sql << " failed: " << n << std::endl;
  59.         }
  60.     }
  61.     */
  62.     // sleep(10);
  63.     // std::cout << "connnect success" << std::endl;
  64.     // 关闭释放该句柄
  65.     mysql_close(my);
  66.     return 0;
  67. }
复制代码
这下插入就没有编码不同等带来的乱码了


查询的后序处置处罚

mysql_store_result()

MySQL :: MySQL 5.7 C API Developer Guide :: 5.4.77 mysql_store_result()
把查询到的结果转存到某个地方，MYSQL_RES


MYSQL_RES的内容实在就是一个布局体

mysql_num_rows() 

MySQL :: MySQL 5.7 C API Developer Guide :: 5.4.49 mysql_num_rows()
拿取行 


mysql_num_fields()

MySQL :: MySQL 5.7 C API Developer Guide :: 5.4.48 mysql_num_fields()
拿取列 
 
此中 my_ulonglong 实在就是 unsigned long long 范例的数据
 
测试4：行列获取测试

  1. #include <iostream>
  2. #include <unistd.h>
  3. #include <string>
  4. #include <mysql/mysql.h>
  6. // const std::string host = "127.0.0.1";
  7. const std::string host = "localhost";   // 使用本地回环也可以
  8. const std::string user = "connector";
  9. const std::string passwd = "123456";
  10. const std::string db = "conn";
  11. const unsigned int port = 8080;
  13. int main()
  14. {
  15.     // std::cout << "mysql client version: " << mysql_get_client_info() << std::endl;
  17.     // 创建一个mysql句柄
  18.     MYSQL *my = mysql_init(nullptr);
  19.     if(nullptr == my)
  20.     {
  21.         std::cerr << "init MySQL error" << std::endl;
  22.         return 1;
  23.     }
  24.     if(mysql_real_connect(my, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr)
  25.     {
  26.         std::cerr << "connect MySQL error" << std::endl;
  27.         return 2;
  28.     }
  29.     mysql_set_character_set(my, "utf8");
  31.     // std::string sql = "update user set name='Jimmy' where id=2"; // 改
  32.     // std::string sql = "insert into user (name, age, telphone) values ('peter', 19, '987654321')";
  33.     // std::string sql = "delete from user where id=4";
  34.     // std::string sql = "insert into user (name, age, telphone) values ('张三', 19, '666666666')";
  36.     std::string sql = "select * from user";
  37.     int n = mysql_query(my, sql.c_str());
  38.     if(n == 0) std::cout << sql << " success: " << n << std::endl;
  39.     else
  40.     {
  41.         std::cerr << sql << " failed: " << n << std::endl;
  42.         return 3;
  43.     }
  44.     MYSQL_RES *res = mysql_store_result(my);
  45.     if(nullptr == res)
  46.     {
  47.         std::cerr << "mysql_store_result error" << std::endl;
  48.         return 4;
  49.     }
  51.     my_ulonglong rows = mysql_num_rows(res); // 拿取行
  52.     my_ulonglong fields = mysql_num_fields(res); // 拿取列
  54.     std::cout << "行: " << rows << std::endl;
  55.     std::cout << "列: " << fields << std::endl;
  57.     /*
  58.     // 其实我们并不需要这么麻烦去写一个MySQL的客户端，我们只需要使用即可
  59.     std::string sql;
  60.     while(true)
  61.     {
  62.         std::cout << "MySQL>>> ";
  63.         if(!std::getline(std::cin, sql) || sql == "quit")
  64.         {
  65.             std::cout << "bye bye" << std::endl;
  66.             break;
  67.         }
  68.         int n = mysql_query(my, sql.c_str());
  69.         if(n == 0)
  70.         {
  71.             std::cout << sql << " success: " << n << std::endl;
  72.         }
  73.         else
  74.         {
  75.             std::cerr << sql << " failed: " << n << std::endl;
  76.         }
  77.     }
  78.     */
  79.     // sleep(10);
  80.     // std::cout << "connnect success" << std::endl;
  81.     // 关闭释放该句柄
  82.     mysql_close(my);
  83.     return 0;
  84. }
复制代码
看到结果，我们确实拿到了具体的行和列 

当我们测试拿取一条数据的时候，也是正确的，用where进行筛选



mysql_fetch_row()

MySQL :: MySQL 5.7 C API Developer Guide :: 5.4.21 mysql_fetch_row()
自动迭代遍历，获取数据


一个新的宏，MYSQL_ROW ，实在就是一个指针，我们将其看做一个指向一个二维数组的指针就行了

测试5：读取数据测试

  1. #include <iostream>
  2. #include <unistd.h>
  3. #include <string>
  4. #include <mysql/mysql.h>
  6. // const std::string host = "127.0.0.1";
  7. const std::string host = "localhost";   // 使用本地回环也可以
  8. const std::string user = "connector";
  9. const std::string passwd = "123456";
  10. const std::string db = "conn";
  11. const unsigned int port = 8080;
  13. int main()
  14. {
  15.     // std::cout << "mysql client version: " << mysql_get_client_info() << std::endl;
  17.     // 创建一个mysql句柄
  18.     MYSQL *my = mysql_init(nullptr);
  19.     if(nullptr == my)
  20.     {
  21.         std::cerr << "init MySQL error" << std::endl;
  22.         return 1;
  23.     }
  24.     if(mysql_real_connect(my, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr)
  25.     {
  26.         std::cerr << "connect MySQL error" << std::endl;
  27.         return 2;
  28.     }
  29.     mysql_set_character_set(my, "utf8");
  31.     // std::string sql = "update user set name='Jimmy' where id=2"; // 改
  32.     // std::string sql = "insert into user (name, age, telphone) values ('peter', 19, '987654321')";
  33.     // std::string sql = "delete from user where id=4";
  34.     // std::string sql = "insert into user (name, age, telphone) values ('张三', 19, '666666666')";
  35.     // std::string sql = "select * from user where id=3";
  36.     std::string sql = "select * from user";
  37.     int n = mysql_query(my, sql.c_str());
  38.     if(n == 0) std::cout << sql << " success: " << n << std::endl;
  39.     else
  40.     {
  41.         std::cerr << sql << " failed: " << n << std::endl;
  42.         return 3;
  43.     }
  44.     MYSQL_RES *res = mysql_store_result(my);
  45.     if(nullptr == res)
  46.     {
  47.         std::cerr << "mysql_store_result error" << std::endl;
  48.         return 4;
  49.     }
  51.     // 到这里都是和结果集有关的,MYSQL_RES
  52.     my_ulonglong rows = mysql_num_rows(res); // 拿取行
  53.     my_ulonglong fields = mysql_num_fields(res); // 拿取列
  55.     std::cout << "行: " << rows << std::endl;
  56.     std::cout << "列: " << fields << std::endl;
  58.     // 将其当作一个二维数组去遍历即可
  59.     for(my_ulonglong i = 0; i < rows; ++i)
  60.     {
  61.        MYSQL_ROW row = mysql_fetch_row(res);    // 和迭代器很像，会自己维护一个指针，自动遍历
  62.        for(my_ulonglong j = 0; j < fields; ++j)
  63.        {
  64.             std::cout << row[j] << "\t"; // *(row+j) 其实就是解引用
  65.        }
  66.        std::cout << std::endl;
  67.     }
  69.     /*
  70.     // 其实我们并不需要这么麻烦去写一个MySQL的客户端，我们只需要使用即可
  71.     std::string sql;
  72.     while(true)
  73.     {
  74.         std::cout << "MySQL>>> ";
  75.         if(!std::getline(std::cin, sql) || sql == "quit")
  76.         {
  77.             std::cout << "bye bye" << std::endl;
  78.             break;
  79.         }
  80.         int n = mysql_query(my, sql.c_str());
  81.         if(n == 0)
  82.         {
  83.             std::cout << sql << " success: " << n << std::endl;
  84.         }
  85.         else
  86.         {
  87.             std::cerr << sql << " failed: " << n << std::endl;
  88.         }
  89.     }
  90.     */
  91.     // sleep(10);
  92.     // std::cout << "connnect success" << std::endl;
  93.     // 关闭释放该句柄
  94.     mysql_close(my);
  95.     return 0;
  96. }
复制代码
可以看到我们拿取到了结果，而且没有错误


mysql_fetch_fields()

MySQL :: MySQL 5.7 C API Developer Guide :: 5.4.19 mysql_fetch_fields()
获取列名信息 
 
MYSQL_FIELD


这里是不是很熟悉，这里就是MySQL里面的那一套 
 
 
测试6：读取数据测试


  1. #include <iostream>
  2. #include <unistd.h>
  3. #include <string>
  4. #include <mysql/mysql.h>
  6. // const std::string host = "127.0.0.1";
  7. const std::string host = "localhost";   // 使用本地回环也可以
  8. const std::string user = "connector";
  9. const std::string passwd = "123456";
  10. const std::string db = "conn";
  11. const unsigned int port = 8080;
  13. int main()
  14. {
  15.     // std::cout << "mysql client version: " << mysql_get_client_info() << std::endl;
  17.     // 创建一个mysql句柄
  18.     MYSQL *my = mysql_init(nullptr);
  19.     if(nullptr == my)
  20.     {
  21.         std::cerr << "init MySQL error" << std::endl;
  22.         return 1;
  23.     }
  24.     if(mysql_real_connect(my, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr)
  25.     {
  26.         std::cerr << "connect MySQL error" << std::endl;
  27.         return 2;
  28.     }
  29.     mysql_set_character_set(my, "utf8");
  31.     // std::string sql = "update user set name='Jimmy' where id=2"; // 改
  32.     // std::string sql = "insert into user (name, age, telphone) values ('peter', 19, '987654321')";
  33.     // std::string sql = "delete from user where id=4";
  34.     // std::string sql = "insert into user (name, age, telphone) values ('张三', 19, '666666666')";
  35.     // std::string sql = "select * from user where id=3";
  36.     std::string sql = "select * from user";
  37.     int n = mysql_query(my, sql.c_str());
  38.     if(n == 0) std::cout << sql << " success: " << n << std::endl;
  39.     else
  40.     {
  41.         std::cerr << sql << " failed: " << n << std::endl;
  42.         return 3;
  43.     }
  44.     MYSQL_RES *res = mysql_store_result(my);
  45.     if(nullptr == res)
  46.     {
  47.         std::cerr << "mysql_store_result error" << std::endl;
  48.         return 4;
  49.     }
  51.     // 到这里都是和结果集有关的,MYSQL_RES
  52.     my_ulonglong rows = mysql_num_rows(res); // 拿取行
  53.     my_ulonglong fields = mysql_num_fields(res); // 拿取列
  55.     std::cout << "行: " << rows << std::endl;
  56.     std::cout << "列: " << fields << std::endl;
  58.     // 将其当作一个二维数组去遍历即可
  59.     // 读取属性
  60.     MYSQL_FIELD *fields_arry = mysql_fetch_fields(res);
  61.     for(my_ulonglong i = 0; i < fields; i++)
  62.     {
  63.         std::cout << fields_arry[i].name << "\t";
  64.     }
  65.     std::cout << "\n";
  67.     // 读取内容
  68.     for(my_ulonglong i = 0; i < rows; ++i)
  69.     {
  70.        MYSQL_ROW row = mysql_fetch_row(res);    // 和迭代器很像，会自己维护一个指针，自动遍历
  71.        for(my_ulonglong j = 0; j < fields; ++j)
  72.        {
  73.             std::cout << row[j] << "\t"; // *(row+j) 其实就是解引用
  74.        }
  75.        std::cout << std::endl;
  76.     }
  78.     // 读取数据库名,表名
  79.     std::cout << fields_arry[0].db << " " << fields_arry[0].table << std::endl;
  81.     /*
  82.     // 其实我们并不需要这么麻烦去写一个MySQL的客户端，我们只需要使用即可
  83.     std::string sql;
  84.     while(true)
  85.     {
  86.         std::cout << "MySQL>>> ";
  87.         if(!std::getline(std::cin, sql) || sql == "quit")
  88.         {
  89.             std::cout << "bye bye" << std::endl;
  90.             break;
  91.         }
  92.         int n = mysql_query(my, sql.c_str());
  93.         if(n == 0)
  94.         {
  95.             std::cout << sql << " success: " << n << std::endl;
  96.         }
  97.         else
  98.         {
  99.             std::cerr << sql << " failed: " << n << std::endl;
  100.         }
  101.     }
  102.     */
  103.     // sleep(10);
  104.     // std::cout << "connnect success" << std::endl;
  105.     // 关闭释放该句柄
  106.     mysql_close(my);
  107.     return 0;
  108. }
复制代码

我们可以看到，实在MySQL的客户端本质上就是对这些数据进行处置处罚，本身就是看做对字符串的处置处罚，原理很简单
mysql_free_result()

MySQL :: MySQL 5.7 C API Developer Guide :: 5.4.25 mysql_free_result()
释放结果集 

官方提供了专门用来释放结果集的函数

利用起来也很简单，就像C++里面的free函数一样就行 
  1. mysql_free_result(res);
复制代码

增补2：事务

我们都知道每一次的单SQL语句在MySQL看来都是一个事务，以是我们这里并没有测试事务的启动和提交，我们知道这一点就行了，通常我们会把一堆SQL语句放一起提交，那么MySQL就会把它当成一个事务，以是我们在代码上一样平常也不怎么讨论事务的启动和提交，当然了我们也可以开启事务，MySQL也提供了相应的函数好比下面这几个
  1. my_bool STDCALL mysql_autocommit(MYSQL * mysql, my_bool auto_mode);
  2. my_bool STDCALL mysql_commit(MYSQL * mysql);
  3. my_bool STDCALL mysql_rollback(MYSQL * mysql);
复制代码
实在我们也可以用mysql_query()这个提交来开启事务，好比提交begin，commit，rollback都能够实现，看自己需求

全部的测试代码

  1. #include <iostream>
  2. #include <unistd.h>
  3. #include <string>
  4. #include <mysql/mysql.h>
  6. // const std::string host = "127.0.0.1";
  7. const std::string host = "localhost";   // 使用本地回环也可以
  8. const std::string user = "connector";
  9. const std::string passwd = "123456";
  10. const std::string db = "conn";
  11. const unsigned int port = 8080;
  13. int main()
  14. {
  15.     // std::cout << "mysql client version: " << mysql_get_client_info() << std::endl;
  17.     // 创建一个mysql句柄
  18.     MYSQL *my = mysql_init(nullptr);
  19.     if(nullptr == my)
  20.     {
  21.         std::cerr << "init MySQL error" << std::endl;
  22.         return 1;
  23.     }
  24.     if(mysql_real_connect(my, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr)
  25.     {
  26.         std::cerr << "connect MySQL error" << std::endl;
  27.         return 2;
  28.     }
  29.     mysql_set_character_set(my, "utf8");
  31.     // std::string sql = "update user set name='Jimmy' where id=2"; // 改
  32.     // std::string sql = "insert into user (name, age, telphone) values ('peter', 19, '987654321')";
  33.     // std::string sql = "delete from user where id=4";
  34.     // std::string sql = "insert into user (name, age, telphone) values ('张三', 19, '666666666')";
  35.     // std::string sql = "select * from user where id=3";
  36.     std::string sql = "select * from user";
  37.     int n = mysql_query(my, sql.c_str());
  38.     if(n == 0) std::cout << sql << " success: " << n << std::endl;
  39.     else
  40.     {
  41.         std::cerr << sql << " failed: " << n << std::endl;
  42.         return 3;
  43.     }
  44.     MYSQL_RES *res = mysql_store_result(my);
  45.     if(nullptr == res)
  46.     {
  47.         std::cerr << "mysql_store_result error" << std::endl;
  48.         return 4;
  49.     }
  51.     // 到这里都是和结果集有关的,MYSQL_RES
  52.     my_ulonglong rows = mysql_num_rows(res); // 拿取行
  53.     my_ulonglong fields = mysql_num_fields(res); // 拿取列
  55.     std::cout << "行: " << rows << std::endl;
  56.     std::cout << "列: " << fields << std::endl;
  58.     // 将其当作一个二维数组去遍历即可
  59.     // 读取属性
  60.     MYSQL_FIELD *fields_arry = mysql_fetch_fields(res);
  61.     for(my_ulonglong i = 0; i < fields; i++)
  62.     {
  63.         std::cout << fields_arry[i].name << "\t";
  64.     }
  65.     std::cout << "\n";
  67.     // 读取内容
  68.     for(my_ulonglong i = 0; i < rows; ++i)
  69.     {
  70.        MYSQL_ROW row = mysql_fetch_row(res);    // 和迭代器很像，会自己维护一个指针，自动遍历
  71.        for(my_ulonglong j = 0; j < fields; ++j)
  72.        {
  73.             std::cout << row[j] << "\t"; // *(row+j) 其实就是解引用
  74.        }
  75.        std::cout << std::endl;
  76.     }
  78.     // 读取数据库名,表名
  79.     std::cout << fields_arry[0].db << " " << fields_arry[0].table << std::endl;
  81.     /*
  82.     // 其实我们并不需要这么麻烦去写一个MySQL的客户端，我们只需要使用即可
  83.     std::string sql;
  84.     while(true)
  85.     {
  86.         std::cout << "MySQL>>> ";
  87.         if(!std::getline(std::cin, sql) || sql == "quit")
  88.         {
  89.             std::cout << "bye bye" << std::endl;
  90.             break;
  91.         }
  92.         int n = mysql_query(my, sql.c_str());
  93.         if(n == 0)
  94.         {
  95.             std::cout << sql << " success: " << n << std::endl;
  96.         }
  97.         else
  98.         {
  99.             std::cerr << sql << " failed: " << n << std::endl;
  100.         }
  101.     }
  102.     */
  103.     // sleep(10);
  104.     // std::cout << "connnect success" << std::endl;
  105.     // 关闭释放该句柄
  106.     mysql_free_result(res);
  107.     mysql_close(my);
  108.     return 0;
  109. }
复制代码


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

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

没腿的鸟

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表