refactor(datasource,rm): insert on update executor

Closes apache#441
iSuperCoder · Jan 13, 2023 · 110dc95 · 110dc95
1 parent 47929ca
commit 110dc95
Show file tree

Hide file tree

Showing 6 changed files with 949 additions and 39 deletions.
diff --git a/pkg/datasource/sql/exec/at/at_executor.go b/pkg/datasource/sql/exec/at/at_executor.go
@@ -63,6 +63,8 @@ func (e *AtExecutor) ExecWithNamedValue(ctx context.Context, execCtx *types.Exec
  exec = NewUpdateExecutor(parser, execCtx, e.hooks)
  case types.SQLTypeDelete:
  exec = NewDeleteExecutor(parser, execCtx, e.hooks)
+ case types.SQLTypeInsertOnUpdate:
+ exec = NewInsertOnUpdateExecutor(parser, execCtx, e.hooks)
  //case types.SQLTypeSelectForUpdate:
  //case types.SQLTypeMultiDelete:
  //case types.SQLTypeMultiUpdate: