mongodb-query

install

npm install mongodb-query

github

homePage

Download

import

import mongodb-query

var mongodb = require('mongodb-query').host('mongodb://localhost:27017/student');

or

var mongodb = require('mongodb-query');
mongodb('mongodb://localhost:27017/student');

config collection

var db = mongodb.collection('users'); // uses is collection name

query methods

find

where| limit | sort | skip| find ---|---|---| ---|--- | options | number | number | number | callback Object| int | int |int| function

var mongodb = require('mongodb-query').host('mongodb://localhost:27017/student');
var db = mongodb.collection('users'); 

// find all
db.users
.find(function(err, data) {
    console.log(data);
});

// limit 2 row find
db.users
.limit(2)
.find(function(err, data) {
    console.log(data);
});

// limit 2 row and skip 1 row find

db.users
.limit(2)
.skip(1)
.find(function(err, data) {
    console.log(data);
})

// where
db.users
.where({username:'hello'})
.limit(2)
.skip(1)
.find(function(err, data) {
    console.log(data);
})

// sort 

db.users.sort({ 'email': '-1' }).find(function(err,data) {
    console.log(data);
})

count

where| limit | skip| count ---|---|---|--- | options | number | number | callback Object| int |int| function

db.users.count(function(err, data) {
    console.log(err)
    console.log(data)
})

validate formdata

data | validate ---|--- formdata|function require|require

validate require data({})

// insert validate
db.users.data({
    username: "123",
    password: '222',
    email: '2222',
    phone: '18523291194'
}).validate({
    rule: {
        username: 'require|length:3,6',
        password: 'require|length:3,6',
        email: 'require|email',
        phone: 'require|mobile'
    },
    message: {
        username: {
            require: '账户必须',
            length: '账户长度有误'
        },
        password: {
            require: '密码必须',
            length: '密码长度有误'
        },
        email: {
            require: '密码必须',
            email: '邮箱格式不正确'
        },
        phone: {
            require: '手机必须',
            mobile: '手机格式不正确'
        }

    }
}).insert(function(err, data) {
    console.log(err);
    console.log(data);
})


// update validate 

db.users.data({
    username: "123",
    password: '222',
    email: '2222',
    phone: '18523291194'
}).validate({
    rule: {
        username: 'require|length:3,6',
        password: 'require|length:3,6',
        email: 'require|email',
        phone: 'require|mobile'
    },
    message: {
        username: {
            require: '账户必须',
            length: '账户长度有误'
        },
        password: {
            require: '密码必须',
            length: '密码长度有误'
        },
        email: {
            require: '密码必须',
            email: '邮箱格式不正确'
        },
        phone: {
            require: '手机必须',
            mobile: '手机格式不正确'
        }

    }
}).update(function(err, data) {
    console.log(err);
    console.log(data);
});

update

where| data | update ---|--- |--- options | options | callback Object| Object | function(err,data)

db.users.where({username:'hello'})
.data({ $set:{'name':'hello',age:'22'}})
.update(function(err,data){
    console.log(data);
})

delete

where | delete ---|--- options | callback Object | function(err,data)

db
.users
.where({ username: 'hello' })
.delete(function(err, data) {
    console.log(data);
});

insert

data | insert --- | --- options | callback Object | function(err,data)

db
.users
.data({ username: 'hello',age:'22' })
.insert(function(err, data) {
    console.log(data);
});