at

Documentation

Index

• Variables
• func AddEscape(colName string, dbType types.DBType) string
• func BuildWhereConditionByPKs(pkNameList []string, dbType types.DBType) string
• func DataValidationAndGoOn(sqlUndoLog undo.SQLUndoLog, conn *sql.Conn) bool
• func DelEscape(colName string, dbType types.DBType) string
• func GetOrderedPkList(image *types.RecordImage, row types.RowImage, dbType types.DBType) ([]types.ColumnImage, error)
• func Init()
• func NewDeleteExecutor(parserCtx *types.ParseContext, execContent *types.ExecContext, ...) executor
• func NewInsertExecutor(parserCtx *types.ParseContext, execContent *types.ExecContext, ...) executor
• func NewInsertOnUpdateExecutor(parserCtx *types.ParseContext, execContent *types.ExecContext, ...) executor
• func NewMultiDeleteExecutor(parserCtx *types.ParseContext, execContent *types.ExecContext, ...) *multiDeleteExecutor
• func NewMultiExecutor(parserCtx *types.ParseContext, execContext *types.ExecContext, ...) executor
• func NewMultiUpdateExecutor(parserCtx *types.ParseContext, execContext *types.ExecContext, ...) *multiUpdateExecutor
• func NewPlainExecutor(parserCtx *types.ParseContext, execCtx *types.ExecContext) executor
• func NewSelectForUpdateExecutor(parserCtx *types.ParseContext, execContext *types.ExecContext, ...) executor
• func NewUpdateExecutor(parserCtx *types.ParseContext, execContent *types.ExecContext, ...) executor
• type ATExecutor
  • func (e *ATExecutor) ExecWithNamedValue(ctx context.Context, execCtx *types.ExecContext, f exec.CallbackWithNamedValue) (types.ExecResult, error)
  • func (e *ATExecutor) ExecWithValue(ctx context.Context, execCtx *types.ExecContext, f exec.CallbackWithNamedValue) (types.ExecResult, error)
  • func (e *ATExecutor) Interceptors(hooks []exec.SQLHook)

Variables

var LockConfig rm.LockConfig

Functions

func AddEscape

func AddEscape(colName string, dbType types.DBType) string

AddEscape if necessary, add escape by db type

func BuildWhereConditionByPKs

func BuildWhereConditionByPKs(pkNameList []string, dbType types.DBType) string

BuildWhereConditionByPKs each pk is a condition.the result will like :" id =? and userCode =?"

func DataValidationAndGoOn

func DataValidationAndGoOn(sqlUndoLog undo.SQLUndoLog, conn *sql.Conn) bool

DataValidationAndGoOn check data valid Todo implement dataValidationAndGoOn

func DelEscape

func DelEscape(colName string, dbType types.DBType) string

DelEscape del escape by db type

func GetOrderedPkList

func GetOrderedPkList(image *types.RecordImage, row types.RowImage, dbType types.DBType) ([]types.ColumnImage, error)

func Init

func Init()

func NewDeleteExecutor

func NewDeleteExecutor(parserCtx *types.ParseContext, execContent *types.ExecContext, hooks []exec.SQLHook) executor

NewDeleteExecutor get delete executor

func NewInsertExecutor

func NewInsertExecutor(parserCtx *types.ParseContext, execContent *types.ExecContext, hooks []exec.SQLHook) executor

NewInsertExecutor get insert executor

func NewInsertOnUpdateExecutor

func NewInsertOnUpdateExecutor(parserCtx *types.ParseContext, execContent *types.ExecContext, hooks []exec.SQLHook) executor

NewInsertOnUpdateExecutor get insert on update executor

func NewMultiDeleteExecutor

func NewMultiDeleteExecutor(parserCtx *types.ParseContext, execContent *types.ExecContext, hooks []exec.SQLHook) *multiDeleteExecutor

NewMultiDeleteExecutor get multiDelete executor

func NewMultiExecutor

func NewMultiExecutor(parserCtx *types.ParseContext, execContext *types.ExecContext, hooks []exec.SQLHook) executor

NewMultiExecutor get new multi executor

func NewMultiUpdateExecutor

func NewMultiUpdateExecutor(parserCtx *types.ParseContext, execContext *types.ExecContext, hooks []exec.SQLHook) *multiUpdateExecutor

NewMultiUpdateExecutor get new multi update executor

func NewPlainExecutor

func NewPlainExecutor(parserCtx *types.ParseContext, execCtx *types.ExecContext) executor

func NewSelectForUpdateExecutor

func NewSelectForUpdateExecutor(parserCtx *types.ParseContext, execContext *types.ExecContext, hooks []exec.SQLHook) executor

func NewUpdateExecutor

func NewUpdateExecutor(parserCtx *types.ParseContext, execContent *types.ExecContext, hooks []exec.SQLHook) executor

NewUpdateExecutor get update executor

Types

type ATExecutor

type ATExecutor struct {
	// contains filtered or unexported fields
}

func (*ATExecutor) ExecWithNamedValue

func (e *ATExecutor) ExecWithNamedValue(ctx context.Context, execCtx *types.ExecContext, f exec.CallbackWithNamedValue) (types.ExecResult, error)

ExecWithNamedValue find the executor by sql type

func (*ATExecutor) ExecWithValue

func (e *ATExecutor) ExecWithValue(ctx context.Context, execCtx *types.ExecContext, f exec.CallbackWithNamedValue) (types.ExecResult, error)

ExecWithValue transfer value to nameValue execute

func (*ATExecutor) Interceptors

func (e *ATExecutor) Interceptors(hooks []exec.SQLHook)