Skip to content

Commit 1d27ac9

Browse files
wbtlbwangbo
andauthored
chore(sharding): fix sum prepare error (#389)
* fix(sharding): fix min max error Signed-off-by: wangbo <wangbo@sphere-ex.com> * feat(sharding): support sum Signed-off-by: wangbo <wangbo@sphere-ex.com> * chore(sharding): fix sum prepare Signed-off-by: wangbo <wangbo@sphere-ex.com> * chore(sharding): fix sum prepare Signed-off-by: wangbo <wangbo@sphere-ex.com> Signed-off-by: wangbo <wangbo@sphere-ex.com> Co-authored-by: wangbo <wangbo@sphere-ex.com>
1 parent 3640d84 commit 1d27ac9

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

pisa-proxy/runtime/mysql/src/server/executor.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -461,6 +461,10 @@ where
461461
_ => {}
462462
}
463463

464+
if chunk.par_iter().map(|x| &x[4..]).min() == chunk.par_iter().map(|x| &x[4..]).max() {
465+
return Ok(())
466+
}
467+
464468
let chunk_data = &chunk[0];
465469
let ori_row_data = row_data.clone();
466470
let mut row_data = row_data.clone();

0 commit comments

Comments
 (0)