(QS.getQuery(e.getObject(), prop));
(qs.getQuery(e.getObject(), prop));
    public void flush() {        try {            generate();            for (Iterator it = m_operations.iterator(); it.hasNext(); ) {                Operation op = (Operation) it.next();                it.remove();                ResultCycle rc = execute(op);                if (rc != null) { rc.close(); }            }            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 = prop.getRoot().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();                }            }        } finally {            clear();        }    }