Skip to content

Commit 095965c

Browse files
committed
Update change stream retryable reads tests
1 parent f9d7705 commit 095965c

File tree

3 files changed

+5
-4
lines changed

3 files changed

+5
-4
lines changed

driver-core/src/test/functional/com/mongodb/client/CommandMonitoringTestHelper.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,8 @@ public static List<CommandEvent> getExpectedEvents(final BsonArray expectedEvent
7676
String commandName = eventDescriptionDocument.getString("command_name", new BsonString("")).getValue();
7777
if (eventType.equals("command_started_event")) {
7878
BsonDocument commandDocument = eventDescriptionDocument.getDocument("command");
79-
String actualDatabaseName = databaseName;
79+
String actualDatabaseName = eventDescriptionDocument.containsKey("database_name")
80+
? eventDescriptionDocument.getString("database_name").getValue() : databaseName;
8081
// If the spec test supplies a $db field in the command, then use that database.
8182
if (commandDocument.containsKey("$db")) {
8283
actualDatabaseName = commandDocument.getString("$db").getValue();

driver-core/src/test/resources/retryable-reads/changeStreams-client.watch-serverErrors.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
]
1414
}
1515
],
16-
"database_name": "admin",
16+
"database_name": "retryable-reads-tests",
1717
"collection_name": "coll",
1818
"data": [
1919
{

driver-core/src/test/resources/retryable-reads/changeStreams-client.watch.json

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
]
1414
}
1515
],
16-
"database_name": "admin",
16+
"database_name": "retryable-reads-tests",
1717
"collection_name": "coll",
1818
"data": [
1919
{
@@ -204,7 +204,7 @@
204204
}
205205
]
206206
},
207-
"database_name": "admin"
207+
"database_name": "admin"
208208
}
209209
}
210210
]

0 commit comments

Comments
 (0)