如何在Common Lisp中借助Postmodern实现Postgres表变更通知？

问题1：理解并使用database-connection #

database-connection是cl-postgres（Postmodern的底层依赖）的核心连接对象，代表与PostgreSQL的活跃连接。你可以通过Postmodern的连接API轻松获取它：

1. 通过顶层连接获取
   使用connect-toplevel建立全局连接后，*database-connection*变量会自动绑定到当前连接对象：

   (postmodern:connect-toplevel "数据库名" "用户名" "密码" "主机地址")
   ;; 直接使用全局变量
   (defvar *active-conn* postmodern:*database-connection*)
   

2. 在连接上下文内使用
   用with-connection创建临时连接上下文时，*database-connection*会在上下文范围内有效：

   (postmodern:with-connection ("数据库名" "用户名" "密码" "主机地址")
     ;; 此处直接使用*database-connection*作为wait-for-notifications的参数
     (postmodern:wait-for-notifications postmodern:*database-connection* ...))
   

需要注意：wait-for-notifications并非Postmodern的内部函数——它定义在cl-postgres的public.lisp中，属于公开API，完全可以在业务代码中使用。

问题2：正确实现表变更触发逻辑 #

要实现数据库主动通知，需要结合PostgreSQL的NOTIFY/LISTEN机制和Postmodern的监听能力，步骤如下：

步骤1：在PostgreSQL中配置触发器发送通知 #

针对目标表创建触发器函数，当表发生INSERT/UPDATE/DELETE操作时，通过pg_notify发送通知到指定频道。以users表为例：

-- 创建通知函数
CREATE OR REPLACE FUNCTION notify_user_change()
RETURNS TRIGGER AS $$
BEGIN
  CASE TG_OP
    WHEN 'INSERT' THEN PERFORM pg_notify('user_changes', 'INSERT:' || NEW.id);
    WHEN 'UPDATE' THEN PERFORM pg_notify('user_changes', 'UPDATE:' || NEW.id);
    WHEN 'DELETE' THEN PERFORM pg_notify('user_changes', 'DELETE:' || OLD.id);
  END CASE;
  RETURN COALESCE(NEW, OLD);
END;
$$ LANGUAGE plpgsql;

-- 绑定触发器到users表
CREATE TRIGGER users_change_trigger
AFTER INSERT OR UPDATE OR DELETE ON users
FOR EACH ROW EXECUTE FUNCTION notify_user_change();

步骤2：在Common Lisp中监听并处理通知 #

通过Postmodern订阅频道，然后循环监听通知并执行业务逻辑：

(ql:quickload :postmodern)

;; 建立数据库连接
(postmodern:connect-toplevel "your_db" "your_user" "your_pass" "localhost")

;; 订阅PostgreSQL中的通知频道
(postmodern:execute "LISTEN user_changes;")

;; 定义通知处理函数
(defun handle-user-update (channel payload)
  (format t "捕获表变更：[频道]~a [内容]~a~%" channel payload)
  ;; 在这里编写你的业务逻辑，例如更新本地缓存、触发计算任务等
  )

;; 持续监听通知的循环
(defun start-change-listener ()
  (loop
    ;; 每10秒超时一次，避免永久阻塞
    (postmodern:wait-for-notifications postmodern:*database-connection*
                                       :timeout 10
                                       :callback #'handle-user-update)))

关键注意事项 #

• 保持连接活跃：监听过程中不能断开数据库连接，否则会丢失通知
• 线程安全：如果在多线程环境中使用，确保每个线程使用独立的连接对象
• 异常处理：可以在循环中添加错误捕获逻辑，避免监听因临时异常中断

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