Versions in this module Expand all Collapse all v0 v0.8.0 Sep 12, 2025 Changes in this version + const DefaultConnIdleTimeSecond + const DefaultConnLifeTimeSecond + const DefaultIdleConns + const DefaultMaxConns + const EngineMigrationTable + const EngineSchema + const ErrEmptyDSN + const ErrInvalidConnIdleTime + const ErrInvalidConnLifeTime + const ErrInvalidIdleConns + const ErrInvalidMaxConns + const ErrNilConfig + const MigrationLockId + const MigrationTable + const SchemaDefault + const TblTypeForeignTable + const TblTypeLocal + const TblTypeTable + const TblTypeView + func ColumnExists(ctx context.Context, client *db.SqlClient, tableName string, columnName string, ...) (bool, error) + func DialectOptions() *goqu.SQLDialectOptions + func ForeignTableExists(ctx context.Context, client *db.SqlClient, tableName string, schema string) (bool, error) + func GetServerVersion(db *sqlx.DB, ctx context.Context) (string, error) + func NewClient(config *ClientConfig) (*db.SqlClient, error) + func NewMigrationManager(ctx context.Context, client *db.SqlClient, opts ...PgMigrationOption) (migrations.Manager, error) + func TableExists(ctx context.Context, client *db.SqlClient, tableName string, schema string) (bool, error) + func ViewExists(ctx context.Context, client *db.SqlClient, tableName string, schema string) (bool, error) + type AdvisoryLock struct + func NewAdvisoryLock(ctx context.Context, db *sqlx.DB, id int) (*AdvisoryLock, error) + func (l *AdvisoryLock) Close() + func (l *AdvisoryLock) Lock(ctx context.Context) error + func (l *AdvisoryLock) TryLock(ctx context.Context) (bool, error) + func (l *AdvisoryLock) Unlock(ctx context.Context) error + type ClientConfig struct + ConnIdleTime int + ConnLifetime int + DSN string + MaxIdleConns int + MaxOpenConns int + func NewClientConfig() *ClientConfig + func (c ClientConfig) Apply(db *sqlx.DB) error + func (c ClientConfig) Validate() error + type LockConn interface + Exec func(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error) + QueryRow func(ctx context.Context, sql string, args ...any) pgx.Row + type PgMigrationOption func(s *pgMigrationManager) error + func WithModule(module string) PgMigrationOption Other modules containing this package github.com/oddbit-project/blueprint
Go to main page