Skip to content

Commit 40ee8d5

Browse files
nhachicharozza
andauthored
Fix NamespaceExists test failure (#1956)
* Drop test databases between Micrometer tracing tests --------- Co-authored-by: Ross Lawley <ross@mongodb.com>
1 parent 541af75 commit 40ee8d5

3 files changed

Lines changed: 24 additions & 0 deletions

File tree

driver-reactive-streams/src/test/functional/com/mongodb/reactivestreams/client/unified/MicrometerTracingTest.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,12 +16,21 @@
1616

1717
package com.mongodb.reactivestreams.client.unified;
1818

19+
import com.mongodb.client.unified.UnifiedTestModifications.TestDef;
1920
import org.junit.jupiter.params.provider.Arguments;
2021

2122
import java.util.Collection;
2223

24+
import static com.mongodb.client.Fixture.getMongoClient;
25+
2326
final class MicrometerTracingTest extends UnifiedReactiveStreamsTest {
2427
private static Collection<Arguments> data() {
2528
return getTestData("open-telemetry/tests");
2629
}
30+
31+
@Override
32+
protected void postCleanUp(final TestDef testDef) {
33+
super.postCleanUp(testDef);
34+
getEntities().getDatabaseNames().forEach(name -> getMongoClient().getDatabase(name).drop());
35+
}
2736
}

driver-sync/src/test/functional/com/mongodb/client/unified/Entities.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -189,6 +189,12 @@ public MongoDatabase getDatabase(final String id) {
189189
return getEntity(id, databases, "database");
190190
}
191191

192+
public Set<String> getDatabaseNames() {
193+
return databases.values().stream()
194+
.map(MongoDatabase::getName)
195+
.collect(Collectors.toSet());
196+
}
197+
192198
public boolean hasCollection(final String id) {
193199
return collections.containsKey(id);
194200
}

driver-sync/src/test/functional/com/mongodb/client/unified/MicrometerTracingTest.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,12 +16,21 @@
1616

1717
package com.mongodb.client.unified;
1818

19+
import com.mongodb.client.unified.UnifiedTestModifications.TestDef;
1920
import org.junit.jupiter.params.provider.Arguments;
2021

2122
import java.util.Collection;
2223

24+
import static com.mongodb.client.Fixture.getMongoClient;
25+
2326
final class MicrometerTracingTest extends UnifiedSyncTest {
2427
private static Collection<Arguments> data() {
2528
return getTestData("open-telemetry/tests");
2629
}
30+
31+
@Override
32+
protected void postCleanUp(final TestDef testDef) {
33+
super.postCleanUp(testDef);
34+
getEntities().getDatabaseNames().forEach(name -> getMongoClient().getDatabase(name).drop());
35+
}
2736
}

0 commit comments

Comments
 (0)