stmt.addLine(connection, ".prepareStatement(", query, ")");
jm.addTry();
LocalJavaField rs = jm.newJavaField(ResultSet.class);
rs.addLine(stmt, ".executeQuery();");
jm.addTry();
jm.addWhile(rs, ".next()");
LocalJavaField elem = jm.newJavaField(qName);
elem.addLine("(", qName, ") create()");
getResultSet(jm, rs, elem, table.getColumns(), 0);
jm.addLine(pObserver, ".notify(", elem, ");");
jm.addEndWhile();