最近玩node 的时候，我发现我需要个数据库，我选择了mongodb这个数据库，问了一下度娘基本都是数据库的基本操作，所以我也就简单的封装了几个操作，以方便我的使用

首先引入mongodb的包

var mongodb = require('mongodb'); // 引入mongodb依赖

引入数据库配置文件

var dataconfig = require('../config/config'); // 引入mongodb配置

数据库配置文件

配置文件根据自己的不同需求配置

/* @dataconfig 数据库配置*/
var dataconfig={
 dataurl:"localhost", 
dataport:'27017',
 dataname:'db'
};
module.exports = dataconfig;

创建对象，并且向其中写入数据库操作方法

/*
创建mongodb操作对象
*/
var Mainpulation = {
    /*
    @selectall 方法返回全部所有数据
        @dataname  数据库名称
      @dealdata   回调处理函数  格式function(result){};
    */
    selectall: function(dataname, dealdata) {
        var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
            auto_reconnect: true
        }); // 创建mongodb服务
        var db = new mongodb.Db(dataconfig.dataname, server, {
            safe: true
        });
        db.open(function(err, db) {
            if (err) {
                console.log('数据库打开失败');
            } else {
                db.createCollection(dataname, {
                    safe: true
                }, function(err, collection) {
                    if (err) {
                        console.log('数据库连接失败');
                    } else {
                        //  var tmp1 = {title:'hellodsad'};
                        //  var tmp2 = {title:'worlddsad'};
                        //  collection.insert([tmp1,tmp2],{safe:true},function(err,result){
                        //          console.log(result);
                        //  });
                        collection.find().toArray(function(err, docs) {
                            console.log('find');
                            dealdata(docs);
                            db.close();
                        });
                    }
                })
            }
        })
        db.on("close", function(err, data) {
            if (err) {
                console.log("数据库关闭失败");
            }
            console.log('数据库已经关闭');
        });
    },
    /*
    @selectone 查询符合条件的数据
    @dataname 数据库名称
    @selectlanguage 查询控制语句  格式{index:value,index,value};
    @dealdata   回调处理函数  格式function(result){};
    */
    select: function(dataname, selectlanguage, dealdata) {
        var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
            auto_reconnect: true
        }); // 创建mongodb服务
        var db = new mongodb.Db(dataconfig.dataname, server, {
            safe: true
        });
        db.open(function(err, db) {
            if (err) {
                console.log('数据库打开失败');
            } else {
                db.createCollection(dataname, {
                    safe: true
                }, function(err, collection) {
                    if (err) {
                        console.log('数据库连接失败');
                    } else {
                        collection.find(selectlanguage).toArray(function(err, docs) {
                            console.log('find');
                            dealdata(docs);
                            db.close();
                        });
                    }
                })
            }
        })
        db.on("close", function(err, data) {
            if (err) {
                console.log("数据库关闭失败");
            }
            console.log('数据库已经关闭');
        });
    },
    /*
    @insert添加数据格式json格式
    @dataname 数据库名称
    @dealdata 回调函数处理函数有一个result参数
    */
    insert: function(dataname, insertlanguage, dealdata) {
        var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
            auto_reconnect: true
        }); // 创建mongodb服务
        var db = new mongodb.Db(dataconfig.dataname, server, {
            safe: true
        });
        db.open(function(err, db) {
            if (err) {
                console.log('数据库打开失败');
            } else {
                db.createCollection(dataname, {
                    safe: true
                }, function(err, collection) {
                    if (err) {
                        console.log('数据库连接失败');
                    } else {
                        collection.insert(insertlanguage, {
                            safe: true
                        }, function(err, result) {
                                                    console.log(result+'插入成功');
                            dealdata(result);
                            db.close();
                        });
                    }
                })
            }
        })
        db.on("close", function(err, data) {
            if (err) {
                console.log("数据库关闭失败");
            }
            console.log('数据库已经关闭');
        });
    },
    /*
     @update 修改数据的方法
     @update添加数据格式json格式
     @dataname 数据库名称
     @dealdata 回调函数处理函数有一个result参数
     */
    update: function(dataname, updatelanguage,updatecondition, dealdata) {
        var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
            auto_reconnect: true
        }); // 创建mongodb服务
        var db = new mongodb.Db(dataconfig.dataname, server, {
            safe: true
        });
        db.open(function(err, db) {
            if (err) {
                console.log('数据库打开失败');
            } else {
                db.createCollection(dataname, {
                    safe: true
                }, function(err, collection) {
                    if (err) {
                        console.log('数据库连接失败');
                    } else {
                        collection.update(updatecondition,updatelanguage, {
                            safe: true
                        }, function(err, result) {
                            console.log(result+'修改成功');
                            dealdata(result);
                            db.close();
                        });
                    }
                })
            }
        })
        db.on("close", function(err, data) {
            if (err) {
                console.log("数据库关闭失败");
            }
            console.log('数据库已经关闭');
        });
    },
    /*
    @remove  删除数据的方法
    @dataname 数据库名称
    @removelanguage 删除数据的条件
    @dealdata 回调函数处理函数有一个result参数
    */
    remove: function(dataname, removelanguage, dealdata) {
        var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
            auto_reconnect: true
        }); // 创建mongodb服务
        var db = new mongodb.Db(dataconfig.dataname, server, {
            safe: true
        });
        db.open(function(err, db) {
            if (err) {
                console.log('数据库打开失败');
            } else {
                db.createCollection(dataname, {
                    safe: true
                }, function(err, collection) {
                    if (err) {
                        console.log('数据库连接失败');
                    } else {
                        collection.remove(removelanguage, {
                            safe: true
                        }, function(err, result) {
                            dealdata(result);
                            db.close();
                        });
                    }
                })
            }
        })
        db.on("close", function(err, data) {
            if (err) {
                console.log("数据库关闭失败");
            }
            console.log('数据库已经关闭');
        });
    },
    /*
    @remove  删除全部数据的方法
    @dataname 数据库名称
    @dealdata 回调函数处理函数有一个result参数
    */
    removeall: function(dataname, dealdata) {
        var server = new mongodb.Server(dataconfig.dataurl, dataconfig.dataport, {
            auto_reconnect: true
        }); // 创建mongodb服务
        var db = new mongodb.Db(dataconfig.dataname, server, {
            safe: true
        });
        db.open(function(err, db) {
            if (err) {
                console.log('数据库打开失败');
            } else {
                db.createCollection(dataname, {
                    safe: true
                }, function(err, collection) {
                    if (err) {
                        console.log('数据库连接失败');
                    } else {
                        collection.remove({}, {
                            safe: true
                        }, function(err, result) {
                            dealdata(result);
                            db.close();
                        });
                    }
                })
            }
        })
        db.on("close", function(err, data) {
            if (err) {
                console.log("数据库关闭失败");
            }
            console.log('数据库已经关闭');
        });
    }
};

数据库封装完毕，我们测试一下

//测试用例


Mainpulation.select('test', {"title": "hello"}, function(result) {
    console.log("select查询结果");
    console.log(result);
})
Mainpulation.insert('test',{"insert":"hello"},function(result){
 console.log('inserts插入结果');
  console.log(result);
})
Mainpulation.remove('test',{"insert":"hello"},function(result){
 console.log(result);
})
Mainpulation.removeall('test',function(result){
console.log(result);
})
Mainpulation.selectall('test', function(result) {
    console.log('selectall查询结果');
    console.log(result);
});

当然最后我们封装完毕后，我们要把这个模块导出一下方便我们以后的使用

module.exports = Mainpulation;