非常详细的文档http://mongodb.github.io/node-mongodb-native/2.2/quick-start/quick-start/

连接数据库

安装express 和 mongodb .

npm　install express mongodb --save

通过 MongoClient.connect(url, function(err, db) {}) API 连接

'use strict';

const express = require("express"),

    mongoClient = require("mongodb").MongoClient;

var app = express(),

    url = 'mongodb://localhost:27017/test';

app.listen(3000, function(err) {

    if (err) {

        console.log("has error");

    }

});

app.get("/", function(req, res) {

    mongoClient.connect(url, function(err, db) {

        if (err) {

            console.log("数据库连接失败")

        }

        res.send("连接成功");

        db.close();

    })

})

这样就连接成功了 .

用ES6 还是更棒的, 不过觉得配babel 比较麻烦.., 等到结尾的dao 层封装我会使用ES6的语法来完成

插入数据

提供了两个api,分别为 db.collection("student").insertOne() & db.collection("student").insertMany

app.get("/", function(req, res) {

    mongoClient.connect(url, function(err, db) {

        if (err) {

            console.log("数据库连接失败")

        }

        db.collection("student").insertOne({ "name": "筱原明里", "age": "18" }, function(err, result) {

            if (err) {

                console.log(err);

            }

            res.send(result);

        })

        db.collection("student").insertMany([{ "name": "远野贵树", "age": "18" }, { "name": "澄田花苗" }], function(err, result) {

            if (err) {

                console.log(err);

            }

            res.send(result);

        })

        db.close();

    })

})

查找和分页

通过db.collection().find() 会返回一个游标,通过游标的迭代来访问所有数据.

注意,each 迭代的过程是异步的 !

app.get("/", function(req, res) {

    mongoClient.connect(url, function(err, db) {

        if (err) {

            console.log("数据库连接失败")

        }

        var collection = db.collection('student'),

            cursor = collection.find({}),

            result = [];

        cursor.each(function(err, doc) {

            console.log(doc)

            if (err) {

                console.log(err);

            }

            if (doc == null) {

                res.send(result);

            }else{

                result.push(doc);

           }

        });

        db.close();

    })

})

但是通过each判断是否迭代完成并不是很好的方式,mongo给这个游标赋予一个更好的方法 toArray

app.get("/", function(req, res) {

    mongoClient.connect(url, function(err, db) {

        if (err) {

            console.log("数据库连接失败")

        }

        var collection = db.collection('student'),

            cursor = collection.find({});

        cursor.toArray(function(err, docs) {

            // docs 就是所有的文档

            console.log(docs);

        })

        db.close();

    })

})

这样做是取出全部的数据,下面是分页查询呢

mongoDB 的分页查询非常方便,封装的skip,limit 有点像 .net 中的 EF中的skip,take 等方法.

app.get("/", function(req, res) {

    mongoClient.connect(url, function(err, db) {

        if (err) {

            console.log("数据库连接失败")

        }

        var collection = db.collection('student'),

            // 跳过5条再取5条

            cursor = collection.find({}).skip(10).limit(5);

        cursor.toArray(function(err, docs) {

            // docs 就是所有的文档

            console.log(docs);

        })

        db.close();

    })

})

实际当然不能这么写,稍后会封装一个DAO,在里面会使用参数进行分页

修改

app.get("/", function(req, res) {

    mongoClient.connect(url, function(err, db) {

        if (err) {

            console.log("数据库连接失败")

        }

        db.collection('student').updateOne({ name: "远野贵树" }, { $set: { age: 20, gender: "男" } }, function(err, result) {

            if (err) {

                console.log(err);

            } else {

                console.log(result);

            }

        })

        db.collection('student').updateMany({ name: "澄田花苗" }, { $set: { age: 20, gender: "女" } }, function(err, result) {

            if (err) {

                console.log(err);

            } else {

                res.send(result);

            }

        })

        db.close();

    })

})

删除

删除同样包含两个api ,deleteMany & deleteOne.

app.get("/", function(req, res) {

    mongoClient.connect(url, function(err, db) {

        if (err) {

            console.log("数据库连接失败")

        }

        db.collection("student").deleteOne({ 'name': '澄田花苗' }, function(err, result) {

            res.send(result);

        })

        db.collection("student").deleteMany({ 'name': '澄田花苗' }, function(err, result) {

            res.send(result);

        })

        db.close();

    })

})

DAO 封装

每次像上面一样调用肯定是不可行的,所以需要封装一个DAO层.

mongodbdao.js

/*

 * @Author: Administrator

 * @Date:   2017-03-13 17:14:40

 * @Last Modified by:   Administrator

 * @Last Modified time: 2017-03-13 20:24:23

 */

'use strict';

const mongoClient = require("mongodb").MongoClient,

    dburl = require("config").dburl;

// 连接数据库,内部函数

function _connectDB(callback) {

    mongoClient.connect(dburl, function(err, db) {

            if (err) {

                console.log(err);

                return;

            }

            callback(err, db);

        }

    })

}

exports.find = function(collectionName, json, pageOption, callback) {

    // 第 0 页,就跳过 0 条,第 1 页,跳过10条 ,取 10条

    // skip & limit ,如果参数为0,那么就忽略参数

    var skipNumber = pageOption.page * pageOption.count || 0,

        takeNumber = pageOption || 0,

        sort = pageOption.sort || {};

    _connectDB(function(err, db) {

        db.collection(collectionName).find(json).skip(skipNumber).limit(takeNumber).sort(sort) toArray(function(err, docs) {

            callback(err, docs);

            db.close();

        });

    })

};

exports.insertOne = function(collectionName, json, callback) {

    _connectDB(function(err, db) {

        db.insertOne(collectionName).insertOne(function(err, res) {

            callback(err, res);

            db.close();

        })

    })

}

exports.insertMany = function(collectionName, json, callback) {

    _connectDB(function(err, db) {

        db.insertOne(collectionName).insertMany(function(err, res) {

            callback(err, res);

            db.close();

        })

    })

}

exports.deteleOne = function(collectionName, json, callback) {

    _connectDB(function(err, db) {

        db.collection(collectionName).deteleOne(json, function(err, res) {

            callback(err, res);

            db.close();

        })

    })

};

exports.deteleMany = function(collectionName, json, callback) {

    _connectDB(function(err, db) {

        db.collection(collectionName).deteleMany(json, function(err, res) {

            callback(err, res);

            db.close();

        })

    })

};

exports.updateOne = function(collectionName, jsonQeury, jsonSet, callback) {

    _connectDB(function(err, db) {

        db.collection(collectionName).updateOne(jsonQeury, { $set: jsonSet }, function(err, res) {

            callback(err, res);

            db.close();

        })

    })

};

exports.updateMany = function(collectionName, jsonQeury, jsonSet, callback) {

    _connectDB(function(err, db) {

        db.collection(collectionName).updateMany(jsonQeury, { $set: jsonSet }, function(err, res) {

            callback(err, res);

            db.close();

        })

    })

};

exports.getAllCount = function(collectionName, json, callback) {

    _connectDB(function(err, db) {

        db.collection(collectionName).count(json, function(err, count) {

            callback(err, count);

            db.close();

        })

    })

};

简单地完成了一个DAO 的封装,但是在项目中, 也是不会这样用的

因为有一个更强大的东西 mongooose,它就相当于 EF 之于 ADO.NET.