postgresql

Dec 26, 2025

Changes in this version

+ type Connection interface

+ BeginTx func(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

+ Close func() error

+ ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error)

+ PingContext func(ctx context.Context) error

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

+ QueryContext func(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ QueryRowContext func(ctx context.Context, query string, args ...any) *sql.Row

+ Raw func(f func(driverConn any) error) (err error)

+ type Pool interface

+ Begin func() (*sql.Tx, error)

+ BeginTx func(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

+ Close func() error

+ Conn func(ctx context.Context) (*sql.Conn, error)

+ Driver func() driver.Driver

+ Exec func(query string, args ...any) (sql.Result, error)

+ ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error)

+ Ping func() error

+ PingContext func(ctx context.Context) error

+ Prepare func(query string) (*sql.Stmt, error)

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

+ Query func(query string, args ...any) (*sql.Rows, error)

+ QueryContext func(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ QueryRow func(query string, args ...any) *sql.Row

+ QueryRowContext func(ctx context.Context, query string, args ...any) *sql.Row

+ SetConnMaxIdleTime func(d time.Duration)

+ SetConnMaxLifetime func(d time.Duration)

+ SetMaxIdleConns func(n int)

+ SetMaxOpenConns func(n int)

+ Stats func() sql.DBStats

+ type Transaction interface

+ Commit func() error

+ Exec func(query string, args ...any) (sql.Result, error)

+ ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error)

+ Prepare func(query string) (*sql.Stmt, error)

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

+ Query func(query string, args ...any) (*sql.Rows, error)

+ QueryContext func(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ QueryRow func(query string, args ...any) *sql.Row

+ QueryRowContext func(ctx context.Context, query string, args ...any) *sql.Row

+ Rollback func() error

+ Stmt func(stmt *sql.Stmt) *sql.Stmt

+ StmtContext func(ctx context.Context, stmt *sql.Stmt) *sql.Stmt

Dec 11, 2025

Changes in this version

+ func BuildDsn(config Config) string

+ func CloseConnectionContext(ctx context.Context, connection *sql.Conn, logger logging.Logger)

+ func GetEntityColumns(entity any) []any

+ type CommonConnector struct

+ func New(dsn, driver string, logger logging.Logger, opts ...PoolOption) (*CommonConnector, error)

+ func (connector *CommonConnector) Close() error

+ func (connector *CommonConnector) Connection(ctx context.Context) (*sql.Conn, error)

+ func (connector *CommonConnector) Pool() *sql.DB

+ func (connector *CommonConnector) Transaction(ctx context.Context, opts ...TransactionOption) (*sql.Tx, error)

+ type Config struct

+ DatabaseName string

+ Driver string

+ Host string

+ Password string

+ Pool PoolConfig

+ Port int

+ SSLMode string

+ User string

+ type Connector interface

+ Close func() error

+ Connection func(ctx context.Context) (*sql.Conn, error)

+ Pool func() *sql.DB

+ Transaction func(ctx context.Context, opts ...TransactionOption) (*sql.Tx, error)

+ type NilDBConnectionError struct

+ BaseErr error

+ Message string

+ func (e NilDBConnectionError) Error() string

+ func (e NilDBConnectionError) Unwrap() error

+ type PoolConfig struct

+ MaxConnectionIdleTime time.Duration

+ MaxConnectionLifetime time.Duration

+ MaxIdleConnections int

+ MaxOpenConnections int

+ type PoolOption func(options *poolOptions) error

+ func WithMaxConnectionIdleTime(idleTime time.Duration) PoolOption

+ func WithMaxConnectionLifetime(lifetime time.Duration) PoolOption

+ func WithMaxIdleConnections(num int) PoolOption

+ func WithMaxOpenConnections(num int) PoolOption

+ type TransactionOption func(options *transactionOptions) error

+ func WithTransactionIsolationLevel(isolationLevel sql.IsolationLevel) TransactionOption

+ func WithTransactionReadOnly(readOnly bool) TransactionOption