session

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

type DBWrapper[T any] interface {
	GetDB(ctx context.Context) T
}

type Database[T any] interface {
	GetDB(ctx context.Context) T
	ConvertTx(ctx context.Context, tx *sql.Tx) T
}

type Executor 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 Session interface {
	WithTransaction(ctx context.Context, f func(ctx context.Context) error) error
}