+
+ /*
+ PreparedStatement query = conn.prepareStatement("select headers_,body_,flags_ from 'mail' where messageid_=?");
+ query.setString(1, m.messageid);
+ Log.warn("SQL", "select headers_,body_,flags_ from 'mail' where messageid_="+m.messageid);
+ ResultSet rs2 = query.executeQuery();
+ if (rs2.next()) {
+ Message m2 = Message.newMessage(Fountain.Util.concat(Fountain.Util.create(rs2.getString(1)),
+ Fountain.Util.create("\r\n\r\n"),
+ Fountain.Util.create(rs2.getString(2))));
+ StringBuffer s1 = new StringBuffer();
+ m.getBody().getStream().transcribe(s1);
+ StringBuffer s2 = new StringBuffer();
+ m2.getBody().getStream().transcribe(s2);
+ if (!s1.toString().equals(s2.toString())) {
+ Log.error(this.toString(),
+ "attempt to insert two messages with identical messageid ("+m.messageid+") but different bodies:\n"+
+ " (body length="+s1.length()+") "+m.summary()+"\n"+
+ " (body length="+s2.length()+") "+m2.summary()+"\n");
+ } else {
+ Log.warn(this.toString(),
+ "silently dropping duplicate insert() [messageids and bodies match]: " + m.summary());
+ return;
+ }
+ }
+ */