Versions in this module Expand all Collapse all v1 v1.0.1 Sep 1, 2026 Changes in this version + const DuplicateKeyErrorCode + const ForeignKeyViolationErrorCode + const MaxQueryParams + var ErrBeginTransactionFailed = errors.New("begin transaction failed") + var ErrCommitTransactionFailed = errors.New("commit transaction failed") + var ErrCommitWithoutTransaction = errors.New("invalid transaction, can not perform commit without transaction") + var ErrNoPgConnection = errors.New("postgres connection is not established") + var ErrRollbackTransactionFailed = errors.New("revert transaction failed") + var ErrRollbackWithoutTransaction = errors.New("invalid transaction, can not perform rollback without transaction") + func IsErrorCode(err error, errCode pq.ErrorCode) bool + func NullStringToString(value sql.NullString) string + func NullStringToStringPointer(value sql.NullString) *string + func NullTimeToTimePointer(value sql.NullTime) *time.Time + func TimePointerToNullTime(value *time.Time) sql.NullTime + func TryCastErrorToPgError(err error) any + type DbConnection interface + BeginTx func(ctx context.Context) (DbConnection, error) + Commit func() error + EnableQueryLogging func() + Exec func(ctx context.Context, query string, args ...interface{}) (sql.Result, error) + Get func(ctx context.Context, dest interface{}, query string, args ...interface{}) error + NamedExec func(ctx context.Context, query string, arg interface{}) (sql.Result, error) + NamedQuery func(ctx context.Context, query string, arg interface{}) (*sqlx.Rows, error) + Ping func() error + PrepareNamed func(query string) (*sqlx.NamedStmt, error) + QueryRowx func(ctx context.Context, query string, args ...interface{}) *sqlx.Row + Queryx func(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error) + Rebind func(query string) string + Rollback func() error + SetSqlConnection func(db *sqlx.DB) + func NewDbConnection(db *sqlx.DB) DbConnection + func NewEmptyDbConnection() DbConnection + func NewFakeDbConnection() DbConnection + type PgConfig struct + ApplicationName string + ConnectionMaxIdleTimeSeconds *int + ConnectionMaxLifetimeSeconds *int + Database string + Host string + MaxIdleConnections *int + MaxOpenConnections *int + Pass string + Port uint32 + SSLMode string + UseOpenTelemetry bool + User string + type Postgres interface + Close func() error + Connect func(ctx context.Context) (*sqlx.DB, error) + GetSqlConnection func() (*sqlx.DB, error) + func NewPostgres(config PgConfig) Postgres
Go to main page