Готовые модули для просмотра и редактирования БД

[deMax]

А когда поток не работает останавливать его? Или в цикле со sleep гонять?
Может есть правильный пример?

[deMax]

Для каждого подключения к БД создать поток, когда приходят запросы выполнять их, когда запросов нет гонять пустой цикл со slepp, перед закрытием подключения отключаться от БД?
QThreadPool? QTHread? QtConcurent... что выбрать?

[Bepec]

Я решил проблему классом который держит объект соединения и дублирует функции слотами. Ну и собственно его и запуливаю в поток, сигналами и слотами шмалять.
Правда он крайне урезанный, поддерживает буквально exec, commit, ошибки.

[deMax]

Я решил проблему классом который держит объект соединения и дублирует функции слотами. Ну и собственно его и запуливаю в поток, сигналами и слотами шмалять.
Правда он крайне урезанный, поддерживает буквально exec, commit, ошибки.

А можно пример? И что делать когда задач нет sleep в цикле гонять?

[Bepec]

У меня он событийный поток. Т.е. там в run exec, а все задачи сигналами посылаются.

[deMax]

QSqlDatabase не является наследником QObject, поэтому у него нет метода moveToThread.
А так да, для каждой нитки нужно создавать отдельное подключение.

А что выбрать: moveTothread, QtConcurrent, Qthread, QThreadPool?

мне нужно class LibDB {public slots: setConfig(Config); int query(Qstring); signals void data(int id, QVariantList);}

[Bepec]

Я плохой советчик по потокам, т.к. я просто создаю класс наследуемый от QThread и делаю moveToThread в конструктор С другой стороны этот подход работает, не имеет никаких отрицательных сторон, кроме слабой переносимости

[deMax]

Создать несколько потоков(например 4), в конструкторе каждого потока:
db = QSqlDatabase::addDatabase()
db.open()
В деструкторе:
db.close()
?

[Bepec]

Не, у меня приложение не ресурсоёмкое, потому запросы выполняются последовательно. Т.е. 1 поток, одно соединение.
Хотя при частых запросах, создать несколько соединений... Хз, на мой неискушенный взгляд такое не особо сильно прибавит быстродействия.

[deMax]

А как из потока структуру вернуть?
прописал:
typedef QList<QVariantList> ResultFromDB;
Q_DECLARE_METATYPE(ResultFromDB)

консоль:
QObject::connect: Cannot queue arguments of type 'ResultFromDB'
(Make sure 'ResultFromDB' is registered using qRegisterMetaType().)

[MrDron]

А как из потока структуру вернуть?
прописал:
typedef QList<QVariantList> ResultFromDB;
Q_DECLARE_METATYPE(ResultFromDB)

консоль:
QObject::connect: Cannot queue arguments of type 'ResultFromDB'
(Make sure 'ResultFromDB' is registered using qRegisterMetaType().)

qRegisterMetaType<ResultFromDB>("ResultFromDB");

http://doc.qt.io/qt-5/qmetatype.html#qRegisterMetaType

[deMax]

Спасибо, заработало.
Как лучше результат из базы возвращать? ссылка/unique_ptr/по значению...?
qRegisterMetaType<My>("My") - это функция, вне кода(под структурой её не написать) где её лучше вызвать?

[lit-uriy]

>>qRegisterMetaType<My>("My") - это функция, вне кода(под структурой её не написать) где её лучше вызвать?
можно в конструкторе где у тебя соединение создаётся

[deMax]

У меня N потоков с QThread, как посылать сигнал DB::queryWork только одному? Вызвать слот напрямую в другом потоке вряд ли получиться, добавить идентификатор потока чтобы поток если это не ему не выполнял запрос?

Код:

    for(QThread *&threadDB: threadsDB) {
        threadDB = new QThread;
        Worker *worker = new Worker;
        worker->moveToThread(threadDB);

        connect(threadDB, &QThread::finished, worker, &QObject::deleteLater);
        connect(this, &DB::queryWork, worker, &Worker::queryWork);
        connect(this, &DB::workerConnectDB, worker, &Worker::connectDB);
        connect(this, &DB::workerDisconnectDB, worker, &Worker::disconnectDB);
        connect(worker, &Worker::queryResult, this, &DB::queryResult);
        threadDB->start(); }

[MrDron]

Вызвать слот напрямую в другом потоке вряд ли получиться

Слот, чтобы он выполнился в нужном потоке, можно написать:

Код

C++ (Qt)
QMetaObject::invokeMethod(worker, "queryWork");