Method postgresQuery

plugin-server/src/utils/db/db.ts:190–227

(
        queryString: string,
        values: I | undefined,
        tag: string,
        client?: PoolClient
    )

    // Postgres

    public postgresQuery<R extends QueryResultRow = any, I extends any[] = any[]>(
        queryString: string,
        values: I | undefined,
        tag: string,
        client?: PoolClient
    ): Promise<QueryResult<R>> {
        return instrumentQuery(this.statsd, 'query.postgres', tag, async () => {
            let fullQuery = ''
            try {
                fullQuery = getFinalPostgresQuery(queryString, values as any[])
            } catch {}
            const timeout = timeoutGuard('Postgres slow query warning after 30 sec', {
                queryString,
                values,
                fullQuery,
            })

            // Annotate query string to give context when looking at DB logs
            queryString = `/* plugin-server:${tag} */ ${queryString}`
            try {
                if (client) {
                    return await client.query(queryString, values)
                } else {
                    return await this.postgres.query(queryString, values)
                }
            } catch (error) {
                if (
                    error.message &&
                    POSTGRES_UNAVAILABLE_ERROR_MESSAGES.some((message) => error.message.includes(message))
                ) {
                    throw new DependencyUnavailableError(error.message, 'Postgres', error)
                }
                throw error
            } finally {
                clearTimeout(timeout)
            }
        })
    }

    public postgresTransaction<ReturnType>(
        tag: string,