for (int i = 0; i < m_mutations.size(); i++) { SetEvent e = (SetEvent) m_mutations.get(i); int jdbcType = ((Integer) m_mutationTypes.get(i)).intValue(); Property prop = e.getProperty(); RDBMSRecordSet rs = (RDBMSRecordSet) execute (QS.getQuery(e.getObject(), prop)); Adapter ad = Adapter.getAdapter(prop.getType()); try { if (rs.next()) { ad.mutate(rs.getResultSet(), rs.getColumn(Path.get(prop.getName())), e.getArgument(), jdbcType); } else { throw new IllegalStateException ("cannot update blob"); } } catch (SQLException se) { throw new Error(se.getMessage()); } finally { rs.close(); } }
    public void flush() {        try {            generate();            for (Iterator it = m_operations.iterator(); it.hasNext(); ) {                Operation op = (Operation) it.next();                it.remove();                ResultSet rs = execute(op);                if (rs != null) {                    try {                        rs.close();                    } catch (SQLException e) {                        throw new Error(e.getMessage());                    }                }            }        } finally {            clear();        }    }