at

package
v1.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 30, 2024 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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

ExecWithValue transfer value to nameValue execute

func (*ATExecutor) Interceptors

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL