database

Documentation

Index

• func Exec(pool *pgxpool.Pool, tx pgx.Tx) ...
• func MigrateDB(pg *PostgresInstance, configService config_service.ConfigService)
• func Query(pool *pgxpool.Pool, tx pgx.Tx) func(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
• func QueryRow(pool *pgxpool.Pool, tx pgx.Tx) func(ctx context.Context, sql string, args ...any) pgx.Row
• type PostgresInstance
  • func NewPostgresInstance(configService config_service.ConfigService) (*PostgresInstance, func())
  • func (pg *PostgresInstance) Close()

Functions

func Exec

func Exec(pool *pgxpool.Pool, tx pgx.Tx) func(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)

func MigrateDB

func MigrateDB(pg *PostgresInstance, configService config_service.ConfigService)

func Query

func Query(pool *pgxpool.Pool, tx pgx.Tx) func(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

func QueryRow

func QueryRow(pool *pgxpool.Pool, tx pgx.Tx) func(ctx context.Context, sql string, args ...any) pgx.Row

Types

type PostgresInstance

type PostgresInstance struct {
	Pool *pgxpool.Pool
}

func NewPostgresInstance

func NewPostgresInstance(configService config_service.ConfigService) (*PostgresInstance, func())

func (*PostgresInstance) Close

func (pg *PostgresInstance) Close()