manager

Feb 16, 2021

Changes in this version

+ const DeleteSqlTemplate

+ const DeleteUndoLogByCreateSql

+ const DeleteUndoLogSql

+ const InsertSqlTemplate

+ const InsertUndoLogSql

+ const SelectSqlTemplate

+ const SelectUndoLogSql

+ const UpdateSqlTemplate

+ func DeleteBuildUndoSql(undoLog undo.SqlUndoLog) string

+ func InsertBuildUndoSql(undoLog undo.SqlUndoLog) string

+ func UpdateBuildUndoSql(undoLog undo.SqlUndoLog) string

+ type BuildUndoSql func(undoLog undo.SqlUndoLog) string

+ type MysqlUndoExecutor struct

+ func NewMysqlUndoExecutor(undoLog undo.SqlUndoLog) MysqlUndoExecutor

+ func (executor MysqlUndoExecutor) Execute(tx *sql.Tx) error

+ type MysqlUndoLogManager struct

+ func (manager MysqlUndoLogManager) BatchDeleteUndoLog(db *sql.DB, xids []string, branchIds []int64) error

+ func (manager MysqlUndoLogManager) DeleteUndoLog(db *sql.DB, xid string, branchId int64) error

+ func (manager MysqlUndoLogManager) DeleteUndoLogByLogCreated(db *sql.DB, logCreated time.Time, limitRows int) (sql.Result, error)

+ func (manager MysqlUndoLogManager) FlushUndoLogs(tx *proxy_tx.ProxyTx) error

+ func (manager MysqlUndoLogManager) Undo(db *sql.DB, xid string, branchId int64, resourceId string) error

+ type State byte

+ const GlobalFinished

+ const Normal

+ func (state State) String() string

+ type UndoLogManager interface

+ BatchDeleteUndoLog func(db *sql.DB, xids []string, branchIds []int64) error

+ DeleteUndoLog func(db *sql.DB, xid string, branchId int64) error

+ DeleteUndoLogByLogCreated func(db *sql.DB, logCreated time.Time, limitRows int) (sql.Result, error)

+ FlushUndoLogs func(tx *proxy_tx.ProxyTx) error

+ Undo func(db *sql.DB, xid string, branchId int64, resourceId string) error

+ func GetUndoLogManager() UndoLogManager