diff --git a/driver-sync/src/test/functional/com/mongodb/client/unified/UnifiedCrudHelper.java b/driver-sync/src/test/functional/com/mongodb/client/unified/UnifiedCrudHelper.java index 0c91057aee..3b7c371e63 100644 --- a/driver-sync/src/test/functional/com/mongodb/client/unified/UnifiedCrudHelper.java +++ b/driver-sync/src/test/functional/com/mongodb/client/unified/UnifiedCrudHelper.java @@ -638,6 +638,9 @@ OperationResult executeFindOneAndUpdate(final BsonDocument operation) { case "arrayFilters": options.arrayFilters(cur.getValue().asArray().stream().map(BsonValue::asDocument).collect(toList())); break; + case "bypassDocumentValidation": + options.bypassDocumentValidation(cur.getValue().asBoolean().getValue()); + break; default: throw new UnsupportedOperationException("Unsupported argument: " + cur.getKey()); } @@ -714,6 +717,9 @@ OperationResult executeFindOneAndReplace(final BsonDocument operation) { case "collation": options.collation(asCollation(cur.getValue().asDocument())); break; + case "bypassDocumentValidation": + options.bypassDocumentValidation(cur.getValue().asBoolean().getValue()); + break; default: throw new UnsupportedOperationException("Unsupported argument: " + cur.getKey()); } @@ -831,6 +837,9 @@ OperationResult executeAggregate(final BsonDocument operation) { case "maxAwaitTimeMS": iterable.maxAwaitTime(cur.getValue().asNumber().longValue(), TimeUnit.MILLISECONDS); break; + case "bypassDocumentValidation": + iterable.bypassDocumentValidation(cur.getValue().asBoolean().getValue()); + break; default: throw new UnsupportedOperationException("Unsupported argument: " + cur.getKey()); } @@ -981,6 +990,9 @@ OperationResult executeInsertOne(final BsonDocument operation) { case "comment": options.comment(cur.getValue()); break; + case "bypassDocumentValidation": + options.bypassDocumentValidation(cur.getValue().asBoolean().getValue()); + break; default: throw new UnsupportedOperationException("Unsupported argument: " + cur.getKey()); } @@ -1018,6 +1030,9 @@ OperationResult executeInsertMany(final BsonDocument operation) { case "comment": options.comment(cur.getValue()); break; + case "bypassDocumentValidation": + options.bypassDocumentValidation(cur.getValue().asBoolean().getValue()); + break; default: throw new UnsupportedOperationException("Unsupported argument: " + cur.getKey()); } @@ -1062,6 +1077,9 @@ OperationResult executeBulkWrite(final BsonDocument operation) { case "let": options.let(cur.getValue().asDocument()); break; + case "bypassDocumentValidation": + options.bypassDocumentValidation(cur.getValue().asBoolean().getValue()); + break; default: throw new UnsupportedOperationException("Unsupported argument: " + cur.getKey()); } @@ -1192,6 +1210,9 @@ private UpdateOptions getUpdateOptions(final BsonDocument arguments) { case "sort": options.sort(cur.getValue().asDocument()); break; + case "bypassDocumentValidation": + options.bypassDocumentValidation(cur.getValue().asBoolean().getValue()); + break; default: throw new UnsupportedOperationException("Unsupported argument: " + cur.getKey()); } @@ -1229,6 +1250,9 @@ private ReplaceOptions getReplaceOptions(final BsonDocument arguments) { case "sort": options.sort(cur.getValue().asDocument()); break; + case "bypassDocumentValidation": + options.bypassDocumentValidation(cur.getValue().asBoolean().getValue()); + break; default: throw new UnsupportedOperationException("Unsupported argument: " + cur.getKey()); } diff --git a/driver-sync/src/test/functional/com/mongodb/client/unified/UnifiedTestModifications.java b/driver-sync/src/test/functional/com/mongodb/client/unified/UnifiedTestModifications.java index 2d4d4f49b2..4dc336da3c 100644 --- a/driver-sync/src/test/functional/com/mongodb/client/unified/UnifiedTestModifications.java +++ b/driver-sync/src/test/functional/com/mongodb/client/unified/UnifiedTestModifications.java @@ -168,8 +168,6 @@ public static void applyCustomizations(final TestDef def) { .when(() -> def.isReactive() && UnifiedTest.Language.KOTLIN.equals(def.getLanguage())) .file("crud", "findOne"); - def.skipJira("https://jira.mongodb.org/browse/JAVA-5827") - .file("crud", "bypassDocumentValidation"); def.skipNoncompliant("Updates and Replace bulk operations are split in the java driver") .file("crud", "bulkWrite-comment");