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

MySQL数据库访问(C/C++)

访问数据库的方式:

  • 命令行:使用命令行输入SQL指令直接访问。需记忆命令和SQL语法,对新手不友好。正因如此推荐新手使用该方式访问,能倒逼学习者对SQL语法的记忆,并对MySQL更深入理解。
  • 图形化界面访问:使用图形化界面工具,如:DBeaver、DataGrip、Navicat、HeidiSQL(MySQL)、 MySQL Workbench。特点:有语法提示,可以直接对数据手动增删改。
  • 编程接口:在编写程序时,可以直接通过API接口来连接并访问数据库,嵌入代码,与业务逻辑结合。
  • ......

        MySQL的访问者都属于客户端,如以上三种方式,这一期将要讲的是C/C++编程接口的访问。

        第三方库的准备:C/C++原生库并不提供连接MySQL的API接口,需要导入第三方库,不过通常都在下载MySQL服务时就下好了,只需要在编译时加上动态库链接和相应地址。如果没有库,使用以下指令安装:

yum install myaql-community-server

客户端初始化过程:

  1. 初始化mysql操作句柄
  2. 连接mysql服务器
  3. 设置客户端的字符集
  4. 选择想要操作的数据库
  5. 操作库(增删改查)

初始化句柄

句柄类似一个数据结构的地址,到时候用来找到MySQL的相关信息,类似FILE*。

代码示例:

MYSQL* mysql=mysql_init(nullptr);

连接mysql服务器

函数原型:

MYSQL *mysql_real_connect(MYSQL *mysql,           // MySQL 连接句柄const char *host,       // 主机名或IP地址const char *user,       // MySQL用户名const char *passwd,     // 密码const char *db,         // 默认数据库unsigned int port,      // 端口号const char *unix_socket,// Unix域套接字路径unsigned long client_flag // 客户端标志
);

参数: 

  • mysql:mysql句柄,由 mysql_init() 初始化的连接句柄指针。

  • host:主机名 (如 "localhost"或"127.0.0.1")。

  • user:用户名,如果为NULL,表示使用当前登录用户名。

  • passwd:用户密码。如果为NULL,表示不使用密码。

  • db:要使用的默认数据库名称,可以为NULL。

  • port:mysql服务的端口号,如果为0,使用默认端口(3306)。

  • unix_socket:套接字路径,暂不关心,设置为NULL,表示使用默认套接字。

  • client_flag:标志位,很少用到,暂时不关系,设置为0即可。

返回值:

  • 成功:返回原来的mysql句柄。
  • 失败:返回nullptr。

代码示例:

#include <iostream>
#include <mysql/mysql.h>
#define HOST "localhost"  //或#define HOST "120.0.0.1"
#define USER "root"
#define PASSWORD "XyK@71986582"
#define DB "conn"
#define PORT 3306
main()
{//......mysql = mysql_real_connect(mysql,HOST,USER,PASSWORD,DB,PORT,nullptr,0);if(mysql==nullptr){std::cout<<"mysql_real_connect fail"<<std::endl;return 1;}//......return 0;
}

在实际开发中最好不要用root用户访问。

设置客户端的字符集

        在连接数据库后要保持客户端与mysqld的字符集一致,要不然会出现乱码。通常都统一设为utf8。

代码示例:

mysql_set_character_set(mysql,"utf8");

实参mysql是由 mysql_init() 初始化的连接句柄指针。


选择需要操作的数据库

        在做连接时已经选好了现在就不用选,只是考虑到中途需要换其他库的情况。

mysql_select_db(mysql,"conn");

conn为一个准备好的数据库的库名。 


执行sql语句(增删改查)

使用

        int mysql_query(MYSQL*, const char*)

 其中参数为mysql句柄和SQL语句,SQL语句以字符串的形式传入。成功返回0,否则返回非0。

以增为例,如下:

std::string insert1 = "insert into stu values(null,'张三',18,187562354)";
n = mysql_query(mysql, insert1.c_str());
if (n != 0)
{std::cout << "mysql_query fail" << std::endl;return 1;
}

        增删改都只要sql语句执行成功,数据库中的时间就发生改变了,没有反馈结果。而查询是不一样的,因为首先执行语句成功,结果在服务器里边,需要把它保存到本地进行访问。

数据查询流程:

  1. 使用sql语句查询成功后把查询结果保存到本地(获取结果集)
  2. 获取查询结果集的结果条数
  3. 遍历结果集
  4. 释放结果集的空间

数据查询结果是在服务器端的,我们需要把它保存到本地内存才能进行访问。使用

        MYSQL_RES* mysql_store_result(MYSQL*)

        返回值为MYSQL_RES*类型,是一个结构体类型的指针,里面保存了查询结果和相关属性。其中mysqld把所有查询结果都当做字符串类型给我们返回。我们可以把结果当做char* [ ][ ](或char** []),即储存char*的二维数组。

获取结果集,代码示例:

MYSQL_RES *res = mysql_store_result(mysql);
if (res == nullptr)
{std::cout << "mysql_store_result fail" << std::endl;return 1;
}

接下来要做的从res中获取结果即可,如果做呢?需要知道它的行和列然后进行遍历。

获取行数:

int row = mysql_num_rows(res);

获取列数:

int col = mysql_num_fields(res);

遍历并打印数据:

使用函数

        MYSQL_ROW mysql_fetch_row(MYSQL_RES*) 

获取单个行信息, result会记录每次遍历的到行。代码示例:

for (int i = 0; i < row; i++)
{MYSQL_ROW r = mysql_fetch_row(res);for (int j = 0; j < col; j++){std::cout << r[j] << '/t';}std::cout << std::endl;
}

释放结果集:

结果集在本地开辟了空间使用完后需要释放,使用mysql提供的接口:

        void mysql_free_result(MYSQL_RES*)

释放MySQL操作句柄,使用函数:
        void mysql_close(MYSQL*);

即:

mysql_free_result(res);
mysql_close(mysql);

源码:

#include <iostream>
#include <mysql/mysql.h>
#define HOST "localhost" // 或#define HOST "120.0.0.1"
#define USER "root"
#define PASSWORD "XyK@71986582"
#define DB "conn"
#define PORT 3306
int main()
{// 创建MySQL句柄MYSQL *mysql = mysql_init(nullptr);// 连接数据库mysql = mysql_real_connect(mysql, HOST, USER, PASSWORD, DB, PORT, nullptr, 0);if (mysql == nullptr){std::cout << "mysql_real_connect fail" << std::endl;return 1;}// 设置客户端字符集,与mysqld保持一致。int n = mysql_set_character_set(mysql, "utf8");if (n != 0){std::cout << "mysql_setcharacter_set fail" << std::endl;return 1;}// 选择要操作的数据库// 在做连接时已经选好了现在就不用选,只是考虑到中途需要换其他库的情况。// n = mysql_select_db(mysql,"conn");// 准备工作做好了,接下来操作库:// 执行SQL语句std::string insert1 = "insert into stu values(null,'张三',18,187562354)";std::string insert2 = "insert into stu values(null,'李四',18,187562154)";std::string delete1 = "delete from stu where id=1";std::string update = "update stu set name='王五' where name = '李四'";std::string sel = "select * from stu";n = mysql_query(mysql, sel.c_str());if (n != 0){std::cout << "mysql_query fail" << std::endl;return 1;}MYSQL_RES *res = mysql_store_result(mysql);if (res == nullptr){std::cout << "mysql_store_result fail" << std::endl;return 1;}int row = mysql_num_rows(res);int col = mysql_num_fields(res);for (int i = 0; i < row; i++){MYSQL_ROW r = mysql_fetch_row(res);for (int j = 0; j < col; j++){std::cout << r[j] << '\t';}std::cout << std::endl;}mysql_free_result(res);mysql_close(mysql);return 0;
}

非常感谢您能耐心读完这篇文章。倘若您从中有所收获,还望多多支持呀!74c0781738354c71be3d62e05688fecc.png

http://www.lryc.cn/news/582477.html

相关文章:

  • 赛博威破解快消品渠道营销三重困局,助力企业实现“活动即战力”
  • 小米YU7预售现象深度解析:智能电动汽车的下一个范式革命
  • 内容页模板表格显示不全的问题处理
  • IP 能ping通,服务器是否开机?
  • 第8章:应用层协议HTTP、SDN软件定义网络、组播技术、QoS
  • 【快手】数据挖掘面试题0002:求某地铁站每日客流量,乘地铁经过、进出站人都包括在内
  • Tourism Management and Technology Economy,旅游管理与技术经济知网期刊
  • Oracle 存储过程、函数与触发器
  • 【OceanBase诊断调优】—— 执行计划显示分区 PARTITIONS[P0SP9] 如何查询是哪个分区?
  • 数据结构与算法:博弈类问题
  • 服务器经常出现蓝屏是什么原因导致的?如何排查和修复?
  • node.js中yarn、npm、cnpm详解
  • npm : 无法加载文件 D:\Node\npm.ps1,因为在此系统上禁止运行脚本。
  • 【QT】-隐式转换 explicit用法
  • React18+TypeScript状态管理最佳实践
  • 说说SpringBoot常用的注解?
  • 【Nginx】Nginx代理WebSocket
  • Ollama+OpenWebUI 0.42+0.3.35 最新版一键安装教程,解决手动更新失败问题
  • kafka如何让消息均匀的写入到每个partition
  • OpenWebUI(5)源码学习-后端socket通信模块
  • App Trace功能实战:一键拉起应用实践
  • 【保姆级图文详解】RAG 实战(Spring AI + 本地知识库)旅游知识库问答
  • 微软上线 Deep Research 预览版:o3+必应赋能研究自动化
  • OGRE 3D----6. 背景图片渲染实现详解
  • 【Unity3D】微信小游戏适配安全区域或胶囊控件(圆圈按钮)水平高度一致方案
  • element el-table渲染二维对象数组
  • 什么是 3D 文件?
  • 开源 python 应用 开发(三)python语法介绍
  • 【电脑】主要组成部分
  • 装备制造数字孪生底座平台