0

我有两个 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 上进行了测试，但结果是“分段错误”。

怎么了？

主程序

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

数据处理程序.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(); 
}

数据处理器线程.h

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

private:
    void run() Q_DECL_OVERRIDE;

    DataHandler* m_dh;

};

数据处理器线程.cpp

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

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

1 回答 1

1

我找到了解决问题的方法。解决方案是在 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 模块”链接中的信息似乎有些正确。由于某种原因，“本地”连接仍然可以从线程工作。

于 2016-06-03T11:20:11.933 回答