summaryrefslogtreecommitdiff
path: root/jstests/change_streams/change_stream.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/change_streams/change_stream.js')
-rw-r--r--jstests/change_streams/change_stream.js10
1 files changed, 9 insertions, 1 deletions
diff --git a/jstests/change_streams/change_stream.js b/jstests/change_streams/change_stream.js
index 80356aa3b48..59e8df872f1 100644
--- a/jstests/change_streams/change_stream.js
+++ b/jstests/change_streams/change_stream.js
@@ -6,10 +6,18 @@
load("jstests/libs/change_stream_util.js");
load('jstests/libs/uuid_util.js');
+ jsTestLog("Testing $changeStream on non-existent database");
+ const dbDoesNotExist = db.getSiblingDB("database-does-not-exist");
+ assert.commandWorked(dbDoesNotExist.dropDatabase());
+ assert.commandFailedWithCode(
+ dbDoesNotExist.runCommand(
+ {aggregate: dbDoesNotExist.getName(), pipeline: [{$changeStream: {}}], cursor: {}}),
+ ErrorCodes.NamespaceNotFound);
+
let cst = new ChangeStreamTest(db);
jsTestLog("Testing single insert");
- assertDropCollection(db, "t1");
+ assertDropAndRecreateCollection(db, "t1");
let cursor = cst.startWatchingChanges({pipeline: [{$changeStream: {}}], collection: db.t1});
// Test that if there are no changes, we return an empty batch.
assert.eq(0, cursor.firstBatch.length, "Cursor had changes: " + tojson(cursor));