Qt - 同时处理多个数据库连接

Question

我正在将 .net / c# 应用程序转换为 Qt。我不是每天都使用 Qt / C++，所以请耐心等待。

应用程序同时使用 SQLite 和 MS SQL Server。建立连接后，它会保持打开状态，因为两个数据存储的数据事务都非常高，我不想浪费时间打开和关闭事务之间的连接。

我的目标是创建一个可用于两种数据库类型的通用管理器类。当任何一个连接在没有另一个连接的情况下打开时，该类就可以正常工作。但是，当我尝试同时建立与两者的连接时，我收到错误：

QSqlDatabasePrivate::removeDatabase: connection 'qt_sql_default_connection' 仍在使用中，所有查询都将停止工作。

QSqlDatabasePrivate::addDatabase：重复的连接名称“qt_sql_default_connection”，旧连接已删除。

所以，我已经阅读了有关connection naming 的信息，但是，我在访问数据库时遇到了问题。我已经发布了没有连接命名的数据库管理器类的内容。我正在寻找有关如何以干净通用的方式处理此问题的建议。谢谢！

.h 文件

#ifndef DATABASEMGR_H
#define DATABASEMGR_H

#include <QObject>
#include <QSqlDatabase>
#include <QVariant>
#include <QSqlQuery>
#include <QSqlQueryModel>
#include <QSqlRecord>

class DatabaseMgr : public QObject
{
public:
    DatabaseMgr(const QString &databaseType, const QString &connectionString, QObject *parent = 0);
    ~DatabaseMgr();
    QVariant ExecuteScalar(const QString &cmd);
    bool ExecuteNonQuery(const QString &cmd);
    bool IsOpen() const;
    bool Connect();
    bool Disconnect();
    QSqlQueryModel *GetQueryModel(const QString &cmd);
    QSqlQueryModel *GetQueryModel(const QString &cmd, const QMap<QString, QVariant> &params);

private:
    QSqlDatabase mDb;
};

#endif // DATABASEMGR_H

.cpp

#include "databasemgr.h"

DatabaseMgr::DatabaseMgr(const QString &databaseType, const QString &connectionString, QObject *parent) {
    mDb = QSqlDatabase::addDatabase(databaseType);
    mDb.setDatabaseName(connectionString);
}

DatabaseMgr::~DatabaseMgr() {
    if (mDb.open()) {
        mDb.close();
    }
}

QVariant DatabaseMgr::ExecuteScalar(const QString &cmd) {
    QVariant mVariant;
    if (mDb.isOpen()) {
        QSqlQuery query;
        if (query.exec(cmd)) {
            while (query.next()) {
                mVariant = query.value(0);
            }
        }
    }
    return mVariant;
}

bool DatabaseMgr::ExecuteNonQuery(const QString &cmd) {
    if (mDb.isOpen()) {
        QSqlQuery query;
        if (query.exec(cmd)) {
            return true;
        } else {
            //todo handle error
        }
    } else {
        //todo handle error
    }
    return false;
}

bool DatabaseMgr::IsOpen() const {
    return mDb.isOpen();
}

bool DatabaseMgr::Connect(){
    if (!mDb.open()) {
        //todo error opening database??
        return false;
    }
    return true;
}

bool DatabaseMgr::Disconnect() {
    return mDb.isOpen();
}

QSqlQueryModel *DatabaseMgr::GetQueryModel(const QString &cmd) {
    QSqlQueryModel *model = new QSqlQueryModel;

    if (mDb.isOpen()) {
        model->setQuery(cmd, mDb);
    }

    return model;
}

QSqlQueryModel *DatabaseMgr::GetQueryModel(const QString &cmd, const QMap<QString, QVariant> &params) {
    QSqlQueryModel *model = new QSqlQueryModel;

    if (mDb.isOpen()) {
        QSqlQuery query;
        query.prepare(cmd);

        if (params.count() > 0) {
            QMapIterator<QString, QVariant> i(params);
            while (i.hasNext()) {
                i.next();
                query.bindValue(i.key(), i.value());
            }
        }

        model->setQuery(query);
    }

    return model;
}

以下示例用法：

ma​​in.cpp（SQLite db 用于存储全局应用程序设置）

DatabaseMgr mSqliteDb("QSQLITE", app.applicationName() + ".db", &app);
mSqliteDb.Connect();
Program prgm(mSqliteDb, &app);

program.cpp

mMsSqlDb = new DatabaseMgr("QODBC3", GetMsSqlConnectionString());
if (mMsSqlDb->Connect()) {
    AddToActivityLog("Connected to MS SQL DB");
} else {
    AddToActivityLog("Error connecting to MS SQL DB");
}

从程序成员函数中获取结果：

QString cmd = "SELECT DISTINCT some_things FROM the_table ORDER BY these_columns";

QSqlQueryModel *model = mMsSqlDb->GetQueryModel(cmd);

if (model->rowCount() > 0) {
    for (int i = 0; i < model->rowCount(); ++i) {
        //Do stuff...
    }
}

Answer 1

您犯的第一个基本错误是您的数据库连接管理器是多余的。您希望实现的目标已经内置到 QtSql 框架中。

当您使用QSqlDatabase::addDatabase 创建QSqlDatabase 的新实例时，该对象将保留在Qt 内部，直到您调用QSqlDatabase::removeDatabase。您无需将变量与其连接。如果您需要访问中间的连接，您只需调用QSqlDatabase::database。

第二个基本错误是您将connectionName 与connectionString 混淆了。

connectionName 是您为连接指定的任意名称，以将其标识为数据库连接的内部集合中的一个单独的、唯一的对象。这可以被认为是一个变量名。

connectionString是用来连接数据库引擎本身的指令集，包含数据库名、用户名、密码等，你好像对此有所了解，我就不多解释了。

您可以在不指定数据库名称的情况下创建与数据库的连接，QtSql 框架将创建一个匿名连接，它将用作您在不指定连接名称的情况下进行的任何调用的默认连接。

如果您尝试创建没有名称的第二个连接，而默认连接已经存在，您将强制销毁第一个连接并用新连接替换。这就是您收到该消息时发生的情况。

你的错误：

QSqlDatabase sqliteConnection = QSqlDatabase::addDatabase("QSQLITE");
sqliteConnection.setConnectionString("blah blah");

QSqlDatabase sqlServerConnection = QSqlDatabase::addDatabase("QODBC3"); // no name specified means overwrite default connection, generates warning message
sqlServerConnection.setConnectionString("blah blah");

你应该做什么：

QSqlDatabase sqliteConnection = QSqlDatabase::addDatabase("QSQLITE", "myUniqueSQLITEConnection");
sqliteConnection.setConnectionString("blah blah");

QSqlDatabase sqlServerConnection = QSqlDatabase::addDatabase("QODBC3", "myUniqueMSSQLConnection"); 
sqlServerConnection.setConnectionString("blah blah");

正如我所提到的，这些连接将持续存在于 QtSql 内部，直到您调用 QSqlDatabase::removeDatabase。

这样做：

QSqlDatabase myAlreadyExistingMSSqlConnection = QSqlDatabase::database("myUniqueMSSQLConnection");