node操作mongodb数据库的封装

lizhiheng 7年前
   <p>最近玩node 的时候,我发现我需要个数据库,我选择了mongodb这个数据库,问了一下度娘基本都是数据库的基本操作,所以我也就简单的封装了几个操作,以方便我的使用</p>    <p><strong>首先引入mongodb的包</strong></p>    <pre>  <code class="language-javascript">var mongodb = require('mongodb'); // 引入mongodb依赖</code></pre>    <p><strong>引入数据库配置文件</strong></p>    <pre>  <code class="language-javascript">var dataconfig = require('../config/config'); // 引入mongodb配置</code></pre>    <p><strong>数据库配置文件</strong></p>    <p>配置文件根据自己的不同需求配置</p>    <pre>  <code class="language-javascript">/* @dataconfig 数据库配置*/  var dataconfig={   dataurl:"localhost",   dataport:'27017',   dataname:'db'  };  module.exports = dataconfig;</code></pre>    <p><strong>创建对象,并且向其中写入数据库操作方法</strong></p>    <pre>  <code class="language-javascript">/*  创建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('数据库已经关闭');          });      }  };</code></pre>    <p><strong>数据库封装完毕,我们测试一下</strong></p>    <pre>  <code class="language-javascript">//测试用例      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);  });</code></pre>    <p>当然最后我们封装完毕后,我们要把这个模块导出一下方便我们以后的使用</p>    <pre>  <code class="language-javascript">module.exports = Mainpulation;</code></pre>    <p> </p>    <p>来自:http://www.jianshu.com/p/d44451117537</p>    <p> </p>