NodeJS中使用MongoDB的简单封装

使用示例    

/* 
使用示例：
*/
var DB = require('./DB.js').DB;
var ObjectId = require('mongodb').ObjectID;
var docName = 'User';
DB(docName, function (db, collection) {
	collection.bulkWrite([{insertOne:{document:message}}], function (err, result) {
		assert.equal(null, err);
		invokeCallback.call(callback, result);
		db.close();
	});
});

连接封装部分    

var mongo = require('mongodb').MongoClient;
var assert = require('assert');

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

module.exports.DB = function (name, callback) {
    mongo.connect(url, function (err, db) {
        assert.equal(null, err);
        var collection = db.collection(name);
        if (typeof collection === 'undefined') {
            db.createCollection(name);
            collection = db.collection(name);
        }
        if (typeof callback === 'function') {
            callback(db, collection);
        }
    });
};

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点！
本站所提供的图片等素材，版权归原作者所有，如需使用，请与原作者联系。