JOOQ 中的提交钩子

Question

我在后端 Web 服务中使用 JOOQ 已经有一段时间了。在其中许多服务中，在将数据持久化到数据库之后（或者更好地说，在成功提交数据之后），我们通常希望向 Kafka 写入一些关于持久化记录的消息，以便其他服务知道这些事件。

我实际上在寻找的是：有没有办法让我使用 JOOQ 的 DSLContext 对象注册提交后挂钩或回调，以便在事务成功提交时运行一些代码？

我知道ExecuteListener 和ExecuteListenerProvider 接口，但据我所知，void end(ExecuteContext ctx) 方法（应该用于生命周期结束时使用）在提交事务时不会被调用。但在每次查询后都会调用它。

这是一个例子：

 public static void main(String[] args) throws Throwable {
    Class.forName("org.postgresql.Driver");
    Connection connection = DriverManager.getConnection("<url>", "<user>", "<pass>");
    connection.setAutoCommit(false);

    DSLContext context = DSL.using(connection, SQLDialect.POSTGRES_9_5);
    context.transaction(conf -> {
        conf.set(new DefaultExecuteListenerProvider(new DefaultExecuteListener() {
            @Override
            public void end(ExecuteContext ctx) {
                System.out.println("End method triggered.");
            }
        }));

        DSLContext innerContext = DSL.using(conf);
        System.out.println("Pre insert.");
        innerContext.insertInto(...).execute();
        System.out.println("Post insert.");
    });

    connection.close();
}

似乎总是打印出来：

Pre insert.
End method triggered.
Post insert.

让我相信这不适用于提交挂钩。

是否有一位 JOOQ 大师可以告诉我 JOOQ 中是否支持提交挂钩？如果是这样，请指出我正确的方向？

Answer 1

ExecuteListener SPI 正在侦听单个查询执行的生命周期，即：

innerContext.insertInto(...).execute();

这不是你要找的。相反，您应该实现自己的TransactionProvider（可能委托给jOOQ 的DefaultTransactionProvider）。然后，您可以在实际提交逻辑之前实现您想要的任何逻辑。

请注意，jOOQ 3.9 还将提供一个新的TransactionListener SPI (see #5378) 来促进这一点。