From 15f7fac8f4d01d02489f7273c60eee04b64e2f29 Mon Sep 17 00:00:00 2001
From: Andrey Antukh <niwi@niwi.nz>
Date: Mon, 27 Jan 2025 12:04:59 +0100
Subject: [PATCH] :sparkles: Add more reasonable default fetch size for db/plan

Making it more general purpose and not only for streaming
---
 backend/src/app/db.clj            | 2 +-
 backend/src/app/tasks/file_gc.clj | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/backend/src/app/db.clj b/backend/src/app/db.clj
index 625fe872f..a5ca68056 100644
--- a/backend/src/app/db.clj
+++ b/backend/src/app/db.clj
@@ -413,7 +413,7 @@
 
 (def ^:private default-plan-opts
   (-> default-opts
-      (assoc :fetch-size 1)
+      (assoc :fetch-size 1000)
       (assoc :concurrency :read-only)
       (assoc :cursors :close)
       (assoc :result-type :forward-only)))
diff --git a/backend/src/app/tasks/file_gc.clj b/backend/src/app/tasks/file_gc.clj
index 2f1edd1d7..daa3d6003 100644
--- a/backend/src/app/tasks/file_gc.clj
+++ b/backend/src/app/tasks/file_gc.clj
@@ -60,7 +60,7 @@
                 (map (partial bfc/decode-file cfg))
                 xf:collect-used-media)
 
-        used   (->> (db/plan conn [sql:get-snapshots id])
+        used   (->> (db/plan conn [sql:get-snapshots id] {:fetch-size 1})
                     (transduce xform conj #{}))
         used   (into used xf:collect-used-media [file])
 
@@ -164,7 +164,7 @@
         (mapcat (partial get-used-components deleted-components file-id))
 
         used-remote
-        (->> (db/plan conn [sql:get-files-for-library file-id])
+        (->> (db/plan conn [sql:get-files-for-library file-id] {:fetch-size 1})
              (transduce (comp (map (partial bfc/decode-file cfg)) xform) conj #{}))
 
         used-local