pgdb

Mar 18, 2024

Changes in this version

+ var QueryExecerCtxKey queryExecerCtxKeyType

type Config

+ PoolParam PoolParam

+ func (c Config) Connect(ctx context.Context) (p *EnhancedDbPool, err error)

+ type EnhancedDbPool struct

+ func (p *EnhancedDbPool) AcquireCtx(c context.Context) (atx *ctxConn, err error)

+ func (p *EnhancedDbPool) BeginCtx(c context.Context) (atx *ctxTx, err error)

+ func (p *EnhancedDbPool) BeginTxCtx(c context.Context, t pgx.TxOptions) (atx *ctxTx, err error)

+ func (p *EnhancedDbPool) Exec(ctx context.Context, sql string, args ...interface{}) (pgconn.CommandTag, error)

+ func (p *EnhancedDbPool) QbExec(ctx context.Context, builtQuery sq.Sqlizer) (c pgconn.CommandTag, err error)

+ func (p *EnhancedDbPool) QbQuery(ctx context.Context, builtQuery sq.Sqlizer) (pgx.Rows, error)

+ func (p *EnhancedDbPool) QbQueryRow(ctx context.Context, builtQuery sq.Sqlizer) (pgx.Row, error)

+ func (p *EnhancedDbPool) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)

+ func (p *EnhancedDbPool) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row

+ type PoolParam struct

+ ConnectTimeout string

+ HealthCheckPeriod string

+ MaxConnIdleTime string

+ MaxConnLifetime string

+ MaxConns int

+ MinConns int

+ type QueryExecer interface

+ Exec func(ctx context.Context, sql string, arguments ...any) (commandTag pgconn.CommandTag, err error)

+ Query func(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

+ QueryRow func(ctx context.Context, sql string, args ...any) pgx.Row

Oct 15, 2022

Changes in this version

type Config

+ URL string

Nov 26, 2021

Changes in this version

+ func Exec(ctx context.Context, sql string, args ...interface{}) (pgconn.CommandTag, error)

+ func QbExec(ctx context.Context, builtQuery sq.Sqlizer) (pgconn.CommandTag, error)

+ func QbQuery(ctx context.Context, builtQuery sq.Sqlizer) (pgx.Rows, error)

+ func QbQueryRow(ctx context.Context, builtQuery sq.Sqlizer) (pgx.Row, error)

+ func Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)

+ func QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row

Nov 26, 2021

Changes in this version

+ func MigrateGetSourceFs(ctx context.Context, c Config, embeddedDirs ...embed.FS) (migrationFS fs.FS, err error)

Nov 26, 2021

Changes in this version

+ func MigrateGetDbDriver(ctx context.Context, c Config) (pgDatabaseDriver database.Driver, err error)

+ func MigrateGetInstance(ctx context.Context, c Config, embeddedDirs ...embed.FS) (migrateInstance *migrate.Migrate, err error)

+ func MigrateGetSource(ctx context.Context, c Config, embeddedDirs ...embed.FS) (migrationSourceDriver source.Driver, err error)

Nov 26, 2021

Changes in this version

+ var DbPool *pgxpool.Pool

+ var Qb sq.StatementBuilderType

+ var StdDb *sql.DB

+ func ConnectPgxPool(c Config) error

+ func ConnectStdLib(c Config) error

+ func DoExec(ctx context.Context, builtQuery squirrelBuiltQuery) (pgconn.CommandTag, error)

+ func DoQuery(ctx context.Context, builtQuery squirrelBuiltQuery) (pgx.Rows, error)

+ func DoQueryRow(ctx context.Context, builtQuery squirrelBuiltQuery) (pgx.Row, error)

+ func MigrateEntryPoint(config Config, optionally1EmbeddedDirs ...embed.FS)

+ type Config struct

+ Database string

+ Host string

+ MigrationDirectory string

+ MigrationFromEmbedded bool

+ MigrationStatementTimeoutSeconds int

+ Password string

+ Port int

+ SSL string

+ Username string

+ func (c Config) GetDsn() string