Skip to content

Commit f9079a4

Browse files
committed
handle optional store_id
Signed-off-by: Aminu Oluwaseun Joshua <[email protected]>
1 parent 21bd073 commit f9079a4

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

crates/key-value-azure/src/store.rs

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -458,13 +458,19 @@ impl AzureCosmosStore {
458458
}
459459

460460
fn get_id_query(&self, key: &str) -> String {
461-
let mut query = format!("SELECT c.id, c.store_id FROM c WHERE c.id='{key}'");
461+
let mut query = match self.store_id {
462+
Some(_) => format!("SELECT c.id, c.store_id FROM c WHERE c.id='{key}'"),
463+
None => format!("SELECT c.id FROM c WHERE c.id='{key}'"),
464+
};
462465
self.append_store_id(&mut query, true);
463466
query
464467
}
465468

466469
fn get_keys_query(&self) -> String {
467-
let mut query = "SELECT c.id, c.store_id FROM c".to_owned();
470+
let mut query = match self.store_id {
471+
Some(_) => "SELECT c.id, c.store_id FROM c".to_owned(),
472+
None => "SELECT c.id FROM c".to_owned(),
473+
};
468474
self.append_store_id(&mut query, false);
469475
query
470476
}

0 commit comments

Comments
 (0)