1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
(function() {
'use strict';
var conn = MongoRunner.runMongod({auth: "", nojournal: ""});
var admin = conn.getDB("admin");
var data = conn.getDB("data_storage");
admin.createUser({user: 'admin', pwd: 'admin', roles: jsTest.adminUserRoles});
admin.auth("admin", "admin");
data.createUser({user: 'admin', pwd: 'admin', roles: jsTest.basicUserRoles});
data.createUser({user: 'user0', pwd: 'password', roles: jsTest.basicUserRoles});
admin.logout();
data.auth("user0", "password");
assert.writeOK(data.test.insert({name: "first", data: 1}));
assert.writeOK(data.test.insert({name: "second", data: 2}));
// Test that getMore works correctly on the same session.
{
var session1 = conn.startSession();
var session2 = conn.startSession();
var res = assert.commandWorked(
session1.getDatabase("data_storage").runCommand({find: "test", batchSize: 0}));
var cursorId = res.cursor.id;
assert.commandWorked(session1.getDatabase("data_storage")
.runCommand({getMore: cursorId, collection: "test"}));
session2.endSession();
session1.endSession();
}
// Test that getMore correctly gives an error, when using a cursor on a different session.
{
var session1 = conn.startSession();
var session2 = conn.startSession();
var res = assert.commandWorked(
session1.getDatabase("data_storage").runCommand({find: "test", batchSize: 0}));
var cursorId = res.cursor.id;
assert.commandFailed(session2.getDatabase("data_storage")
.runCommand({getMore: cursorId, collection: "test"}));
session2.endSession();
session1.endSession();
}
MongoRunner.stopMongod(conn);
})();
|
