Skip to content

Commit

Permalink
Update DatabaseTestCase to Junit 5 (#1238)
Browse files Browse the repository at this point in the history
  • Loading branch information
rozza committed Oct 31, 2023
1 parent fd8352f commit 8043b35
Show file tree
Hide file tree
Showing 21 changed files with 92 additions and 89 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -17,8 +17,8 @@
package com.mongodb.reactivestreams.client;

import org.bson.Document;
import org.junit.After;
import org.junit.Before;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;

import static com.mongodb.ClusterFixture.getDefaultDatabaseName;
import static com.mongodb.reactivestreams.client.Fixture.drop;
Expand All @@ -32,15 +32,15 @@ public class DatabaseTestCase {
protected MongoCollection<Document> collection;
//CHECKSTYLE:ON

@Before
@BeforeEach
public void setUp() {
client = getMongoClient();
database = client.getDatabase(getDefaultDatabaseName());
collection = database.getCollection(getClass().getName());
drop(collection.getNamespace());
}

@After
@AfterEach
public void tearDown() {
if (collection != null) {
drop(collection.getNamespace());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@

import com.mongodb.client.RetryableWritesProseTest;
import com.mongodb.reactivestreams.client.syncadapter.SyncMongoClient;
import org.junit.Test;
import org.junit.jupiter.api.Test;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeoutException;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,8 @@
import com.mongodb.reactivestreams.client.syncadapter.SyncMongoClient;
import org.bson.Document;
import org.bson.codecs.DocumentCodec;
import org.junit.Before;
import org.junit.Test;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Mono;

import java.util.concurrent.ExecutionException;
Expand All @@ -35,9 +35,9 @@
import static com.mongodb.ClusterFixture.isSharded;
import static com.mongodb.ClusterFixture.serverVersionAtLeast;
import static com.mongodb.ClusterFixture.serverVersionLessThan;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
import static org.junit.Assume.assumeTrue;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assumptions.assumeTrue;

/**
* See
Expand All @@ -46,7 +46,7 @@
public class RetryableWritesProseTest extends DatabaseTestCase {
private CollectionHelper<Document> collectionHelper;

@Before
@BeforeEach
@Override
public void setUp() {
super.setUp();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,31 +19,32 @@
import com.mongodb.ClientSessionOptions;
import com.mongodb.MongoClientException;
import org.bson.Document;
import org.junit.Before;
import org.junit.Test;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Mono;

import static com.mongodb.ClusterFixture.TIMEOUT_DURATION;
import static com.mongodb.ClusterFixture.isSharded;
import static com.mongodb.ClusterFixture.serverVersionLessThan;
import static org.junit.Assume.assumeTrue;
import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.junit.jupiter.api.Assumptions.assumeTrue;

public class TransactionFailureTest extends DatabaseTestCase {
public TransactionFailureTest() {
}

@Before
@BeforeEach
public void setUp() {
assumeTrue(canRunTests());
super.setUp();
}

@Test(expected = MongoClientException.class)
@Test
public void testTransactionFails() {

try (ClientSession clientSession = createSession()) {
clientSession.startTransaction();
Mono.from(collection.insertOne(clientSession, Document.parse("{_id: 1, a: 1}"))).block(TIMEOUT_DURATION);
assertThrows(MongoClientException.class, () ->
Mono.from(collection.insertOne(clientSession, Document.parse("{_id: 1, a: 1}"))).block(TIMEOUT_DURATION));
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,8 +25,8 @@
import org.bson.BsonString;
import org.bson.Document;
import org.bson.codecs.DocumentCodec;
import org.junit.Before;
import org.junit.Test;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Mono;

import static com.mongodb.ClusterFixture.TIMEOUT_DURATION;
Expand All @@ -35,16 +35,16 @@
import static com.mongodb.reactivestreams.client.Fixture.getDefaultDatabaseName;
import static java.lang.String.format;
import static java.util.Arrays.asList;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.fail;
import static org.junit.Assume.assumeTrue;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.fail;
import static org.junit.jupiter.api.Assumptions.assumeTrue;

// See https://github.com/mongodb/specifications/tree/master/source/change-streams/tests/README.rst#prose-tests
public class WriteConcernProseTest extends DatabaseTestCase {
private BsonDocument failPointDocument;
private CollectionHelper<Document> collectionHelper;

@Before
@BeforeEach
@Override
public void setUp() {
assumeTrue(canRunTests());
Expand Down
12 changes: 6 additions & 6 deletions driver-sync/src/examples/documentation/DocumentationSamples.java
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,8 @@
import org.bson.BsonType;
import org.bson.Document;
import org.bson.conversions.Bson;
import org.junit.After;
import org.junit.Test;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Test;

import java.util.ArrayList;
import java.util.Arrays;
Expand Down Expand Up @@ -79,9 +79,9 @@
import static com.mongodb.client.model.Updates.set;
import static java.util.Arrays.asList;
import static java.util.Collections.singletonList;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
import static org.junit.Assume.assumeTrue;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assumptions.assumeTrue;

// imports required for change streams
// end required change streams imports
Expand Down Expand Up @@ -738,7 +738,7 @@ public void testCreateIndexes() {
// End Index Example 2
}

@After
@AfterEach
public void tearDown() {
collection.drop();
}
Expand Down
2 changes: 1 addition & 1 deletion driver-sync/src/examples/primer/AggregatePrimer.java
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@

import com.mongodb.client.AggregateIterable;
import org.bson.Document;
import org.junit.Test;
import org.junit.jupiter.api.Test;

import static java.util.Arrays.asList;

Expand Down
2 changes: 1 addition & 1 deletion driver-sync/src/examples/primer/IndexesPrimer.java
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@

package primer;

import org.junit.Test;
import org.junit.jupiter.api.Test;

// @imports: start
import org.bson.Document;
Expand Down
2 changes: 1 addition & 1 deletion driver-sync/src/examples/primer/InsertPrimer.java
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@

package primer;

import org.junit.Test;
import org.junit.jupiter.api.Test;

// @imports: start
import org.bson.Document;
Expand Down
2 changes: 1 addition & 1 deletion driver-sync/src/examples/primer/QueryPrimer.java
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@

import com.mongodb.client.FindIterable;
import org.bson.Document;
import org.junit.Test;
import org.junit.jupiter.api.Test;

import static com.mongodb.client.model.Filters.and;
import static com.mongodb.client.model.Filters.eq;
Expand Down
2 changes: 1 addition & 1 deletion driver-sync/src/examples/primer/RemovePrimer.java
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@

package primer;

import org.junit.Test;
import org.junit.jupiter.api.Test;

// @import: start
import org.bson.Document;
Expand Down
2 changes: 1 addition & 1 deletion driver-sync/src/examples/primer/UpdatePrimer.java
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@

package primer;

import org.junit.Test;
import org.junit.jupiter.api.Test;

// @import: start
import org.bson.Document;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,29 +34,30 @@
import org.bson.BsonInt32;
import org.bson.BsonString;
import org.bson.Document;
import org.junit.Before;
import org.junit.Test;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

import java.lang.reflect.Field;

import static com.mongodb.ClusterFixture.isDiscoverableReplicaSet;
import static com.mongodb.ClusterFixture.serverVersionAtLeast;
import static com.mongodb.ClusterFixture.serverVersionLessThan;
import static com.mongodb.client.model.Updates.set;
import static com.mongodb.client.CrudTestHelper.repeat;
import static com.mongodb.client.model.Updates.set;
import static java.util.Arrays.asList;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertTrue;
import static org.junit.Assume.assumeTrue;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assumptions.assumeTrue;


// See https://github.com/mongodb/specifications/tree/master/source/change-streams/tests/README.rst#prose-tests
public class ChangeStreamProseTest extends DatabaseTestCase {
private BsonDocument failPointDocument;

@Before
@BeforeEach
@Override
public void setUp() {
assumeTrue(canRunTests());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,27 +27,27 @@
import org.bson.BsonInt32;
import org.bson.BsonString;
import org.bson.Document;
import org.junit.Before;
import org.junit.Test;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

import static com.mongodb.ClusterFixture.isDiscoverableReplicaSet;
import static com.mongodb.ClusterFixture.serverVersionAtLeast;
import static java.lang.String.format;
import static java.util.Arrays.asList;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
import static org.junit.Assume.assumeTrue;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assertions.fail;
import static org.junit.jupiter.api.Assumptions.assumeTrue;

/**
* See https://github.com/mongodb/specifications/blob/master/source/crud/tests/README.rst#prose-tests
*/
public class CrudProseTest extends DatabaseTestCase {
private BsonDocument failPointDocument;

@Before
@BeforeEach
@Override
public void setUp() {
super.setUp();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,8 +23,8 @@
import org.bson.BsonDocumentWrapper;
import org.bson.Document;
import org.bson.codecs.DocumentCodec;
import org.junit.After;
import org.junit.Before;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;

import static com.mongodb.client.Fixture.getDefaultDatabaseName;
import static com.mongodb.client.Fixture.getMongoClient;
Expand All @@ -38,15 +38,15 @@ public class DatabaseTestCase {
protected MongoCollection<Document> collection;
//CHECKSTYLE:ON

@Before
@BeforeEach
public void setUp() {
client = getMongoClient();
database = client.getDatabase(getDefaultDatabaseName());
collection = database.getCollection(getClass().getName());
collection.drop();
}

@After
@AfterEach
public void tearDown() {
if (collection != null) {
collection.drop();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@
import org.bson.codecs.pojo.entities.conventions.BsonRepresentationModel;
import org.bson.json.JsonObject;
import org.bson.types.ObjectId;
import org.junit.Test;
import org.junit.jupiter.api.Test;

import java.util.ArrayList;
import java.util.Collections;
Expand All @@ -47,10 +47,10 @@
import static org.bson.codecs.configuration.CodecRegistries.fromRegistries;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import static org.junit.Assume.assumeFalse;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assumptions.assumeFalse;

public class MongoCollectionTest extends DatabaseTestCase {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@

package com.mongodb.client;

import org.junit.Test;
import org.junit.jupiter.api.Test;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeoutException;
Expand Down
Loading

0 comments on commit 8043b35

Please sign in to comment.