Skip to content

Commit 9b1020c

Browse files
committed
Optimize querying for existing objects
1 parent 41c06d5 commit 9b1020c

File tree

1 file changed

+1
-11
lines changed

1 file changed

+1
-11
lines changed

core/src/repositories/sqlite/inventory.rs

+1-11
Original file line numberDiff line numberDiff line change
@@ -74,17 +74,7 @@ impl InventoryRepository for SqliteInventoryRepository {
7474
let incoming_objects: HashSet<String, RandomState> =
7575
HashSet::from_iter(hashes.clone().into_iter());
7676

77-
let mut query_builder = QueryBuilder::new("SELECT hash FROM inventory WHERE hash IN (");
78-
let mut separated = query_builder.separated(", ");
79-
for h in hashes.clone() {
80-
separated.push_bind(h);
81-
}
82-
separated.push_unseparated(") ");
83-
84-
let existing_objects = query_builder
85-
.build_query_scalar::<String>()
86-
.fetch_all(&self.pool)
87-
.await?;
77+
let existing_objects = self.get().await?;
8878

8979
let existing_objects = HashSet::from_iter(existing_objects.into_iter());
9080

0 commit comments

Comments
 (0)