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);
        });
    }
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
Execute simple statement without parameters