[364809] DBStore with Postgres fail to recover from crash

https://bugs.eclipse.org/bugs/show_bug.cgi?id=364809

2 files changed, 11 insertions, 1 deletions

diff --git a/plugins/org.eclipse.emf.cdo.server.db/src/org/eclipse/emf/cdo/server/internal/db/DBStore.java b/plugins/org.eclipse.emf.cdo.server.db/src/org/eclipse/emf/cdo/server/internal/db/DBStore.java
index 2748db6e3d..3926ed3fb7 100644
--- a/plugins/org.eclipse.emf.cdo.server.db/src/org/eclipse/emf/cdo/server/internal/db/DBStore.java
+++ b/plugins/org.eclipse.emf.cdo.server.db/src/org/eclipse/emf/cdo/server/internal/db/DBStore.java
@@ -259,9 +259,19 @@ public class DBStore extends Store implements IDBStore, CDOAllRevisionsProvider
       try
       {
         visitor.visitTable(connection, name);
+        connection.commit();
       }
       catch (SQLException ex)
       {
+        try
+        {
+          connection.rollback();
+        }
+        catch (SQLException ex1)
+        {
+          throw new DBException(ex1);
+        }
+
         if (!COLUMN_NOT_FOUND.equalsIgnoreCase(ex.getSQLState()))
         {
           throw new DBException(ex);
diff --git a/plugins/org.eclipse.net4j.db/src/org/eclipse/net4j/spi/db/DBAdapter.java b/plugins/org.eclipse.net4j.db/src/org/eclipse/net4j/spi/db/DBAdapter.java
index c39832a36f..0949d7d455 100644
--- a/plugins/org.eclipse.net4j.db/src/org/eclipse/net4j/spi/db/DBAdapter.java
+++ b/plugins/org.eclipse.net4j.db/src/org/eclipse/net4j/spi/db/DBAdapter.java
@@ -459,7 +459,7 @@ public abstract class DBAdapter implements IDBAdapter
       {
         if (maxRows != 1)
         {
-          statement.setMaxRows(1);
+          statement.setMaxRows(maxRows);
         }
       }
     }