PreparedStatement add = conn.prepareStatement("insert into pending values(?,?,?,?)");
add.setString(1, messageid);
add.setString(2, to.toString(false));
- add.setString(3, streamToString(m.getStream()));
+ add.setString(3, SqliteDB.streamToString(m.getStream()));
add.setTimestamp(4, new Timestamp(System.currentTimeMillis()));
add.executeUpdate();
}
} catch (Exception e) { throw new RuntimeException(e); }
}
- private static String streamToString(Stream stream) throws Exception {
- StringBuffer b = new StringBuffer();
- for(String s = stream.readln(); s!=null; s=stream.readln())
- b.append(s+"\n");
- return b.toString();
- }
}