svn commit: r1727358 - /jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/rdb/RDBDocumentStore.java

[reschke]

Author: reschke
Date: Thu Jan 28 14:13:22 2016
New Revision: 1727358

URL: http://svn.apache.org/viewvc?rev=1727358&view=rev
Log:
OAK-3945: RDBDocumentStore: internalCreateOrUpdate() needs to check return code 
of insertDocuments()

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=1727358&r1=1727357&r2=1727358&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
 Thu Jan 28 14:13:22 2016
@@ -1178,7 +1178,9 @@ public class RDBDocumentStore implements
             UpdateUtils.applyChanges(doc, update);
             try {
                 Stopwatch watch = startWatch();
-                insertDocuments(collection, Collections.singletonList(doc));
+                if (!insertDocuments(collection, 
Collections.singletonList(doc))) {
+                    throw new DocumentStoreException("Can't insert the 
document: " + doc.getId());
+                }
                 if (collection == Collection.NODES) {
                     nodesCache.putIfAbsent((NodeDocument) doc);
                 }