src/Db/Pgsql/PgClient.php
public function executeStatement(string $queryString, array $parameters = [])
    {
        return Observable::defer(function() use ($queryString, $parameters) {
            $conn = $this->getLeastBusyConnection();

            return $conn->executeStatement($queryString, $parameters);
        });
    }
public function executeStatement(string $queryString, array $parameters = [])
    {
        return Observable::defer(function() use ($queryString, $parameters) {
            $conn = $this->getLeastBusyConnection();

            return $conn->executeStatement($queryString, $parameters);
        });
    }
Execute statement with parameters
@param string $queryString
@param array  $parameters
@return Observable