nodejs 对mongodb数据库的增加修删该查操作

Posted 码上加油站

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了nodejs 对mongodb数据库的增加修删该查操作相关的知识,希望对你有一定的参考价值。

/**
1.npm install mongodb --save-dev / cnpm install mongodb --save-dev

2.var MongoClient = require(‘mongodb‘).MongoClient;

 var url = ‘mongodb://localhost:27017/test‘;   连接数据库的地址

 3.连接数据库

 MongoClient.connect(url, function(err, db) {

});

 4.实现增加修改删除

 MongoClient.connect(url, function(err, db) {

    db.collection(‘user‘).insertOne({‘name‘:‘zhangsan‘},function(error,data){

    })

});


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

var ejs=require(‘ejs‘);

var MongoClient = require(‘mongodb‘).MongoClient;  /*引入数据库 MongoClient*/

var DBurl = ‘mongodb://localhost:27017/userDb‘;  // 连接数据库的地址   student表示数据库的名称

var url=require(‘url‘); /*引入url模块*/
var app=require(‘./model/express-route.js‘);

http.createServer(app).listen(3000);


app.get(‘/‘,function(req,res){
    var msg=‘这是数据库的数据‘
    ejs.renderFile(‘views/index.ejs‘,{msg:msg},function(err,data){
        res.send(data);
    })

})



app.get(‘/add‘,function(req,res){
   //增加数据

    MongoClient.connect(DBurl,function(err,db){  /*连接数据库*/

        if(err){

            console.log(err);
            console.log(‘数据库连接失败‘);
            return;
        }

        //增加数据

        db.collection(‘user‘).insertOne({

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

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

                console.log(‘增加数据失败‘);
                return;
            }
            res.send(‘增加数据成功‘);
            db.close();/*关闭数据库*/
        })



    })
})




app.get(‘/edit‘,function(req,res){
    //增加数据

    //res.send(‘修改数据成功‘);


    MongoClient.connect(DBurl,function(err,db){

        if(err){

            console.log(err);
            console.log(‘数据库连接失败‘);
            return;
        }
        db.collection(‘user‘).updateOne({"name":"loaderman"},{$set:{
            "age":666
        }},function(error,data){
            if(error){

                console.log(‘修改数据失败‘);
                return;
            }

            console.log(data);
            res.send(‘修改数据成功‘);
            db.close();/*关闭数据库*/

        })



    })

})


app.get(‘/delete‘,function(req,res){
    //增加数据
    //delete?name=lisi


    //console.log(url.parse(req.url,true));

    var query=url.parse(req.url,true).query;


    //console.log(query.name);

    var name=query.name;


    MongoClient.connect(DBurl,function(err,db){

        if(err){

            console.log(err);
            console.log(‘数据库连接失败‘);
            return;
        }

        db.collection(‘user‘).deleteOne({"name":name},function(error,data){

            if(error){

                console.log(‘删除失败‘);
                return;
            }

            console.log(data);
            res.send(‘删除数据成功‘);
            db.close();

        })
    })
})
app.get(‘/query‘,function(req,res){
MongoClient.connect(DBurl,function(err,db){
if(err){

console.log(‘连接数据库失败‘);
return;
}

//查询数据
var list=[]; /*放数据库里面查询的所有数据*/

var result=db.collection(‘user‘).find({});


result.each(function(error,doc){


//console.log(doc);
if(error){
console.log(error);
}else{

if(doc!=null){
list.push(doc);

}else{ /*doc==null表示数据循环完成*/

/*获取数据以后*/
//console.log(list);

ejs.renderFile(‘views/index.ejs‘,{list:list},function(err,data){

res.send(data);
})

}

}

})

//console.log(result);

})

})
 

 

以上是关于nodejs 对mongodb数据库的增加修删该查操作的主要内容,如果未能解决你的问题,请参考以下文章

nodejs操作mongodb数据库(mongodb)

nodejs对mongodb数据库的增删改查操作(转载)

nodejs对mongodb数据库的增删改查操作(转载)

按月对记录进行分组并计数 - Mongoose、nodeJs、mongoDb

库增删该查,表增删该查,记录增删该查,mysql用户管理,表与表关系(多对多,多对一,一对一)

Nodejs,mongodb在插入许多后更新数组