postgresql - clojure.java.jdbc 惰性查询

Question

我有一个基本上是 select * 的查询。在开发中这个表只有 30000 行，但在生产中它会更大。所以我想懒惰地使用这个查询。为什么下面的查询不是惰性的？我正在使用 Postgres 9.5.4.1。

(do
  (def pg-uri {:connection-uri "jdbc:postgresql://localhost/..."})
  (def row (atom 0))
  (take 10 (clojure.java.jdbc/query 
          pg-uri
          ["select * from mytable"]
          {:fetch-size 10
           :auto-commit false
           :row-fn (fn [r] (swap! row inc))}))
  @row) ;;=> 300000

Answer 1

首先，请参阅 https://jdbc.postgresql.org/documentation/83/query.html#query-with-cursor .

这样解决了。

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

其中 :result-set-fn 是一个使用惰性结果集的函数。

with-db-transaction 负责将 autoCommit 设置为 false。:fetch-size 不是从 query 传递过来的，所以你必须自己做一个 prepare-statement。