SoFunction
Updated on 2025-03-09

Nodejs adds and deletes the mongodb database.

The following is the example code:

/**
  install mongodb --save-dev / cnpm install mongodb --save-dev

  MongoClient = require('mongodb').MongoClient;

  var url = 'mongodb://localhost:27017/test'; Address to connect to the database

  3. Connect to the database

  (url, function(err, db) {

 });

  4. Implement addition, modification and deletion

  (url, function(err, db) {

   ('user').insertOne({'name':'zhangsan'},function(error,data){

   })

 });


  */
var http=require('http');

var ejs=require('ejs');

var MongoClient = require('mongodb').MongoClient; /*Introduce database MongoClient*/

var DBurl = 'mongodb://localhost:27017/userDb'; // The address of the connection database student represents the name of the database
var url=require('url'); /*Introduce url module*/
var app=require('./model/');

(app).listen(3000);


('/',function(req,res){
  var msg='This is the data of the database'
  ('views/',{msg:msg},function(err,data){
    (data);
  })

})



('/add',function(req,res){
  //Add data
  (DBurl,function(err,db){ /*Connect the database*/

    if(err){

      (err);
      ('Database connection failed');
      return;
    }

    //Add data
    ('user').insertOne({

      "name":"loaderman",
      "age":10

    },function(error,result){
      if(error){

        ('Increasing data failed');
        return;
      }
      ('Add data successfully');
      ();/*Close the database*/
    })



  })
})




('/edit',function(req,res){
  //Add data
  //('The data is modified successfully');

  (DBurl,function(err,db){

    if(err){

      (err);
      ('Database connection failed');
      return;
    }
    ('user').updateOne({"name":"loaderman"},{$set:{
      "age":666
    }},function(error,data){
      if(error){

        ('Failed to modify data');
        return;
      }

      (data);
      ('The data is modified successfully');
      ();/*Close the database*/

    })



  })

})


('/delete',function(req,res){
  //Add data  //delete?name=lisi


  //((,true));

  var query=(,true).query;


  //();

  var name=;


  (DBurl,function(err,db){

    if(err){

      (err);
      ('Database connection failed');
      return;
    }

    ('user').deleteOne({"name":name},function(error,data){

      if(error){

        ('Delete failed');
        return;
      }

      (data);
      ('Delete data successfully');
      ();

    })
  })
})

('/query',function(req,res){
  (DBurl,function(err,db){
    if(err){

      ('Connecting to the database failed');
      return;
    }

    //Query data    var list=[]; /*Stack all data in the database*/

    var result=('user').find({});


    (function(error,doc){


      //(doc);
        if(error){
          (error);
        }else{

          if(doc!=null){
            (doc);

          }else{ /*doc==null means that the data loop is completed*/

            /*After getting data*/
            //(list);

            ('views/',{list:list},function(err,data){

              (data);
            })

          }

        }

    })

    //(result);

  })

})

Insert data

/**
  * Insert a single piece of data
  * @param table_name table name
  * @param insertData Inserted Data
  * @param callback method
  */
= function (table_name, insertData , callback) {
  var node_model = (table_name);
  node_model.insertOne(insertData , function (err, res) {
    if (err) {
      callback(err);
    } else {
      callback(null, res);
    }
  });
};

Query data

/**
  * Query a single piece of data
  * @param table_name table name
  * @param conditions Query conditions
  * @param callback method
  */
 = function (table_name, conditions, callback) {
  var node_model = (table_name);
  node_model.findOne(conditions, function (err, res) {
    if (err) {
      callback(err);
    } else {
      callback(null, res);
    }
  });
};

Update data

/**
  * Update single data
  * @param table_name table name
  * @param conditions Query conditions {"name":'jackson Yingqi'};
  * @param updateStr Update data {$set: { "url" : "/jackson-zhangjiang" }};
  * @param callback method
  */
= function (table_name, conditions,updateStr , callback) {
  var node_model = (table_name);
  node_model.updateOne(conditions,updateStr, function (err, res) {
    if (err) {
      callback(err);
    } else {
      callback(null, res);
    }
  });
};

The above are all the relevant knowledge points introduced this time. Thank you for your study. If you have any additional information, you can contact the editor.