Skip to content

Commit 8a66f8a

Browse files
committed
feat: use shard-aware identifiers in queries
[integration]
1 parent d5b15d7 commit 8a66f8a

36 files changed

Lines changed: 4313 additions & 81 deletions

File tree

query-compiler/query-compiler/src/translate/query/write.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -201,10 +201,10 @@ pub(crate) fn translate_write_query(query: WriteQuery, builder: &dyn QueryBuilde
201201
.map(|(field, val)| (field.db_name().into(), FieldInitializer::Value(val.clone())))
202202
.collect();
203203

204-
// Keep track of the operations that are applied to the primary identifier fields.
204+
// Keep track of the operations that are applied to the primary identifier or shard key fields.
205205
// They need to be applied in-memory to the record we intend to return.
206206
let operations = model
207-
.primary_identifier()
207+
.shard_aware_primary_identifier()
208208
.selections()
209209
.filter_map(|field| {
210210
Some((

query-engine/connector-test-kit-rs/query-engine-tests/tests/query_engine_tests.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,4 +7,5 @@
77
mod new;
88
mod queries;
99
mod raw;
10+
mod sharding;
1011
mod writes;

0 commit comments

Comments
 (0)