postgresql – clojure.java.jdbc中的嵌套事务

我们有一个包含数百万条记录的表m1.我们想要生成一个表m2,其中包含m1中每条记录的计算结果.
我们目前运行如下：

(jdbc/with-db-transaction [tx connection]
  (jdbc/query tx
    [(jdbc/prepare-statement (:connection tx)
                              "select * from m1"
                              {:fetch-size 1000})]
     {:result-set-fn (process! [tx result-set] ...)}))

过程！是

(defn process! [tx result-set]
  (jdbc/with-db-transaction [tx tx]
    (jdbc/insert-multi! tx :m2 [:m2_column]
      (mapv (fn [r] [(calculate r)]) 
        result-set))))

select查询使用游标并且懒惰地使用.请参阅：clojure.java.jdbc lazy query.这就是它被包装在外部事务中的原因.

问题：

> Postgres是否存在数百万条记录的(嵌套)交易？ clojure.java.jdbc docs说嵌套交易被外部交易所吸收,所以实际上我们只有一笔交易.它是否正确？
>如果我们想要为插入创建单独的事务,那么使用与数据库的不同连接的解决方案是什么？我们已经使用了连接池,所以可能已经是这种情况了？

解决方法

nested transactions are absorbed by the outer one

这是完全正确的.您可以查看sources：这是我们已经在交易时执行的分支;正如您所看到的,func(表示带有事务宏的主体的函数)只是在没有其他设置的情况下被调用.

is the solution to use a different connection to the database?

使用clojure.java.jdbc这似乎是唯一的选择.只需通过你的游泳池而不是tx来处理！功能.问题是这些事务不再嵌套,因此如果内部事务提交和外部由于某种原因而失败,则内部事务将不会回滚.您可以使用raw JDBC and savepoints实现“嵌套事务行为”.