luciano/next-jdbc
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Use map for some interleaving of combine and join #125

Browse source
This commit is contained in:
Sean Corfield 2020-06-26 21:31:28 -07:00
parent 469eb0959a
commit efa37ad84f
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/next/jdbc/result_set.clj
View file

@ -623,7 +623,7 @@
(recur (conj batch (realize rs-map)) tasks)) (recur (conj batch (realize rs-map)) tasks))
(#'r/fjinvoke (#'r/fjinvoke
#(r/reduce combinef (combinef) #(r/reduce combinef (combinef)
(mapv #'r/fjjoin (conj tasks (#'r/fjfork (chunk batch))))))))) (map #'r/fjjoin (conj tasks (#'r/fjfork (chunk batch)))))))))
(reducef (combinef) {:next.jdbc/update-count (.getUpdateCount stmt)}))) (reducef (combinef) {:next.jdbc/update-count (.getUpdateCount stmt)})))
(defn- stmt-sql->result-set (defn- stmt-sql->result-set
@ -678,7 +678,7 @@
(recur (conj batch (realize rs-map)) tasks)) (recur (conj batch (realize rs-map)) tasks))
(#'r/fjinvoke (#'r/fjinvoke
#(r/reduce combinef (combinef) #(r/reduce combinef (combinef)
(mapv #'r/fjjoin (conj tasks (#'r/fjfork (chunk batch))))))))) (map #'r/fjjoin (conj tasks (#'r/fjfork (chunk batch)))))))))
(reducef (combinef) {:next.jdbc/update-count (.getUpdateCount stmt)}))) (reducef (combinef) {:next.jdbc/update-count (.getUpdateCount stmt)})))
(extend-protocol p/Executable (extend-protocol p/Executable