pgx

Documentation

Overview

Package pgx provides helpers for working Postgres database via jackc/pgx driver. Should be imported explicitly. To register postgres as retryable func use side effect import like so:

import _ "github.com/acronis/go-dbkit/pgx"

Index

• func CheckInvalidCachedPlanError(err error) bool
• func CheckPostgresError(err error, errCode dbkit.PostgresErrCode) bool

Functions

func CheckInvalidCachedPlanError

func CheckInvalidCachedPlanError(err error) bool

CheckInvalidCachedPlanError checks if the passed error is related to the invalid cached plan. By default, https://github.com/jackc/pgx has a cache for prepared statements (https://github.com/jackc/pgx/wiki/Automatic-Prepared-Statement-Caching), which can lead to the error "cached plan must not change result type (SQLSTATE 0A000)" for queries like `SELECT * FROM table` in case of the schema changes (e.g. column was added during the migration). It's recommended to handle this error as retryable since the statement cache will be invalidated, and the query will be re-prepared (it's done automatically by the driver).

func CheckPostgresError

func CheckPostgresError(err error, errCode dbkit.PostgresErrCode) bool

CheckPostgresError checks if the passed error relates to Postgres, and it's internal code matches the one from the argument.