PyQt实现异步数据库请求，实战记录！

PyQt实现异步数据库请求的实战记录

更新时间：2023年12月08日 08:16:26 作者：之一Yo

开发软件的时候不可避免要和数据库发生交互,但是有些 SQL 请求非常耗时,如果在主线程中发送请求,可能会造成界面卡顿,本文将介绍一种让数据库请求变得和前端的 ajax 请求一样简单,希望对大家有所帮助

Python客栈送红包、纸质书

需求

开发软件的时候不可避免要和数据库发生交互，但是有些 SQL 请求非常耗时，如果在主线程中发送请求，可能会造成界面卡顿。这篇博客将会介绍一种让数据库请求变得和前端的 ajax 请求一样简单，且不会阻塞界面的异步请求方法。

实现过程

在实现异步请求之前，需要先明确一下函数签名：

def sqlRequest(
    service: str, 
    method: str, 
    slot, 
    params: dict = None
)

免费讲解

各个参数的解释如下：

service: 业务名
method: 接口名
slot: 拿到数据后调用的回调函数
params: 请求参数

总体流程如下图所示，包括子界面发送请求、数据库线程处理请求、主界面调用回调函数来消费响应结果三个步骤。

信号总线

在 Qt 中，子线程无法直接更新主界面，只能发送信号通知主线程，然后在主线程中更新界面。在之前的博客《如何在 pyqt 中实现全局事件总线》介绍了信号总线的使用，通过引入信号总线，可实现任意层级的组件之间的通信。

本文的信号总线只含有两个信号，一个用来请求数据，一个用来消费数据：

class SignalBus(QObject):
    """ Signal bus """
    fetchDataSig = Signal(SqlRequest)    # 请求数据信号
    dataFetched = Signal(SqlResponse)    # 响应数据信号
 
     
signalBus = SignalBus()
     
     
class SqlRequest:
    """ Sql request """
 
    def __init__(self, service: str, method: str, slot=None, params: dict = None):
        self.service = service
        self.method = method
        self.slot = slot
        self.params = params or {}
 
 
class SqlResponse:
    """ Sql response """
 
    def __init__(self, data, slot):
        self.slot = slot
        self.data = data

免费讲解

发送请求

子界面中通过调用 sqlRequest() 函数来发起异步 SQL 请求，该函数只是将参数封装为 SqlRequest 对象，然后通过 signalBus 的 fetchDataSig 信号发送给数据库子线程：

def sqlRequest(service: str, method: str, slot=None, params: dict = None):
    """ query sql from database """
    request = SqlRequest(service, method, slot, params)
    signalBus.fetchDataSig.emit(request)

免费讲解

比如下图中商品类型下拉框的数据就来自于数据库：

在组件 LicenseCard 中使用下述代码就能完成数据的请求和消费（组件库参见 https://qfluentwidgets.com/zh/ ）：

from qfluentwidgets import HeaderCardWidget, ComboBox
 
class LicenseCard(HeaderCardWidget):
     
    def __init__(self, parent=None):
        super().__init__("许可证", parent)
        self.goodsComboBox = ComboBox(self)
         
        # 请求商品信息
        sqlRequest("goodsService", "listAll", self.onGoodsFetched)
 
    def onGoodsFetched(self, goods: List[Goods]):
        """ 将商品信息添加到下拉框中 """
        for good in goods:
            self.goodsComboBox.addItem(good.name, userData=good)

免费讲解

处理请求

子线程 DatabaseThread 中维护着一个请求队列 tasks，每当收到信号总线的 fetchDataSig 信号时，就会使用反射机制将请求中携带的 service 和 method 字符串转换为数据库业务类的方法指针，并将这个指针添加到队列中等待调用。调用方法返回的数据会被封装为 SqlResponse 对象，接着通过信号总线发送给主界面。

class DatabaseThread(QThread):
    """ Database thread """
 
    def __init__(self, db: QSqlDatabase = None, parent=None):
        super().__init__(parent=parent)
        self.database = Database(db, self)
        self.tasks = deque()
 
        # 处理请求信号
        signalBus.fetchDataSig.connect(self.onFetchData)
 
    def run(self):
        """ 处理请求 """
        while self.tasks:
            task, request = self.tasks.popleft()
            result = task(**request.params)
            signalBus.dataFetched.emit(SqlResponse(result, request.slot))
 
    def onFetchData(self, request: SqlRequest):
        """ 将请求添加到队列中 """
        service = getattr(self.database, request.service)
        task = getattr(service, request.method)
        self.tasks.append((task, request))
 
        if not self.isRunning():
            self.start()
                 
 
class Database(QObject):
    """ Database """
 
    def __init__(self, db: QSqlDatabase = None, parent=None):
        super().__init__(parent=parent)
        self.orderService = OrderService(db)
        self.userService = UserService(db)
        self.goodsService = GoodsService(db)

免费讲解

处理响应结果

主界面中只需将信号总线的 dataFetched 信号连接槽函数，然后在槽函数中对取出 response 对象中的数据，并调用回调函数来消费数据即可：

from qfluentwidgets import MSFluentWindow
 
class MainWindow(MSFluentWindow):
    """ 主界面 """
     
    def __init__(self):
        super().__init__()
         
        # 处理响应结果
        signalBus.dataFetched.connect(self.onDataFetched)
 
    def onDataFetched(self, response: SqlResponse):
        if response.slot:
            response.slot(response.data)

免费讲解

到此这篇关于PyQt实现异步数据库请求的实战记录的文章就介绍到这了,更多相关PyQt异步数据库请求内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

微信公众号搜索 “ 脚本之家 ” ，选择关注

程序猿的那些事、送书等活动等着你

原文链接：https://www.cnblogs.com/zhiyiYo/p/17883607.html

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若内容造成侵权/违法违规/事实不符，请将相关资料发送至 reterry123@163.com 进行投诉反馈，一经查实，立即处理！

python中jsonpath的使用小结
JsonPath是一种信息抽取类库,是从JSON文档中抽取指定信息的工具,提供多种语言实现版本,本文主要介绍了python中jsonpath的使用小结,具有一定的参考价值,感兴趣的可以了解一下
2024-03-03
Python数据标准化的实例分析
在本篇文章里小编给大家整理了关于Python数据标准化的实例内容，有需要的朋友们可以测试学习下。
2021-08-08
浅谈python处理json和redis hash的坑
这篇文章主要介绍了浅谈python处理json和redis hash的坑，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-07-07
Python处理时间日期坐标轴过程详解
这篇文章主要介绍了Python处理时间日期坐标轴过程详解，当日期数据作为图表的坐标轴时通常需要特殊处理，应为日期字符串比较长，容易产生重叠现象,需要的朋友可以参考下
2019-06-06
Flask中基于Token的身份认证的实现
本文主要介绍了Flask中基于Token的身份认证的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2023-02-02
基于python实现把图片转换成素描
这篇文章主要介绍了基于python实现把图片转换成素描,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2019-11-11
python2爬取百度贴吧指定关键字和图片代码实例
这篇文章主要介绍了python2爬取百度贴吧指定关键字和图片代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2019-08-08
python tkinter实现弹窗的输入输出
这篇文章主要为大家详细介绍了python tkinter实现弹窗的输入输出，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-02-02
python实现搜索文本文件内容脚本
这篇文章主要为大家详细介绍了python实现搜索文本文件内容的脚本，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2018-06-06
Python自动扫描出微信不是好友名单的方法
很多人想要清楚已经被删除的好友名单。面对庞大的好友数量想要清除谈何容易，本文主要介绍了Python自动扫描出微信不是好友名单的方法，感兴趣的可以了解一下
2021-05-05

PyQt实现异步数据库请求，实战记录！

PyQt实现异步数据库请求的实战记录

目录

需求

实现过程

信号总线

发送请求

处理请求

处理响应结果

相关文章

最新评论