transaction

Documentation

Index

• type DefaultTransaction
  • func NewDefaultTransaction(ds datasource.DataSource, db *sql.DB) *DefaultTransaction
  • func (trans *DefaultTransaction) Begin() error
  • func (trans *DefaultTransaction) Close()
  • func (trans *DefaultTransaction) Commit() error
  • func (trans *DefaultTransaction) GetConnection() connection.Connection
  • func (trans *DefaultTransaction) Rollback() error
• type Transaction
• type TransactionConnection
  • func (transConnection *TransactionConnection) Exec(ctx context.Context, sqlStr string, params ...interface{}) (common.Result, error)
  • func (transConnection *TransactionConnection) Prepare(sqlStr string) (statement.Statement, error)
  • func (transConnection *TransactionConnection) Query(ctx context.Context, result reflection.Object, sqlStr string, ...) error
• type TransactionStatement
  • func (transStatement *TransactionStatement) Close()
  • func (transStatement *TransactionStatement) Exec(ctx context.Context, params ...interface{}) (common.Result, error)
  • func (transStatement *TransactionStatement) Query(ctx context.Context, result reflection.Object, params ...interface{}) error

Types

type DefaultTransaction

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

func NewDefaultTransaction

func NewDefaultTransaction(ds datasource.DataSource, db *sql.DB) *DefaultTransaction

func (*DefaultTransaction) Begin

func (trans *DefaultTransaction) Begin() error

func (*DefaultTransaction) Close

func (trans *DefaultTransaction) Close()

func (*DefaultTransaction) Commit

func (trans *DefaultTransaction) Commit() error

func (*DefaultTransaction) GetConnection

func (trans *DefaultTransaction) GetConnection() connection.Connection

func (*DefaultTransaction) Rollback

func (trans *DefaultTransaction) Rollback() error

type Transaction

type Transaction interface {
	Close()

	GetConnection() connection.Connection

	Begin() error

	Commit() error

	Rollback() error
}

type TransactionConnection

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

func (*TransactionConnection) Exec

func (transConnection *TransactionConnection) Exec(ctx context.Context, sqlStr string, params ...interface{}) (common.Result, error)

func (*TransactionConnection) Prepare

func (transConnection *TransactionConnection) Prepare(sqlStr string) (statement.Statement, error)

func (*TransactionConnection) Query

func (transConnection *TransactionConnection) Query(ctx context.Context, result reflection.Object, sqlStr string, params ...interface{}) error

type TransactionStatement

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

func (*TransactionStatement) Close

func (transStatement *TransactionStatement) Close()

func (*TransactionStatement) Exec

func (transStatement *TransactionStatement) Exec(ctx context.Context, params ...interface{}) (common.Result, error)

func (*TransactionStatement) Query

func (transStatement *TransactionStatement) Query(ctx context.Context, result reflection.Object, params ...interface{}) error