win下node-mongodb-native操作mongodb

jsnjzlw

　　nodejs win下没有npm功能，应用各种库文件相当杯具,这里用了node-mongodb-native在win下操作mongodb,小D很菜，对nodejs各种不懂，勉强简单封装了个对mongodb的curd操作,,,,
　　首先去下载https://github.com/christkv/node-mongodb-native，把文件lib下的东西放到了如下目录

　　如何操作看他的文档吧，e文不行的估计看例子也能看个大概....下面是封装代码mghp.js


View Code


var mongodb = require('./refLib/mongodb');
var _server = function(mongoCollection, mongoDB) {
    var sv = new mongodb.Server('127.0.0.1', 27017, {});
    this.mongoCollection = mongoCollection || 'nodeCollection';
    this.mongoDB = mongoDB || 'nodeDB';
    this.db = new mongodb.Db(this.mongoDB, sv, {});
}
_server.prototype.Open = function(callback) {
    var that = this;
    if (that.db && that.db.state == 'connected') {
        callback && callback();
    } else {
        that.db.open(function(error, client) {
            if (error) throw error;
            that.collection = new mongodb.Collection(client, that.mongoCollection);
            callback && callback();
        });
    }
}
_server.prototype.Close = function(isClose) {
    if (!!isClose && this.db) {
        this.db.close();
        this.collection = null;
        this.db = null;
    }
}
_server.prototype.Insert = function(obj, func, isClose) {
    var that = this;
    that.Open(function() {
        that.collection.insert(obj, { safe: true }, function(err) {
            that.Close(isClose);
            if (err) {
                console.warn(err.message);
            }
            if (err && err.message.indexOf('E11000') !== -1) {
                //this _id was already inserted in the database
            }
            func && func();
        });
    });
}

_server.prototype.Find = function(obj, func, isClose) {
    var that = this;
    that.Open(function() {
        that.collection.find(obj, function(err, cursor) {
            that.Close(isClose);
            if (err) {
                console.warn(err.message);
            }
            cursor.toArray(function(err, items) {
                func && func(items);
            });
        });
    });
}
_server.prototype.Update = function(obj, objN, func, isClose) {
    var that = this;
    that.Open(function() {
        that.collection.update(obj, { $set: objN }, { safe: true }, function(err) {
            that.Close(isClose);
            if (err) {
                console.warn(err.message);
            }
            func && func();
        });
    });
}
_server.prototype.Remove = function(obj, func, isClose) {
    var that = this;
    that.Open(function() {
        that.collection.remove(obj, function(err, result) {
            that.Close(isClose);
            if (err) {
                console.warn(err.message);
            }
            func && func(result);
        });
    });
}
exports.Server = _server;

　　因为是异步的所以连续操作的话要放在回调函数中，方法还有第三个参数，如果是true则关闭链接
　　s.Insert({ "ID": "10001", "name": "ygm" }, function() {
　　....
　　},true);
　　查看操作结果