Threads and the SQL Module

[CuteBunny]

Не понятки с QSqlDatabase...

A connection can only be used from within the thread that created it. Moving connections between threads or creating queries from a different thread is not supported.

У меня простенькая задача: необходимо "проверять" таблицу на новые строки - я создал отдельный поток через QObject & moveToThread(), в котором по timerEvent'у делаю запрос и проверяю текущее кол-во строк, с тем что выдает запрос.

Так вот, решил я не создавать никаких соединений в рабочем потоке... Я ожидал сообщения в output'е "database not open" или еще что-нибудь плохое, но все работает, либо я просто не понимаю, что значит "A connection can only be used from within the thread that created it. Moving connections between threads or creating queries from a different thread is not supported.", либо где-то я не правильно что-то делаю???

В гуи первый запрос был вида: select count([id]) from [orders], его же я и использовал в рабочем потоке...

В том, что поток у меня отдельно работает от гуи-потока я проверял, ставил цикл forever в timerEvent хендлере, гуи работает как часы, не зависая...

Думал, что дефолтное подключение, особое, решил в гуи потоке дать имя подключению, в рабочем потоке его же и использую - результат работает...

Думал, что драйвер QODBC хитрый - попробовал на QSQLITE - работает...

Пробовал и через QThreadPool и QRunnable...

Запросы - только селекты были...

[Bepec]

Не понял вопроса. Слишком расплывчато и непонятно, что вы пытаетесь сделать.

Если всё работает и ошибок в консоле нет - всё прекрасно.

[CuteBunny]

Я попытался сделать то, что теоретически not supported:

Создал в гуи(основном) потоке дефолтное соединение с бд, создал отдельно поток и в нем через QSqlQuery выполнил запрос, при чем не указал, какое соединение я использовал, т.е. использовалось дефолтное и все работает.

Меня это просто настораживает...

[Bepec]

Какой ide пользуешься? Если QtCreator - то я не смогу тебе подсказать, как точно определить, где выполняется запрос

Ничего без кода сказать нельзя, но... % 90 что у тебя запрос происходит в том потоке, в котором создано соединение Другой вопрос, почему ты думаешь, что оно используется в другом потоке

[CuteBunny]

IDE - vs2010...

Код:

#ifndef STORE_H
#define STORE_H

#include <QtGui/QDialog>
#include "ui_store.h"

class QThread;
class threadobj;

class store : public QDialog
{
	Q_OBJECT

public:
	store(QWidget *parent = 0, Qt::WFlags flags = 0);
	~store();

private:
	Ui::storeClass ui;
	QThread *m_thread;
	threadobj *m_obj;
};

#include "store.h"

#include "threadobj.h"

#include <QSqlDatabase>
#include <QThread>

store::store(QWidget *parent, Qt::WFlags flags)
	: QDialog(parent, flags)
{
	ui.setupUi(this);
	QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE");
	db.setDatabaseName("test.sqlite");
	db.open();
	m_thread = new QThread;
	m_obj = new threadobj;
	m_obj->moveToThread(m_thread);
	connect(m_thread, SIGNAL(started()), m_obj, SLOT(checkTable()));
	connect(m_obj, SIGNAL(finished()), m_thread, SLOT(quit()));
	m_thread->start();
}

store::~store()
{
	if (m_thread->isRunning()) {
		m_thread->quit();
		m_thread->wait();
	}
	QSqlDatabase db = QSqlDatabase::database();
	db.close();
}


#endif // STORE_H

Код:

#ifndef THREADOBJ_H
#define THREADOBJ_H

#include <QObject>

class threadobj : public QObject
{
	Q_OBJECT

public:
	threadobj(QObject *parent = 0);
	~threadobj();
public slots:
	void checkTable();
signals:
	void finished();
};

#endif // THREADOBJ_H


#include "threadobj.h"

#include <QSqlQuery>
#include <QSqlError>
#include <QVariant>

#include <QDebug>

threadobj::threadobj(QObject *parent)
	: QObject(parent)
{

}

threadobj::~threadobj()
{

}

void threadobj::checkTable()
{
	QSqlQuery q;
	if (!q.exec("select count(id) from orders")) {
		qDebug() << q.lastError().text();
	} else {
		q.first();
		int c = q.value(0).toInt();
		qDebug() << c;
	}
	emit finished();
}

[mutineer]

А кто будет удалять m_thread и m_obj?

[DmitryM]

У тебя select из-за count отрабатывается быстро.

[CuteBunny]

А кто будет удалять m_thread и m_obj?

Да, удалять нужно - не спорю... Но суть все равно в том, что для QSqlQuery, получается, необязательно создавать отдельное соединение в потоке, на сколько я понял.

Еще я попробовал сделать много инсертов в том же потоке, соединение у меня было заблокировано и модель в основном потоке стала тупить.

[DmitryM]

Да, удалять нужно - не спорю... Но суть все равно в том, что для QSqlQuery, получается, необязательно создавать отдельное соединение в потоке, на сколько я понял.

Еще я попробовал сделать много инсертов в том же потоке, соединение у меня было заблокировано и модель в основном потоке стала тупить.

Это не модель тупит, это поток в котором было создано подключение заблокирован, на время работы с подключением в другом потоке.

[vregess]

Да, удалять нужно - не спорю... Но суть все равно в том, что для QSqlQuery, получается, необязательно создавать отдельное соединение в потоке, на сколько я понял.

Потоки такая штука.. однажды может вылезти проблема.
Для уверенности попробуй вставить

Код

C++ (Qt)
qDebug() << QThread::currentThreadId();

в threadobj::checkTable() и store::store().

Сразу станет ясно, что откуда вызывается.

[vregess]

Кстати, возможно проблемы не вылазят, тк ты используешь подключение только в потоке.
Попробуй в главном и дочернем потоке поюзать одно подключение.

И еще про sqlite. Там есть 3 варианта работы с потоками: Single-thread, Multi-thread и Serialized.
У тебя по умолчанию может стоять Serialized, у которого меньше всего ограничений для работы в многопоточной среде.
Тут подробности: http://www.sqlite.org/threadsafe.html

[xokc]

Кстати, возможно проблемы не вылазят, тк ты используешь подключение только в потоке.
Попробуй в главном и дочернем потоке поюзать одно подключение.

Скорее всего дело именно в этом.

[kostya2vntu]

Подобная дискуссия была когда-то на StackOverflow: http://stackoverflow.com/questions/7566949/qsql-module-and-multithreaded-application
Цитирую:

Your QSqlQuery object knows nothing about the QSqlDatabase you also created because you're not using the "db connected" constructor QSqlQuery::QSqlQuery(QString&, QSqlDatabase) (i.e. you don't pass the pre-created db to the query). The way you instantiate the query means that a new, separate DB connection will be created/torn down each time req() is called. Which is thread-safe, but potentially expensive. – FrankH. Sep 27 '11 at 11:45

Если коротко: у тебя в потоке создается новое подключение.

[vregess]

Хм, не знал.
В документации про такое поведение не сказано.

QSqlQuery::QSqlQuery ( const QString & query = QString(), QSqlDatabase db = QSqlDatabase() )

Constructs a QSqlQuery object using the SQL query and the database db. If db is not specified, or is invalid, the application's default database is used. If query is not an empty string, it will be executed.

Наверное там внутри используется QSqlDatabase::cloneDatabase(), если affinity не совпадают.. хз.

[kostya2vntu]

Завтра посмотрю что там внутри, самому интересно стало. А пока, насколько я понял, под подключением имеется ввиду конкретный обьект QSqlDatabase.