datafx

type Config struct {
	Sources map[string]ConfigDatasource `conf:"SOURCES"`
}

type ConfigDatasource struct {
	Provider string `conf:"PROVIDER"`
	DSN      string `conf:"DSN"`
}

type ContextKey string

type Datasource interface {
	GetDialect() Dialect
	GetConnection() SqlExecutor
	UseUnitOfWork(ctx context.Context) (*UnitOfWork, error)
}

type Dialect string

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

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

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

type TransactionFinalizer interface {
	Rollback() error
	Commit() error
}

type TransactionStarter interface {
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
}

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