node-mongodb-wrapper
node-mongodb-wrapper copied to clipboard
A simplified interface to common MongoDB operations
Node MongoDB Wrapper
This package greatly simplifies working with MongoDB and Node MongoDB Native.
It removes a lot of the callback madness and provides a simple shorthand for common operations. This was used in production at Playtomic as part of a high-volume api server.
It has a rudimentary caching layer that can greatly minimize round trips to the database without introducing 3rd party dependencies, although the cache is thread-specific so multiple instances/workers/whatever will each have their own.
Requires
- MongoDB has to be running somewhere.
- Node MongoDB Native and NodeJS
How to use
- git clone https://github.com/benlowry/node-mongodb-wrapper
- cd node-mongodb-wrapper
- see tests for examples
or just npm install node-mongodb-wrapper
Methods
Node MongoDB Wrapper provides methods for:
-
get
performs a find() with optional caching -
getAndCount
performs a find() + count() with optional caching -
getOrInsert
performs a find() and inserts if not exists -
aggregate
performs an aggregate() -
aggregateAndCount
, performs an aggregate and a second aggregate for counting -
count
performs a count() with optional caching -
insert
performs a save() -
update
performs an update() -
move
performs a save(doc) on new collection then remove(doc) on old -
remove
performs a remove()
Examples
A complete suite of examples is available in the included test.js file.
var query = {filter: {x: 1, y: 2, z: 3}, cache: true, cachetime: 60};
db.get("test", "stuff", query, function(error, items) {
console.log("huzzah!");
});
or (see shorthand note below)
db.test.stuff.get(query, function(error, items) {
console.log("huzzah!");
});
In that short example "test" is one of our configured database's names:
var databases = {
test: {
address: "127.0.0.1",
port: 27017,
name: "test", // your db and this object's name must match
//username: "optional",
//password: "optional"
}
}
We're passing an object that contains a nested filter object which is the query criteria and is exactly as you would use directly, it also supports limit, sort and skip in the outer object. The query is marked as cacheable and will store the results for 60 seconds.
Shorthand
I saw this on mongode and thought it looked super cool, so I copied the idea.
You can use traditional db.databasename.collectionname.method as well now to save on the parameter overload. This also has the benefit of making sure your collection names are strict.
The only bad bit is you have to predefine the collection names because JavaScript has no 'catch all' property which is unfortunate, but you can do it in 3 ways and if a collection is already defined it will just skip doing it again.
db.databasename.collection("acollection");
db.databasename.collections(["an", "array", "of", "collections"]);
db.databasename.collections(callback);
The final example will query your database and create the shorthand path for any collection names without dots (eg no system.indexes).
The callback has only an error parameter so you know if it worked or not, this is an async operation and you cannot use the shorthand until it is complete.
Databases
You can either define your databases inside the included mongo-wrapper.js or pass
a same-structured object as above via db.setDatabases(dblist)
.
Configuration
You can enable or disable some functionality:
var db = require("node-mongodb-wrapper");
// caching lets you store results from get, getAndCount, count ops
db.cacheEnabled = true;
db.defaultCacheTime = 60;
Why
Because without this you end up with too much boilerplate and nesting:
var db = new Db("local", new Server("127.0.0.1", 27017));
db.open(function(error, connection) {
if(error) {
console.log("error: " + error);
return;
}
connection.authenticate(username, password, function(error) {
if(error) {
console.log("error2: " + error);
return;
}
var collection = new mongodb.Collection(connection, "stuff");
collection.find({x: 1, y: 2, z: 3}, function(error, items) {
if(error) {
console.log("error3: " + error);
return;
}
console.log("huzzah!");
});
});
});
License
Copyright Ben Lowry 2012. Licensed under the MIT license. Certain portions may come from 3rd parties and carry their own licensing terms and are referenced where applicable.