PgsqlConnection::queryInternal

protected function queryInternal($sql, array $binds = null, DiagSqlTrackerQuery $trackerQuery = null)
{
	$this->connectInternal();

	$trackerQuery?->startQuery($sql, $binds);

	$result = pg_query($this->resource, $sql);

	$trackerQuery?->finishQuery();

	$this->lastQueryResult = $result;

	if (!$result)
	{
		throw new SqlQueryException('Pgsql query error', $this->getErrorMessage(), $sql);
	}

	return $result;
}