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
|
// Cannot implicitly shard accessed collections because of collection existing when none
// expected.
// @tags: [assumes_no_implicit_collection_creation_after_drop, does_not_support_stepdowns]
t = db.mr_errorhandling;
t.drop();
t.save({a: [1, 2, 3]});
t.save({a: [2, 3, 4]});
m_good = function() {
for (var i = 0; i < this.a.length; i++) {
emit(this.a[i], 1);
}
};
m_bad = function() {
for (var i = 0; i < this.a.length; i++) {
emit(this.a[i]);
}
};
r = function(k, v) {
var total = 0;
for (var i = 0; i < v.length; i++)
total += v[i];
return total;
};
res = t.mapReduce(m_good, r, "mr_errorhandling_out");
assert.eq({1: 1, 2: 2, 3: 2, 4: 1}, res.convertToSingleObject(), "A");
res.drop();
res = null;
theerror = null;
try {
res = t.mapReduce(m_bad, r, "mr_errorhandling_out");
} catch (e) {
theerror = e.toString();
}
assert.isnull(res, "B1");
assert(theerror, "B2");
assert(theerror.indexOf("emit") >= 0, "B3");
// test things are still in an ok state
res = t.mapReduce(m_good, r, "mr_errorhandling_out");
assert.eq({1: 1, 2: 2, 3: 2, 4: 1}, res.convertToSingleObject(), "A");
res.drop();
assert.throws(function() {
t.mapReduce(m_good, r, {out: "xxx", query: "foo"});
});
// Test namespace does not exist.
db.mr_nonexistent.drop();
assert.commandFailedWithCode(
db.runCommand({mapReduce: "mr_nonexistent", map: m_good, reduce: r, out: "out_nonexistent"}),
ErrorCodes.NamespaceNotFound);
|
