1
1
require . paths . unshift ( '../lib' ) ;
2
+ require . paths . unshift ( '../external-libs/bson' ) ;
2
3
3
4
var Db = require ( 'mongodb' ) . Db ,
4
5
Server = require ( 'mongodb' ) . Server ,
5
- ObjectID = require ( 'mongodb' ) . ObjectID ,
6
6
Cursor = require ( 'mongodb' ) . Cursor ,
7
7
Collection = require ( 'mongodb' ) . Collection ,
8
- sys = require ( 'sys' ) ;
8
+ sys = require ( 'sys' ) ;
9
+ var BSON = require ( 'bson' ) ;
9
10
10
- new Db ( 'streaming_benchmark' , new Server ( "127.0.0.1" , 27017 , { auto_reconnect : true } ) , { } ) . open ( function ( err , client ) {
11
+ var db = new Db ( 'streaming_benchmark' , new Server ( "127.0.0.1" , 27017 , { auto_reconnect : true } ) , { } )
12
+ // Set native deserializer
13
+ db . bson_deserializer = BSON ;
14
+ db . bson_serializer = BSON ;
15
+ db . pkFactory = BSON . ObjectID ;
16
+
17
+ // Open the db
18
+ db . open ( function ( err , client ) {
11
19
client . collection ( 'streaming_benchmark' , function ( err , collection ) {
12
20
collection . remove ( { } , function ( err , result ) {
13
21
// Benchmark
14
22
var started_at = new Date ( ) . getTime ( ) ;
15
23
// Add documents
16
24
for ( var i = 0 ; i < 100000 ; i ++ ) {
25
+ // for(var i = 0; i < 1000; i++) {
17
26
collection . save ( { 'i' :i , 'a' :i , 'c' :i , 'd' :{ 'i' :i } } , function ( err , result ) { } ) ;
18
27
}
19
28
sys . puts ( "save recs: " + ( ( new Date ( ) . getTime ( ) - started_at ) / 1000 ) + "seconds" ) ;
@@ -32,7 +41,7 @@ new Db('streaming_benchmark', new Server("127.0.0.1", 27017, {auto_reconnect: tr
32
41
if ( ( count % 10000 ) == 0 ) sys . puts ( "recs:" + count + " :: " +
33
42
( ( new Date ( ) . getTime ( ) - started_at ) / 1000 ) + "seconds" ) ;
34
43
} ) ;
35
- } ) ;
44
+ } ) ;
36
45
} )
37
46
} )
38
47
} ) ;
0 commit comments