最近玩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;
