Renamed insert bench

pull/2/head
Louis Chatriot 12 years ago
parent b1ee4ac29c
commit 52af6d2330
  1. 72
      benchmarks/find.js
  2. 8
      benchmarks/insert.js

@ -0,0 +1,72 @@
var Datastore = require('../lib/datastore')
, benchDb = 'workspace/find.bench.db'
, fs = require('fs')
, path = require('path')
, async = require('async')
, customUtils = require('../lib/customUtils')
, d
, order = customUtils.getRandomArray(10000)
;
console.log("Benchmarking find");
async.waterfall([
function (cb) {
console.log("Preparing database");
customUtils.ensureDirectoryExists(path.dirname(benchDb), function () {
fs.exists(benchDb, function (exists) {
if (exists) {
fs.unlink(benchDb, cb);
} else { return cb(); }
});
});
}
, function (cb) {
d = new Datastore(benchDb);
d.loadDatabase(cb);
}
, function (cb) {
var beg = new Date()
, i = 0;
console.log("Inserting 10,000 documents");
async.whilst( function () { return i < 10000; }
, function (_cb) {
i += 1;
d.insert({ docNumber: i }, function (err) {
return _cb(err);
});
}, function (err) {
var timeTaken = (new Date()).getTime() - beg.getTime(); // In ms
if (err) { return cb(err); }
console.log("Time taken: " + (timeTaken / 1000) + "s");
return cb();
});
}
, function (cb) {
var beg = new Date()
, i = 0;
console.log("Finding 10,000 documents");
async.whilst( function () { return i < 10000; }
, function (_cb) {
i += 1;
d.find({ docNumber: order[i] }, function (err, docs) {
if (docs.length !== 1) { return _cb('Strangely, the doc was not found'); }
return _cb(err);
});
}, function (err) {
var timeTaken = (new Date()).getTime() - beg.getTime(); // In ms
if (err) { return cb(err); }
console.log("Time taken: " + (timeTaken / 1000) + "s");
return cb();
});
}
], function (err) {
console.log("Benchmark finished");
if (err) { return console.log("An error was encountered: ", err); }
});

@ -4,10 +4,13 @@ var Datastore = require('../lib/datastore')
, path = require('path') , path = require('path')
, async = require('async') , async = require('async')
, customUtils = require('../lib/customUtils') , customUtils = require('../lib/customUtils')
, n = 10000
, d , d
; ;
console.log("Benchmarking inserts"); if (process.argv[2]) { console.log(process.argv);}
console.log("Benchmarking insert");
async.waterfall([ async.waterfall([
function (cb) { function (cb) {
@ -39,10 +42,9 @@ async.waterfall([
}); });
}, function (err) { }, function (err) {
var timeTaken = (new Date()).getTime() - beg.getTime(); // In ms var timeTaken = (new Date()).getTime() - beg.getTime(); // In ms
if (err) { return cb(err); } if (err) { return cb(err); }
console.log("Time taken: " + (timeTaken / 1000) + "s"); console.log("Time taken: " + (timeTaken / 1000) + "s");
return cb();
}); });
} }
], function (err) { ], function (err) {
Loading…
Cancel
Save