Disable tests of legacy wire protocol on 5.1+ servers

In 5.1+, the legacy wire protocol is no longer supported.  This includes

* OP_QUERY
* OP_INSERT
* OP_UPDATE
* OP_DELETE
* OP_KILL_CURSORS

Although none of these wire protocol messsage will be used in 5.1+ under
normal usage, there are integration tests in driver-core that test them directly,
and those have been disabled or modified so that they will work.

JAVA-4228

Author: jyemin

driver-core/src/test/functional/com/mongodb/internal/connection/GetMoreProtocolCommandEventSpecification.groovy

@@ -33,14 +33,16 @@ import org.bson.BsonInt64
 import org.bson.BsonString
 import org.bson.Document
 import org.bson.codecs.BsonDocumentCodec
+import spock.lang.IgnoreIf
 import spock.lang.Shared
 
 import static com.mongodb.ClusterFixture.getPrimary
 import static com.mongodb.ClusterFixture.getSslSettings
+import static com.mongodb.ClusterFixture.serverVersionGreaterThan
 import static com.mongodb.connection.ConnectionFixture.getCredentialListWithCache
 import static com.mongodb.internal.connection.ProtocolTestHelper.execute
 
-
+@IgnoreIf({ serverVersionGreaterThan('5.0') })
 class GetMoreProtocolCommandEventSpecification extends OperationFunctionalSpecification {
     @Shared
     InternalStreamConnection connection

driver-core/src/test/functional/com/mongodb/internal/connection/KillCursorProtocolCommandEventSpecification.groovy

@@ -30,14 +30,16 @@ import org.bson.BsonInt64
 import org.bson.BsonString
 import org.bson.Document
 import org.bson.codecs.BsonDocumentCodec
+import spock.lang.IgnoreIf
 import spock.lang.Shared
 
 import static com.mongodb.ClusterFixture.getPrimary
 import static com.mongodb.ClusterFixture.getSslSettings
+import static com.mongodb.ClusterFixture.serverVersionGreaterThan
 import static com.mongodb.connection.ConnectionFixture.getCredentialListWithCache
 import static com.mongodb.internal.connection.ProtocolTestHelper.execute
 
-
+@IgnoreIf({ serverVersionGreaterThan('5.0') })
 class KillCursorProtocolCommandEventSpecification extends OperationFunctionalSpecification {
     @Shared
     InternalStreamConnection connection;

driver-core/src/test/functional/com/mongodb/internal/connection/QueryProtocolCommandEventSpecification.groovy

@@ -42,11 +42,12 @@ import spock.lang.Shared
 import static com.mongodb.ClusterFixture.getPrimary
 import static com.mongodb.ClusterFixture.getSslSettings
 import static com.mongodb.ClusterFixture.isNotAtLeastJava7
+import static com.mongodb.ClusterFixture.serverVersionGreaterThan
 import static com.mongodb.connection.ConnectionFixture.getCredentialListWithCache
 import static com.mongodb.internal.connection.ProtocolTestHelper.execute
 import static org.bson.BsonDocument.parse
 
-@IgnoreIf({ isNotAtLeastJava7() || getSslSettings().isEnabled() })
+@IgnoreIf({ isNotAtLeastJava7() || getSslSettings().isEnabled() || serverVersionGreaterThan('5.0') })
 class QueryProtocolCommandEventSpecification extends OperationFunctionalSpecification {
     @Shared
     InternalStreamConnection nettyConnection

driver-core/src/test/functional/com/mongodb/internal/connection/WriteProtocolCommandEventSpecification.groovy

@@ -33,16 +33,18 @@ import org.bson.BsonDocument
 import org.bson.BsonInt32
 import org.bson.BsonString
 import org.bson.codecs.BsonDocumentCodec
+import spock.lang.IgnoreIf
 import spock.lang.Shared
 
 import static com.mongodb.ClusterFixture.getPrimary
 import static com.mongodb.ClusterFixture.getSslSettings
+import static com.mongodb.ClusterFixture.serverVersionGreaterThan
 import static com.mongodb.bulk.WriteRequest.Type.REPLACE
 import static com.mongodb.bulk.WriteRequest.Type.UPDATE
 import static com.mongodb.connection.ConnectionFixture.getCredentialListWithCache
 import static com.mongodb.internal.connection.ProtocolTestHelper.execute
 
-
+@IgnoreIf({ serverVersionGreaterThan('5.0') })
 class WriteProtocolCommandEventSpecification extends OperationFunctionalSpecification {
     @Shared
     InternalStreamConnection connection

driver-core/src/test/functional/com/mongodb/internal/connection/WriteProtocolSpecification.groovy

@@ -27,14 +27,16 @@ import org.bson.BsonDocument
 import org.bson.BsonInt32
 import org.bson.BsonString
 import org.bson.codecs.BsonDocumentCodec
+import spock.lang.IgnoreIf
 import spock.lang.Shared
 
 import static com.mongodb.ClusterFixture.getPrimary
 import static com.mongodb.ClusterFixture.getSslSettings
+import static com.mongodb.ClusterFixture.serverVersionGreaterThan
 import static com.mongodb.connection.ConnectionFixture.getCredentialListWithCache
 import static com.mongodb.internal.connection.ProtocolTestHelper.execute
 
-
+@IgnoreIf({ serverVersionGreaterThan('5.0') })
 class WriteProtocolSpecification extends OperationFunctionalSpecification {
     @Shared
     InternalStreamConnection connection;

driver-core/src/test/functional/com/mongodb/operation/AsyncQueryBatchCursorFunctionalSpecification.groovy

@@ -25,19 +25,23 @@ import com.mongodb.ReadPreference
 import com.mongodb.ServerCursor
 import com.mongodb.WriteConcern
 import com.mongodb.async.FutureResultCallback
-import com.mongodb.async.SingleResultCallback
 import com.mongodb.binding.AsyncConnectionSource
 import com.mongodb.binding.AsyncReadBinding
 import com.mongodb.client.model.CreateCollectionOptions
 import com.mongodb.connection.AsyncConnection
 import com.mongodb.connection.Connection
 import com.mongodb.connection.QueryResult
+import com.mongodb.internal.connection.NoOpSessionContext
+import com.mongodb.internal.validator.NoOpFieldNameValidator
+import org.bson.BsonArray
 import org.bson.BsonBoolean
 import org.bson.BsonDocument
 import org.bson.BsonInt32
+import org.bson.BsonInt64
 import org.bson.BsonString
 import org.bson.BsonTimestamp
 import org.bson.Document
+import org.bson.codecs.BsonDocumentCodec
 import org.bson.codecs.DocumentCodec
 import org.junit.experimental.categories.Category
 import spock.lang.IgnoreIf
@@ -58,6 +62,7 @@ import static com.mongodb.internal.connection.ServerHelper.waitForRelease
 import static com.mongodb.internal.operation.ServerVersionHelper.serverIsAtLeastVersionThreeDotTwo
 import static com.mongodb.operation.OperationHelper.cursorDocumentToQueryResult
 import static java.util.Arrays.asList
+import static java.util.Collections.singletonList
 import static java.util.concurrent.TimeUnit.SECONDS
 import static org.junit.Assert.assertEquals
 import static org.junit.Assert.fail
@@ -341,16 +346,17 @@ class AsyncQueryBatchCursorFunctionalSpecification extends OperationFunctionalSp
         when:
         cursor = new AsyncQueryBatchCursor<Document>(firstBatch, 0, 2, 0, new DocumentCodec(), connectionSource, connection)
 
-        def latch = new CountDownLatch(1)
         def connection = getConnection(connectionSource)
         def serverCursor = cursor.cursor.get()
-        connection.killCursorAsync(getNamespace(), asList(serverCursor.id), new SingleResultCallback<Void>() {
-            @Override
-            void onResult(final Void result, final Throwable t) {
-                latch.countDown()
-            }
-        })
-        latch.await()
+        if (serverVersionLessThan(3, 6)) {
+            connection.killCursor(getNamespace(), asList(cursor.getServerCursor().id))
+        } else {
+            connection.command(getNamespace().databaseName,
+                    new BsonDocument('killCursors', new BsonString(namespace.getCollectionName()))
+                            .append('cursors', new BsonArray(singletonList(new BsonInt64(serverCursor.getId())))),
+                    new NoOpFieldNameValidator(), ReadPreference.primary(),
+                    new BsonDocumentCodec(), new NoOpSessionContext())
+        }
         connection.release()
         nextBatch()
 

driver-core/src/test/functional/com/mongodb/operation/QueryBatchCursorFunctionalSpecification.groovy

@@ -27,12 +27,17 @@ import com.mongodb.binding.ConnectionSource
 import com.mongodb.client.model.CreateCollectionOptions
 import com.mongodb.connection.Connection
 import com.mongodb.connection.QueryResult
+import com.mongodb.internal.connection.NoOpSessionContext
+import com.mongodb.internal.validator.NoOpFieldNameValidator
+import org.bson.BsonArray
 import org.bson.BsonBoolean
 import org.bson.BsonDocument
 import org.bson.BsonInt32
+import org.bson.BsonInt64
 import org.bson.BsonString
 import org.bson.BsonTimestamp
 import org.bson.Document
+import org.bson.codecs.BsonDocumentCodec
 import org.bson.codecs.DocumentCodec
 import org.junit.experimental.categories.Category
 import spock.lang.IgnoreIf
@@ -45,9 +50,11 @@ import static com.mongodb.ClusterFixture.getBinding
 import static com.mongodb.ClusterFixture.isDiscoverableReplicaSet
 import static com.mongodb.ClusterFixture.isSharded
 import static com.mongodb.ClusterFixture.serverVersionAtLeast
-import static com.mongodb.operation.OperationHelper.cursorDocumentToQueryResult
+import static com.mongodb.ClusterFixture.serverVersionLessThan
 import static com.mongodb.internal.operation.ServerVersionHelper.serverIsAtLeastVersionThreeDotTwo
+import static com.mongodb.operation.OperationHelper.cursorDocumentToQueryResult
 import static java.util.Arrays.asList
+import static java.util.Collections.singletonList
 import static org.junit.Assert.assertEquals
 import static org.junit.Assert.fail
 
@@ -520,7 +527,15 @@ class QueryBatchCursorFunctionalSpecification extends OperationFunctionalSpecifi
         cursor = new QueryBatchCursor<Document>(firstBatch, 0, 2, new DocumentCodec(), connectionSource)
 
         def connection = connectionSource.getConnection()
-        connection.killCursor(getNamespace(), asList(cursor.getServerCursor().id))
+        if (serverVersionLessThan(3, 6)) {
+            connection.killCursor(getNamespace(), asList(cursor.getServerCursor().id))
+        } else {
+            connection.command(getNamespace().databaseName,
+                    new BsonDocument('killCursors', new BsonString(namespace.getCollectionName()))
+                            .append('cursors', new BsonArray(singletonList(new BsonInt64(cursor.getServerCursor().id)))),
+                    new NoOpFieldNameValidator(), ReadPreference.primary(),
+                    new BsonDocumentCodec(), new NoOpSessionContext())
+        }
         connection.release()
         cursor.next()