expression: Fix wrong result of microsecond function in vectorized (#…

…29310) (#29387) close #29244
pingcap · Apr 12, 2022 · 4407184 · 4407184
1 parent 36ac14e
commit 4407184
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 2 deletions.
diff --git a/expression/builtin_time_vec.go b/expression/builtin_time_vec.go
@@ -964,12 +964,11 @@ func (b *builtinMicroSecondSig) vecEvalInt(input *chunk.Chunk, result *chunk.Col
  result.ResizeInt64(n, false)
  result.MergeNulls(buf)
  i64s := result.Int64s()
- ds := buf.GoDurations()
  for i := 0; i < n; i++ {
  if result.IsNull(i) {
  continue
  }
- i64s[i] = int64((ds[i] % time.Second) / time.Microsecond)
+ i64s[i] = int64(buf.GetDuration(i, int(types.UnspecifiedFsp)).MicroSecond())
  }
  return nil
 }

diff --git a/expression/integration_test.go b/expression/integration_test.go
@@ -10198,3 +10198,16 @@ func (s *testIntegrationSuite) TestIssue28643(c *C) {
  tk.MustExec("set tidb_enable_vectorized_expression = off;")
  tk.MustQuery("select hour(a) from t;").Check(testkit.Rows("838", "838"))
 }
+
+func (s *testIntegrationSuite) TestIssue29244(c *C) {
+ tk := testkit.NewTestKit(c, s.store)
+ tk.MustExec("use test")
+ tk.MustExec("drop table if exists t")
+ tk.MustExec("create table t(a time(4));")
+ tk.MustExec("insert into t values(\"-700:10:10.123456111\");")
+ tk.MustExec("insert into t values(\"700:10:10.123456111\");")
+ tk.MustExec("set tidb_enable_vectorized_expression = on;")
+ tk.MustQuery("select microsecond(a) from t;").Check(testkit.Rows("123500", "123500"))
+ tk.MustExec("set tidb_enable_vectorized_expression = off;")
+ tk.MustQuery("select microsecond(a) from t;").Check(testkit.Rows("123500", "123500"))
+}