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
英文地址，請注明出處：http://en.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