【问题标题】:QSqlDatabase: unable to use connection from QThreadQSqlDatabase:无法使用来自 QThread 的连接
【发布时间】:2016-06-02 15:11:13
【问题描述】:

我有两个 QSqlDatabase 数据库连接,“本地”和“远程”。我有一个使用两个连接的函数(从本地数据库获取数据并发送到远程数据库)。当我从 QThread 类运行此函数时,本地连接有效(我得到了预期的数据),但远程连接失败。但是如果我在 QThread 类之外(在 main() 中)运行这个函数,两个连接都可以工作。

当我尝试打开连接时,远程连接失败并显示错误消息:“QSqlDatabasePrivate::database: 无法打开数据库:QMYSQL: 无法连接”。在此之前,我测试了连接是否有效(isValid())并且它是好的。我还检查了连接是否已经打开,但不是。

我也找到了这些信息,但由于“本地”连接从线程工作,这可能不是问题:

线程和 SQL 模块 只能在创建它的线程内使用连接。不支持在线程之间移动连接或从不同线程创建查询。 http://doc.qt.io/qt-5/threads-modules.html#threads-and-the-sql-module

在 Qt 5.5.1, 32bit, Ubuntu 14.04 中发现错误。还在 Raspberry Pi、Qt 5.6 上进行了测试,但结果是“分段错误”。

怎么了?

ma​​in.c

main()
{
  DataHandler dh();
  DataHandlerThread dht(&dh); //pointer to dh to get access to dh functions from the thread

  //here I run dh.foo() or dht.run(), never both functions
  dh.foo();
  dht.run();
  ...
}

datahandler.cpp

DataHandler::DataHandler()
{
  m_dbLocal = QSqlDatabase::addDatabase("QMYSQL", "local");
  m_dbLocal.setHostName("localhost");
  ...

  m_dbRemote = QSqlDatabase::addDatabase("QMYSQL", "remote");
  m_dbRemote.setHostName(...);
  ...
}

DataHandler::foo()
{
  qDebug() << QSqlDatabase::connectionNames(); //always ("remote", "local")
  m_dbLocal.isValid(); //always true
  m_dbLocal.open(); //always true

  m_dbRemote.isValid(); //always true

  //true if foo() is called from main using dm.foo()
  //QSqlDatabasePrivate::database: unable to open database: " QMYSQL: Unable to connect" if called from main using dmt.run()
  m_dbRemote.open(); 
}

datahandlerthread.h

class DataHandlerThread : public QThread
{
    Q_OBJECT
public:
    explicit DataHandlerThread(DataHandler* dh);

private:
    void run() Q_DECL_OVERRIDE;

    DataHandler* m_dh;

};

datahandlerthread.cpp

DataHandlerThread::DataHandlerThread(DataHandler* dh)
{
    m_dh = dh;
}

void DataHandlerThread::run()
{
    m_dh->foo();
}

【问题讨论】:

  • 或许贴出代码有助于发现问题?
  • 帖子更新代码

标签: qt qthread qsqldatabase


【解决方案1】:

我找到了解决问题的方法。解决方案是在 DataHandlerThread 构造函数中创建本地和远程连接的新实例:

datahandlerthread.cpp

DataHandlerThread::DataHandlerThread(DataHandler* dh)
{
  m_dh = dh;
  m_dbLocal = QSqlDatabase::addDatabase("QMYSQL", "local_thread");
  m_dbLocal.setHostName("localhost");
  ...

  m_dbRemote = QSqlDatabase::addDatabase("QMYSQL", "remote_thread");
  m_dbRemote.setHostName(...);
  ...
}

据我了解,这些新实例也可以通过使用 QSqlDatabase::cloneDatabase() 创建并将这些新实例传递给 DataHandlerThread 构造函数(未测试)。

因此,“线程和 SQL 模块”链接中的信息似乎有些正确。由于某种原因,“本地”连接仍然可以从线程工作。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多