Move legacy write operations into driver-legacy (#1030)

JAVA-4795

Author: jyemin

driver-core/src/main/com/mongodb/internal/operation/DeleteOperation.java

@@ -49,7 +49,7 @@ import com.mongodb.internal.connection.ServerHelper
 import com.mongodb.internal.connection.SplittablePayload
 import com.mongodb.internal.operation.AsyncReadOperation
 import com.mongodb.internal.operation.AsyncWriteOperation
-import com.mongodb.internal.operation.InsertOperation
+import com.mongodb.internal.operation.MixedBulkWriteOperation
 import com.mongodb.internal.operation.ReadOperation
 import com.mongodb.internal.operation.WriteOperation
 import com.mongodb.internal.session.SessionContext
@@ -108,12 +108,13 @@ class OperationFunctionalSpecification extends Specification {
     }
 
     void acknowledgeWrite(final SingleConnectionBinding binding) {
-        new InsertOperation(getNamespace(), true, ACKNOWLEDGED, false, [new InsertRequest(new BsonDocument())]).execute(binding)
+        new MixedBulkWriteOperation(getNamespace(), [new InsertRequest(new BsonDocument())], true, ACKNOWLEDGED, false).execute(binding)
         binding.release()
     }
 
     void acknowledgeWrite(final AsyncSingleConnectionBinding binding) {
-        executeAsync(new InsertOperation(getNamespace(), true, ACKNOWLEDGED, false, [new InsertRequest(new BsonDocument())]), binding)
+        executeAsync(new MixedBulkWriteOperation(getNamespace(), [new InsertRequest(new BsonDocument())], true, ACKNOWLEDGED, false),
+                binding)
         binding.release()
     }
 
@@ -129,6 +130,10 @@ class OperationFunctionalSpecification extends Specification {
         new CollectionHelper<Worker>(new WorkerCodec(), getNamespace())
     }
 
+    def execute(operation) {
+        execute(operation, false)
+    }
+
     def execute(operation, boolean async) {
         def executor = async ? ClusterFixture.&executeAsync : ClusterFixture.&executeSync
         executor(operation)

driver-core/src/main/com/mongodb/internal/operation/InsertOperation.java

@@ -42,7 +42,6 @@
 import com.mongodb.internal.operation.DropCollectionOperation;
 import com.mongodb.internal.operation.DropDatabaseOperation;
 import com.mongodb.internal.operation.FindOperation;
-import com.mongodb.internal.operation.InsertOperation;
 import com.mongodb.internal.operation.ListIndexesOperation;
 import com.mongodb.internal.operation.MixedBulkWriteOperation;
 import org.bson.BsonArray;
@@ -191,7 +190,7 @@ public void insertDocuments(final List<BsonDocument> documents, final WriteConce
         for (BsonDocument document : documents) {
             insertRequests.add(new InsertRequest(document));
         }
-        new InsertOperation(namespace, true, writeConcern, false, insertRequests).execute(binding);
+        new MixedBulkWriteOperation(namespace, insertRequests, true, writeConcern, false).execute(binding);
     }
 
     public void insertDocuments(final Document... documents) {

driver-core/src/main/com/mongodb/internal/operation/UpdateOperation.java

@@ -16,10 +16,10 @@
 
 package com.mongodb.internal.operation
 
+import com.mongodb.MongoBulkWriteException
 import com.mongodb.MongoWriteConcernException
 import com.mongodb.OperationFunctionalSpecification
 import com.mongodb.WriteConcern
-import com.mongodb.WriteConcernException
 import com.mongodb.client.model.ValidationAction
 import com.mongodb.client.model.ValidationLevel
 import org.bson.BsonDocument
@@ -241,8 +241,8 @@ class CreateCollectionOperationSpecification extends OperationFunctionalSpecific
         getCollectionHelper().insertDocuments(BsonDocument.parse('{ level: 8}'))
 
         then:
-        WriteConcernException writeConcernException = thrown()
-        writeConcernException.getErrorCode() == 121
+        MongoBulkWriteException writeConcernException = thrown()
+        writeConcernException.getWriteErrors().get(0).getCode() == 121
 
         where:
         async << [true, false]