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

Question

我正在将.net / c＃应用程序转换为Qt。我不会每天使用Qt / C ++，所以请多多包涵。

该应用程序同时使用SQLite和MS SQL Server。建立连接后，由于两个数据存储的数据事务量都很高，因此它保持打开状态，并且我不想浪费时间打开和关闭事务之间的连接。

我的目标是创建可用于两种数据库类型的通用管理器类。当其中一个连接打开而没有另一个连接时，该类将按预期工作。但是，当我尝试同时建立到两者的连接时，会收到错误消息：

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

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

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

.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;
}

用法示例如下：

main.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带有QSqlDatabase::addDatabase该对象的新实例时，该对象会保留在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");