cqrsnode.dbstore
Advanced tools
Comparing version 0.0.4 to 0.0.5
@@ -1,2 +0,1 @@ | ||
exports.Mongoose = require('./mongoose'); | ||
exports.Tiny = require('./tiny'); |
@@ -0,3 +1,4 @@ | ||
var path = require('path'); | ||
var Tiny = require('tiny'); | ||
module.exports = DB; | ||
@@ -9,18 +10,23 @@ | ||
function init(dbname){ | ||
Tiny(path.join(cfg.mainpath,cfg.names[n]),function(err,db){ | ||
dbs[dbname] = db; | ||
}); | ||
} | ||
for(var n in cfg.names){ | ||
Tiny('dbs/'+cfg.names[n],function(err,db){ | ||
dbs[db.name] = db; | ||
}); | ||
var dbname = cfg.names[n]; | ||
init(dbname); | ||
} | ||
this.remove = function(AggreName,id,callback){ | ||
dbs['dbs/'+AggreName].remove(id,callback) | ||
dbs[AggreName].remove(id,callback) | ||
} | ||
this.save = function(AggreName,data,callback){ | ||
dbs['dbs/'+AggreName].set(data.id,data,callback) | ||
dbs[AggreName].set(data.id,data,callback) | ||
} | ||
this.update = function(AggreName,id,data,callback){ | ||
dbs['dbs/'+AggreName].update(id,data,callback); | ||
dbs[AggreName].update(id,data,callback); | ||
} | ||
@@ -30,3 +36,3 @@ | ||
var name = [].shift.apply(arguments); | ||
var db = dbs["dbs/"+name]; | ||
var db = dbs[name]; | ||
return db.find.apply(db,arguments); | ||
@@ -33,0 +39,0 @@ } |
{ | ||
"name": "cqrsnode.dbstore", | ||
"version": "0.0.4", | ||
"version": "0.0.5", | ||
"description": "db store for cqrsnode", | ||
@@ -26,3 +26,4 @@ "main": "index.js", | ||
"author": "brighthas <brighthas@gmail.com>", | ||
"license": "MIT" | ||
"license": "MIT", | ||
"readmeFilename": "README.md" | ||
} |
3213
84