我正在将.net/c＃应用程序转换为Qt。我每天都不用Qt/C++工作，所以请耐心等待。Qt - 同时处理多个数据库连接

该应用程序同时使用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

#include

#include

#include

#include

#include

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 &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 &params) {

QSqlQueryModel *model = new QSqlQueryModel;

if (mDb.isOpen()) {

QSqlQuery query;

query.prepare(cmd);

if (params.count() > 0) {

QMapIterator 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);

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

}

}

2017-02-03

DonJoe

+0

请出示您使用这个类来创建这两个数据库的两个对象。我已经用MySQL和SQLite完成了这个任务，没有任何问题。 –

+0

查看上面发布的例子，我在程序中创建了两个manager类的实例，一个用于sqlite，另一个用于ms sql。 sqlite实例通过引用传递，并可用于应用程序的所有类。 ms sql实例是程序类中的私有成员指针。在实例化和连接之后，我随后调用当时需要的db管理器类的任何公共函数，例如：用于更新记录，检索记录等。 –

+1

你的代码和我的代码之间的区别在于我用连接名称发送; myDB = QSqlDatabase :: addDatabase(databaseType，connectionName);我认为这可能会解决您的问题。 (每个数据库的连接名称不同) –