Documentation
¶
Index ¶
- Constants
- 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
- func NewUpdateJoinExecutor(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)
Constants ¶
View Source
const (
LowerSupportGroupByPksVersion = "5.7.5"
)
Variables ¶
View Source
var LockConfig rm.LockConfig
Functions ¶
func BuildWhereConditionByPKs ¶
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 GetOrderedPkList ¶
func GetOrderedPkList(image *types.RecordImage, row types.RowImage, dbType types.DBType) ([]types.ColumnImage, error)
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
func NewUpdateJoinExecutor ¶
func NewUpdateJoinExecutor(parserCtx *types.ParseContext, execContent *types.ExecContext, hooks []exec.SQLHook) executor
NewUpdateJoinExecutor get 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)
Source Files
¶
Click to show internal directories.
Click to hide internal directories.