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.hqwc.cn/news/205873.html

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

相关文章

SpringBoot Admin

SpringBoot Admin

前言 Spring Boot Admin 是一个管理和监控 Spring Boot 应用程序的开源项目&#xff0c;它提供了一个简洁的 Web 界面来监控 Spring Boot 应用程序的状态和各种运行时指标。Spring Boot Admin 可以帮助开发者快速了解应用程序的状态&#xff0c;并快速定位错误或性能问题。下面…
阅读更多...
HarmonyOS ArkTS Video组件的使用（七）

HarmonyOS ArkTS Video组件的使用（七）

概述 在手机、平板或是智慧屏这些终端设备上&#xff0c;媒体功能可以算作是我们最常用的场景之一。无论是实现音频的播放、录制、采集&#xff0c;还是视频的播放、切换、循环&#xff0c;亦或是相机的预览、拍照等功能&#xff0c;媒体组件都是必不可少的。以视频功能为例&a…
阅读更多...
Selenium4+python被单独定义＜div＞的动态输入框和二级下拉框要怎么定位?

Selenium4+python被单独定义＜div＞的动态输入框和二级下拉框要怎么定位?

今天在做练习题的时候,发现几个问题捣鼓了好久,写下这篇来记录 问题一: 有层级的复选框无法定位到二级目录 对于这种拥有二级框的选项无法定位,也不是<select>属性. 我们查看下HTML,发现它是被单独封装在body内拥有动态属性的独立<div>,当窗口点击的时候才会触发…
阅读更多...
如何编辑WordPress配置文件wp-config.php

如何编辑WordPress配置文件wp-config.php

目录 wp-config.php文件全部内容&#xff1a; 修改wp-config.ph文件中的数据库设置&#xff1a; 设置wp-config.ph文件中的密钥部分 修改数据库表前缀 设置绝对路径 WordPress会把数据库的相关信息存在wp-config.php文件中。如果编辑有问题&#xff0c;则会出现建立数据库连…
阅读更多...
做Python自动化测试，我教你个方法还能快一倍！

做Python自动化测试，我教你个方法还能快一倍！

如果你学过 python 进行自动化测试&#xff0c;你一定使用过 unittest。 今天我们要讲的 nose2 是一个高级版本的 unittest。他比 unittest 更容易理解&#xff0c;用起来也更加方便一些。 快速开始 nose2 在 unittest 的基础上开发的&#xff0c;所以如果你之前是用 unitte…
阅读更多...
枚举 蓝桥oj DNA序列修正

枚举 蓝桥oj DNA序列修正

题目详情&#xff1a; 简单翻译&#xff1a; 主要思路&#xff1a; 1 本题采用贪心思路&#xff0c;要使调整次数最少&#xff0c;就是尽量交换两个碱基对&#xff0c;而不是单个替换&#xff0c;因为本题已经说明只能每个碱基对只能交换一次&#xff0c;所以不考虑A与B交换再…
阅读更多...
三、Keil安装芯片包、下载固件库、建立STM32工程模板

三、Keil安装芯片包、下载固件库、建立STM32工程模板

目录 一、首先在Keil软件上安装好芯片包 二、下载官方固件库 三、建立基于固件库的Keil5工程模板 一、首先在Keil软件上安装好芯片包 STM32有很多系列的芯片&#xff0c;我们平常用的最多的是STM32F1系列的&#xff0c;因此安装F1系列的芯片包在我们初学时&#xff0c;只按照…
阅读更多...
priority_queue简单实现（优先级队列）（c++）

priority_queue简单实现（优先级队列）（c++）

priority_queue priority_queue介绍逻辑实现框架调整算法adjust_up()adjust_down() 仿函数/比较函数仿函数特性 构造函数迭代器区间构造 完整优先级队列代码 priority_queue介绍 pri_que是一个容器适配器&#xff0c;它的底层是其他容器&#xff0c;并由这些容器再封装而来。类…
阅读更多...
wvp-gb28181-pro打包

wvp-gb28181-pro打包

生成可执行jar cd wvp-GB28181-pro mvn package复制错误已复制 生成war cd wvp-GB28181-pro mvn package -P war 生成的包的路径 wvp-GB28181-pro\target
阅读更多...
Windows 7 连接 Windows 10 共享打印机，Windows 无法连接打印机，操作失败，错误为0x0000011b 的终极解决办法

Windows 7 连接 Windows 10 共享打印机，Windows 无法连接打印机，操作失败，错误为0x0000011b 的终极解决办法

Windows 7 连接 Windows 10 共享打印机出现错误 0x000001b&#xff0c;建议不要通过卸载Windows10系统的KB5005565安全更新来解决该问题&#xff08;犹如削足适履&#xff09;&#xff0c;正确的处理方法是手工添加一个本地打印机&#xff0c;本方法是安全可靠的。本文详述了该…
阅读更多...
【word技巧】Word制作试卷，ABCD选项如何对齐？

【word技巧】Word制作试卷，ABCD选项如何对齐？

使用word文件制作试卷&#xff0c;如何将ABCD选项全部设置对齐&#xff1f;除了一直按空格或者Tab键以外&#xff0c;还有其他方法吗&#xff1f;今天分享如何将ABCD选项对齐。 首先&#xff0c;我们打开【替换和查找】&#xff0c;在查找内容输入空格&#xff0c;然后点击全部…
阅读更多...
9.Docker的虚悬镜像-Dangling Image

9.Docker的虚悬镜像-Dangling Image

1.虚悬镜像的概念 虚悬镜像 (Dangling Image) 指的是仓库名 (镜像名) 和标签 TAG 都是 的镜像。 2.构建本地虚悬镜像 这里我以unbuntu为例来说明。 2.1 编写Dockerfile文件 FROM ubuntu:22.042.2 根据Dockerfile文件构建虚悬镜像 docker build .上面这段命令&#xff0c…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023