欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Nodejs实现的操作MongoDB数据库功能完整示例

程序员文章站 2022-05-14 09:15:20
本文实例讲述了nodejs实现的操作mongodb数据库功能。分享给大家供大家参考,具体如下: mongodb_demo.js /** cnpm instal...

本文实例讲述了nodejs实现的操作mongodb数据库功能。分享给大家供大家参考,具体如下:

mongodb_demo.js

/**
cnpm install mongodb
 */
var mongoclient = require('mongodb').mongoclient;
var db_conn_str = 'mongodb://test:123456@127.0.0.1:27017/test'; // 数据库为 test
var insertdata = function (db, callback) {
  //连接到表 site
  var collection = db.collection('site');
  //插入数据
  var data = [{ "name": "网站1", "url": "www.test1.com" }, { "name": "网站2", "url": "www.test2.com" }];
  collection.insert(data, function (err, result) {
    if (err) {
      console.log('error:' + err);
      return;
    }
    callback(result);
  });
}
var selectdata = function (db, callback) {
  //连接到表
  var collection = db.collection('site');
  //查询数据
  var wherestr = { "name": '网站1' };
  collection.find(wherestr).toarray(function (err, result) {
    if (err) {
      console.log('error:' + err);
      return;
    }
    callback(result);
  });
}
var updatedata = function (db, callback) {
  //连接到表
  var collection = db.collection('site');
  //更新数据
  var wherestr = { "name": '网站1' };
  var updatestr = { $set: { "url": "https://www.test1.com" } };
  collection.update(wherestr, updatestr, function (err, result) {
    if (err) {
      console.log('error:' + err);
      return;
    }
    callback(result);
  });
}
var deldata = function (db, callback) {
  //连接到表
  var collection = db.collection('site');
  //删除数据
  var wherestr = { "name": '网站1' };
  collection.remove(wherestr, function (err, result) {
    if (err) {
      console.log('error:' + err);
      return;
    }
    callback(result);
  });
}
mongoclient.connect(db_conn_str, function (err, db) {
  if (err) {
    console.log(err);
    return;
  }
  console.log("连接成功!");
  //1、插入
  insertdata(db, function (result) {
    console.log(result);
    db.close();
  });
  //2、查询数据
  selectdata(db, function (result) {
    console.log(result);
    db.close();
  });
  //3、更新数据
  updatedata(db, function (result) {
    console.log(result);
    db.close();
  });
  //4、删除数据
  deldata(db, function (result) {
    console.log(result);
    db.close();
  });
});

运行:

node mongodb_demo.js

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