mongoskin

This project is a wrapper of node-mongodb-native.
The api is same to node-mongodb-native, please see the document first.
Test
Test pass [mongodb] versions
$ make test-version
Mongoskin document
Nodejs Mongodb Driver Comparison
node-mongodb-native
One of the most powerful Mongo drivers is node-mongodb-native. Most other drivers build
on top of it, including mongoskin. Unfortunately, it has an awkward interface with too many
callbacks. Also, mongoskin needs a way to hold a Collection instance as an MVC model.
See mongodb-native
mongoose
Mongoose provides an ORM way to hold Collection instance as Model,
you should define schema first. But why mongodb need schema?
Some guys like me, want to write code from application layer but not database layer,
and we can use any fields without define it before.
Mongoose provide a DAL that you can do validation, and write your middlewares.
But some guys like me would like to validate manually, I think it is the tao of mongodb.
If you don't thinks so, Mongoose-ORM is probably your choice.
mongoskin
Mongoskin is an easy to use driver of mongodb for nodejs,
it is similar with mongo shell, powerful like node-mongodb-native,
and support additional javascript method binding, which make it can act as a Model(in document way).
It will provide full features of node-mongodb-native,
and make it future.
If you need validation, you can use node-iform.
Back to index
Install
$ npm install mongoskin
Back to index
Quick Start
Is mongoskin synchronized?
Nope! It is asynchronized, it use the future pattern.
Mongoskin is the future layer above node-mongodb-native
Connect easier
You can connect to mongodb easier now.
var mongo = require('mongoskin');
mongo.db('localhost:27017/testdb').collection('blog').find().toArray(function (err, items) {
console.dir(items);
})
Server options and BSON options
You can also set auto_reconnect
options querystring.
And native_parser options will automatically set if native_parser is avariable.
var mongo = require('mongoskin');
var db = mongo.db('localhost:27017/test?auto_reconnect');
Similar API with node-mongodb-native
You can do everything that node-mongodb-native can do.
db.createCollection(...);
db.collection('user').ensureIndex([['username', 1]], true, function (err, replies) {});
db.collection('posts').hint = 'slug';
db.collection('posts').findOne({slug: 'whats-up'}, function (err, post) {
});
Cursor easier
db.collection('posts').find().toArray(function (err, posts) {
});
MVC helper
You can bind additional methods for collection.
It is very useful if you want to use MVC patterns with nodejs and mongodb.
You can also invoke collection by properties after bind,
it could simplfy your require
.
db.bind('posts', {
findTop10 : function (fn) {
this.find({}, {limit:10, sort:[['views', -1]]}).toArray(fn);
},
removeTagWith : function (tag, fn) {
this.remove({tags:tag},fn);
}
});
db.bind('comments');
db.collection('posts').removeTagWith('delete', function (err, replies) {
});
db.posts.findTop10(function (err, topPosts) {
});
db.comments.find().toArray(function (err, comments) {
});
Back to index
Documentation
for more information, see the source.
Back to index
Module
MongoSkin Url format
[*://][username:password@]host[:port][/database][?auto_reconnect[=true|false]]`
e.g.
localhost/blog
mongo://admin:pass@127.0.0.1:27017/blog?auto_reconnect
127.0.0.1?auto_reconnect=false
db(databaseUrl, db_options)
Get or create instance of SkinDb.
var db = mongoskin.db('localhost:27017/testdb?auto_reconnect=true&poolSize=5');
for ReplSet server
var db = mongoskin.db([
'192.168.0.1:27017/?auto_reconnect=true',
'192.168.0.2:27017/?auto_reconnect=true',
'192.168.0.3:27017/?auto_reconnect=true'
], {
database: 'testdb',
retryMiliSeconds: 2000
});
router(select)
select is function(collectionName)
returns a database instance, means router collectionName to that database.
var db = mongo.router(function (coll_name) {
switch(coll_name) {
case 'user':
case 'message':
return mongo.db('192.168.1.3/auth_db');
default:
return mongo.db('192.168.1.2/app_db');
}
});
db.bind('user', require('./shared-user-methods'));
var users = db.user;
var messages = db.collection('message');
var products = db.collection('product');
classes extends frome node-mongodb-native
- BSONPure
- BSONNative
- BinaryParser
- Binary
- Code
- DBRef
- Double
- MaxKey
- MinKey
- ObjectID
- Symbol
- Timestamp
- Long
- BaseCommand
- DbCommand
- DeleteCommand
- GetMoreCommand
- InsertCommand
- KillCursorCommand
- QueryCommand
- UpdateCommand
- MongoReply
- Admin
- Collection
- Connection
- Server
- ReplSetServers
- Cursor
- Db
- connect
- Grid
- Chunk
- GridStore
- native
- pure
Back to index
SkinServer
SkinServer(server)
Construct SkinServer from native Server instance.
Construct SkinDb from SkinServer.
Back to index
SkinDb
Construct SkinDb.
open(callback)
Connect to database, retrieval native
Db
instance, callback is function(err, db).
collection(collectionName)
Retrieval SkinCollection instance of specified collection name.
bind(collectionName)
bind(collectionName, SkinCollection)
bind(collectionName, extendObject1, extendObject2 ...)
Bind SkinCollection to db properties as a shortcut to db.collection(name).
You can also bind additional methods to the SkinCollection, it is useful when
you want to reuse a complex operation. This will also affect
db.collection(name) method.
e.g.
db.bind('book', {
firstBook: function (fn) {
this.findOne(fn);
}
});
db.book.firstBook(function (err, book) {});
all the methods from Db.prototype
See Db of node-mongodb-native for more information.
Back to index
SkinCollection
See Collection of node-mongodb-native for more information.
### open(callback)
Retrieval native
Collection
instance, callback is function(err, collection).
id(hex)
Equivalent to
db.bson_serializer.ObjectID.createFromHexString(hex);
See ObjectID.createFromHexString
Collection operation
checkCollectionName(collectionName)
options(callback)
rename(collectionName, callback)
drop(callback)
Indexes
createIndex(fieldOrSpec, unique, callback)
ensureIndex(fieldOrSpec, unique, callback)
indexInformation(callback)
dropIndex(indexName, callback)
dropIndexes(callback)
See mongodb-native indexes
Queries
See mongodb-native queries
findItems(..., callback)
Equivalent to
collection.find(..., function (err, cursor) {
cursor.toArray(callback);
});
See Collection.find
findEach(..., callback)
Equivalent to
collection.find(..., function (err, cursor) {
cursor.each(callback);
});
See Collection.find
findById(id, ..., callback)
Equivalent to
collection.findOne({_id, ObjectID.createFromHexString(id)}, ..., callback);
See Collection.findOne
find(...)
If the last parameter is function, it is equivalent to native
Collection.find
method, else it will return a future SkinCursor.
e.g.
db.book.find({}, function (err, cursor) {});
db.book.find().toArray(function (err, books) {});
normalizeHintField(hint)
find
findAndModify(query, sort, update, options, callback)
findOne(queryObject, options, callback)
Aggregation
mapReduce(map, reduce, options, callback)
e.g.
var map = function () {
emit(test(this.timestamp.getYear()), 1);
}
var reduce = function (k, v){
count = 0;
for (i = 0; i < v.length; i++) {
count += v[i];
}
return count;
}
var options = {scope: {test: new client.bson_serializer.Code(t.toString())}};
collection.mapReduce(map, reduce, options, function (err, collection) {
collection.find(function (err, cursor) {
cursor.toArray(function (err, results) {
test.equal(2, results[0].value)
finished_test({test_map_reduce_functions_scope:'ok'});
})
})
group(keys, condition, initial, reduce, command, callback)
e.g.
collection.group([], {}, {"count":0}, "function (obj, prev) { prev.count++; }", true, function(err, results) {});
count(query, callback)
distinct(key, query, callback)
Inserting
insert(docs, options, callback)
Updating
save(doc, options, callback)
update(spec, document, options, callback)
updateById(_id, ..., callback)
Equivalent to
collection.update({_id, ObjectID.createFromHexString(id)}, ..., callback);
See Collection.update
Removing
remove(selector, options, callback)
removeById(_id, options, callback)
Back to index
SkinCursor
See Cursor
of node-mongodb-native for more information.
All these methods will return the SkinCursor itself.
sort(keyOrList, [direction], [callback])
limit(limit, [callback])
skip(skip, [callback])
batchSize(skip, [callback])
toArray(callback)
each(callback)
count(callback)
nextObject(callback)
getMore(callback)
explain(callback)
Back to index
How to validate input?
I wrote a middleware to validate post data, node-iform
base on node-validator
Authors
Below is the output from git-summary
.
project: node-mongoskin
commits: 112
active : 54 days
files : 39
authors:
49 Lin Gui 43.8%
34 guilin 桂林 30.4%
9 fengmk2 8.0%
5 guilin 4.5%
2 François de Metz 1.8%
2 Paul Gebheim 1.8%
2 Gui Lin 1.8%
1 humanchimp 0.9%
1 Aneil Mallavarapu 0.9%
1 wmertens 0.9%
1 Harvey McQueen 0.9%
1 Joe Faber 0.9%
1 Matt Perpick 0.9%
1 Quang Van 0.9%
1 Rakshit Menpara 0.9%
1 Wout Mertens 0.9%
License
(The MIT License)
Copyright (c) 2011 - 2012 kissjs.org
Permission is hereby granted, free of charge, to any person obtaining
a copy of this software and associated documentation files (the
'Software'), to deal in the Software without restriction, including
without limitation the rights to use, copy, modify, merge, publish,
distribute, sublicense, and/or sell copies of the Software, and to
permit persons to whom the Software is furnished to do so, subject to
the following conditions:
The above copyright notice and this permission notice shall be
included in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED 'AS IS', WITHOUT WARRANTY OF ANY KIND,
EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY
CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,
TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.