Qt 数据库连接池实现与管理

在 Qt 应用程序中，频繁创建和销毁数据库连接会带来显著的性能开销。数据库连接池通过复用现有连接，避免重复创建和销毁连接的开销，从而提高应用程序的响应速度和吞吐量。本文将详细介绍 Qt 中数据库连接池的实现与管理方法。

一、数据库连接池的核心概念

1. 基本原理
  • 连接复用：预先创建一定数量的数据库连接，存储在池中。
  • 按需分配：应用程序需要连接时从池中获取，使用完毕后返回池中而非关闭。
  • 连接管理：监控连接状态，自动回收超时或失效的连接。
2. 关键组件
  • 连接池类：管理连接的创建、分配和回收。
  • 连接包装类：封装数据库连接，确保连接使用完毕后能正确返回池中。
  • 配置类：存储连接池参数（如最大连接数、超时时间等）。

二、简单连接池的实现

以下是一个基于 Qt 的简单数据库连接池实现：

#include <QObject>
#include <QSqlDatabase>
#include <QSqlError>
#include <QString>
#include <QTimer>
#include <QQueue>
#include <QMutex>
#include <QMutexLocker>
#include <QDateTime>
#include <QDebug>class DatabasePool : public QObject
{Q_OBJECT
public:static DatabasePool* getInstance();// 获取数据库连接QSqlDatabase acquireConnection(const QString &connectionName = QString());// 释放数据库连接void releaseConnection(const QString &connectionName);// 配置数据库连接参数void configure(const QString &driver, const QString &host, const QString &databaseName,const QString &username, const QString &password,int port = 0, int maxConnections = 10, int idleTime = 30000);// 销毁连接池void destroy();private:explicit DatabasePool(QObject *parent = nullptr);~DatabasePool();// 禁止拷贝和赋值DatabasePool(const DatabasePool&) = delete;DatabasePool& operator=(const DatabasePool&) = delete;// 创建新连接QSqlDatabase createConnection(const QString &connectionName);// 清理空闲连接void cleanupIdleConnections();private:static DatabasePool* m_instance;static QMutex m_mutex;QString m_driver;QString m_host;QString m_databaseName;QString m_username;QString m_password;int m_port;int m_maxConnections;int m_idleTime;struct ConnectionInfo {QDateTime lastUsed;bool inUse;};QQueue<QString> m_availableConnections;QHash<QString, ConnectionInfo> m_connectionInfo;QMutex m_poolMutex;QTimer *m_cleanupTimer;
};

#include "databasepool.h"DatabasePool* DatabasePool::m_instance = nullptr;
QMutex DatabasePool::m_mutex;DatabasePool* DatabasePool::getInstance()
{QMutexLocker locker(&m_mutex);if (!m_instance) {m_instance = new DatabasePool();}return m_instance;
}DatabasePool::DatabasePool(QObject *parent) : QObject(parent)
{m_maxConnections = 10;m_idleTime = 30000;  // 30秒// 初始化清理定时器m_cleanupTimer = new QTimer(this);connect(m_cleanupTimer, &QTimer::timeout, this, &DatabasePool::cleanupIdleConnections);m_cleanupTimer->start(10000);  // 每10秒检查一次
}DatabasePool::~DatabasePool()
{destroy();
}void DatabasePool::configure(const QString &driver, const QString &host, const QString &databaseName,const QString &username, const QString &password,int port, int maxConnections, int idleTime)
{QMutexLocker locker(&m_poolMutex);m_driver = driver;m_host = host;m_databaseName = databaseName;m_username = username;m_password = password;m_port = port;m_maxConnections = maxConnections;m_idleTime = idleTime;
}QSqlDatabase DatabasePool::acquireConnection(const QString &connectionName)
{QMutexLocker locker(&m_poolMutex);QString name = connectionName;if (name.isEmpty()) {// 生成唯一的连接名称static int counter = 0;name = QString("Connection_%1").arg(++counter);}// 检查是否有可用的连接while (!m_availableConnections.isEmpty()) {QString availableName = m_availableConnections.dequeue();ConnectionInfo &info = m_connectionInfo[availableName];// 检查连接是否有效QSqlDatabase db = QSqlDatabase::database(availableName, false);if (db.isOpen() && db.isValid()) {info.inUse = true;info.lastUsed = QDateTime::currentDateTime();return db;} else {// 连接无效，移除并关闭QSqlDatabase::removeDatabase(availableName);m_connectionInfo.remove(availableName);}}// 没有可用连接，检查是否可以创建新连接if (m_connectionInfo.size() < m_maxConnections) {QSqlDatabase db = createConnection(name);ConnectionInfo info;info.inUse = true;info.lastUsed = QDateTime::currentDateTime();m_connectionInfo[name] = info;return db;}// 达到最大连接数，无法创建新连接qWarning() << "DatabasePool: 达到最大连接数，无法获取连接";return QSqlDatabase();
}void DatabasePool::releaseConnection(const QString &connectionName)
{QMutexLocker locker(&m_poolMutex);if (m_connectionInfo.contains(connectionName)) {ConnectionInfo &info = m_connectionInfo[connectionName];info.inUse = false;info.lastUsed = QDateTime::currentDateTime();m_availableConnections.enqueue(connectionName);} else {qWarning() << "DatabasePool: 尝试释放不存在的连接:" << connectionName;}
}QSqlDatabase DatabasePool::createConnection(const QString &connectionName)
{QSqlDatabase db = QSqlDatabase::addDatabase(m_driver, connectionName);db.setHostName(m_host);db.setDatabaseName(m_databaseName);db.setUserName(m_username);db.setPassword(m_password);if (m_port > 0) {db.setPort(m_port);}if (!db.open()) {qCritical() << "DatabasePool: 无法创建数据库连接:" << db.lastError().text();QSqlDatabase::removeDatabase(connectionName);return QSqlDatabase();}return db;
}void DatabasePool::cleanupIdleConnections()
{QMutexLocker locker(&m_poolMutex);QDateTime now = QDateTime::currentDateTime();QList<QString> connectionsToRemove;// 查找所有空闲时间超过阈值的连接for (auto it = m_connectionInfo.begin(); it != m_connectionInfo.end(); ++it) {const QString &connectionName = it.key();const ConnectionInfo &info = it.value();if (!info.inUse && info.lastUsed.msecsTo(now) > m_idleTime) {connectionsToRemove.append(connectionName);}}// 移除并关闭这些连接for (const QString &connectionName : connectionsToRemove) {// 从可用队列中移除m_availableConnections.removeAll(connectionName);// 关闭并移除数据库连接QSqlDatabase::database(connectionName, false).close();QSqlDatabase::removeDatabase(connectionName);// 从连接信息中移除m_connectionInfo.remove(connectionName);}
}void DatabasePool::destroy()
{QMutexLocker locker(&m_poolMutex);// 停止清理定时器m_cleanupTimer->stop();// 关闭并移除所有数据库连接for (const QString &connectionName : m_connectionInfo.keys()) {QSqlDatabase::database(connectionName, false).close();QSqlDatabase::removeDatabase(connectionName);}// 清空所有数据结构m_availableConnections.clear();m_connectionInfo.clear();
}

三、连接池的使用方法

1. 初始化连接池
#include "databasepool.h"// 初始化连接池
void initDatabasePool()
{DatabasePool::getInstance()->configure("QMYSQL",               // 数据库驱动"localhost",            // 主机名"mydatabase",           // 数据库名"username",             // 用户名"password",             // 密码3306,                   // 端口10,                     // 最大连接数30000                   // 空闲超时时间（毫秒）);
}
2. 获取和释放连接
void performDatabaseOperation()
{// 从连接池获取连接QSqlDatabase db = DatabasePool::getInstance()->acquireConnection();if (db.isOpen()) {// 执行数据库操作QSqlQuery query(db);query.exec("SELECT * FROM users");while (query.next()) {// 处理结果QString name = query.value("name").toString();qDebug() << "User:" << name;}// 操作完成后释放连接DatabasePool::getInstance()->releaseConnection(db.connectionName());} else {qCritical() << "无法获取数据库连接:" << db.lastError().text();}
}
3. 使用 RAII 技术自动管理连接

为了更安全地管理连接，可以创建一个 RAII（资源获取即初始化）包装类：

class DatabaseConnection {
public:explicit DatabaseConnection(const QString &connectionName = QString()) {m_db = DatabasePool::getInstance()->acquireConnection(connectionName);}~DatabaseConnection() {if (m_db.isOpen()) {DatabasePool::getInstance()->releaseConnection(m_db.connectionName());}}QSqlDatabase& database() {return m_db;}bool isValid() const {return m_db.isOpen();}private:QSqlDatabase m_db;
};

使用示例：

void safeDatabaseOperation()
{DatabaseConnection conn;if (conn.isValid()) {QSqlQuery query(conn.database());query.exec("INSERT INTO logs (message) VALUES ('Operation completed')");}// 连接会在 conn 离开作用域时自动释放
}

四、连接池的高级特性

1. 多数据库支持

扩展连接池以支持多个不同的数据库配置：

// 添加一个数据库配置
void addDatabaseConfig(const QString &configName, const QString &driver,const QString &host, const QString &databaseName,const QString &username, const QString &password,int port = 0, int maxConnections = 10, int idleTime = 30000);// 从指定配置获取连接
QSqlDatabase acquireConnection(const QString &configName, const QString &connectionName = QString());
2. 连接健康检查

在获取连接时检查连接是否有效：

bool isConnectionValid(const QString &connectionName)
{QSqlDatabase db = QSqlDatabase::database(connectionName, false);if (!db.isOpen()) {return false;}// 执行简单的查询检查连接是否真正可用QSqlQuery query("SELECT 1", db);return query.next();
}
3. 连接超时处理

在获取连接时添加超时机制，避免长时间等待：

QSqlDatabase acquireConnectionWithTimeout(const QString &connectionName = QString(), int timeoutMs = 5000)
{QMutexLocker locker(&m_poolMutex);QTime timer;timer.start();while (timer.elapsed() < timeoutMs) {// 尝试获取连接...// 如果没有可用连接，等待一段时间再试locker.unlock();QThread::msleep(100);locker.relock();}// 超时处理qWarning() << "DatabasePool: 获取连接超时";return QSqlDatabase();
}

五、性能优化与注意事项

1. 连接数配置
  • 过小：会导致应用程序频繁等待连接，降低性能。
  • 过大：会消耗过多数据库服务器资源，甚至导致服务器崩溃。
  • 建议：根据数据库服务器配置和应用程序负载测试确定最佳连接数。
2. 线程安全
  • 使用互斥锁（如 QMutex）保护共享资源（连接池）。
  • 每个线程应使用独立的数据库连接，避免多线程共享同一连接。
3. 错误处理
  • 捕获并记录数据库操作中的错误。
  • 实现连接恢复机制，当连接失效时能够自动重新建立连接。
4. 监控与统计
  • 添加连接池使用情况的统计功能（如当前连接数、等待时间等）。
  • 实现监控接口，便于运行时调整连接池参数。

六、总结

数据库连接池是 Qt 应用程序中提高数据库访问性能的重要技术，通过连接复用和有效管理，可以显著减少连接创建和销毁的开销。实现一个高效、稳定的连接池需要考虑线程安全、连接健康检查、超时处理等多方面因素。合理配置和使用连接池，可以使 Qt 应用程序在处理大量数据库请求时保持高性能和稳定性。

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

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

相关文章

数据采集分析：从信息洪流中掘金的科学与艺术

数据采集分析：从信息洪流中掘金的科学与艺术

——如何将原始数据转化为商业决策的黄金&#xff1f;&#x1f310; 引言&#xff1a;我们正淹没在数据的海洋&#xff0c;却渴求着知识的甘泉每天全球产生 2.5万亿字节 数据&#xff08;相当于每秒下载4.5万部高清电影&#xff09;&#xff0c;但未经分析的数据如同未提炼的原…
阅读更多...
Oracle国产化替代：一线DBA的技术决策突围战

Oracle国产化替代：一线DBA的技术决策突围战

从“如履薄冰”到“游刃有余”，中国数据库的自主之路正重塑技术人的思维地图。 “凌晨三点的最后一次数据校验通过，割接系统绿灯全亮——**河北移动核心账务系统的Oracle数据库已被GoldenDB完全替代**。”2025年6月底，这场持续两年的攻坚战画上句号。当全省业务流量平稳切…
阅读更多...
OS19.【Linux】进程状态(1)

OS19.【Linux】进程状态(1)

目录 1.情景引入 2.操作系统学科对进程状态的分类 运行状态 基于时间片的轮转调度算法 阻塞状态 等待IO设备的例子 等待其他进程中需要获取的数据 进程唤醒 挂起状态(全称为阻塞挂起状态) 简单谈谈虚拟内存管理 就绪状态 笔面试题 3.Linux对进程状态的分类 R和S状…
阅读更多...
Hadoop小文件合并技术深度解析：HAR文件归档、存储代价与索引结构

Hadoop小文件合并技术深度解析：HAR文件归档、存储代价与索引结构

HDFS小文件问题的背景与挑战在Hadoop分布式文件系统&#xff08;HDFS&#xff09;的设计哲学中&#xff0c;"大文件、流式访问"是核心原则。然而现实场景中&#xff0c;海量小文件&#xff08;通常指远小于HDFS默认块大小128MB的文件&#xff09;的涌入却成为系统性能…
阅读更多...
Verilog 提取信号的上升沿或者下降沿

Verilog 提取信号的上升沿或者下降沿

上升沿提取代码&#xff1a;reg [1:0] F1;always (posedge clk)beginif(rst_n 1b0) F1[1:0]<2b00;else F1[1:0]<{F1[0],start_i};endwire start_l2h (F1[1:0]2b01)?1b1:1b0;下降沿提取代码&#xff1a;reg [1:0] F1;always (posedge clk)b…
阅读更多...
.Net core 部署到IIS出现500.19Internal Server Error 解决方法

.Net core 部署到IIS出现500.19Internal Server Error 解决方法

.Net core 部署到IIS&#xff0c;网页出现500.19Internal Server Error 解决方法解决方法 在URL:https://dotnet.microsoft.com/zh-tw/download/dotnet/8.0下载并安装dotnet-hosting-8.0.18-win.exe 重启IIS服务器
阅读更多...
Linux 基本命令整理

Linux 基本命令整理

&#x1f427; Linux 基本命令整理 为了方便初学者快速掌握 Linux 常用命令&#xff0c;以下是经过分类整理的核心命令及用法说明。 &#x1f4c2; 目录操作与文件管理 pwd 核心功能&#xff1a;打印当前工作目录的绝对路径&#xff0c;明确用户所在位置。 实操示例&#x…
阅读更多...
牛客周赛 Round 101（题解的token计算， 76修地铁 ，76选数，76构造，qcjj寄快递，幂中幂plus）

牛客周赛 Round 101（题解的token计算， 76修地铁 ，76选数，76构造，qcjj寄快递，幂中幂plus）

A题解的token计算要记住c中的对数函数&#xff1a;log(n) 是自然对数&#xff08;以e为底&#xff09;ln(nlog10(n) 是以10为底的对log1p(n) 是ln(1n)&#xff0c;提供更高的数值精log2(n) 是以2为底的对logl(n) 和 log10l(n) 是long double版#define _CRT_SECURE_NO_WARNINGS …
阅读更多...
商场导航软件：3D+AI 基于Deepseek 模型的意图识别技术解析

商场导航软件：3D+AI 基于Deepseek 模型的意图识别技术解析

本文面向室内导航工程师、商场导航系统优化师及LBS 应用开发的技术员&#xff0c;解析商场室内导航系统 3DAI 三大核心技术模块&#xff0c;并提供可直接复用的工程解决方案。如需获取商场导航系统技术方案可前往文章最下方获取&#xff0c;如有项目合作及技术交流欢迎私信作者…
阅读更多...
借助Aspose.HTML控件，使用 Python 编程将网页转换为 PDF

借助Aspose.HTML控件，使用 Python 编程将网页转换为 PDF

使用 Python 将网页转换为 PDF 有时您需要离线访问网页&#xff0c;使其更易于访问。因此&#xff0c;将HTML页面转换为PDF即可满足您的需求。令人惊讶的是&#xff0c;您可以在几秒钟内在 Python 项目中启用 HTML 到 PDF 的转换。本指南将为 Python 开发人员介绍一个功能强大…
阅读更多...
数据结构：找出字符串中重复的字符（Finding Duplicates in a String）——使用位运算

数据结构：找出字符串中重复的字符（Finding Duplicates in a String）——使用位运算

目录 预备知识 左移运算&#xff08;<<&#xff09; 位运算 一、从最朴素的方法开始 二、如果只关心“有没有出现过”&#xff0c;不关心“次数”&#xff0c;还能不能更省&#xff1f; 三、有没有一种更“紧凑”的方式表示26个开关&#xff1f; 四、用一个整数的…
阅读更多...
DevOps 完整实现指南：从理论到实践

DevOps 完整实现指南：从理论到实践

DevOps 是一种集软件开发&#xff08;Dev&#xff09;与 IT 运维&#xff08;Ops&#xff09;于一体的文化、实践和工具链&#xff0c;旨在通过自动化流程、持续集成/持续交付&#xff08;CI/CD&#xff09;、基础设施即代码&#xff08;IaC&#xff09;和跨团队协作&#xff0…
阅读更多...
使用 5 种安全解决方案将 Android 短信导出为PDF

使用 5 种安全解决方案将 Android 短信导出为PDF

想要将安卓手机短信导出为 PDF 格式&#xff0c;用于法律用途、情感表达或仅仅为了记录&#xff1f;总之&#xff0c;您可以保存安卓手机短信并将其转换为 PDF 格式&#xff0c;确保它们井然有序&#xff0c;方便打印。快来获取解决方案吧&#xff01;第 1 部分&#xff1a;如何…
阅读更多...
再谈fpga开发（fpga开发的几个差异）

再谈fpga开发（fpga开发的几个差异）

【 声明&#xff1a;版权所有&#xff0c;欢迎转载&#xff0c;请勿用于商业用途。 联系信箱&#xff1a;feixiaoxing 163.com】学习嵌入式的同学都知道&#xff0c;嵌入式一般分成这几种chip&#xff0c;有51&#xff0c;有stm32 mcu&#xff0c;有soc&#xff0c;有dsp&#…
阅读更多...
Kafka运维实战 11 - kafka查看消息的具体内容【实战】

Kafka运维实战 11 - kafka查看消息的具体内容【实战】

目录kafka 消息查看1. 直接查看日志文件内容步骤&#xff1a;2. 使用 Kafka 工具查看日志主要参数说明常用命令&#xff1a;输出说明&#xff1a;3. 注意事项kafka 消息日志文件详解我们有时候遇到这样的需求&#xff0c;需要查看下kafka消息的内容。 kafka 消息查看 查看 Ka…
阅读更多...
【自动化测试】JMeter+Jenkins自动化接口与性能测试环境部署指南

【自动化测试】JMeter+Jenkins自动化接口与性能测试环境部署指南

环境准备与基础配置 软硬件环境要求 工具链安装部署 工具链安装部署涉及JDK、JMeter、Jenkins等核心组件，其在Linux与Windows环境下的安装流程存在显著差异，企业级部署需重点关注静默安装、权限控制及数据备份配置。以下从组件安装差异、企业级部署要点及备份配置三方面展开…
阅读更多...
三步实现Android系统级集成：预装Google TTS + 默认引擎设置 + 语音包预缓存方案

三步实现Android系统级集成：预装Google TTS + 默认引擎设置 + 语音包预缓存方案

在定制Android系统时&#xff0c;预装Google TTS引擎并实现开箱即用的语音服务能显著提升用户体验。本文将详解预装APK→设为默认引擎→语音包预缓存的实现方案&#xff0c;适用于ROM开发者或系统定制场景。分步实现方案 预装Google TTS APK 预装APK这里可以采用很多种方式&…
阅读更多...
Python基础学习第三课：数据结构与文件操作

Python基础学习第三课：数据结构与文件操作

以下是Python基础学习第三课的完整内容&#xff0c;重点讲解数据结构&#xff08;列表、字典、元组、集合&#xff09;和文件操作&#xff0c;通过实例演示如何高效管理和操作数据&#xff1a;Python基础学习第三课&#xff1a;数据结构与文件操作一、课程目标1. 掌握四种核心数…
阅读更多...
【PHP 流程控制完全指南】

【PHP 流程控制完全指南】

PHP 流程控制完全指南&#x1f9e0; 一、什么是流程控制&#xff1f; 在编程中&#xff0c;流程控制是指控制程序执行顺序的语句。它决定了代码是“从上往下执行”&#xff0c;还是“根据条件跳转”&#xff0c;或者“循环执行某些代码”。 PHP 中的流程控制语句主要包括&#…
阅读更多...
Kafka运维实战 05 - kafka 消费者组和重平衡（Rebalance）

Kafka运维实战 05 - kafka 消费者组和重平衡（Rebalance）

目录什么是消费者组&#xff1f;消费者组如何工作&#xff1f;位移&#xff08;Offset&#xff09;消费者组的核心机制&#xff1a;重平衡&#xff08;Rebalance&#xff09;触发条件重平衡影响在消息队列&#xff08;如 Kafka&#xff09;的世界里&#xff0c;消费者组是实现高…
阅读更多...
最新文章

Copyright @ 2022~2023