QT mysql 数据库线程池 与数据库操作封装

最近事情比较多很久没有写学习笔记了,数据库线程池,+ 数据库封装,虽说数据库操作有很多不需要写sql 的,ORM 封装的方式去操作数据库。但是从业这些年一直是自己动手写sql ,还是改不了这个习惯。不说了直接上代码。

数据库线程池

ConnectionPool.h 文件#ifndef CONNECTIONPOOL_H
#define CONNECTIONPOOL_H#include <QtSql>
#include <QQueue>
#include <QString>
#include <QMutex>
#include <QMutexLocker>#include "ConnectionPool.h"class ConnectionPool {
public:static void release(); // 关闭所有的数据库连接static QSqlDatabase createConnection();                 // 获取数据库连接static void closeConnection(QSqlDatabase connection); // 释放数据库连接回连接池~ConnectionPool();private:static ConnectionPool& getInstance();ConnectionPool();ConnectionPool(const ConnectionPool &other);ConnectionPool& operator=(const ConnectionPool &other);QSqlDatabase createConnection(const QString &connectionName); // 创建数据库连接void initialize();void loadConfigFile();public:QQueue<QString> usedConnectionNames;   // 已使用的数据库连接名QQueue<QString> unusedConnectionNames; // 未使用的数据库连接名QJsonObject mJsonObject;// 数据库信息QString hostName;QString databaseName;QString username;QString password;QString databaseType;int     port;bool    testOnBorrow;    // 取得连接的时候验证连接是否有效QString testOnBorrowSql; // 测试访问数据库的 SQLint maxWaitTime;  // 获取连接最大等待时间int waitInterval; // 尝试获取连接时等待间隔时间int maxConnectionCount; // 最大连接数static QMutex mutex;static QWaitCondition waitConnection;static ConnectionPool *instance;
};#endif // CONNECTIONPOOL_H
ConnectionPool.cpp#include "ConnectionPool.h"
#include <QDebug>QMutex ConnectionPool::mutex;
QWaitCondition ConnectionPool::waitConnection;
ConnectionPool* ConnectionPool::instance = NULL;ConnectionPool::ConnectionPool()
{initialize();
}ConnectionPool::~ConnectionPool()
{// 销毁连接池的时候删除所有的连接foreach(QString connectionName, usedConnectionNames){QSqlDatabase::removeDatabase(connectionName);}foreach(QString connectionName, unusedConnectionNames){QSqlDatabase::removeDatabase(connectionName);}
}void ConnectionPool::loadConfigFile()
{QString path = qApp->applicationDirPath();QString strFile;strFile = path + "/config/DBConfig.json";QFile file(strFile);if(!file.open(QIODevice::ReadOnly | QIODevice::Text)){qDebug() << "could't open projects json";return;}QString value = file.readAll();file.close();QJsonParseError parseJsonErr;QJsonDocument document = QJsonDocument::fromJson(value.toUtf8(), &parseJsonErr);if(!(parseJsonErr.error == QJsonParseError::NoError)){qDebug() << parseJsonErr.errorString();return;}mJsonObject=document.object();
}void ConnectionPool::initialize()
{//loadConfigFile();hostName     = "127.0.0.1";databaseName = "test";username     = "root";password     = "admin";databaseType = "QMYSQL";port         = 3306;testOnBorrow = true;testOnBorrowSql = "SELECT 1";waitInterval = 200;maxWaitTime     = 5000;maxConnectionCount = 10;}ConnectionPool& ConnectionPool::getInstance()
{if (NULL == instance){QMutexLocker locker(&mutex);if (NULL == instance){instance = new ConnectionPool();}}return *instance;
}void ConnectionPool::release()
{QMutexLocker locker(&mutex);delete instance;instance = NULL;
}QSqlDatabase ConnectionPool::createConnection()
{ConnectionPool& pool = ConnectionPool::getInstance();QString connectionName;QMutexLocker locker(&mutex);// 已创建连接数int connectionCount = pool.unusedConnectionNames.size() + pool.usedConnectionNames.size();// 如果连接已经用完,等待 waitInterval 毫秒看看是否有可用连接,最长等待 maxWaitTime 毫秒for (int i = 0;i < pool.maxWaitTime&& pool.unusedConnectionNames.size() == 0 && connectionCount == pool.maxConnectionCount;i += pool.waitInterval){waitConnection.wait(&mutex, pool.waitInterval);// 重新计算已创建连接数connectionCount = pool.unusedConnectionNames.size() + pool.usedConnectionNames.size();}qDebug() << "connectionCount:"<<connectionCount;qDebug() << "pool.maxConnectionCount:"<<pool.maxConnectionCount;if (pool.unusedConnectionNames.size() > 0){// 有已经回收的连接,复用它们connectionName = pool.unusedConnectionNames.dequeue();}else if (connectionCount < pool.maxConnectionCount){// 没有已经回收的连接,但是没有达到最大连接数,则创建新的连接connectionName = QString("Connection-%1").arg(connectionCount + 1);}else{// 已经达到最大连接数qDebug() << "Cannot create more connections.";return QSqlDatabase();}// 创建连接QSqlDatabase db = pool.createConnection(connectionName);// 有效的连接才放入 usedConnectionNamesif (db.isOpen()){pool.usedConnectionNames.enqueue(connectionName);}return db;
}void ConnectionPool::closeConnection(QSqlDatabase connection)
{ConnectionPool& pool = ConnectionPool::getInstance();QString connectionName = connection.connectionName();// 如果是我们创建的连接,从 used 里删除,放入 unused 里if (pool.usedConnectionNames.contains(connectionName)){QMutexLocker locker(&mutex);pool.usedConnectionNames.removeOne(connectionName);pool.unusedConnectionNames.enqueue(connectionName);waitConnection.wakeOne();}
}QSqlDatabase ConnectionPool::createConnection(const QString &connectionName)
{// 连接已经创建过了,复用它,而不是重新创建if (QSqlDatabase::contains(connectionName)){QSqlDatabase db1 = QSqlDatabase::database(connectionName);if (testOnBorrow){// 返回连接前访问数据库,如果连接断开,重新建立连接qDebug() << "Test connection on borrow, execute:" << testOnBorrowSql << ", for" << connectionName;QSqlQuery query(testOnBorrowSql, db1);if (query.lastError().type() != QSqlError::NoError && !db1.open()){qDebug() << "Open datatabase error:" << db1.lastError().text();return QSqlDatabase();}}return db1;}// 创建一个新的连接QSqlDatabase db = QSqlDatabase::addDatabase(databaseType, connectionName);db.setHostName(hostName);db.setDatabaseName(databaseName);db.setUserName(username);db.setPassword(password);db.setPort(port);if (!db.open()){qDebug() << "Open datatabase error:" << db.lastError().text();return QSqlDatabase();}return db;
}

数据库封装:

SqlDatabase.h#ifndef SQLDATABASE_H
#define SQLDATABASE_H#include <QJsonArray>
#include <QJsonValue>
#include <QJsonObject>class  SqlDatabase
{
public:SqlDatabase();~SqlDatabase();public:static void InsertDB(QString strTableName,QJsonArray jsonValue);static void UpdateDB(QString strTableName,QJsonArray jsonValue,QString strColumnCondition);static int  InsertDB(QString strTableName,QJsonObject jsonValue);static void UpdateDB(QString strTableName,QJsonObject jsonValue,QString strCondition);static void QueryRecord(QString strSql,QJsonArray &nJsonValue);static int  QueryCount(QString strSql);static bool Delete(QString strSql);static bool Delete(QString strTableName,QString strCondition);
};#endif // SQLDATABASE_H

 

SqlDatabase.cpp#include "SqlDatabase.h"
#include "ConnectionPool.h"
#include <QDebug>#pragma execution_character_set("utf-8")SqlDatabase::SqlDatabase()
{}SqlDatabase::~SqlDatabase()
{ConnectionPool::Destroy();
}void SqlDatabase::InsertDB(QString strTableName,QJsonArray jsonValues)
{QSqlDatabase db =ConnectionPool::CreateConnection();QString strValues="";QString strNames="";bool iskeyName=false;for(int j=0;j<jsonValues.size();j++){QJsonObject::iterator it;QString strKeyValue;QJsonObject tmpObj =jsonValues.at(j).toObject();for(it=tmpObj.begin();it!=tmpObj.end();it++){if(strKeyValue.isEmpty()){if(it.value().isDouble()){it.value()=QString::number(it.value().toDouble(),'f',12);}strKeyValue=QString("'%1'").arg(it.value().toString());if(!iskeyName){strNames=QString("%1").arg(it.key());}}else{if(it.value().isDouble()){it.value()=QString::number(it.value().toDouble(),'f',12);}strKeyValue+=QString(",'%1'").arg(it.value().toString());if(!iskeyName){strNames+=QString(",%1").arg(it.key());}}}iskeyName =true;if(strValues.isEmpty()){strValues +="("+strKeyValue+")";}else{strValues +=",("+strKeyValue+")";}}QString strSql=QString("INSERT INTO %1 (%2)  VALUES %3 ").arg(strTableName).arg(strNames).arg(strValues);QSqlQuery query(db);if(!query.exec(strSql)){qDebug()<<"Failed to INSERT:"<<strSql;}ConnectionPool::CloseConnection(db);
}void SqlDatabase::UpdateDB(QString strTableName,QJsonArray jsonValue,QString strColumnCondition)
{QString mHeadSql= QString(" UPDATE  %1 m,( ").arg(strTableName);QString mEndSql=" ) n ";QString mSetConditionSql="";QString mValueSql="";QString mCondition="";QString strSql="";for(int i=0;i<jsonValue.size();i++){QJsonObject jsonObject=jsonValue.at(i).toObject();QJsonObject::iterator it;QString strValue="";if(!mValueSql.isEmpty()){mValueSql +=  " UNION ";}for(it=jsonObject.begin();it!=jsonObject.end();it++){if(it.value().isDouble()){it.value()=QString::number(it.value().toDouble(),'f',3);}if(strValue ==""){strValue =QString(" SELECT '%0' as `%1`").arg(it.value().toString()).arg(it.key());mSetConditionSql =QString(" SET m.%0 = n.%1").arg(it.key()).arg(it.key());}else{strValue +=QString(",'%0' as `%1`").arg(it.value().toString()).arg(it.key());mSetConditionSql += QString(" ,m.%0 = n.%1").arg(it.key()).arg(it.key());}	}mValueSql += strValue;}mCondition += QString(" WHERE m.%0 = n.%1").arg(strColumnCondition).arg(strColumnCondition);strSql =mHeadSql +mValueSql + mEndSql + mSetConditionSql+ mCondition;qDebug()<<strSql;
}int SqlDatabase::InsertDB(QString strTableName,QJsonObject jsonValue)
{QSqlDatabase db =ConnectionPool::CreateConnection();QString strValues="";QString strNames="";int nLastNum=0;QJsonObject::iterator it;for(it=jsonValue.begin();it!=jsonValue.end();it++){if(strValues.isEmpty()){if(it.value().isDouble()){it.value()=QString::number(it.value().toDouble(),'f',12);}strValues=QString("'%1'").arg(it.value().toString());strNames=QString("%1").arg(it.key());}else{if(it.value().isDouble()){it.value()=QString::number(it.value().toDouble(),'f',12);}strValues+=QString(",'%1'").arg(it.value().toString());strNames+=QString(",%1").arg(it.key());}}QString strSql=QString("INSERT INTO %1 (%2)  VALUES(%3) ").arg(strTableName).arg(strNames).arg(strValues);QSqlQuery query(db);if(!query.exec(strSql)){qDebug()<<"Failed to InsertDB:"<<query.lastError().text();}else{nLastNum=query.lastInsertId().toInt();}ConnectionPool::CloseConnection(db);return  nLastNum;
}void SqlDatabase::UpdateDB(QString strTableName,QJsonObject jsonValue,QString strCondition)
{QSqlDatabase db =ConnectionPool::CreateConnection();QString strValues="";QString strNames="";QJsonObject::iterator it;for(it=jsonValue.begin();it!=jsonValue.end();it++){if(strValues.isEmpty()){if(it.value().isDouble()){it.value()=QString::number(it.value().toDouble(),'f',12);}strValues=QString("%1='%2'").arg(it.key()).arg(it.value().toString());}else{if(it.value().isDouble()){it.value()=QString::number(it.value().toDouble(),'f',12);}strValues+=QString(",%1='%2'").arg(it.key()).arg(it.value().toString());}}QString strSql=QString("UPDATE  %1  SET %2  %3 ").arg(strTableName).arg(strValues).arg(strCondition);QSqlQuery query(db);if(!query.exec(strSql)){qDebug()<<"Failed to UpdateDB:"<<query.lastError().text();}ConnectionPool::CloseConnection(db);
}void SqlDatabase::QueryRecord(QString strSql,QJsonArray &nJsonValue)
{QSqlDatabase db =ConnectionPool::CreateConnection();QSqlQuery query(db);if(!query.exec(strSql)){qDebug()<<"Failed to QueryRecord:"<<query.lastError().text();}while(query.next()){QSqlRecord qResultRecord=query.record();QJsonObject jsonObject;for(int fileIndex =0; fileIndex<qResultRecord.count();fileIndex++){if(query.value(fileIndex).isNull()){jsonObject.insert(qResultRecord.fieldName(fileIndex),QJsonValue::Null);}else if(query.value(fileIndex).type() ==QVariant::Int){jsonObject.insert(qResultRecord.fieldName(fileIndex),query.value(fileIndex).toInt());}else if(query.value(fileIndex).type() == QVariant::Double){jsonObject.insert(qResultRecord.fieldName(fileIndex),query.value(fileIndex).toDouble());}else if(query.value(fileIndex).type() == QVariant::LongLong){jsonObject.insert(qResultRecord.fieldName(fileIndex),query.value(fileIndex).toLongLong());}else{jsonObject.insert(qResultRecord.fieldName(fileIndex),query.value(fileIndex).toString());}}nJsonValue.append(jsonObject);}ConnectionPool::CloseConnection(db);
}int SqlDatabase::QueryCount(QString strSql)
{QSqlDatabase db =ConnectionPool::CreateConnection();QSqlQuery query(db);int totalCnt=0;QString strSqlCount=QString(" SELECT COUNT(*) AS Cnt FROM  (%1) t ").arg(strSql);if(!query.exec(strSqlCount)){qDebug()<<"Failed to QueryCount:"<<query.lastError().text();}while(query.next()){totalCnt=query.value("Cnt").toInt();}ConnectionPool::CloseConnection(db);return totalCnt;
}bool SqlDatabase::Delete(QString strSql)
{bool bRet =true;QSqlDatabase db =ConnectionPool::CreateConnection();QSqlQuery query(db);if(!query.exec(strSql)){qDebug()<<"Failed to Delete:"<<query.lastError().text();bRet = false;}ConnectionPool::CloseConnection(db);return bRet;
}bool SqlDatabase::Delete(QString strTableName,QString strCondition)
{bool bRet =true;QSqlDatabase db =ConnectionPool::CreateConnection();QSqlQuery query(db);QString strSql=QString(" DELETE FROM %1 %2 ").arg(strTableName).arg(strCondition);if(!query.exec(strSql)){qDebug()<<"Failed to Delete:"<<query.lastError().text();bRet = false;}ConnectionPool::CloseConnection(db);return bRet;
}

此处说一下批量更新

源数据是这样需要更新

id:1      shorName  :aaaaa       score1:56.9   ranking  :22

id:2      shorName  :bbbbb       score1:89.9  score3:59.9  ranking  :27

id:3      shorName  :ccccc       score1:76.9   score2:81.9  ranking  :29

sql 语句 批量更新

UPDATE test m,(SELECT'1.000' AS `id`,'a' AS `name`,'22.000' AS `ranking`,'56.900' AS `score1`,'39.500' AS `score2`,'56.700' AS `score3`,'aaaa' AS `shorName` UNIONSELECT'2.000' AS `id`,'b' AS `name`,'27.000' AS `ranking`,'89.900' AS `score1`,'39.500' AS `score2`,'59.900' AS `score3`,'bbbbb' AS `shorName` UNIONSELECT'3.000' AS `id`,'c' AS `name`,'29.000' AS `ranking`,'76.900' AS `score1`,'72.900' AS `score2`,'81.900' AS `score3`,'ccccc' AS `shorName` ) n SET m.id = n.id,m.NAME = n.NAME,m.ranking = n.ranking,m.score1 = n.score1,m.score2 = n.score2,m.score3 = n.score3,m.shorName = n.shorName 
WHEREm.id = n.id

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

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

相关文章

【23真题】劝退211!今年突变3门课!

今天分享的是23年云南大学847&#xff08;原827&#xff09;的考研试题及解析。同时考SSDSP的院校做一个少一个&#xff0c;珍惜&#xff01;同时考三门课的院校&#xff0c;复习压力极大&#xff0c;但是也会帮大家劝退很多人&#xff0c;有利有弊&#xff0c;请自行分析~ 本…

YOLOv5 环境搭建

YOLOv5 环境搭建 flyfish 环境 Ubuntu20.04 驱动、CUDA Toolkit、cuDNN、PyTorch版本对应 1 NVIDIA驱动安装 在[附加驱动界]面安装驱动时&#xff0c;需要输入安全密码&#xff0c;需要记下&#xff0c;后面还需要输入这个密码 重启之后有的机器会出现 perform mok manage…

Android修行手册-溢出父布局的按钮实现点击

Unity3D特效百例案例项目实战源码Android-Unity实战问题汇总游戏脚本-辅助自动化Android控件全解手册再战Android系列Scratch编程案例软考全系列Unity3D学习专栏蓝桥系列ChatGPT和AIGC &#x1f449;关于作者 专注于Android/Unity和各种游戏开发技巧&#xff0c;以及各种资源分…

【EI会议征稿】第五届人工智能、网络与信息技术国际学术会议(AINIT 2024)

第五届人工智能、网络与信息技术国际学术会议&#xff08;AINIT 2024&#xff09; 2024 5th International Seminar on Artificial Intelligence, Networking and Information Technology 第五届人工智能、网络与信息技术国际学术会议&#xff08;AINIT 2024&#xff09;将于…

变态跳台阶,剑指offer

目录 题目&#xff1a; 我们直接看题解吧&#xff1a; 相似题目&#xff1a; 解题方法&#xff1a; 审题目事例提示&#xff1a; 解题思路&#xff1a; 代码实现&#xff1a; 题目地址&#xff1a; 【剑指Offer】9、变态跳台阶 难度&#xff1a;简单 今天刷变态跳台阶&#xf…

sd-webui-controlnet代码分析

controlnet前向代码解析_Kun Li的博客-CSDN博客文章浏览阅读1.5k次。要分析下controlnet的yaml文件&#xff0c;在params中分成了4个部分&#xff0c;分别是control_stage_config、unnet_config、first_stage_config、cond_stage_config。其中control_stage_config对应的是13层…

Maven依赖管理项目构建工具(保姆级教学---下篇)

对于Maven依赖管理项目构建工具的介绍&#xff0c;我们将其分为上篇和下篇。如果您对文章感兴趣&#xff0c;您可以在此链接中找到上篇详细内容&#xff1a; Maven依赖管理项目构建工具&#xff08;保姆级教学上篇&#xff09;-CSDN博客 一、Maven依赖传递和依赖冲突 1. …

left join查询耗时太慢,添加索引解决问题

背景 因为最近自己用的小app越用感觉加载越慢&#xff0c;以为是自己app开发逻辑出现问题了&#xff0c;结果才发现是自己很早以前的代码用到的是left join多表联查&#xff0c;以前因为数据少&#xff0c;所以没有感觉&#xff0c;现在数据量稍微一大&#xff0c;耗时就非常严…

珠宝饰品配送经营小程序商城作用如何

饰品有较强的价值/品牌之分&#xff0c;贵的上万元&#xff0c;便宜的几毛钱&#xff0c;适应不同消费群体和需求&#xff0c;对于珠宝类商家及小饰品商家来说&#xff0c;市场中都有着海量用户。 相较于以前等客上门&#xff0c;用户们的消费方式只有同城&#xff0c;如今互联…

psutil - Python中用于进程和系统监控的跨平台库

1、简介 psutil&#xff08;进程和系统实用程序&#xff09;是一个跨平台库&#xff0c;用于检索 Python 中运行的进程和系统利用率&#xff08;CPU、内存、磁盘、网络、传感器&#xff09;的信息。 它主要用于系统监控、分析和限制进程资源以及管理正在运行的进程。 它实现…

我们对凌鲨的一次重构

在10月我们对凌鲨进行了一次重构&#xff0c;把所有鸡肋的功能都删除了。 新版本界面 老版本界面 我们干掉的功能 移除沟通频道功能 沟通频道类似slack功能&#xff0c;用于团队沟通。由于国内有大量的沟通软件&#xff0c;比如企业微信&#xff0c;飞书&#xff0c;钉钉等。…

材料电磁参数综合测试解决方案-材料电磁参数测试系统 (100MHz-500GHz)

材料电磁参数测试系统 100MHz-500GHz 材料电磁参数测试系统测试频率范围覆盖100MHz&#xff5e;500GHz&#xff0c;可实现材料复介电常数、复磁导率等参数测试。系统由矢量网络分析仪、测试夹具、系统软件等组成&#xff0c;根据用户不同频率、材料类型的测试需求&#xff…

Doris数据模型的选择建议(十三)

Doris 的数据模型主要分为 3 类&#xff1a;Aggregate、Uniq、Duplicate Aggregate: Doris 数据模型-Aggregate 模型 Uniq&#xff1a;Doris 数据模型-Uniq 模型 Duplicate&#xff1a;Doris 数据模型-Duplicate 模型 因为数据模型在建表时就已经确定&#xff0c;且无法修改…

三十分钟学会Linux的基本操作

GNU/Linux GNU项目是由Richard Stallman发起的自由软件运动&#xff0c;旨在创建一个完全自由的操作系统。虽然GNU项目已经开发了大量的系统组件和工具&#xff0c;但它一直缺少一个完整的操作系统内核。在这时Linus Torvalds开发了Linux内核&#xff0c;并将其发布为自由软件…

安卓:Android Studio4.0~2023中正确的打开Android Device Monitor

Android Studio4.0~2023 中如何正确的打开Android Device Monitor(亲测有效) 前些天买了新电脑&#xff0c;安装了新版本的Android Studio4.0想试一试&#xff0c;结果就出现了一些问题。 问题引出&#xff1a; Android Device Monitor在工具栏中找不到&#xff0c;后来上网查…

Linux通过端口号找到对应的服务及其安装位置

Linux服务器中&#xff0c;通过端口号找到对应的服务及其安装位置&#xff0c;需要两步操作&#xff0c;如下&#xff1a; 第一步&#xff1a;根据端口号&#xff0c;确定对应的进程号&#xff08;以redis服务为例&#xff09; netstat -antup|grep 6379第二步&#xff1a;通…

ubuntu安装nvm

需求 在 virtualbox 虚拟机上运行的 ubuntu &#xff08;22.04.3&#xff09;里安装 nvm &#xff08;Node Version Manager&#xff09; 简述 官网文档 &#xff08;github地址&#xff09;上有提到两种安装方式&#xff0c;一种是直接 curl | wget 命令安装&#xff0c;一…

2014年7月15日 Go生态洞察:Go将亮相OSCON 2014

&#x1f337;&#x1f341; 博主猫头虎&#xff08;&#x1f405;&#x1f43e;&#xff09;带您 Go to New World✨&#x1f341; &#x1f984; 博客首页——&#x1f405;&#x1f43e;猫头虎的博客&#x1f390; &#x1f433; 《面试题大全专栏》 &#x1f995; 文章图文…

【转】OAK-D双目相机进行标定及标定结果说明

编辑&#xff1a;OAK中国 首发&#xff1a;A. hyhCSDN 喜欢的话&#xff0c;请多多&#x1f44d;⭐️✍ 内容来自用户的分享&#xff0c;如有疑问请与原作者交流&#xff01; ▌前言 Hello&#xff0c;大家好&#xff0c;这里是OAK中国&#xff0c;我是助手君。 近期在CSDN刷…

目标检测算法 - YOLOv3

文章目录 1. Backbone Darknet-532. 整体架构3. 损失函数4. 训练过程5. 预测过程 YOLOv1、YOLOv2都是在CVPR这种正规的计算机视觉学术会议上发表的正式学术论文。 YOLOv3不算一篇严谨的学术论文&#xff0c;是作者随笔写的技术报告。 YOLOv3性能&#xff1a; 1. Backbone Dark…