tx

type Context interface {
	Transaction() Transaction
	Parent() Context
	Resources() any
}

type Executor interface {
	Execute(ctx context.Context, fn Func) (any, error)
	ExecutorInTransaction(ctx context.Context, fn Func, options ...Option) (any, error)
	TransactionManager() Manager
}

type Func func(ctx context.Context, template Template) (any, error)

type IsolationLevel int

type Manager interface {
	CreateContext() Context
	Connection() *sql.DB
	GetOrCreateTransaction(ctx context.Context, options ...Option) (Transaction, error)
	Commit(ctx context.Context, tx Transaction) error
	Rollback(ctx context.Context, tx Transaction) error
}

type Option func(options *Options)

type Options struct {
	Propagation    Propagation
	Timeout        time.Duration
	ReadOnly       bool
	IsolationLevel IsolationLevel
}

type Propagation int

type Template interface {
	Exec(query string, args ...any) (sql.Result, error)
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	Prepare(query string) (*sql.Stmt, error)
	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
	Query(query string, args ...any) (*sql.Rows, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRow(query string, args ...any) *sql.Row
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
}

type Transaction interface {
	Tx() *sql.Tx
	IsNew() bool
	IsReadOnly() bool
	MarkAsRollbackOnly()
	IsRollbackOnly() bool
	MarkAsCompleted()
	IsCompleted() bool
}