transactions

Documentation

Index

• Variables
• func NewTransaction(ctx context.Context, opts *sql.TxOptions, db database.DB, sessionID string) (*transaction, error)
• type Transaction

Variables

var ErrTransactionNotFound = errors.New("no transaction found").WithCode(errors.CodInvalidParameterValue)

Functions

func NewTransaction

func NewTransaction(ctx context.Context, opts *sql.TxOptions, db database.DB, sessionID string) (*transaction, error)

Types

type Transaction

type Transaction interface {
	GetID() string
	IsClosed() bool
	Rollback() error
	Commit(ctx context.Context) ([]*sql.SQLTx, error)
	GetSessionID() string
	SQLExec(ctx context.Context, request *schema.SQLExecRequest) error
	SQLQuery(ctx context.Context, request *schema.SQLQueryRequest) (*schema.SQLQueryResult, error)
}