psycopg2와 Qthreads를 함께 사용 (또는 postgresql과 qthreads 만 사용) GUI 업데이트

Question

DB의 주문 서적에는 항상 올바른 주문 도서가 표시되므로 계속 GUI에서 계속 업데이트하고 싶습니다. 이 작업을 얻으려고 노력했지만 cur 문을 실행하려고하면 응용 프로그램이 충돌합니다. 나는 내가 tableelement를 지울 필요가 없도록 약간의 도움이 필요하다고 생각하지만, 변경된 항목 만 업데이트한다 (나는 똑똑한 것이지만 확실하지 않다). 나는 것입니다 Qt의 PostgreSQL의 lib 디렉토리를 사용해야하지만, 당신은 물건을 관련된 모든 포스트 그레스를 이동, 그 실행 :

from PyQt5 import QtCore, QtGui, QtWidgets 
from PyQt5.QtCore import pyqtSignal, QThread 
import psycopg2 
import sys 
import time 
conn = psycopg2.connect("dbname=myDb user=kris") 
cur = conn.cursor() 

class Ui_MainWindow(QThread): 
    def setupUi(self, MainWindow): 
     MainWindow.setObjectName("MainWindow") 
     MainWindow.resize(800, 600) 
     self.centralwidget = QtWidgets.QWidget(MainWindow) 
     self.centralwidget.setObjectName("centralwidget") 
     self.tableWidget = QtWidgets.QTableWidget(self.centralwidget) 
     self.tableWidget.setGeometry(QtCore.QRect(50, 50, 711, 481)) 
     self.tableWidget.setRowCount(3) 
     self.tableWidget.setColumnCount(4) 
     self.tableWidget.setHorizontalHeaderLabels(['Sum', 'Total', 'Size', 'Bid']) 
     self.tableWidget.setObjectName("tableWidget") 
     self.btnBuy = QtWidgets.QPushButton(self.centralwidget) 
     self.btnBuy.setGeometry(QtCore.QRect(50, 10, 91, 33)) 
     self.btnBuy.setObjectName("btnBuy") 
     MainWindow.setCentralWidget(self.centralwidget) 
     self.menubar = QtWidgets.QMenuBar(MainWindow) 
     self.menubar.setGeometry(QtCore.QRect(0, 0, 800, 29)) 
     self.menubar.setObjectName("menubar") 
     MainWindow.setMenuBar(self.menubar) 
     self.statusbar = QtWidgets.QStatusBar(MainWindow) 
     self.statusbar.setObjectName("statusbar") 
     MainWindow.setStatusBar(self.statusbar) 

     self.retranslateUi(MainWindow) 
     QtCore.QMetaObject.connectSlotsByName(MainWindow) 

    def retranslateUi(self, MainWindow): 
     _translate = QtCore.QCoreApplication.translate 
     MainWindow.setWindowTitle(_translate("MainWindow", "MainWindow")) 
     self.btnBuy.setText(_translate("MainWindow", "BUY")) 


class MainUIClass(QtWidgets.QMainWindow, Ui_MainWindow): 
    def __init__(self, parent=None): 
     super().__init__() 
     self.setupUi(self) 
     self.threadclass = ThreadClass() 
     self.threadclass.start() 
     self.threadclass.updateTable.connect(self.updateTable) 

    def updateTable(self, val): 
     print(val) 
     if 'setRowCount' in val: 
      self.tableWidget.setRowCount(val['setRowCount']) 
     elif 'insertRow' in val: 
      self.tableWidget.insertRow(val['insertRow']) 
     elif 'setItem' in val: 
      rowNum = val['setItem'][0] 
      colNum = val['setItem'][1] 
      data = val['setItem'][2] 
      self.tableWidget.setItem(rowNum, colNum+2,  QtWidgets.QTableWidgetItem(str(data))) 

class ThreadClass(QtCore.QThread): 
    updateTable = pyqtSignal(dict) 

    def __init__(self, parent=None): 
     super().__init__() 

    def run(self): 
     cur.execute("select quantity, rate from orderbook where type = %s and market = %s order by rate asc limit 10;", (0, "BTC-ADA")) 
     orderbook = cur.fetchall() 
     conn.commit() 
     for rowNum, rowData in enumerate(orderbook): 
      self.updateTable.emit({"insertRow": 0}) 
      for colNum, data in enumerate(rowData): 
       self.updateTable.emit({"setItem": [rowNum, colNum, data]}) 

if __name__ == "__main__": 
    a = QtWidgets.QApplication(sys.argv) 
    app = MainUIClass() 
    app.show() 
    #a.exec_() 

    cur.close() 
    conn.close() 
    sys.exit(a.exec_()) 

Answer 1

당신은 시작 Qt의 메인 루프 전에 데이터베이스 연결을 닫는 활용하는 방법을 도와해야하는 경우 스레드로.

class ThreadClass(QtCore.QThread): 
    updateTable = pyqtSignal(dict) 

    def __init__(self, parent=None): 
     super().__init__() 

    def run(self): 
     conn = psycopg2.connect("dbname=motocompano_dev user=pg_admin password=pGsql_#--w3N_a0X!s7J-o1U+ host=localhost port=5555") 

     cur = conn.cursor()   
     cur.execute("select * from events") 
     orderbook = cur.fetchall() 

     for rowNum, rowData in enumerate(orderbook): 
      self.updateTable.emit({"insertRow": 0}) 
      for colNum, data in enumerate(rowData): 
       self.updateTable.emit({"setItem": [rowNum, colNum, data]}) 

     cur.close() 
     conn.close()