如何通过PyQt5 QSqlDatabase发送PostgreSQL通知？

核心结论 #

PyQt5的QSqlDatabase及PostgreSQL驱动（QPSQL）没有提供直接发送NOTIFY通知的专用API函数，你目前通过执行NOTIFY SQL语句的方案，是当前标准且推荐的实现方式。

原因说明 #

Qt的SQL模块是面向多数据库的通用抽象层，仅针对数据库的共性功能做封装。对于PostgreSQL独有的LISTEN/NOTIFY机制，Qt只实现了监听相关的接口（subscribeToNotification()和notification()事件）——这是因为监听需要驱动层和Qt事件循环做集成才能实时接收通知。而发送通知本质就是执行一条标准SQL命令，不需要额外的驱动层封装，直接执行原生SQL是最直接且兼容的做法。

优化你的现有实现 #

为了避免payload中的特殊字符（比如单引号）导致SQL语法错误，建议使用参数绑定的方式重构代码，同时增加错误处理：

def send_postgres_notification(db, channel, payload):
    query = QSqlQuery(db)
    # 使用参数绑定处理特殊字符，避免语法错误与注入风险
    query.prepare("NOTIFY :channel, :payload;")
    query.bindValue(":channel", channel)
    query.bindValue(":payload", payload)
    
    if not query.exec_():
        print(f"发送通知失败: {query.lastError().text()}")

# 调用示例
# db = QSqlDatabase.addDatabase('QPSQL')  # 已完成连接初始化
# send_postgres_notification(db, "some_channel", "包含'单引号'的payload")

这种实现和你之前的临时方案效果一致，PostgreSQL服务器会正确处理通知，你的监听器也能正常捕获到带负载的消息。

内容的提问来源于stack exchange，提问作者RuslanS