svn commit: r1774519 - /jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoBlobStore.java

[mreutegg]

Author: mreutegg
Date: Thu Dec 15 20:10:28 2016
New Revision: 1774519

URL: http://svn.apache.org/viewvc?rev=1774519&view=rev
Log:
OAK-5317: MongoBlobStore creates _id index unnecessarily

Modified:
    
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoBlobStore.java

Modified: 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoBlobStore.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoBlobStore.java?rev=1774519&r1=1774518&r2=1774519&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoBlobStore.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/mongo/MongoBlobStore.java
 Thu Dec 15 20:10:28 2016
@@ -71,6 +71,7 @@ public class MongoBlobStore extends Cach
         // space allocated for a record to the next power of two
         // (there is an overhead per record, let's assume it is 1 KB at most)
         setBlockSize(2 * 1024 * 1024 - 1024);
+        initBlobCollection();
     }
 
     @Override
@@ -160,6 +161,12 @@ public class MongoBlobStore extends Cach
         return collection;
     }
 
+    private void initBlobCollection() {
+        if (!db.collectionExists(COLLECTION_BLOBS)) {
+            db.createCollection(COLLECTION_BLOBS, new BasicDBObject());
+        }
+    }
+
     private MongoBlob getBlob(String id, long lastMod) {
         DBObject query = getBlobQuery(id, lastMod);