add fallback for else

pingcap · Sep 14, 2020 · f15c7c0 · f15c7c0
1 parent 15ef76b
commit f15c7c0
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 9 deletions.
diff --git a/expression/builtin_compare_vec_generated.go b/expression/builtin_compare_vec_generated.go
diff --git a/expression/generator/compare_vec.go b/expression/generator/compare_vec.go
@@ -248,16 +248,21 @@ func (b *builtin{{ .compare.CompareName }}{{ .type.TypeName }}Sig) vecEval{{ .ty
  argLen := len(b.args)
 
  bufs := make([]*chunk.Column, argLen)
-
+ sc := b.ctx.GetSessionVars().StmtCtx
+ beforeWarns := sc.WarningCount()
  for i := 0; i < argLen; i++ {
  buf, err := b.bufAllocator.get(types.ETInt, n)
  if err != nil {
  return err
  }
  defer b.bufAllocator.put(buf)
  err = b.args[i].VecEval{{ .type.TypeName }}(b.ctx, input, buf)
- if err != nil {
- return err
+ afterWarns := sc.WarningCount()
+ if err != nil || afterWarns > beforeWarns {
+ if afterWarns > beforeWarns {
+ sc.TruncateWarnings(int(beforeWarns))
+ }
+ return b.fallbackEval{{ .type.TypeName }}(input, result)
  }
  bufs[i]=buf
  }