src/Db/Pgsql/PgClient.php
public function query($s)
    {
        return Observable::defer(function() use ($s) {
            $conn = $this->getLeastBusyConnection();

            return $conn->query($s);
        });
    }
public function query($s)
    {
        return Observable::defer(function() use ($s) {
            $conn = $this->getLeastBusyConnection();

            return $conn->query($s);
        });
    }
Execute simple statement without parameters
@param string $s
@return Observable