C++：MySQL的事务概念与使用（四）

1、事务的概念

  • 定义：事务是构成单一逻辑工作单元的操作集合，要么完整的执行，要么完全不执行。无论发生何种情况，DBS必须保证事务能正确、完整的执行。

  • 性质：事务的四大ACID性质。

    • 原子性(Atomicity)：一个事务对数据库的所有操作，是一个不可分割的工作单元。这些操作要么全部执行，要么全都不执行。既要么执行成功要么执行失败
    • 一致性(Consistency)：一个事务独立执行的结果，应该保持数据库的一致性，既数据不会因事务的执行而遭受破坏
    • 隔离性(Isolation)：在多个事务并发执行时，系统应该保证与这些事务先后单独执行时的结果一样，此时称事务打到了隔离性的要求。也就是在多个事务并发执行时，保证执行结果是正确的，如同单用户环境一样。早些年的MyISAM数据库引擎是采用表锁的形式，当执行SQL语句时锁定一张表，而当今的InnoDB引擎是采用行锁定的，在操纵数据库的的时候只锁定操作的行不锁定这张表，这就是隔离性
    • 持久性(Durability)：一个事务一旦完成全部操作后，它对数据库的所有更新应永久的反映在数据库中，不会丢失、即以后系统发生故障也是如此。
2、事务的并发读和隔离级别问题
2.1、事务的并发读问题
  • 脏读：一个事务读取到了另一个事务未成功提交的数据；例如：事务A对数据库中的数据进行了修改但是还未提交、此时事务B进行数据读取；但是事务A因为某些原因回滚了，此时B拿到的数据是一个无效数据，也叫脏数据！

  1. 不可重复读：同一个事务内，先后两次读取数据返回结果不一致；例如：事务A第一次读取到数据、事务B修改数据并且成功提交、事务A第二次读取数据；两次读取数据结果不一致。由于事务没有形成隔离导致

  2. 幻读：一个事务读取到另一个事务已经提交的添加或者删除的数据；例如：A事务读取数据、B事务删除（增加）数据，A事务再次读取数据，发现多出一些新的数据，像出现了幻觉一样。

  3. 幻读与不可重复度的区别：不可重复度强调的是修改数据；幻读强调的是添加、删除数据。

  4. 总结：脏读是致命的操作，因为拿到的数据是无效数据；而不可重复度与幻读是一种现象，只是先后读取不一致的问题，但是数据是有效的（其他事物成功提交）！

2.2、事务的隔离级别

  • TRANSACTION_NONE：无事务。

  • TRANSACTION_READ_UNCOMMITTED：未解决任何问题，可能出现一系列并发问题

  • TRANSACTION_READ_COMMITTED：解决了脏读问题

  • TRANSACTION_REPEATABLE_READ：解决了脏读和不可重复读问题

TRANSACTION_SERIALIZABLE：解决了脏读、不可重复读、幻读问题，采用串行化访问。
在这里插入图片描述

3、C++使用MySQL事务操作
3.1、事务的测试
  • 事务操作主要分4-5个步骤
    • 开启事务：“start transaction”
    • 关闭自动提交：“set autocommit = 0;”
    • 执行SQL语句：主要是一些增删改操作
    • 回滚或提交：当出现问题时可以rollback回滚，如果没有问题直接commit提交
    • 恢复自动提交：“set autocommit = 1;”
void transaction_test(MYSQL &mysql)
{/** 事务的操作：* 1. 开启事务* 2. 关闭自动提交，开启手动提交* 3. 执行sql* 4. 成功 commit 或者 rollback* 5. 开启自动提交*/// 1. 开启事务string sql = "start transaction;";mysql_real_query(&mysql, sql.c_str(), sql.length());// 2. 开启手动提交sql = "set autocommit = 0;";mysql_real_query(&mysql, sql.c_str(), sql.length());// 3. 执行sql语句for(int i = 1;i <= 5;i++){stringstream ss;sql = "insert into `test`(`username`, `password`) values('Admin', '123456');";int insert_result = mysql_real_query(&mysql, sql.c_str(), sql.length());if(insert_result != 0){cout << "insert data failed! sql = " << sql << ", error msg = " << mysql_error(&mysql) << endl;}}// 4. rollbacksql = "rollback";mysql_real_query(&mysql, sql.c_str(), sql.length());// 5. 再次执行插入操作sql = "insert into `test`(`username`, `password`) values('Splay', '123456');";mysql_real_query(&mysql, sql.c_str(), sql.length());// 6. commit提交sql = "commit";mysql_real_query(&mysql, sql.c_str(), sql.length());// 7. 回复自动提交sql = "set autocommit = 1;";mysql_real_query(&mysql, sql.c_str(), sql.length());// 8. 查询数据库数据的数量sql = "select count(*) from `test`;";mysql_real_query(&mysql, sql.c_str(), sql.length());// 释放mysql结构体MYSQL_RES* result = mysql_store_result(&mysql);cout << "当前数据库的数据行数：" << mysql_fetch_row(result)[0] << endl;
}
3.2、事务与不同批量插入数据的性能对比

对于不同的类型的操作每次都插入1000条数据，在插入之前将表清空。

  • 单条插入：每次插入一条数据，这样就会导致一个问题执行一条SQL语句，频繁的开启关闭事务会造成性能浪费
  • 批量插入：1000条数据一次性组合，通过CLIENT_MULTI_STATEMENT设置进行多SQL的同时执行
  • 事务插入：将1000条数据打包成一个事务里，最后一次性提交（一个事务内）
void truncate_table(MYSQL &mysql)
{string sql = "truncate table `test`;";mysql_real_query(&mysql, sql.c_str(), sql.length());
}void test_single_insert(MYSQL &mysql)
{truncate_table(mysql);auto start = std::chrono::system_clock::now();for(int i = 1;i <= 1000;i++){string sql = "insert into `test`(`username`, `password`) values('Splay', '123456');";mysql_real_query(&mysql, sql.c_str(), sql.length());}auto end = std::chrono::system_clock::now();auto duration = duration_cast<chrono::milliseconds> (end - start);cout << "single_insert插入1万条数据所需的时间: " << duration.count()/1000.0 << "秒" << endl;
}void test_multi_insert(MYSQL &mysql)
{truncate_table(mysql);auto start = std::chrono::system_clock::now();string sql = "";for(int i = 1;i <= 1000;i++){sql += "insert into `test`(`username`, `password`) values('Splay', '123456');";}mysql_real_query(&mysql, sql.c_str(), sql.length());do{mysql_affected_rows(&mysql);} while(mysql_next_result(&mysql) == 0);auto end = std::chrono::system_clock::now();auto duration = duration_cast<chrono::milliseconds> (end - start);cout << "multi_insert插入1万条数据所需的时间: " << duration.count()/1000.0 << "秒" << endl;
}void test_transaction_insert(MYSQL &mysql)
{truncate_table(mysql);auto start = std::chrono::system_clock::now();// 1. 开启事务string sql = "start transaction;";mysql_real_query(&mysql, sql.c_str(), sql.length());// 2. 开启手动提交sql = "set autocommit = 0;";mysql_real_query(&mysql, sql.c_str(), sql.length());// 3. 执行sql语句for(int i = 1;i <= 1000;i++){sql = "insert into `test`(`username`, `password`) values('Admin', '123456');";mysql_real_query(&mysql, sql.c_str(), sql.length());}// 4. commit提交sql = "commit";mysql_real_query(&mysql, sql.c_str(), sql.length());// 5. 恢复自动提交sql = "set autocommit = 1;";mysql_real_query(&mysql, sql.c_str(), sql.length());auto end = std::chrono::system_clock::now();auto duration = duration_cast<chrono::milliseconds> (end - start);cout << "transaction_insert插入1万条数据所需的时间: " << duration.count()/1000.0 << "秒" << endl;
}// mysql connect 127.0.0.1 success!
// single_insert插入1万条数据所需的时间: 5.379秒
// multi_insert插入1万条数据所需的时间: 5.516秒
// transaction_insert插入1万条数据所需的时间: 0.068秒
3.3、连接等其他代码
#include <iostream>
#include <mysql/mysql.h>
#include <cstring>
#include <sstream>
#include <string>
#include <chrono>
#include <unordered_map>
using namespace std;
using namespace chrono;void create_table(MYSQL &mysql)
{string sql = "CREATE TABLE IF NOT EXISTS `test` (\`id` int(10) unsigned NOT NULL AUTO_INCREMENT,\`username` varchar(255) NOT NULL,\`password` varchar(255) NOT NULL,\PRIMARY KEY (`id`)\) ENGINE=InnoDB DEFAULT CHARSET=utf8;";if(mysql_real_query(&mysql, sql.c_str(), sql.length()) != 0){cout << "mysql_query failed!" << endl;}
}int main(int argc, char *argv[])
{MYSQL mysql;// 初始化mysql结构体并且初始化服务连接环境mysql_init(&mysql);const char *host = "127.0.0.1";const char *user = "root";const char *password = "123456";const char *db = "cpp";int timeout = 3;// 连接超时时长设置mysql_options(&mysql, MYSQL_OPT_CONNECT_TIMEOUT, &timeout);// 断开重连设置int reconnect = 1;mysql_options(&mysql, MYSQL_OPT_RECONNECT, &reconnect);// MySQL连接建立if(!mysql_real_connect(&mysql, host, user, password, db, 3306, 0, CLIENT_MULTI_STATEMENTS)){std::cout << "mysql connect failed!" << mysql_error(&mysql) << std::endl;}else{std::cout << "mysql connect " << host << " success!" << std::endl;}
//    create_table(mysql);
//    transaction_test(mysql);test_single_insert(mysql);test_multi_insert(mysql);test_transaction_insert(mysql);mysql_close(&mysql);mysql_library_end();return 0;
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/798711.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

2.网络编程-HTTP和HTTPS

2.网络编程-HTTP和HTTPS

目录 HTTP介绍 HTTP协议主要组成部分 GET 和 POST有什么区别 常见的 HTTP 状态码有哪些 http状态码100 HTTP1.1 和 HTTP1.0 的区别有哪些 HTTPS 和 HTTP 的区别是什么 HTTP2 和 HTTP1.1 的区别是什么 HTTP3 和 HTTP2 的区别是什么 HTTPS的请求过程 对称加密和非对称…
阅读更多...
甘特图在生产进度管理中的应用

甘特图在生产进度管理中的应用

生产进度管理在生产制造过程中起着至关重要的作用。 它主要关注对生产进程的掌控和安排&#xff0c;确保生产活动能够按照预定的计划和时间顺利进行&#xff0c;以达到按时交付产品的目标。 在生产进度管理中&#xff0c;首先需要制定一个详细且合理的生产计划&#xff0c;明…
阅读更多...
Advanced RAG 02：揭开 PDF 文档解析的神秘面纱

Advanced RAG 02：揭开 PDF 文档解析的神秘面纱

编者按&#xff1a; 自 2023 年以来&#xff0c;RAG 已成为基于 LLM 的人工智能系统中应用最为广泛的架构之一。由于诸多产品的关键功能&#xff08;如&#xff1a;领域智能问答、知识库构建等&#xff09;严重依赖RAG&#xff0c;优化其性能、提高检索效率和准确性迫在眉睫&am…
阅读更多...
STM32智能家居小助手

STM32智能家居小助手

​ 设计的目的 大部分家用电器开关仍旧是传统的机械式按键开关&#xff0c;原因是传统式的电器开关开发周期短&#xff0c;制作成本低&#xff0c;方案成熟&#xff0c;但是传统的遥控家电开关已经不能满足人们对家电控制的要求&#xff0c;传统的遥控器具有单一性&#xff0c;…
阅读更多...
类脑计算芯片：机器学习的新硬件革命

类脑计算芯片：机器学习的新硬件革命

热爱编程的小落… &#x1f54a;️系列专栏&#xff1a;&#x1f5bc;️ 零基础学Java——小白入门必备&#x1f525; 重识C语言——复习回顾&#x1f525; 计算机网络体系———深度详讲 HCIP数通工程师-刷题与实战&#x1f525;&#x1f525;&#x1f525; 微信小程序开发——…
阅读更多...
初识Java中的NIO

初识Java中的NIO

1.概述 Java NIO 全称java non-blocking IO &#xff0c;是指 JDK 提供的新 API。从 JDK1.4 开始&#xff0c;Java 提供了一系列改进的输入/输出新特性&#xff0c;被统称为 NIO(即 New IO)&#xff0c;是同步非阻塞的。NIO采用内存映射文件的方式来处理输入输出&#xff0c;NI…
阅读更多...
Linux Shell：`awk` 命令

Linux Shell：`awk` 命令

Linux Shell&#xff1a;awk 命令 awk 是一种强大的文本分析工具&#xff0c;广泛用于文本处理、数据提取和报告生成。它使用自己的编程语言来处理文件中的数据。在 Linux Shell 中&#xff0c;awk 命令能够执行复杂的模式匹配、编辑和分析任务。本文将介绍 awk 的基础用法、高…
阅读更多...
激光雷达和相机的联合标定工具箱[cam_lidar_calibration]介绍

激光雷达和相机的联合标定工具箱[cam_lidar_calibration]介绍

激光雷达和相机的联合标定工具箱[cam_lidar_calibration]介绍 写在前面安装过程调试过程标定成功可视化展示 写在前面 激光雷达和相机联合标定工具 论文地址&#xff1a;https://ieeexplore.ieee.org/stamp/stamp.jsp?tp&arnumber9564700 github地址: https://github.com…
阅读更多...
系统架构评估_2.SAAM方法

系统架构评估_2.SAAM方法

SAAM&#xff08;Scenarios-based Architecture Analysis Method&#xff09;是卡耐基梅隆大学软件工程研究所&#xff08;SEI at CMU&#xff09;的Kazman等人于1983年提出的一种非功能质量属性的架构分析方法&#xff0c;是最早形成文档并得到广泛使用的软件架构分析方法。最…
阅读更多...
RabbitMQ Docker 安装与应用

RabbitMQ Docker 安装与应用

1.官方镜像 该镜像包含用户操作界面 2.Docker运行&#xff0c;并设置开机自启动 docker run -d --restartalways --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3.10-management 默认登录账户和密码 guest 3、使用 队列和交换机绑定
阅读更多...
【CicadaPlayer】视频切换/音视频同时切换

【CicadaPlayer】视频切换/音视频同时切换

G:\CDN\all_players\CicadaPlayer-github-0.44\mediaPlayer\SuperMediaPlayer.hCicadaPlayer https://github.com/alibaba/CicadaPlayer可以clone 整个仓库的历史 git clone --bare https://github.com/username/project.git整体架构 ：根据这个更容易理解：切换就是judgeFunc…
阅读更多...
zookeeper中的znode节点的一些功能和应用

zookeeper中的znode节点的一些功能和应用

zookeeper是一个挺好玩的东西 有着独特的选举机制&#xff0c;一般在中小型集群中&#xff0c;zookeeper一般装在三个节点 其中只有一个节点对外提供服务&#xff0c;处于leader状态&#xff0c;另外两台未follower状态 这得益于zookeeper独特的选举机制&#xff0c;可以保证le…
阅读更多...
Ubuntu22.04平台编译完美解决问题“error: GLSL 4.5 is not supported.”【GLSL（OpenGL着色器语言）】

Ubuntu22.04平台编译完美解决问题“error: GLSL 4.5 is not supported.”【GLSL（OpenGL着色器语言）】

GLSL介绍 GLSL&#xff08;OpenGL着色器语言&#xff09;是用于编写OpenGL着色器程序的语言。GLSL 4.5 是 GLSL 的一个版本&#xff0c;引入了许多新的特性和改进&#xff0c;旨在提高着色器编程的灵活性和性能。GLSL 4.5 工具通常是用于编写、调试和优化 GLSL 4.5 着色器代码…
阅读更多...
【TI毫米波雷达】官方工业雷达包的生命体征检测环境配置及避坑（Vital_Signs、IWR6843AOPEVM）

【TI毫米波雷达】官方工业雷达包的生命体征检测环境配置及避坑（Vital_Signs、IWR6843AOPEVM）

【TI毫米波雷达】官方工业雷达包的生命体征检测环境配置及避坑&#xff08;Vital_Signs、IWR6843AOPEVM&#xff09; 文章目录 生命体征基本介绍IWR6843AOPEVM的配置上位机配置文件避坑上位机start测试距离检测心跳检测呼吸频率检测空环境测试 附录&#xff1a;结构框架雷达基…
阅读更多...
如何在 Node.js 中使用 bcrypt 对密码进行哈希处理

如何在 Node.js 中使用 bcrypt 对密码进行哈希处理

在网页开发领域中&#xff0c;安全性至关重要&#xff0c;特别是涉及到用户凭据如密码时。在网页开发中至关重要的一个安全程序是密码哈希处理。 密码哈希处理确保明文密码在数据库受到攻击时也难以被攻击者找到。但并非所有的哈希方法都是一样的&#xff0c;这就是 bcrypt 突…
阅读更多...
AcWing刷题-公约数

AcWing刷题-公约数

公约数 代码 from math import gcd a, b map(int, input().split()) p int(input()) max_gcd gcd(a, b) res []for i in range(1, int(max_gcd**0.5)1):if max_gcd % i 0:res.append(i) res.append(max_gcd//i) res sorted(set(res))for _ in range(p):l, r map(int,…
阅读更多...
绘图工具 draw.io / diagrams.net 免费在线图表编辑器

绘图工具 draw.io / diagrams.net 免费在线图表编辑器

拓展阅读 常见免费开源绘图工具 OmniGraffle 创建精确、美观图形的工具 UML-架构图入门介绍 starUML UML 绘制工具 starUML 入门介绍 PlantUML 是绘制 uml 的一个开源项目 UML 等常见图绘制工具 绘图工具 draw.io / diagrams.net 免费在线图表编辑器 绘图工具 excalidr…
阅读更多...
mac老版本如何升级到最新版本

mac老版本如何升级到最新版本

mac老版本如何升级到最新版本 老macbook升级新版本&#xff08;Big sur、Monterey&#xff09; 首先介绍我的电脑的机型及情况&#xff1a; 2015年初的MacBook Air 处理器是1.6Hz 双核Interl Core i5 内存4G 老版本只能升到10.13 想要升到最高版本的原因&#xff1a;想要注册…
阅读更多...
JJVM类的加载过程

JJVM类的加载过程

类的加载过程 一个java文件从被加载到被卸载这个生命过程&#xff0c;总共要经理五个阶段&#xff0c;JVM将类加载过程分为&#xff1a;&#xff08;加链初使卸&#xff09; 1. 加载 首先通过一个类的全限定名来获取此类的二进制字节流&#xff1b;其次将这个字节流所代表的静…
阅读更多...
Centos7下docker删除容器与镜像

Centos7下docker删除容器与镜像

个人记录 查看容器 docker ps -a停止容器运行 docker stop jenkins卸载容器 docker rm jenkins查看镜像 docker images卸载镜像 docker rmi IMAGE ID查看容器与镜像是否卸载完毕 docker images docker ps -a
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023