common

Documentation

Index

• Variables
• func CreateTransaction(tx *sql.Tx, gtid string, branch int, state string) error
• func SetDbSchema(schema string)
• func UpdateTransactionState(tx *sql.Tx, gtid string, branch int, state string) error
• func UpdateTransactionStateOrm(tx *gorm.DB, gtid string, branch int, state string) error
• type RmTransaction
  • func FindTransaction(tx *sql.Tx, gtid string, branch int) (*RmTransaction, error)
  • func FindTransactionOrm(tx *gorm.DB, gtid string, branch int) (*RmTransaction, error)
  • func (*RmTransaction) TableName() string

Variables

var (
	ErrTxnCompleted    = errors.New("transaction is already aborted or committed")
	ErrTxnAborted      = errors.New("transaction is already aborted")
	ErrTxnCommitted    = errors.New("transaction is already committed")
	ErrTxnNotPrepared  = errors.New("transaction is not prepared")
	ErrTxnInvalidState = errors.New("invalid state")
	ErrNotExist        = errors.New("not exist")
)

Functions

func CreateTransaction

func CreateTransaction(tx *sql.Tx, gtid string, branch int, state string) error

func SetDbSchema

func SetDbSchema(schema string)

SetDbSchema set database schema, only useful for postgreSQL

func UpdateTransactionState

func UpdateTransactionState(tx *sql.Tx, gtid string, branch int, state string) error

func UpdateTransactionStateOrm

func UpdateTransactionStateOrm(tx *gorm.DB, gtid string, branch int, state string) error

Types

type RmTransaction

type RmTransaction struct {
	Gtid  string
	Bid   int
	State string
}

RmTransaction

func FindTransaction

func FindTransaction(tx *sql.Tx, gtid string, branch int) (*RmTransaction, error)

func FindTransactionOrm

func FindTransactionOrm(tx *gorm.DB, gtid string, branch int) (*RmTransaction, error)

func (*RmTransaction) TableName

func (*RmTransaction) TableName() string