sql

type Connection interface {
	ExecContext(ctx context.Context, query string, args ...any) (Result, error)
	PrepareContext(ctx context.Context, query string, args ...any) (Statement, error)
	QueryContext(ctx context.Context, query string, args ...any) (RowSet, error)
	QueryRowContext(ctx context.Context, query string, args ...any) (Row, error)
	PingContext(ctx context.Context) error

	SetConnMaxLifetime(d time.Duration) error
	SetConnMaxIdleTime(d time.Duration) error
	SetMaxIdleConns(n int) error
	SetMaxOpenConns(n int) error

	BeginTransaction(ctx context.Context) (TransactionStatus, error)
	Driver() driver.Driver

	Close() error
	IsClosed() bool
}

type DataSource interface {
	GetConnection() (Connection, error)
}

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

type DefaultTransactionStatus struct {
}

type IsolationLevel int

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

type Propagation int

type Result interface {
	LastInsertId() (int64, error)
	RowsAffected() (int64, error)
}

type Row interface {
	Scan(dest ...any) error
}

type RowSet interface {
	Row

	Next() bool
}

type Statement interface {
	ExecContext(ctx context.Context, args ...any) (Result, error)
	QueryContext(ctx context.Context, args ...any) (RowSet, error)
	QueryRowContext(ctx context.Context, args ...any) (Row, error)
	Close() error
}

type TransactionCallback func(ctx context.Context) (any, error)

type TransactionContext struct {
}

type TransactionManager interface {
	GetTransaction(ctx context.Context, options ...any) (TransactionStatus, error)
	Commit() error
	Rollback() error
}

type TransactionOption func(options *TransactionOptions)

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

type TransactionStatus interface {
	IsNewTransaction() bool
	SetRollbackOnly()
	IsRollbackOnly() bool
	IsCompleted() bool
}

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