Documentation
¶
Index ¶
- func NewQuerier[T any](conn *PostgresExecutor) querier.Querier[T]
- type Executor
- type PostgresConf
- type PostgresExecutor
- func (e *PostgresExecutor) Close() error
- func (e *PostgresExecutor) Exec(ctx context.Context, query string, args ...any) error
- func (e *PostgresExecutor) GetDb() *sqlx.DB
- func (e *PostgresExecutor) QueryRows(ctx context.Context, sql string, args ...interface{}) (*sqlx.Rows, error)
- func (e *PostgresExecutor) Select(ctx context.Context, dest any, query string, args ...any) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewQuerier ¶
func NewQuerier[T any](conn *PostgresExecutor) querier.Querier[T]
Types ¶
type PostgresConf ¶
type PostgresExecutor ¶
type PostgresExecutor struct {
// contains filtered or unexported fields
}
func NewPostgresExecutor ¶
func NewPostgresExecutor(ctx context.Context, conf *PostgresConf) (*PostgresExecutor, error)
func (*PostgresExecutor) Close ¶
func (e *PostgresExecutor) Close() error
func (*PostgresExecutor) GetDb ¶
func (e *PostgresExecutor) GetDb() *sqlx.DB
Click to show internal directories.
Click to hide internal directories.