summaryrefslogtreecommitdiff
path: root/jstests/mr_errorhandling.js
blob: 57724f14a883e9872e3e0e4c23581cd5d541015f (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

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 );
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 );
}
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 );
assert.eq( { 1 : 1 , 2 : 2 , 3 : 2 , 4 : 1 } , res.convertToSingleObject() , "A" );
res.drop()