public TesterStatement(Connection conn) 
{
        _connection = conn;
}

 public TesterStatement(Connection conn,
    int resultSetType,
    int resultSetConcurrency) 
{
        _connection = conn;
        _resultSetType = resultSetType;
        _resultSetConcurrency = resultSetConcurrency;
}

 public  void addBatch(String sql) throws SQLException 
{
        checkOpen();
}

 public  void cancel() throws SQLException 
{
        checkOpen();
}

 protected  void checkOpen() throws SQLException 
{
        if(!_open) {
            throw new SQLException("Connection is closed.");
        }
}

 public  void clearBatch() throws SQLException 
{
        checkOpen();
}

 public  void clearWarnings() throws SQLException 
{
        checkOpen();
}

 public  void close() throws SQLException 
{
        checkOpen();
        _open = false;
        if (_resultSet != null) {
            _resultSet.close();
            _resultSet = null;
        }
}

 public boolean execute(String sql) throws SQLException 
{
        checkOpen();
        return _executeResponse;
}

 public boolean execute(String sql,
    int autoGeneratedKeys) throws SQLException 
{
        throw new SQLException("Not implemented.");
}

 public boolean execute(String sql,
    int[] columnIndexes) throws SQLException 
{
        throw new SQLException("Not implemented.");
}

 public boolean execute(String sql,
    String[] columnNames) throws SQLException 
{
        throw new SQLException("Not implemented.");
}

 public int[] executeBatch() throws SQLException 
{
        checkOpen();
        return new int[0];
}

 public ResultSet executeQuery(String sql) throws SQLException 
{
          
        checkOpen();
        if("null".equals(sql)) {
            return null;
        } if("invalid".equals(sql)) {
            throw new SQLException("invalid query");
        } if ("broken".equals(sql)) {
            throw new SQLException("broken connection");
        } if("select username".equals(sql)) {
            String username = ((TesterConnection) _connection).getUsername();
            Object[][] data = {{username}};
            return new TesterResultSet(this, data);
        } else {
            return new TesterResultSet(this);
        }
}

 public int executeUpdate(String sql) throws SQLException 
{
        checkOpen();
        return _rowsUpdated;
}

 public int executeUpdate(String sql,
    int autoGeneratedKeys) throws SQLException 
{
        throw new SQLException("Not implemented.");
}

 public int executeUpdate(String sql,
    int[] columnIndexes) throws SQLException 
{
        throw new SQLException("Not implemented.");
}

 public int executeUpdate(String sql,
    String[] columnNames) throws SQLException 
{
        throw new SQLException("Not implemented.");
}

 public Connection getConnection() throws SQLException 
{
        checkOpen();
        return _connection;
}

 public int getFetchDirection() throws SQLException 
{
        checkOpen();
        return _fetchDirection;
}

 public int getFetchSize() throws SQLException 
{
        checkOpen();
        return _fetchSize;
}

 public ResultSet getGeneratedKeys() throws SQLException 
{
        throw new SQLException("Not implemented.");
}

 public int getMaxFieldSize() throws SQLException 
{
        checkOpen();
        return _maxFieldSize;
}

 public int getMaxRows() throws SQLException 
{
        checkOpen();
        return _maxRows;
}

 public boolean getMoreResults() throws SQLException 
{
        checkOpen();
        return false;
}

 public boolean getMoreResults(int current) throws SQLException 
{
        throw new SQLException("Not implemented.");
}

 public int getQueryTimeout() throws SQLException 
{
        checkOpen();
        return _queryTimeout;
}

 public ResultSet getResultSet() throws SQLException 
{
        checkOpen();
        if (_resultSet == null) {
            _resultSet = new TesterResultSet(this); 
        }
        return _resultSet;
}

 public int getResultSetConcurrency() throws SQLException 
{
        checkOpen();
        return _resultSetConcurrency;
}

 public int getResultSetHoldability() throws SQLException 
{
        checkOpen();
        throw new SQLException("Not implemented.");
}

 public int getResultSetType() throws SQLException 
{
        checkOpen();
        return _resultSetType;
}

 public int getUpdateCount() throws SQLException 
{
        checkOpen();
        return _rowsUpdated;
}

 public SQLWarning getWarnings() throws SQLException 
{
        checkOpen();
        return null;
}

 public  void setCursorName(String name) throws SQLException 
{
        checkOpen();
        _cursorName = name;
}

 public  void setEscapeProcessing(boolean enable) throws SQLException 
{
        checkOpen();
        _escapeProcessing = enable;
}

 public  void setFetchDirection(int direction) throws SQLException 
{
        checkOpen();
        _fetchDirection = direction;
}

 public  void setFetchSize(int rows) throws SQLException 
{
        checkOpen();
        _fetchSize = rows;
}

 public  void setMaxFieldSize(int max) throws SQLException 
{
        checkOpen();
        _maxFieldSize = max;
}

 public  void setMaxRows(int max) throws SQLException 
{
        checkOpen();
        _maxRows = max;
}

 public  void setQueryTimeout(int seconds) throws SQLException 
{
        checkOpen();
        _queryTimeout = seconds;
}