github/penpot
1
0
Fork 0
mirror of https://github.com/penpot/penpot.git synced 2026-09-09 21:49:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

📎 Normalize default opts for db/plan function

Browse Source
This commit is contained in:
Andrey Antukh 2025-01-20 23:21:41 +01:00
parent 066b1235a6
commit da0704081f
2 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
backend/src/app/db.clj
View File

@ -411,13 +411,20 @@
:hint "database object not found")) :hint "database object not found"))
row)) row))
(def ^:private default-plan-opts
(-> default-opts
(assoc :fetch-size 1)
(assoc :concurrency :read-only)
(assoc :cursors :close)
(assoc :result-type :forward-only)))
(defn plan (defn plan
([ds sql] ([ds sql]
(-> (get-connectable ds) (-> (get-connectable ds)
(jdbc/plan sql default-opts))) (jdbc/plan sql default-plan-opts)))
([ds sql opts] ([ds sql opts]
(-> (get-connectable ds) (-> (get-connectable ds)
(jdbc/plan sql (merge default-opts opts))))) (jdbc/plan sql (merge default-plan-opts opts)))))
(defn cursor (defn cursor
"Return a lazy seq of rows using server side cursors" "Return a lazy seq of rows using server side cursors"

10
backend/src/app/tasks/file_gc.clj
View File

@ -56,12 +56,6 @@
(map :data) (map :data)
(mapcat bfc/collect-used-media))) (mapcat bfc/collect-used-media)))
(def ^:private plan-opts
{:fetch-size 1
:concurrency :read-only
:cursors :close
:result-type :forward-only})
(defn- clean-file-media! (defn- clean-file-media!
"Performs the garbage collection of file media objects." "Performs the garbage collection of file media objects."
[{:keys [::db/conn] :as cfg} {:keys [id] :as file}] [{:keys [::db/conn] :as cfg} {:keys [id] :as file}]
@ -69,7 +63,7 @@
(map (partial decode-file cfg)) (map (partial decode-file cfg))
xf:collect-used-media) xf:collect-used-media)
used (->> (db/plan conn [sql:get-snapshots id] plan-opts) used (->> (db/plan conn [sql:get-snapshots id])
(transduce xform conj #{})) (transduce xform conj #{}))
used (into used xf:collect-used-media [file]) used (into used xf:collect-used-media [file])
@ -175,7 +169,7 @@
(mapcat (partial get-used-components deleted-components file-id)) (mapcat (partial get-used-components deleted-components file-id))
used-remote used-remote
(->> (db/plan conn [sql:get-files-for-library file-id] plan-opts) (->> (db/plan conn [sql:get-files-for-library file-id])
(transduce (comp (map (partial decode-file cfg)) xform) conj #{})) (transduce (comp (map (partial decode-file cfg)) xform) conj #{}))
used-local used-local