executor

package

v1.2.1 Latest Latest Go to latest Published: May 30, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Details

View Source

const (
	Dot            = "."
	EscapeStandard = "\""
	EscapeMysql    = "`"
)

This section is empty.

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

AddEscape if necessary, add escape by db type

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

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

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

DataValidationAndGoOn check data valid Todo implement dataValidationAndGoOn

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

DelEscape del escape by db type

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

func IsRecordsEquals(beforeImage *types.RecordImage, afterImage *types.RecordImage) (bool, error)

IsRecordsEquals check before record and after record if equal

func NewMySQLUndoExecutorHolder() undo.UndoExecutorHolder

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

func (b *BaseExecutor) ExecuteOn(ctx context.Context, dbType types.DBType, conn *sql.Conn) error

ExecuteOn

func (b *BaseExecutor) UndoPrepare(undoPST *sql.Stmt, undoValues []types.ColumnImage, pkValueList []types.ColumnImage)

UndoPrepare

type MySQLUndoExecutorHolder struct {
}

func (m *MySQLUndoExecutorHolder) GetDeleteExecutor(sqlUndoLog undo.SQLUndoLog) undo.UndoExecutor

GetDeleteExecutor get the mysql Delete UndoExecutor by sqlUndoLog

func (m *MySQLUndoExecutorHolder) GetInsertExecutor(sqlUndoLog undo.SQLUndoLog) undo.UndoExecutor

GetInsertExecutor get the mysql Insert UndoExecutor by sqlUndoLog

func (m *MySQLUndoExecutorHolder) GetUpdateExecutor(sqlUndoLog undo.SQLUndoLog) undo.UndoExecutor

GetUpdateExecutor get the mysql Update UndoExecutor by sqlUndoLog