[release-18.0] evalengine: Fix the min / max calculation for decimals (…

…#14614) (#14616) Co-authored-by: vitess-bot[bot] <108069721+vitess-bot[bot]@users.noreply.github.com>
vitessio · Nov 27, 2023 · 34db0da · 34db0da
1 parent bd364eb
commit 34db0da
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/go/vt/vtgate/evalengine/api_aggregation.go b/go/vt/vtgate/evalengine/api_aggregation.go
@@ -389,6 +389,7 @@ func (s *aggregationDecimal) Min(value sqltypes.Value) error {
 	}
 	if !s.dec.IsInitialized() || dec.Cmp(s.dec) < 0 {
 		s.dec = dec
+		s.prec = -dec.Exponent()
 	}
 	return nil
 }
@@ -403,6 +404,7 @@ func (s *aggregationDecimal) Max(value sqltypes.Value) error {
 	}
 	if !s.dec.IsInitialized() || dec.Cmp(s.dec) > 0 {
 		s.dec = dec
+		s.prec = -dec.Exponent()
 	}
 	return nil
 }

diff --git a/go/vt/vtgate/evalengine/api_aggregation_test.go b/go/vt/vtgate/evalengine/api_aggregation_test.go
@@ -72,6 +72,12 @@ func TestMinMax(t *testing.T) {
 			min:    sqltypes.NewVarBinary("a"),
 			max:    sqltypes.NewVarBinary("b"),
 		},
+		{
+			type_:  sqltypes.Decimal,
+			values: []sqltypes.Value{sqltypes.NewDecimal("1.001"), sqltypes.NewDecimal("2.1")},
+			min:    sqltypes.NewDecimal("1.001"),
+			max:    sqltypes.NewDecimal("2.1"),
+		},
 		{
 			// accent insensitive
 			type_: sqltypes.VarChar,