blob: aff44fe900ddf758b67f62fe95ffe56563214638 (
plain)
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
48
49
50
51
52
53
54
55
56
57
58
59
|
/**
* Tests support for unprepared transactions larger than 16MB.
*
* @tags: [uses_transactions]
*/
(function() {
"use strict";
const dbName = "test";
const collName = "large_unprepared_transactions";
const testDB = db.getSiblingDB(dbName);
const testColl = testDB.getCollection(collName);
// As we are not able to send a single request larger than 16MB, we insert two documents
// of 10MB each to create a "large" transaction.
const kSize10MB = 10 * 1024 * 1024;
function createLargeDocument(id) {
return {_id: id, longString: new Array(kSize10MB).join("a")};
}
testColl.drop({writeConcern: {w: "majority"}});
assert.commandWorked(testDB.createCollection(testColl.getName(), {writeConcern: {w: "majority"}}));
const session = db.getMongo().startSession({causalConsistency: false});
const sessionDB = session.getDatabase(dbName);
const sessionColl = sessionDB.getCollection(collName);
// Test committing an unprepared large transaction with two 10MB inserts.
try {
let doc1 = createLargeDocument(1);
let doc2 = createLargeDocument(2);
session.startTransaction();
assert.commandWorked(sessionColl.insert(doc1));
assert.commandWorked(sessionColl.insert(doc2));
assert.commandWorked(session.commitTransaction_forTesting());
assert.sameMembers(sessionColl.find().toArray(), [doc1, doc2]);
} catch (e) {
// It may be possible for this test to run in a passthrough where such a large transaction fills
// up the cache and cannot commit. The transaction will be rolled-back with a WriteConflict as a
// result.
if (e.code === ErrorCodes.WriteConflict && e.errmsg.startsWith("Cache full")) {
jsTestLog("Ignoring WriteConflict due to large transaction's size");
} else {
throw e;
}
}
// Test aborting an unprepared large transaction with two 10MB inserts.
let doc3 = createLargeDocument(3);
let doc4 = createLargeDocument(4);
session.startTransaction();
assert.commandWorked(sessionColl.insert(doc3));
assert.commandWorked(sessionColl.insert(doc4));
assert.commandWorked(session.abortTransaction_forTesting());
assert.sameMembers(sessionColl.find({_id: {$gt: 2}}).toArray(), []);
}());
|
