Fixed invalid column indices - unit tests would have caught them.

This commit is contained in:
akwizgran
2013-04-09 21:02:37 +01:00
parent 84b34048ba
commit 0958570405

View File

@@ -1605,7 +1605,7 @@ abstract class JdbcDatabase implements Database<Connection> {
ps.setInt(3, maxMessages);
rs = ps.executeQuery();
List<MessageId> ids = new ArrayList<MessageId>();
while(rs.next()) ids.add(new MessageId(rs.getBytes(2)));
while(rs.next()) ids.add(new MessageId(rs.getBytes(1)));
rs.close();
ps.close();
if(ids.size() == maxMessages)
@@ -1632,7 +1632,7 @@ abstract class JdbcDatabase implements Database<Connection> {
ps.setLong(2, now);
ps.setInt(3, maxMessages - ids.size());
rs = ps.executeQuery();
while(rs.next()) ids.add(new MessageId(rs.getBytes(2)));
while(rs.next()) ids.add(new MessageId(rs.getBytes(1)));
rs.close();
ps.close();
return Collections.unmodifiableList(ids);