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();
getFinally(jm, rs, null, null);
getFinally(jm, stmt, null, null);
Object sqlMsg = new Object[]{JavaSource.getQuoted("Failed to execute query "),