树莓派开发笔记(十七):树莓派4B+上Qt多用户连接操作Mysql数据库同步(单条数据悲观锁)

本文涉及的产品
RDS MySQL DuckDB 分析主实例,集群系列 4核8GB
RDS MySQL DuckDB 分析主实例,基础系列 4核8GB
RDSClaw,2核4GB
简介: 安装了mysq数据库,最终时为了实现在一个树莓派上实现多用户多进程操作的同步问题,避免数据并发出现一些错误,本篇安装了远程服务并且讲述了使用Qt进行悲观锁for update操作,命令行进行同步查询的示例。

前言

  安装了mysq数据库,最终时为了实现在一个树莓派上实现多用户多进程操作的同步问题,避免数据并发出现一些错误,本篇安装了远程服务并且讲述了使用Qt进行悲观锁for update操作,命令行进行同步查询的示例。


其他操作

  这里只是稍微提一下,具体参照博主的树莓派系列博客,非常详细。

  远程登陆界面

sudo apt-get install tightvncserver
sudo apt-get install xrdp
sudo service xrdp restart
sudo ufw allow 3389
sudo service ufw restart

  然后可以使用window远程桌面登陆了:

  默认用户名:pi

  默认密码:raspberry

  

  

安装qt5

sudo apt-get install qt5-default
sudo apt-get install qtcreator

  安装好后,远程桌面的程序里面就多了个qtcreator了:

  

  

  创建一个界面工程,然后运行:

  (编译速度比几年前的3B+快一些,后续开发过程中测试一下,是否可以忽略3B+的交叉编译)

  

  检查数据库驱动:

  

  没有mysql的数据库驱动。

sudo apt-get install libqt5sql5-mysql

  


Qt操作mariadb数据库

QSqlDatabase db;
db = QSqlDatabase::addDatabase("QMYSQL");
db.setHostName("127.0.0.1");
db.setPort(3306);
db.setDatabaseName("data");
db.setUserName("root");
db.setPassword("a1234567");
if(db.open())
{
    LOG << "Succeed to open db";
}else{
    LOG << "Failed to open db:" << db.lastError().text();
    return;
}
QString cmd = "select * from student;";
QSqlQuery query = db.exec(cmd);
while(query.next())
{
    LOG << query.value(0).toString()
        << query.value(1).toString()
        << query.value(2).toString()
        << query.value(3).toString();
}

  


多用户操作

  本意是为了多用户操作,那么读的时候需要加读锁,写的时候需要加写锁。

  两个用户同时读取了数据库中的一条记录,此时用户A对其中一个字段的值进行了修改操作并进行了提交,后来用户B也对这个字段进行了修改,用户B的提交将会覆盖用户A提交的值。

  

锁类型

悲观锁

  每次去取数据,很悲观,都觉得会被别人修改,所以在拿数据的时候都会上锁。简言之,共享资源每次都只给一个线程使用,其他线程阻塞,等第一个线程用完后再把资源转让给其他线程。synchronized和ReentranLock等都是悲观锁思想的体现。

乐观锁

  每次去取数据,都很乐观,觉得不会被被人修改。因此每次都不上锁,但是在更新的时候,就会看别人有没有在这期间去更新这个数据,如果有更新就重新获取,再进行判断,一直循环,直到拿到没有被修改过的数据。(mysql需要自己实现乐观锁)。

for update使用场景(悲观锁)

  for update 可以为数据库中的一行数据加上一个排它锁。当一个事务的操作未完成时候,其他事务可以读取但是不能写入或更新。

  如果项目对某个数据准确性有要求,并且项目存在并发(不一定高并发),则需要使用 for update。

  比如:用户A使用余额购买商品,此时用户B向用户A发起转账,如果恰好处在同一时间,则可能造成用户A最终余额错误。此时需要使用 for update 进行数据加锁防止出错。

  这种情况下,即使并发很小,但是也会有一定的概率会碰到,而余额的错误即使差一分钱也是不能容忍的,所以这种特定的场景,即使不是高并发,也应该使用 for update 规避问题。

for update 用法

begin;
select * from XXX where XXX for update;
...
commit;

  for update 必须在事务中才生效。


Qt测试

使用127.0.0.1的ip进行连接(本地连接)

QSqlDatabase db;
db = QSqlDatabase::addDatabase("QMYSQL");
db.setHostName("127.0.0.1");
db.setPort(3306);
db.setDatabaseName("data");
db.setUserName("root");
db.setPassword("a1234567");
if(db.open())
{
    LOG << "Succeed to open db";
}else{
    LOG << "Failed to open db:" << db.lastError().text();
    return;
}
if(db.transaction())
{
    QString cmd = "select * from student for update;";
    QSqlQuery query = db.exec(cmd);
    while(query.next())
    {
        LOG << query.value(0).toString()
            << query.value(1).toString()
            << query.value(2).toString()
            << query.value(3).toString();
    }
    for(int index = 0; index < 10; index++)
    {
        QThread::sleep(1);
        LOG << "sleep:" << index;
    }
    if(!db.commit())
    {
        LOG << "Failed to commit";
    }
}

  

  至此,我们的锁加入成功,说清楚原理可以方便大家着手开始开发多用户进程操作数据库的同步开发了。

使用局域网的ip进行连接(远程连接)

QSqlDatabase db;
db = QSqlDatabase::addDatabase("QMYSQL");
db.setHostName("192.168.0.103");
db.setPort(3306);
db.setDatabaseName("data");
db.setUserName("root");
db.setPassword("a1234567");
if(db.open())
{
    LOG << "Succeed to open db";
}else{
    LOG << "Failed to open db:" << db.lastError().text();
    return;
}
if(db.transaction())
{
    QString cmd = "select * from student for update;";
    QSqlQuery query = db.exec(cmd);
    while(query.next())
    {
        LOG << query.value(0).toString()
            << query.value(1).toString()
            << query.value(2).toString()
            << query.value(3).toString();
    }
    for(int index = 0; index < 10; index++)
    {
        QThread::sleep(1);
        LOG << "sleep:" << index;
    }
    if(!db.commit())
    {
        LOG << "Failed to commit";
    }
}

  连接不上:

  

  这个时候需要修改下配置:

sudo vi /etc/mysql/mariadb.conf.d/50-server.cnf

  

  重启服务:

systemctl restart mysql.service

  

  继续测试,下面是用树莓派使用局域网ip(之前也不能连接127.0.0.1):

  

  连接成功,然后在局域网pc上连接,但是不能打开事务:

  

  修改一下:

  

  这个其实是跟mysql驱动有关系,因为笔者是几年前弄得libmysql.dll和libmysqld.dll,这个不深究了,已经可以远程操作了。

相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发,帮助IT从业者们通过“阿里云Web应用上云解决方案”,了解一个企业级Web应用上云的常见架构,了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品:云数据库RDS MySQL 版 阿里云关系型数据库RDS(Relational Database Service)是一种稳定可靠、可弹性伸缩的在线数据库服务,提供容灾、备份、恢复、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://www.aliyun.com/product/rds/mysql&nbsp;
相关文章
|
分布式计算 大数据 Hadoop
Hadoop手把手逐级搭建(3) Hadoop高可用(HA)
步骤概述 1). 为完全分布式保存hadoop配置 2). 为hadoop2配置hadoop1的ssh免密 3). 在hadoop2上配置zookeeper 4). 在hadoop1上修改hadoop配置文件为HA高可用模式 5).
5081 0
|
存储 安全 云计算
最受欢迎的云主机推荐
本文介绍什么是云主机以及云主机的优势(性价比高、弹性可扩展、安全隔离高、多操作系统支持),然后提供了选择云主机的选购指南(名气大、口碑好、价格适中),最后推荐了几款备受欢迎的云主机。
483 0
最受欢迎的云主机推荐
|
存储 弹性计算 监控
OSS 解决方案篇-OSS 数据迁移
OSS 迁移数据有三种方式(ossutil、ossimport 、在线迁移服务)用户可以根据场景自由选择
10538 0
OSS 解决方案篇-OSS 数据迁移
|
数据采集 存储 JSON
如何使用Scrapy提取和处理数据
如何使用Scrapy提取和处理数据
501 0
|
存储 机器学习/深度学习 算法
基于python调用摄像头进行人脸识别,支持多张人脸同时识别
基于python调用摄像头进行人脸识别,支持多张人脸同时识别
1427 0
基于python调用摄像头进行人脸识别,支持多张人脸同时识别
|
机器学习/深度学习 数据可视化 Serverless
RNAseq|Lasso构建预后模型,绘制风险评分的KM 和 ROC曲线
RNAseq|Lasso构建预后模型,绘制风险评分的KM 和 ROC曲线
1428 0
|
存储 自然语言处理 算法
Tokenization 指南:字节对编码,WordPiece等方法Python代码详解
在2022年11月OpenAI的ChatGPT发布之后,大型语言模型(llm)变得非常受欢迎。从那时起,这些语言模型的使用得到了爆炸式的发展,这在一定程度上得益于HuggingFace的Transformer库和PyTorch等库。
605 3
|
运维 Linux 程序员
最全树莓派4B安装64位Linux(不用显示器键盘鼠标),Linux运维面试送分题
最全树莓派4B安装64位Linux(不用显示器键盘鼠标),Linux运维面试送分题
最全树莓派4B安装64位Linux(不用显示器键盘鼠标),Linux运维面试送分题
|
6月前
|
Java 调度 数据库
Python threading模块:多线程编程的实战指南
本文深入讲解Python多线程编程,涵盖threading模块的核心用法:线程创建、生命周期、同步机制(锁、信号量、条件变量)、线程通信(队列)、守护线程与线程池应用。结合实战案例,如多线程下载器,帮助开发者提升程序并发性能,适用于I/O密集型任务处理。
639 0
|
Linux 数据安全/隐私保护
树莓派安装ros系统
树莓派安装ros系统
999 0
树莓派安装ros系统

热门文章

最新文章

下一篇
开通oss服务