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

Question

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

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

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

QSqlDatabasePrivate::removeDatabase:连接“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 数据库用于存储全局应用程序设置)

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

程序.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");