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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
"use strict"
// check that shell writeconcern work correctly
// 1.) tests that it can be set on each level and is inherited
// 2.) tests that each operation (update/insert/remove/save) take and ensure a write concern
var collA = db.shell_wc_a;
var collB = db.shell_wc_b;
collA.drop()
collB.drop()
// test inheritance
db.setWriteConcern({w:1})
assert.eq(1, db.getWriteConcern().toJSON().w)
assert.eq(1, collB.getWriteConcern().toJSON().w)
collA.setWriteConcern({w:2})
assert.eq(2, collA.getWriteConcern().toJSON().w)
collA.unsetWriteConcern()
assert.eq(1, collA.getWriteConcern().toJSON().w)
db.unsetWriteConcern()
assert.eq(undefined, collA.getWriteConcern())
assert.eq(undefined, collB.getWriteConcern())
assert.eq(undefined, db.getWriteConcern())
// test methods, by generating an error
var res = assert.writeOK(collA.save({_id:1}, {writeConcern:{w:1}}));
if (!db.getMongo().useWriteCommands() ) {
assert.eq(1, res.n, tojson(res));
assert.eq(1, res.upserted, tojson(res));
} else {
assert.eq(1, res.nUpserted, tojson(res));
}
var res = assert.writeOK(collA.update({_id:1}, {_id:1}, {writeConcern:{w:1}}));
if (!db.getMongo().useWriteCommands() ) {
assert.eq(1, res.n, tojson(res));
} else {
assert.eq(1, res.nMatched, tojson(res));
}
var res = assert.writeOK(collA.update({_id:1}, {_id:1}, {writeConcern:{w:1}}));
if (!db.getMongo().useWriteCommands() ) {
assert.eq(1, res.n, tojson(res));
} else {
assert.eq(1, res.nMatched, tojson(res));
}
var res = assert.writeOK(collA.insert({_id:2}, {writeConcern:{w:1}}));
if (!db.getMongo().useWriteCommands() ) {
assert.eq(0, res.n, tojson(res));
} else {
assert.eq(1, res.nInserted, tojson(res));
}
var res = assert.writeOK(collA.remove({_id:3}, {writeConcern:{w:1}}));
if (!db.getMongo().useWriteCommands() ) {
assert.eq(0, res.n, tojson(res));
} else {
assert.eq(0, res.nRemoved, tojson(res));
}
var res = assert.writeOK(collA.remove({}, {justOne:true, writeConcern:{w:1}}));
if (!db.getMongo().useWriteCommands() ) {
assert.eq(1, res.n, tojson(res));
} else {
assert.eq(1, res.nRemoved, tojson(res));
}
// Test ordered write concern, and that the write concern isn't run/error.
assert.writeOK(collA.insert({_id:1}));
var res = assert.writeError(collA.insert([{_id:1}, {_id:1}], {ordered:true, writeConcern:{w:1}}));
assert.eq(1, res.getWriteErrors().length, tojson(res));
assert.eq(undefined, res.writeConcernErrors, tojson(res));
var res = assert.writeError(collA.insert([{_id:1}, {_id:1}], {ordered:false, writeConcern:{w:1}}));
assert.eq(2, res.getWriteErrors().length, tojson(res))
assert.eq(undefined, res.writeConcernErrors, tojson(res))
|
