К вопросу о применении QSqlDatabase в QThread.

#!/usr/bin/python3
# -*- coding: utf-8 -*-
"""PostgreSQL in Thread v0.05
From iamvic on www.cyberforum.ru
Restrictions: Python 3.x, PyQt and no more.
"""
 
import copy
 
from PyQt5.QtCore import pyqtSignal
from PyQt5.QtCore import QMutex, QMutexLocker
from PyQt5.QtCore import QObject, QThread
from PyQt5.QtWidgets import QApplication
from PyQt5.QtSql import QSqlDatabase, QSqlQuery
 
class Thread_postgresql(QThread):
    connect_parm = [
        'localhost',    # хост
        '5432',         # порт
        'postgres',     # база данных
        'postgres',     # пользователь
        'postgres'      # пароль
        ]
    thread_mutex = QMutex()
    connection_created = pyqtSignal()
 
    def set_connection_parm(self, parm):
        '''для наружного употребления
        '''
        def check_list(x):
            rc = True
            for a in x:
                if type(a) != str:
                    rc = False
                    break
            return rc
 
        rc = False
        with QMutexLocker(self.thread_mutex):
            rc = (type(parm) == list and
                  len(parm) == 5 and
                  check_list(parm) and
                  parm[1].isdigit())
            if rc:
                self.connect_parm = copy.deepcopy(parm)
        return rc
 
    def get_connection_parm(self):
        '''для внутреннего употребления
        '''
        with QMutexLocker(self.thread_mutex):
            rc = copy.deepcopy(self.connect_parm)
        return rc
 
    def run(self):
        '''именно этот код выполняется в дополнительном потоке
        '''
        def inner_run(connect_name, current_parm):
            '''поскольку удалить соединение можно только вне области
            видимости соединения, то его создание и вся работа с БД
            выполняется только в теле этой функции, а удаление соединения
            производится снаружи после выхода из неё
            '''
            db = QSqlDatabase.addDatabase('QPSQL', connect_name)
            db.setHostName(current_parm[0])
            db.setPort(int(current_parm[1]))
            db.setDatabaseName(current_parm[2])
            db.setUserName(current_parm[3])
            db.setPassword(current_parm[4])
 
            if not db.open():
                # сигнал об ошибке с информацией из db.lastError().text()
                pass
            else:
                self.connection_created.emit()
                query = QSqlQuery(db)
                if query.exec(
                    "SET APPLICATION_NAME = '({!s})';".format(connect_name)):
                    # хоть какая-то идентификация для админа БД
 
                    pass
                else:
                    # сигнал об ошибке с информацией из query.lastError().text()
                    pass
 
                QThread.sleep(10)
                # тут вся остальная работа с БД, сопровождающаяся
                # периодической отправкой сигналов (если надо),
                # например, сейчас просто спим 10 сек.
                # self.sleep() не используем, потому как self живёт
                # в основном потоке (мало ли что приключится).
                # в качестве местной экзотики :) можно использовать
                # proxy.thread().sleep(), поскольку вспомогательный
                # объект живёт как раз в дополнительном потоке.
 
            db.close()
            # закрыли БД
            return
            # и вышли из функции
 
        current_parm = self.get_connection_parm()
        # запросили параметры соединения, переданные снаружи
 
        proxy = QObject()
        # вспомогательный объект живёт в дополнительном потоке,
        # а self - в основном потоке.
        # поскольку вспомогательный объект один одинёшенек на весь доп.поток,
        # то и родителя ему назначить невохможно, потому как родитель
        # тоже должен жить в дополнительном потоке,
 
        connect_name = 'thread_connection_' + hex(id(proxy.thread()))
        # по идентификатору доп.потока создали уникальное имя соединения.
 
        inner_run(connect_name, current_parm)
        # отработали с БД
 
        QSqlDatabase.removeDatabase(connect_name)
        # удалили соединение

    def to_start_thread(self):
        '''стартуем дополнительный поток
        '''
        abettor = Thread_postgresql(self)
        if abettor.set_connection_parm(self.current_connection_parm):
            abettor.connection_created.connect(self.to_refresh_protocol)
            # abettor.started.connect(self.to_refresh_protocol)
            # интересная особенность - под Linux хватало сигнала started,
            # а под Windows пришлось свой сигнал городить,
            # иначе соединения не успевали попадать в протокол
 
            abettor.finished.connect(abettor.deleteLater)
            abettor.finished.connect(self.to_refresh_protocol)
            abettor.start()
        else:
            del abettor
            QMessageBox.warning(
                self, 'П Р Е Д У П Р Е Ж Д Е Н И Е !!!',
                'Нарушение структуры параметров, передаваемых'
                ' в дополнительный поток.\n'
                'Дополнительный поток не создан.')