Qt使用QSqlDatabase連接MySQL實(shí)現(xiàn)增刪改查功能
更新時(shí)間：2025年07月07日 15:53:43 作者：TechNomad
這篇文章主要為大家詳細(xì)介紹了Qt如何使用QSqlDatabase連接MySQL實(shí)現(xiàn)增刪改查功能,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下
一、創(chuàng)建數(shù)據(jù)表
數(shù)據(jù)庫(kù)名：
我們先創(chuàng)建一個(gè)數(shù)據(jù)庫(kù)，名字叫 game_db：
CREATE DATABASE IF NOT EXISTS game_db DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci; USE game_db;
創(chuàng)建玩家表：players
CREATE TABLE players (
player_id INT AUTO_INCREMENT PRIMARY KEY,
username VARCHAR(32) NOT NULL UNIQUE,
password_hash VARCHAR(64) NOT NULL,
nickname VARCHAR(32),
level INT DEFAULT 1,
experience INT DEFAULT 0,
gold INT DEFAULT 0,
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);
插入 20 條玩家信息 SQL 語(yǔ)句：
INSERT INTO players (username, password_hash, nickname, level, experience, gold) VALUES
('user001', MD5('password1'), 'Knight001', 5, 1200, 500),
('user002', MD5('password2'), 'Mage002', 3, 800, 300),
('user003', MD5('password3'), 'Archer003', 7, 1800, 750),
('user004', MD5('password4'), 'Rogue004', 2, 400, 100),
('user005', MD5('password5'), 'Cleric005', 10, 3200, 1200),
('user006', MD5('password6'), 'Paladin006', 4, 950, 400),
('user007', MD5('password7'), 'Hunter007', 6, 1400, 600),
('user008', MD5('password8'), 'Druid008', 8, 2200, 900),
('user009', MD5('password9'), 'Monk009', 9, 2500, 1000),
('user010', MD5('password10'), 'Barbarian010', 1, 100, 50),
('user011', MD5('password11'), 'Warrior011', 5, 1300, 550),
('user012', MD5('password12'), 'Sorcerer012', 3, 700, 300),
('user013', MD5('password13'), 'Assassin013', 6, 1600, 650),
('user014', MD5('password14'), 'Priest014', 7, 1900, 800),
('user015', MD5('password15'), 'Ranger015', 2, 500, 200),
('user016', MD5('password16'), 'Berserker016', 4, 1100, 450),
('user017', MD5('password17'), 'Necromancer017', 8, 2300, 950),
('user018', MD5('password18'), 'Templar018', 9, 2700, 1100),
('user019', MD5('password19'), 'Shaman019', 10, 3000, 1250),
('user020', MD5('password20'), 'Witch020', 1, 200, 100);
表中結(jié)果如下所示：
二、連接MySQL數(shù)據(jù)庫(kù)
database_manager.h
#ifndef DATABASEMANAGER_H
#define DATABASEMANAGER_H
#include <QObject>
#include <QMutex>
#include <QSqlDatabase>
#include <QSqlError>
enum DatabaseType {
MySQL = 0,
SQLite,
PostgreSQL,
// 可擴(kuò)展更多類型
};
typedef struct stConnectParams {
DatabaseType dbType;
QString strHostName;
QString strDbName;
QString strUserName;
QString strPassword;
QString strConnectionName;
int port;
} ConnectParams;
class DatabaseManager : public QObject
{
Q_OBJECT
public:
static DatabaseManager& instance();
void initConnectionParams(const ConnectParams& connectParams);
void initializeConnection();
private:
explicit DatabaseManager(QObject *parent = nullptr);
~DatabaseManager();
DatabaseManager(const DatabaseManager&) = delete;
DatabaseManager& operator =(const DatabaseManager&) = delete;
DatabaseManager(const DatabaseManager&&) = delete;
DatabaseManager& operator =(const DatabaseManager&&) = delete;
signals:
private:
ConnectParams m_connectParams;
};
database_manager.cpp
#include "database_manager.h"
#include <QDebug>
DatabaseManager::DatabaseManager(QObject *parent) : QObject(parent)
{
}
DatabaseManager::~DatabaseManager()
{
}
DatabaseManager& DatabaseManager::instance()
{
static DatabaseManager instance;
return instance;
}
void DatabaseManager::initConnectionParams(const ConnectParams& connectParams)
{
m_connectParams.dbType = connectParams.dbType;
m_connectParams.strHostName = connectParams.strHostName;
m_connectParams.strDbName = connectParams.strDbName;
m_connectParams.strUserName = connectParams.strUserName;
m_connectParams.strPassword = connectParams.strPassword;
m_connectParams.strConnectionName = connectParams.strConnectionName;
m_connectParams.port = connectParams.port;
}
void DatabaseManager::initializeConnection()
{
if (QSqlDatabase::contains(m_connectParams.strConnectionName)) {
qDebug() << "db:" << m_connectParams.strConnectionName << "already connected";
return;
}
QString strDriver;
switch (m_connectParams.dbType) {
case DatabaseType::SQLite:
strDriver = "QSQLITE";
break;
case DatabaseType::MySQL:
strDriver = "QMYSQL";
break;
case DatabaseType::PostgreSQL:
strDriver = "QPSQL";
break;
}
if (strDriver.isEmpty()) {
qDebug() << "can't find driver";
return;
}
QSqlDatabase db = QSqlDatabase::addDatabase(strDriver, m_connectParams.strConnectionName);
if (m_connectParams.dbType == DatabaseType::SQLite) {
db.setDatabaseName(m_connectParams.strDbName); // SQLite只需數(shù)據(jù)庫(kù)文件路徑
} else {
db.setConnectOptions("MYSQL_OPT_CONNECT_TIMEOUT=5;"
"MYSQL_OPT_READ_TIMEOUT=5;"
"MYSQL_OPT_WRITE_TIMEOUT=5;");
db.setHostName(m_connectParams.strHostName);
db.setPort(m_connectParams.port);
db.setDatabaseName(m_connectParams.strDbName);
db.setUserName(m_connectParams.strUserName);
db.setPassword(m_connectParams.strPassword);
}
if (!db.open()) {
qDebug() << "Database connection failed:" << db.lastError().text();
} else {
qDebug() << "Database connected successfully!";
}
}
三、封裝成一個(gè)完整的輕量級(jí) ORM 風(fēng)格類
什么是ORM 模型類的？
ORM（Object-Relational Mapping）模型類的作用，是將數(shù)據(jù)庫(kù)中的表與 C++（或其他語(yǔ)言）中的類進(jìn)行映射和封裝，讓你能像操作普通對(duì)象那樣操作數(shù)據(jù)庫(kù)數(shù)據(jù)，避免直接拼接 SQL 字符串，提高代碼的可讀性、可維護(hù)性、安全性和抽象性。
ORM 模型類的作用總結(jié)如下：
3.1 表結(jié)構(gòu) → 類結(jié)構(gòu)
ORM 會(huì)把數(shù)據(jù)庫(kù)表（如 users）映射成一個(gè)類（如 User），表字段對(duì)應(yīng)類成員或字段名：
// 數(shù)據(jù)庫(kù)表字段 // id | name | age // ORM類字段 QVariantMap row; row["id"] = 1; row["name"] = "Alice"; row["age"] = 30;
3.2 簡(jiǎn)化 SQL 操作
讓你寫這樣的代碼：
userModel.insert({{"name", "Tom"}, {"age", 25}});
而不需要寫繁瑣的 SQL：
INSERT INTO users (name, age) VALUES ('Tom', 25);
目標(biāo)功能：
- 封裝成類 OrmModel 或基類 OrmBase
- 支持設(shè)置數(shù)據(jù)庫(kù)連接、表名
- 支持 select / insert / update / delete 等基礎(chǔ)操作
- 使用 QVariantMap 傳入/返回?cái)?shù)據(jù)
- ORM風(fēng)格：調(diào)用 model.select(…) 而不是手寫 SQL 字符串
類定義：OrmBase
#ifndef DBORMBASE_H
#define DBORMBASE_H
#include <QObject>
#include <QSqlDatabase>
#include <QVariantMap>
#include <QVariantList>
class DbOrmBase : public QObject
{
Q_OBJECT
public:
explicit DbOrmBase(const QString &tableName, const QString &connectionName);
~DbOrmBase();
// CRUD
QVariantList select(const QString &strWhereClause = "", const QStringList &columns = {});
bool insert(const QVariantMap &values);
bool update(const QVariantMap &values, const QString &strWhereClause);
bool remove(const QString &strWhereClause);
private:
bool isConnected() const;
private:
QString m_tableName;
QString m_connectionName;
QSqlDatabase m_db; // 保存數(shù)據(jù)庫(kù)實(shí)例
};
#endif // DBORMBASE_H
類實(shí)現(xiàn)：OrmBase.cpp
#include "OrmBase.h"
#include <QSqlQuery>
#include <QSqlError>
#include <QSqlRecord>
#include <QDebug>
OrmBase::OrmBase(const QString &tableName, const QString &connectionName)
: m_tableName(tableName), m_connectionName(connectionName)
{}
QVariantList OrmBase::select(const QString &whereClause, const QStringList &columns)
{
QVariantList results;
QSqlDatabase db = QSqlDatabase::database(m_connectionName);
if (!db.isOpen()) {
qDebug() << "Database not open";
return results;
}
QString columnStr = columns.isEmpty() ? "*" : columns.join(", ");
QString sql = QString("SELECT %1 FROM %2").arg(columnStr, m_tableName);
if (!whereClause.trimmed().isEmpty()) {
sql += " WHERE " + whereClause;
}
QSqlQuery query(db);
if (!query.exec(sql)) {
qDebug() << "Select failed:" << query.lastError().text();
return results;
}
while (query.next()) {
QVariantMap row;
QSqlRecord rec = query.record();
for (int i = 0; i < rec.count(); ++i) {
row[rec.fieldName(i)] = query.value(i);
}
results << row;
}
return results;
}
bool OrmBase::insert(const QVariantMap &values)
{
QSqlDatabase db = QSqlDatabase::database(m_connectionName);
if (!db.isOpen()) return false;
QStringList columns, placeholders;
QVariantList bindValues;
for (auto it = values.begin(); it != values.end(); ++it) {
columns << it.key();
placeholders << "?";
bindValues << it.value();
}
QString sql = QString("INSERT INTO %1 (%2) VALUES (%3)")
.arg(m_tableName)
.arg(columns.join(", "))
.arg(placeholders.join(", "));
QSqlQuery query(db);
query.prepare(sql);
for (const QVariant &val : bindValues) {
query.addBindValue(val);
}
if (!query.exec()) {
qDebug() << "Insert failed:" << query.lastError().text();
return false;
}
return true;
}
bool OrmBase::update(const QVariantMap &values, const QString &whereClause)
{
QSqlDatabase db = QSqlDatabase::database(m_connectionName);
if (!db.isOpen()) return false;
QStringList sets;
QVariantList bindValues;
for (auto it = values.begin(); it != values.end(); ++it) {
sets << QString("%1 = ?").arg(it.key());
bindValues << it.value();
}
QString sql = QString("UPDATE %1 SET %2").arg(m_tableName, sets.join(", "));
if (!whereClause.trimmed().isEmpty()) {
sql += " WHERE " + whereClause;
}
QSqlQuery query(db);
query.prepare(sql);
for (const QVariant &val : bindValues) {
query.addBindValue(val);
}
if (!query.exec()) {
qDebug() << "Update failed:" << query.lastError().text();
return false;
}
return true;
}
bool OrmBase::remove(const QString &whereClause)
{
QSqlDatabase db = QSqlDatabase::database(m_connectionName);
if (!db.isOpen()) return false;
QString sql = QString("DELETE FROM %1").arg(m_tableName);
if (!whereClause.trimmed().isEmpty()) {
sql += " WHERE " + whereClause;
}
QSqlQuery query(db);
if (!query.exec(sql)) {
qDebug() << "Delete failed:" << query.lastError().text();
return false;
}
return true;
}
使用示例：
#include <QCoreApplication>
#include <QDebug>
#include <QDateTime>
#include "database_manager.h"
#include "db_ormbase.h"
int main(int argc, char *argv[])
{
QCoreApplication a(argc, argv);
ConnectParams connectParams;
connectParams.dbType = DatabaseType::MySQL;
connectParams.strHostName = "localhost";
connectParams.strDbName = "game_db";
connectParams.strUserName = "root";
connectParams.strPassword = "root";
connectParams.strConnectionName = "user_game";
connectParams.port = 3306;
DatabaseManager::instance().initConnectionParams(connectParams);
DatabaseManager::instance().initializeConnection();
DbOrmBase userModel("players", "user_game");
QVariantList playerList = userModel.select("experience > 1000");
for (const QVariant &playerVar : playerList) {
QVariantMap playerMap = playerVar.toMap();
int playerId = playerMap.value("player_id").toInt();
QString username = playerMap.value("username").toString();
QString nickname = playerMap.value("nickname").toString();
int level = playerMap.value("level").toInt();
int experience = playerMap.value("experience").toInt();
int gold = playerMap.value("gold").toInt();
QString passwordHash = playerMap.value("password_hash").toString();
QDateTime createdAt = playerMap.value("created_at").toDateTime();
// 可以進(jìn)行打印、顯示、或保存到類對(duì)象中
qDebug() << "ID:" << playerId
<< "用戶名:" << username
<< "昵稱:" << nickname
<< "等級(jí):" << level
<< "經(jīng)驗(yàn):" << experience
<< "金幣:" << gold
<< "密碼Hash:" << passwordHash
<< "創(chuàng)建時(shí)間:" << createdAt.toString(Qt::ISODate);
}
return a.exec();
}
輸出結(jié)果：
四、實(shí)現(xiàn)派生具體模型類
為什么要派生？
雖然 OrmBase 已支持通用 CRUD，但派生后的 UserModel 能實(shí)現(xiàn)：
- 指定固定表名（如 players）
- 添加和 players 表相關(guān)的專屬函數(shù)（如 getAdultUsers()、findByName()）
- 讓調(diào)用更具語(yǔ)義：UserModel user; user.insert(…)
創(chuàng)建 UserModel 類
UserModel.h
#ifndef USERMODEL_H
#define USERMODEL_H
#include "OrmBase.h"
class UserModel : public OrmBase
{
public:
explicit UserModel(const QString &connectionName = "default");
// 自定義業(yè)務(wù)函數(shù)
QVariantList getAdultUsers();
QVariantMap findById(int id);
QVariantList findByName(const QString &name);
};
#endif // USERMODEL_H
UserModel.cpp
#include "UserModel.h"
UserModel::UserModel(const QString &connectionName)
: OrmBase("players", connectionName) // 固定表名為 users
{}
// 查詢年齡 >= 18 的用戶
QVariantList UserModel::getAdultUsers()
{
return select("experience >= 1000", {"player_id", "username", "experience"});
}
// 查詢某個(gè) ID 的用戶（返回一行）
QVariantMap UserModel::findById(int id)
{
auto results = select(QString("player_id = %1").arg(id));
return results.isEmpty() ? QVariantMap() : results.first().toMap();
}
// 查詢某個(gè)名字的所有用戶
QVariantList UserModel::findByName(const QString &name)
{
QString clause = QString("username = '%1'").arg(name.replace("'", "''")); // 簡(jiǎn)單防注入
return select(clause);
}
五、支持多線程連接池 + ORM + 事務(wù)封裝
將構(gòu)建以下組件：
+-------------------------+
| DBConnectionPool | 線程安全連接池類（單例）
+-------------------------+
| OrmBase | ORM 基類（封裝表操作 + 自動(dòng)獲取線程連接）
+-------------------------+
| OrmManager | 管理多個(gè)模型，支持事務(wù)封裝
+-------------------------+
| XxxModel : OrmBase | 表模型（如 UserModel）
+-------------------------+
5.1 線程安全數(shù)據(jù)庫(kù)連接池：DBConnectionPool
DBConnectionPool.h
#ifndef DBCONNECTIONPOOL_H
#define DBCONNECTIONPOOL_H
#include <QSqlDatabase>
#include <QMutex>
#include <QMap>
#include <QThreadStorage>
class DBConnectionPool
{
public:
static DBConnectionPool &instance();
void init(const QString &driver,
const QString &host,
int port,
const QString &dbName,
const QString &user,
const QString &password,
int maxConn = 10);
QSqlDatabase getConnection();
void closeAll();
private:
DBConnectionPool() = default;
Q_DISABLE_COPY(DBConnectionPool)
QString m_driver, m_host, m_dbName, m_user, m_password;
int m_port = 3306;
int m_maxConn = 10;
QMutex m_mutex;
int m_connIndex = 0;
QThreadStorage<QString> m_threadConnName;
};
#endif // DBCONNECTIONPOOL_H
DBConnectionPool.cpp
#include "DBConnectionPool.h"
#include <QSqlDatabase>
#include <QSqlError>
#include <QDebug>
DBConnectionPool &DBConnectionPool::instance()
{
static DBConnectionPool pool;
return pool;
}
void DBConnectionPool::init(const QString &driver,
const QString &host,
int port,
const QString &dbName,
const QString &user,
const QString &password,
int maxConn)
{
m_driver = driver;
m_host = host;
m_port = port;
m_dbName = dbName;
m_user = user;
m_password = password;
m_maxConn = maxConn;
}
QSqlDatabase DBConnectionPool::getConnection()
{
if (!m_threadConnName.hasLocalData()) {
QMutexLocker locker(&m_mutex);
QString connName = QString("conn_%1").arg(++m_connIndex);
m_threadConnName.setLocalData(connName);
QSqlDatabase db = QSqlDatabase::addDatabase(m_driver, connName);
db.setHostName(m_host);
db.setPort(m_port);
db.setDatabaseName(m_dbName);
db.setUserName(m_user);
db.setPassword(m_password);
db.setConnectOptions("MYSQL_OPT_CONNECT_TIMEOUT=5;"
"MYSQL_OPT_RECONNECT=1");
if (!db.open()) {
qCritical() << "Failed to open DB:" << db.lastError().text();
}
}
return QSqlDatabase::database(m_threadConnName.localData());
}
void DBConnectionPool::closeAll()
{
QMutexLocker locker(&m_mutex);
for (int i = 1; i <= m_connIndex; ++i) {
QString name = QString("conn_%1").arg(i);
if (QSqlDatabase::contains(name)) {
QSqlDatabase::removeDatabase(name);
}
}
m_connIndex = 0;
}
5.2 ORM 基類 OrmBase（使用連接池）
class OrmBase
{
public:
OrmBase(const QString &tableName);
virtual ~OrmBase() = default;
bool insert(const QVariantMap &values);
QVariantList select(const QString &whereClause = "", const QStringList &columns = {});
bool update(const QVariantMap &values, const QString &whereClause);
bool remove(const QString &whereClause);
QSqlDatabase db() const;
protected:
QString m_tableName;
};
關(guān)鍵點(diǎn)：OrmBase 中不再保存 QSqlDatabase 實(shí)例，而是每次從線程池中獲?。?/p>
QSqlDatabase OrmBase::db() const
{
return DBConnectionPool::instance().getConnection();
}
5.3 事務(wù)封裝類 OrmManager
用于封裝如下邏輯：
- beginTransaction()
- commit()
- rollback()
class OrmManager
{
public:
static bool beginTransaction();
static bool commit();
static bool rollback();
};
實(shí)現(xiàn)：
bool OrmManager::beginTransaction()
{
QSqlDatabase db = DBConnectionPool::instance().getConnection();
return db.transaction();
}
bool OrmManager::commit()
{
QSqlDatabase db = DBConnectionPool::instance().getConnection();
return db.commit();
}
bool OrmManager::rollback()
{
QSqlDatabase db = DBConnectionPool::instance().getConnection();
return db.rollback();
}
5.4 使用示例：線程內(nèi)事務(wù) + 多表操作
DBConnectionPool::instance().init("QMYSQL", "127.0.0.1", 3306, "testdb", "root", "123456");
UserModel user;
OrderModel order;
OrmManager::beginTransaction();
bool ok1 = user.insert({{"name", "Tom"}});
bool ok2 = order.insert({{"user_id", 1}, {"amount", 200.0}});
if (ok1 && ok2)
OrmManager::commit();
else
OrmManager::rollback();
5.5 線程使用示例（多線程安全）
QtConcurrent::run([](){
UserModel u;
u.insert({{"name", "ThreadUser"}});
});
以上就是Qt使用QSqlDatabase連接MySQL實(shí)現(xiàn)增刪改查功能的詳細(xì)內(nèi)容，更多關(guān)于QSqlDatabase連接MySQL實(shí)現(xiàn)增刪改查的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
這篇文章主要介紹了C語(yǔ)言之如何求三次方根問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-12-12
這篇文章主要為大家詳細(xì)介紹了用C語(yǔ)言實(shí)現(xiàn)猜數(shù)字，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2021-06-06
Easyx實(shí)現(xiàn)窗口自動(dòng)碰撞的小球
這篇文章主要為大家詳細(xì)介紹了Easyx實(shí)現(xiàn)窗口自動(dòng)碰撞的小球，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-01-01
Qt實(shí)現(xiàn)實(shí)時(shí)鼠標(biāo)繪制圖形
這篇文章主要介紹了Qt中QGraphicsView架構(gòu)下如何實(shí)現(xiàn)實(shí)時(shí)鼠標(biāo)繪制圖形，文中的示例代碼講解詳細(xì)，感興趣的小伙伴可以跟隨小編一起動(dòng)手試一試2022-02-02
這篇文章主要給大家介紹了關(guān)于c語(yǔ)言snprintf函數(shù)用法的相關(guān)資料,snprintf()函數(shù)用于將格式化的數(shù)據(jù)寫入字符串,文中通過(guò)代碼介紹的非常詳細(xì),需要的朋友可以參考下2023-09-09
使用C++實(shí)現(xiàn)插件模式時(shí)的避坑要點(diǎn)(推薦)
這篇文章主要介紹了使用C++實(shí)現(xiàn)插件模式時(shí)的避坑要點(diǎn),本文主要分析實(shí)踐中常見的、因?yàn)閷?duì)原理不清楚而搞出來(lái)的產(chǎn)品里的坑，本文給大家介紹的非常詳細(xì)，需要的朋友可以參考下2022-08-08
C語(yǔ)言文字藝術(shù)之?dāng)?shù)據(jù)輸入輸出
這篇文章主要介紹了C語(yǔ)言文字藝術(shù)之?dāng)?shù)據(jù)輸入輸出，C語(yǔ)言的語(yǔ)句用來(lái)向計(jì)算機(jī)系統(tǒng)發(fā)出操作指令。一條語(yǔ)句編寫完成經(jīng)過(guò)編譯后產(chǎn)生若干條機(jī)器指2022-07-07
這篇文章主要介紹了C++using聲明和using編譯指令,C++當(dāng)中提供了兩種機(jī)制來(lái)簡(jiǎn)化對(duì)名稱空間中名稱的使用。using聲明使特定的標(biāo)識(shí)符keys，using編譯指令使整個(gè)名稱空間可用。下面我們就來(lái)看看這兩種機(jī)制的相關(guān)資料吧，需要的小伙伴可以參考一下2021-12-12
C語(yǔ)言for循環(huán)嵌套for循環(huán)在實(shí)踐題目中應(yīng)用詳解
初學(xué)C語(yǔ)言，常常遇到for循環(huán)中嵌套個(gè)for循環(huán)，初學(xué)者對(duì)于這種形式總是一知半解，這次我就整理了常見的for循環(huán)嵌套for循環(huán)的題目，我們一起爭(zhēng)取一舉拿下這類題。學(xué)廢他們，以后再見到就不怕啦！每天都要學(xué)一點(diǎn)呀。加油，奮斗的我們2022-05-05
關(guān)于C++中0是十進(jìn)制還是八進(jìn)制的問(wèn)題
本篇文章中，小編將為大家介紹關(guān)于C++中0是十進(jìn)制還是八進(jìn)制的問(wèn)題，有需要的朋友可以參考一下2013-04-04