Function EnsureDBVersion

internal/storage/postgres/utils/common.go:214–224

EnsureDBVersion checks the version of the given database connection and returns an error if the version is not supported.

(db *pgxpool.Pool)

// EnsureDBVersion checks the version of the given database connection
// and returns an error if the version is not supported.
func EnsureDBVersion(db *pgxpool.Pool) (version string, err error) {
	err = db.QueryRow(context.Background(), "SHOW server_version_num;").Scan(&version)
	if err != nil {
		return version, err
	}
	v, err := strconv.Atoi(version)
	if v < earliestPostgresVersion {
		err = fmt.Errorf("unsupported postgres version: %s, expected >= %d", version, earliestPostgresVersion)
	}
	return version, err
}