refs #337: upgrade for 3.7

fakemongo · Jun 5, 2018 · d82f732 · d82f732
1 parent 2cc5b3f
commit d82f732
Show file tree

Hide file tree

Showing 7 changed files with 27 additions and 16 deletions.
diff --git a/pom.xml b/pom.xml
@@ -73,13 +73,13 @@
         <dependency>
             <groupId>org.mongodb</groupId>
             <artifactId>mongo-java-driver</artifactId>
-            <version>3.6.2</version>
+            <version>3.7.0</version>
             <scope>provided</scope>
         </dependency>
         <dependency>
             <groupId>org.mongodb</groupId>
             <artifactId>mongodb-driver-async</artifactId>
-            <version>3.6.2</version>
+            <version>3.7.0</version>
             <scope>provided</scope>
         </dependency>
         <dependency>

diff --git a/src/main/java/com/github/fakemongo/FongoConnection.java b/src/main/java/com/github/fakemongo/FongoConnection.java
@@ -320,7 +320,7 @@ public BulkWriteResult insertCommand(MongoNamespace namespace, boolean ordered,
 
   private void validateCollectionName(String collectionName) {
     if (collectionName == null || collectionName.isEmpty() || collectionName.startsWith("system.")
-            || collectionName.contains("$") || collectionName.contains("\0"))
+        || collectionName.contains("$") || collectionName.contains("\0"))
       throw new IllegalArgumentException("Invalid collection name " + collectionName);
   }
 
@@ -616,12 +616,10 @@ public <T> T command(String database, BsonDocument command, FieldNameValidator c
         if (payload.hasAnotherSplit()) {
           documentsToDelete = Collections.singletonList(payload.getPayload().get(payload.getPosition()));
           payload.setPosition(payload.getPosition() + 1);
-        }
-        else {
+        } else {
           documentsToDelete = Collections.emptyList();
         }
-      }
-      else {
+      } else {
         documentsToDelete = command.getArray("deletes").getValues();
       }
 
@@ -658,8 +656,7 @@ public <T> T command(String database, BsonDocument command, FieldNameValidator c
 
       if (payload != null) {
         return (T) new BsonDocument("ok", new BsonInt32(1)).append("n", new BsonInt32(numDocsDeleted));
-      }
-      else {
+      } else {
         return (T) new Document("ok", 1).append("n", numDocsDeleted);
       }
     } else if (command.containsKey("find")) {

diff --git a/src/main/java/com/mongodb/MockMongoClient.java b/src/main/java/com/mongodb/MockMongoClient.java
@@ -4,6 +4,9 @@
 import com.github.fakemongo.FongoConnection;
 import com.mongodb.async.SingleResultCallback;
 import com.mongodb.client.MongoDatabase;
+import com.mongodb.client.internal.FongoMongoDatabase;
+import com.mongodb.client.internal.FongoOperationExecutor;
+import com.mongodb.client.internal.OperationExecutor;
 import com.mongodb.connection.AsyncConnection;
 import com.mongodb.connection.BufferProvider;
 import com.mongodb.connection.Cluster;
@@ -186,7 +189,7 @@ public boolean isClosed() {
     };
   }
 
-  com.mongodb.OperationExecutor createOperationExecutor() {
+  OperationExecutor createOperationExecutor() {
     return new FongoOperationExecutor(fongo);
   }
 

diff --git a/...ava/com/mongodb/FongoMongoCollection.java → ...client/internal/FongoMongoCollection.java b/...ava/com/mongodb/FongoMongoCollection.java → ...client/internal/FongoMongoCollection.java
@@ -1,11 +1,15 @@
-package com.mongodb;
+package com.mongodb.client.internal;
 
 import com.github.fakemongo.Fongo;
+import com.mongodb.DBCollection;
+import com.mongodb.DBObject;
+import com.mongodb.MongoNamespace;
+import com.mongodb.ReadConcern;
+import com.mongodb.ReadPreference;
+import com.mongodb.WriteConcern;
 import com.mongodb.client.MongoCollection;
 import com.mongodb.client.model.CountOptions;
 import com.mongodb.client.model.IndexModel;
-import com.mongodb.client.model.UpdateOptions;
-import com.mongodb.client.result.UpdateResult;
 import com.mongodb.util.FongoJSON;
 import java.util.ArrayList;
 import java.util.List;

diff --git a/.../java/com/mongodb/FongoMongoDatabase.java → ...b/client/internal/FongoMongoDatabase.java b/.../java/com/mongodb/FongoMongoDatabase.java → ...b/client/internal/FongoMongoDatabase.java
@@ -1,6 +1,10 @@
-package com.mongodb;
+package com.mongodb.client.internal;
 
 import com.github.fakemongo.Fongo;
+import com.mongodb.MongoNamespace;
+import com.mongodb.ReadConcern;
+import com.mongodb.ReadPreference;
+import com.mongodb.WriteConcern;
 import com.mongodb.client.MongoCollection;
 import com.mongodb.client.MongoDatabase;
 import org.bson.codecs.configuration.CodecRegistry;

diff --git a/...a/com/mongodb/FongoOperationExecutor.java → ...ient/internal/FongoOperationExecutor.java b/...a/com/mongodb/FongoOperationExecutor.java → ...ient/internal/FongoOperationExecutor.java
@@ -1,9 +1,11 @@
 /**
  * Copyright (C) 2017 Deveryware S.A. All Rights Reserved.
  */
-package com.mongodb;
+package com.mongodb.client.internal;
 
 import com.github.fakemongo.Fongo;
+import com.mongodb.ReadPreference;
+import com.mongodb.client.internal.OperationExecutor;
 import com.mongodb.operation.ReadOperation;
 import com.mongodb.operation.WriteOperation;
 import com.mongodb.session.ClientSession;
@@ -14,7 +16,7 @@
 public class FongoOperationExecutor implements OperationExecutor {
   private final Fongo fongo;
 
-  FongoOperationExecutor(Fongo fongo) {
+  public FongoOperationExecutor(Fongo fongo) {
     this.fongo = fongo;
   }
 

diff --git a/src/test/java/com/mongodb/FongoMongoDatabaseTest.java b/src/test/java/com/mongodb/FongoMongoDatabaseTest.java
@@ -3,6 +3,7 @@
 import com.github.fakemongo.Fongo;
 import static com.mongodb.WriteConcern.REPLICA_ACKNOWLEDGED;
 import com.mongodb.client.MongoDatabase;
+import com.mongodb.client.internal.FongoMongoDatabase;
 import static org.assertj.core.api.Assertions.assertThat;
 import org.bson.codecs.configuration.CodecRegistry;
 import org.junit.Before;