Author: reschke
Date: Fri Feb 7 19:09:51 2014
New Revision: 1565766
URL: http://svn.apache.org/r1565766
Log:
OAK-1266 - rollback after SQLExceptions
Modified:
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/rdb/RDBDocumentStore.java
Modified:
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/rdb/RDBDocumentStore.java
URL:
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/rdb/RDBDocumentStore.java?rev=1565766&r1=1565765&r2=1565766&view=diff
==============================================================================
---
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/rdb/RDBDocumentStore.java
(original)
+++
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/rdb/RDBDocumentStore.java
Fri Feb 7 19:09:51 2014
@@ -65,7 +65,8 @@ public class RDBDocumentStore implements
}
/**
- * Creates a {@linkplain RDBDocumentStore} instance using the provided
{@link DataSource}.
+ * Creates a {@linkplain RDBDocumentStore} instance using the provided
+ * {@link DataSource}.
*/
public RDBDocumentStore(DataSource ds) {
try {
@@ -385,6 +386,11 @@ public class RDBDocumentStore implements
connection.commit();
return success;
} catch (SQLException ex) {
+ try {
+ connection.rollback();
+ } catch (SQLException e) {
+ // TODO
+ }
throw new MicroKernelException(ex);
}
}
@@ -398,6 +404,11 @@ public class RDBDocumentStore implements
dbInsert(connection, tableName, document.getId(), modified,
modcount, data);
connection.commit();
} catch (SQLException ex) {
+ try {
+ connection.rollback();
+ } catch (SQLException e) {
+ // TODO
+ }
throw new MicroKernelException(ex);
}
}
