【MySQL】深度学习数据库开发技术:使用CC++语言访问数据库 ...

立山  论坛元老 | 2024-12-28 12:22:15 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题

主题 1029|帖子 1029|积分 3087

**前言:**本节内容介绍使用C/C++访问数据库, 包罗对数据库的增删查改操作。 主要是学习一些接口的调用, 废话不多说, 开始我们的学习吧!
  ps:本节内容比较容易, 友友们放心观看哦!
  目次
准备mysql库
使用mysql库?
编译文件
官方API文档
对象的创建和关闭
链接数据库
下达sql指令
select语句

准备mysql库

其实我们访问mysql不但是使用命令行举行访问, 我们未来访问数据库肯定是一个程序对数据库举行访问, 而程序其实就是代码。所以未来我们可以使用代码来访问数据库, 这里我们使用C/C++代码对数据库举行访问。
首先我们创建一个非root级别用户和一个数据库:

然后我们要知道, 我们访问数据要有对应的开发包, 这些开发包我们可以直接在apt里面找到下载安装。
  1. sudo apt install -y libmysqlclient-dev
复制代码
安装好了之后我们就能在/usr/include/路径下面看到mysql目次
   

  这个 里面包含着我们必要的文件, 像什么mysql.h就是我们所必要的。
  然后在/usr/lib/x86_64-linux-gnu里面也有我们的mysql的连接库:

使用mysql库

编译文件

然后使用库,系统会默认搜索的路径是/lib/include路径, 然后我们要使用的mysql.h头文件在/lib/include西面的/mysql目次下面, 所以我们包含头文件要使用mysql/mysql.h:
  1. #include<mysql/mysql.h>  
复制代码
mysql_get_client_info函数可以打印当前mysql的版本信息。
  1. #include<iostream>#include<mysql/mysql.h>  
  2. using namespace std;int main(){    cout << "mysql_client version: " << mysql_get_client_info() << endl;           return 0;}
复制代码
然后编译大概会出现题目:

这是因为因为我们编译的时候系统找不到链接的库, 所以必要我们使用-l指令指定路径:
  1. -lmysqlclient;
复制代码
然后就能运行成功了:

官方API文档

然后就是我们要对数据库举行增删查改,我们可以去mysql的官方文档举行查看对应的资料
先进入官方网站,点击文档:

然后下滑找到并点击C API:

然后点击function就能看到我们常用的一些函数了:

知道了这些之后, 下面开始学习增删查改:
对象的创建和关闭

  1. #include<iostream>#include<mysql/mysql.h>  
  2. using namespace std;int main(){    MYSQL* my = mysql_init(nullptr);    if (nullptr)    {        cerr << "init MySQL error" << endl;        return 1;    }        mysql_close(my);    return 0;}
复制代码
这里面的MYSQL类型就类似于我们C语言里面的FILE类型, 都是一个句柄。如果成功了就是返回一个非空的值, 就代表我们得到了拒柄。
既然得到句柄, 那么最后情况下还要关闭数据库, 释放一系列资源。 使用mysql_close函数, 就类似于我们关闭文件的操作。
链接数据库

在官方文档中给出的mysql链接函数如下。
  1. MYSQL *
  2. mysql_real_connect(MYSQL *mysql,
  3.                    const char *host,
  4.                    const char *user,
  5.                    const char *passwd,
  6.                    const char *db,
  7.                    unsigned int port,
  8.                    const char *unix_socket,
  9.                    unsigned long client_flag)
复制代码
此中的第一个参数就是我们刚刚获取的句柄。 然后第二个参数就是登录的mysql地点的ip地点, 这里我们接纳本地环回;第三个参数就是就是使用的用户名;第四个参数就是对应用户的暗码;第五个参数就是数据库的名称;第六个参数就是端标语;剩下的参数默认即可。返回值就是MYSQL*也就是句柄, 如果是nullptr就是连接失败。
  1. #include<iostream>#include<mysql/mysql.h>  
  2. #include<string>using namespace std;const string host = "localhost";const string user = "mian_yang";const string passwd = "XXXXXXXXXXXXXXXX";const string db = "school_book_manage";const unsigned int port = 3306;int main(){    MYSQL* my = mysql_init(nullptr);    if (nullptr)    {        cerr << "init MySQL error" << endl;        return 1;    }    //    if (mysql_real_connect(my, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr)    {        cerr << "connect error" << endl;        return 0;    }    //    cout << "connect success" << endl;    mysql_close(my);    return 0;}
复制代码
然后我们编译一下运行一下:

下达sql指令

然后我们就可以使用函数下达sql指令, 在官方文档中给出的函数如下:
  1. int
  2. mysql_query(MYSQL *mysql,
  3.             const char *stmt_str)
复制代码
此中第一个参数就是我们的句柄。 然后第二个参数就是我们要下达的指令。返回值如果为零就实行成功了, 如果不为零, 就实行失败了。然后下面是代码:
  1. #include<iostream>#include<mysql/mysql.h>  
  2. #include<string>using namespace std;const string host = "localhost";const string user = "mian_yang";const string passwd = "MYhylk563_al36huz.6";const string db = "school_book_manage";const unsigned int port = 3306;int main(){    MYSQL* my = mysql_init(nullptr);    if (nullptr)    {        cerr << "init MySQL error" << endl;        return 1;    }    //    if (mysql_real_connect(my, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr)    {        cerr << "connect error" << endl;        return 0;    }    //    cout << "connect success" << endl;    string sql;    while (true)    {        cout << ">>";        if (!getline(cin, sql) || sql == "quit") break;        int n = mysql_query(my, sql.c_str());        if (n == 0)         {            cout << sql << "  success "<<endl;        }        else cout << sql << "  error" << endl;    }    mysql_close(my);    return 0;}
复制代码
  运行的时候我们就来测验一下举行插入:

  然后也可以看到我们的sql语句实行成功了!
  现在我们插入一下李四, 插入中文, 我们查看一下结果:


我们会看到李四被正常的插入进去了。 这里博主要说的是, 对于mysql8.0来说, 博主使用的是mysql8.0, 这里使用插入函数插入中文会正常插入。 但是如果是5.7版本的mysql, 那么这里如果插入中文插入的就是一堆乱码。全部的乱码题目都是客户端和服务器双方没有形成编码同等。好比说服务端使用utf8, 而客户端使用的是其他的编码方式。编码不同等,那么我编码使用的是utf8, 你解码使用的是其他的方式。 那么就乱码了。
这里我们的8.0数据库, 表编码都是utf8mb4的,分析我们的客户端也是utf8mb4的。如果我们设置成其他的再插入就是一堆乱码, 这里试验一下:使用mysql_set_character_set函数设置解码方式:
  1.     mysql_set_character_set(my, "latin1");
复制代码

插入成功:

可以看到, 解码出来就是一堆乱码。
现在题目来了, 我们上面的插入试验成功了, select语句呢? 我们的select语句是查, 要打印给我们一系列信息。 这里博主可以说一下实验结果, 结果是实行成功, 但是没有打印结果。 其他的像update, delete操作都能实行成功。 只有select 固然实行成功但是没有给我们表现信息, 这是因为其他的sql语句都只必要实行成功即可, 但是select语句还要举行后续的处置惩罚, 好比打印。 所以select语句怎么处置惩罚呢?
select语句

我们查出来的是一种表结构。 如果我们查出来有四条数据, 那么就有四行。 如果我们查出来的表有四列属性, 那么查出来就有四列。 我们要知道我们要查的是一些数据。 那么这些数据在mysql内部就肯定要有对应的内存空间生存这个数据。 mysql将全部的数据读取出来的时候全部都看成字符串了。 然后有一个MYSQL_RES对象,MYSQL_RES对象就是将这些数据举行整合一下。 我们可以把MYSQL_RES对象看成一个数组的指针, 这个数组里面存储的数据类型是char**类型。 数组的大小表现一共有多少条记录。

然后这些元素都指向一个char*的数组:

这个char*元素指向的就是我们的表结构里面的属性元素。 所以未来我们就可以把MYSQL_RES堪称一个char** XXX[]数组。
所以, 这个MYSQL_RES其实就是我们使用select语句之后返回的结果, 这个结果的集合就在MYSQL_RES对象中。 未来我们想要去除此中的对象, 我们必要先获取这个结果集里面的行, 里面的列:
  1. MYSQL_RES *
  2. mysql_store_result(MYSQL *mysql); //获得结果集
  3. uint64_t
  4. mysql_num_rows(MYSQL_RES *result); //获取行
  5. unsigned int
  6. mysql_num_fields(MYSQL_RES *result); //获取列
复制代码
为了更好的遍历, mysql提供了一种数据结构MYSQL_ROW, 方便我们更好的遍历, 以后我们就可以直接把这个RES结果集当成一个二维数组来使用。这个MYSQL_ROW就相当于迭代器, 我们每次调用, 它都可以主动加。
  1. MYSQL_ROW
  2. mysql_fetch_row(MYSQL_RES *result);
复制代码
然后我们不但有数据, 还有我们的列名(列属性)所以我们就可以获取一下列名:
  1. MYSQL_FIELD *
  2. mysql_fetch_fields(MYSQL_RES *result)
复制代码
这个函数的返回值是一个结构里, 这个结构体里面有着列名称、取别名后的原生列名称、 属于哪个表、属于哪个数据库等等:

未来我们想要的就是这个name字段。 我们然后就可以向遍历数组一样遍历这个列属性,打印出来列属性。
所以, 下面为全部的代码:
  1. #include<iostream>#include<mysql/mysql.h>  
  2. #include<string>using namespace std;const string host = "localhost";const string user = "mian_yang";    const string passwd = "MYhylk563_al36huz.6";const string db = "school_book_manage";const unsigned int port = 3306;int main(){    MYSQL* my = mysql_init(nullptr);    if (nullptr)    {        cerr << "init MySQL error" << endl;        return 1;    }    //    if (mysql_real_connect(my, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, nullptr, 0) == nullptr)    {        cerr << "connect error" << endl;        return 0;    }    //    cout << "connect success" << endl;    string sql = "select * from user";    int n = mysql_query(my, sql.c_str());    if (n == 0) cout << sql << " success" << endl;    else     {        cerr << sql << " error" << endl;        return 3;    }    //    MYSQL_RES* res = mysql_store_result(my);    if (res == nullptr)     {        cerr << "res error" << endl;        return 4;    }    MYSQL_FIELD* fields = mysql_fetch_fields(res);    my_ulonglong cols = mysql_num_rows(res);    for (int i = 0; i < cols; i++)    {        cout << fields[i].name << "        ";    }    cout << endl;       my_ulonglong rows = mysql_num_rows(res);    for (int i = 0; i < rows; i++)    {        MYSQL_ROW row = mysql_fetch_row(res);        for (int j = 0; j < cols; j++)        {            cout << row[j] << "        ";        }        cout << endl;    }    mysql_close(my);    return 0;}
复制代码
然后打印就打印出来了:

对于MYSQL_RES, 其实MYSQL_RES就是在内存中申请了一大块内存空间, 所以最后我们还要free这块空间。而上层用户如果使用free释放空间就会造成内存泄漏或者使用内部的原生指针太麻烦。 所以就提供了一个接口:
  1. void
  2. mysql_free_result(MYSQL_RES *result)
复制代码
这个函数就是系统提供的释放我们的结果集。
--------------------------------------------------------------------------------------------------------------------------------

——————以上就是本节全部内容哦, 如果对友友们有帮助的话可以关注博主, 方便学习更多知识哦!!!

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

本帖子中包含更多资源

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

x
回复

使用道具 举报

0 个回复

倒序浏览

快速回复

您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

立山

论坛元老
这个人很懒什么都没写!
快速回复 返回顶部 返回列表