澳门新葡11599_www.11599.com_澳门新萄京娱乐11599平台

nodejs操作mongodb的增删改查功能实例澳门新葡115

日期:2019-06-06编辑作者:www.11599.com

本文实例讲述了nodejs操作mongodb的增删改查功能。分享给大家供大家参考,具体如下:

安装相关模块

nodejs操作mongodb的增删改查功能实例,nodejsmongodb

本文实例讲述了nodejs操作mongodb的增删改查功能。分享给大家供大家参考,具体如下:

安装相关模块

如果使用这个的话,你需要先自己安装一下他需要的模块,在根目录输入

npm install mongodb --save

进行模块安装,安装成功以后就可以进行以下的步骤。

文件的引入

以下是我书写的相关代码,放到你可以引用的相关目录,本人放到了express的根目录

function Mongo(options) {
  this.settings = {
    url: 'mongodb://localhost:27017/jk',
    MongoClient:require('mongodb').MongoClient,
    assert:require('assert')
  };
  for(let i in options){
    this.settings[i] = options[i];
  }
  this._run = function (fun) {
    let that = this;
    let settings = this.settings;
    this.settings.MongoClient.connect(this.settings.url, function (err, db) {
      settings.assert.equal(null, err);
      console.log("Connected correctly to server");
      fun(db, function () {
        db.close();
      });
    });
  };
  this.insert = function (collectionName, data, func) {
    //增加数据
    let insertDocuments = function (db, callback) {
      let collection = db.collection(collectionName);
      collection.insertMany([
        data
      ], function (err, result) {
        if (!err) {
          func(true);
        } else {
          func(false);
        }
        callback(result);
      });
    };
    this._run(insertDocuments);
  };
  this.update = function (collectionName, updateData, data, func) {
    //更新数据
    let updateDocument = function (db, callback) {
      let collection = db.collection(collectionName);
      collection.updateOne(updateData
        , {$set: data}, function (err, result) {
          if (!err) {
            func(true);
          } else {
            func(false);
          }
          callback(result);
        });
    };
    this._run(updateDocument);
  };
  this.delete = function (collectionName, data, func) {
    //删除数据
    let deleteDocument = function (db, callback) {
      let collection = db.collection(collectionName);
      collection.deleteOne(data, function (err, result) {
        if (!err) {
          func(true);
        } else {
          func(false);
        }
        callback(result);
      });
    };
    this._run(deleteDocument);
  };
  this.find = function (collectionName, data, func) {
    //查找数据
    let findDocuments = function (db, callback) {
      // Get the documents collection
      let collection = db.collection(collectionName);
      // Find some documents
      collection.find(data).toArray(function (err, docs) {
        if (!err) {
          func(true,docs);
        }
        else {
          func(false, err);
        }
        callback(docs);
      });
    };
    this._run(findDocuments);
  };
}
module.exports = Mongo;

我存入到了一个名字叫server.js的文件名内

使用

我们在需要使用页面先将模块引入,比如我在路由文件index.js里面引入:

const Server = require("../server.js");

然后需要实例化对象,如下:

let server = new Server();

如果需要配置相关信息,可以在实例化的时候传入一个对象配置,可以配置数据库的地址:

let server = new Server({url:"mongodb://localhost:27017/mydb"});

里面封装了四个方法,添删改查,分别是

添加方法

server.insert(数据表名,需要插入的数据(键值对的对象),回调函数);

更新方法

server.update(数据表名,查询的数据(对象),更新的数据(对象),回调函数);

删除方法

server.delete(数据表名,查询的数据(对象),回调函数);

查找方法

server.find(数据表名,查询的数据(对象),回调函数);

回调函数都会返回两个值,第一个布尔类型,是否处理成功,第二个值,查找返回查找到的个数,别的都返回处理成功的个数(现在一次只处理一条)

使用案例

比如我需要在一个路由里面查找数据,我就需要这样:

server.find("users",{username:"username"},function (bool,data) {
    if(bool){
      console.log("查询到数据为" data.length "条");
    }
    else{
      console.log(data);
    }
  });
});

上面的代码是查询了users表里面username为username的字段的数据,如果成功,后面data就会返回一个数组,如果出现错误,就直接返回data错误。

希望本文所述对大家nodejs程序设计有所帮助。

本文实例讲述了nodejs操作mongodb的增删改查功能。分享给大家供大家参考,具体如下: 安装...

安装相关模块

如果使用这个的话,你需要先自己安装一下他需要的模块,在根目录输入

如果使用这个的话,你需要先自己安装一下他需要的模块,在根目录输入

npm install mongodb --save
npm install mongodb --save

进行模块安装,安装成功以后就可以进行以下的步骤。

进行模块安装,安装成功以后就可以进行以下的步骤。

文件的引入

文件的引入

以下是我书写的相关代码,放到你可以引用的相关目录,本人放到了express的根目录

以下是我书写的相关代码,放到你可以引用的相关目录,本人放到了express的根目录

function Mongo(options) {
 this.settings = {
  url: 'mongodb://localhost:27017/jk',
  MongoClient:require('mongodb').MongoClient,
  assert:require('assert')
 };
 for(let i in options){
  this.settings[i] = options[i];
 }
 this._run = function (fun) {
  let that = this;
  let settings = this.settings;
  this.settings.MongoClient.connect(this.settings.url, function (err, db) {
   settings.assert.equal(null, err);
   console.log("Connected correctly to server");
   fun(db, function () {
    db.close();
   });
  });
 };
 this.insert = function (collectionName, data, func) {
  //增加数据
  let insertDocuments = function (db, callback) {
   let collection = db.collection(collectionName);
   collection.insertMany([
    data
   ], function (err, result) {
    if (!err) {
     func(true);
    } else {
     func(false);
    }
    callback(result);
   });
  };
  this._run(insertDocuments);
 };
 this.update = function (collectionName, updateData, data, func) {
  //更新数据
  let updateDocument = function (db, callback) {
   let collection = db.collection(collectionName);
   collection.updateOne(updateData
    , {$set: data}, function (err, result) {
     if (!err) {
      func(true);
     } else {
      func(false);
     }
     callback(result);
    });
  };
  this._run(updateDocument);
 };
 this.delete = function (collectionName, data, func) {
  //删除数据
  let deleteDocument = function (db, callback) {
   let collection = db.collection(collectionName);
   collection.deleteOne(data, function (err, result) {
    if (!err) {
     func(true);
    } else {
     func(false);
    }
    callback(result);
   });
  };
  this._run(deleteDocument);
 };
 this.find = function (collectionName, data, func) {
  //查找数据
  let findDocuments = function (db, callback) {
   // Get the documents collection
   let collection = db.collection(collectionName);
   // Find some documents
   collection.find(data).toArray(function (err, docs) {
    if (!err) {
     func(true,docs);
    }
    else {
     func(false, err);
    }
    callback(docs);
   });
  };
  this._run(findDocuments);
 };
}
module.exports = Mongo;
function Mongo(options) {
  this.settings = {
    url: 'mongodb://localhost:27017/jk',
    MongoClient:require('mongodb').MongoClient,
    assert:require('assert')
  };
  for(let i in options){
    this.settings[i] = options[i];
  }
  this._run = function (fun) {
    let that = this;
    let settings = this.settings;
    this.settings.MongoClient.connect(this.settings.url, function (err, db) {
      settings.assert.equal(null, err);
      console.log("Connected correctly to server");
      fun(db, function () {
        db.close();
      });
    });
  };
  this.insert = function (collectionName, data, func) {
    //增加数据
    let insertDocuments = function (db, callback) {
      let collection = db.collection(collectionName);
      collection.insertMany([
        data
      ], function (err, result) {
        if (!err) {
          func(true);
        } else {
          func(false);
        }
        callback(result);
      });
    };
    this._run(insertDocuments);
  };
  this.update = function (collectionName, updateData, data, func) {
    //更新数据
    let updateDocument = function (db, callback) {
      let collection = db.collection(collectionName);
      collection.updateOne(updateData
        , {$set: data}, function (err, result) {
          if (!err) {
            func(true);
          } else {
            func(false);
          }
          callback(result);
        });
    };
    this._run(updateDocument);
  };
  this.delete = function (collectionName, data, func) {
    //删除数据
    let deleteDocument = function (db, callback) {
      let collection = db.collection(collectionName);
      collection.deleteOne(data, function (err, result) {
        if (!err) {
          func(true);
        } else {
          func(false);
        }
        callback(result);
      });
    };
    this._run(deleteDocument);
  };
  this.find = function (collectionName, data, func) {
    //查找数据
    let findDocuments = function (db, callback) {
      // Get the documents collection
      let collection = db.collection(collectionName);
      // Find some documents
      collection.find(data).toArray(function (err, docs) {
        if (!err) {
          func(true,docs);
        }
        else {
          func(false, err);
        }
        callback(docs);
      });
    };
    this._run(findDocuments);
  };
}
module.exports = Mongo;

我存入到了一个名字叫server.js的文件名内

我存入到了一个名字叫server.js的文件名内

使用

使用

我们在需要使用页面先将模块引入,比如我在路由文件index.js里面引入:

我们在需要使用页面先将模块引入,比如我在路由文件index.js里面引入:

const Server = require("../server.js");
const Server = require("../server.js");

然后需要实例化对象,如下:

然后需要实例化对象,如下:

let server = new Server();
let server = new Server();

如果需要配置相关信息,可以在实例化的时候传入一个对象配置,可以配置数据库的地址:

如果需要配置相关信息,可以在实例化的时候传入一个对象配置,可以配置数据库的地址:

let server = new Server({url:"mongodb://localhost:27017/mydb"});
let server = new Server({url:"mongodb://localhost:27017/mydb"});

里面封装了四个方法,添删改查,分别是

里面封装了四个方法,添删改查,分别是

添加方法

添加方法

server.insert(数据表名,需要插入的数据(键值对的对象),回调函数);

server.insert(数据表名,需要插入的数据(键值对的对象),回调函数);

更新方法

更新方法

server.update(数据表名,查询的数据(对象),更新的数据(对象),回调函数);

server.update(数据表名,查询的数据(对象),更新的数据(对象),回调函数);

删除方法

删除方法

server.delete(数据表名,查询的数据(对象),回调函数);

server.delete(数据表名,查询的数据(对象),回调函数);

查找方法

查找方法

server.find(数据表名,查询的数据(对象),回调函数);

server.find(数据表名,查询的数据(对象),回调函数);

回调函数都会返回两个值,第一个布尔类型,是否处理成功,第二个值,查找返回查找到的个数,别的都返回处理成功的个数(现在一次只处理一条)

回调函数都会返回两个值,第一个布尔类型,是否处理成功,第二个值,查找返回查找到的个数,别的都返回处理成功的个数(现在一次只处理一条)

使用案例

使用案例

比如我需要在一个路由里面查找数据,我就需要这样:

比如我需要在一个路由里面查找数据,我就需要这样:

server.find("users",{username:"username"},function (bool,data) {
  if(bool){
   console.log("查询到数据为" data.length "条");
  }
  else{
   console.log(data);
  }
 });
});
server.find("users",{username:"username"},function (bool,data) {
    if(bool){
      console.log("查询到数据为" data.length "条");
    }
    else{
      console.log(data);
    }
  });
});

上面的代码是查询了users表里面username为username的字段的数据,如果成功,后面data就会返回一个数组,如果出现错误,就直接返回data错误。

上面的代码是查询了users表里面username为username的字段的数据,如果成功,后面data就会返回一个数组,如果出现错误,就直接返回data错误。

以上这篇nodejs操作mongodb的填删改查模块的制作及引入实例就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持脚本之家。

希望本文所述对大家nodejs程序设计有所帮助。

您可能感兴趣的文章:

  • NodeJS学习笔记之MongoDB模块
  • nodejs连接mongodb数据库实现增删改查
  • nodejs中使用monk访问mongodb
  • 基于NodeJS MongoDB AngularJS Bootstrap开发书店案例分析
  • 详解nodejs操作mongodb数据库封装DB类
  • NodeJS中的MongoDB快速入门详细教程
  • 使用Nodejs连接mongodb数据库的实现代码
  • nodejs操作mongodb的增删改查功能实例
  • mongoDB 多重数组查询(AngularJS绑定显示 nodejs)
  • nodejs mongodb vue前后台配置ueditor的示例代码
  • nodejs mongodb aggregate级联查询操作示例

您可能感兴趣的文章:

  • NodeJS学习笔记之MongoDB模块
  • nodejs连接mongodb数据库实现增删改查
  • nodejs中使用monk访问mongodb
  • 基于NodeJS MongoDB AngularJS Bootstrap开发书店案例分析
  • 详解nodejs操作mongodb数据库封装DB类
  • NodeJS中的MongoDB快速入门详细教程
  • 使用Nodejs连接mongodb数据库的实现代码
  • mongoDB 多重数组查询(AngularJS绑定显示 nodejs)
  • nodejs mongodb vue前后台配置ueditor的示例代码
  • nodejs操作mongodb的填删改查模块的制作及引入实例
  • nodejs mongodb aggregate级联查询操作示例

本文由澳门新葡11599发布于www.11599.com,转载请注明出处:nodejs操作mongodb的增删改查功能实例澳门新葡115

关键词: 澳门新葡11599 www.11599.co

AngularJS实现图片上传和预览功能的方法分析澳门

// img id="img-preview"var imgPreview = document.getElementById("img-preview");// input id="img-input" type="file"var imgInput= document.getElementById...

详细>>

jQuery实现动态添加节点与遍历节点功能示例澳门

本文实例讲述了jQuery达成动态增进节点与遍历节点功效。分享给我们供我们参谋,具体如下: 正文实例讲述了jQuery遍...

详细>>

使用ef6创建oracle数据库的实体模型遇到的问题及

消除方案中的数据层项目开始的一段时期使用的是oracle 1一g ef5创造的实人体模型型,在分页时境遇了skip参数为0报错...

详细>>

基于Datatables跳转到指定页的简单实例,datatable

因为品种用到Datatables开采在分页极其多时手足无措跳转到钦点页,本身入手扩充了#Datatables跳转到钦定页#成效,达成...

详细>>