mongoose增删改查

//操作MongoDB数据库

//1.导入mongoose模块

let mongoose = require('mongoose');

//2.连接数据库

//mongoose.connect(数据库的路径url)

mongoose.connect('mongodb://127.0.0.1:27017/mongostudy');

//3.是否连接成功 on连接的事件

mongoose.connection.on('connected', function(){

    console.log('MongoDB数据库已经成功连接了');

});

//4.连接出现错误

mongoose.connection.on('error', function(err){

     console.log(`MongoDB数据库操作异常 Error:${err}`);

})

//5.连接断开

mongoose.connection.on('disconnected', function(){

    console.log('断开MongoDB连接');

});

//文件打包导出为模块

module.exports = mongoose;

//对数据进行操作，访问mongodb数据库

//1.导入db.js文件，作为访问数据库的模块

let mongoose = require('./db.js')

//数据库--集合Collection--文档Document

//mongoose

//Schema：一种数据模式，表示数据的结构,数据的key的部分

//Model——>文档Document，一条数据，就是一个model

/*

{

    username: "xiaobai",

    password: "123456",

    age: 20,

    money: 1000000 

}

{

    username: string,

    password: string,

    age: Int32

}

*/

//2.创建Schema对象（结构）

let Schema = mongoose.Schema;

//3.根据Schema对象，定义数据的结构

let userSchema = new Schema({

    username: {type: String},

    password: {type: String},

    age: {type: Number},

    loginDate: {type: Date}

})

//4.导出为模块

module.exports = mongoose.model('User', userSchema);

//数据库中添加数据

//1.把数据的Schema和model结构作为模块导入

let User = require('./user.js');

/*

({

    username: {type: String},

    password: {type: String},

    age: {type: Number},

    loginDate: {type: Date}

})

*/

function insert() {

    //2.用Mode创建一条数据

    let user1 = new User({

        username: "xiaohei",

        password: "123456",

        age: 20,

        loginDate: new Date()

    })

    //3.把数据保存到数据库中save

    user1.save(function (error, response) {

        if (error) {

            console.log(error);

        } else {

            console.log('Success ' + response);

        }

    })

}

//调用插入的函数

insert();

var User = require("./user");

function del() {

    //需要删除的数据

    var wherestr = {'username' : 'miaomiao'};

    User.remove(wherestr,function (err, res) {

        if(err){

            console.log("Error: " + err)

        }else{

            console.log("Success Remove: " + res);

        }

    })

}

del();

var User = require("./user.js");

function update(){

    //wherestr是我们要进行操作的数据

    var wherestr = {'username' : 'xiaohei'};

    //update是我们更新的数据

    var updatestr = {'userpwd': 'miaomiao'};

    User.update(wherestr, updatestr, function(err, res){

        if (err) {

            console.log("Error:" + err);

        }

        else {

            console.log("Update Res: " + res);

        }

    })

}

update();

var User = require('./user');

//查找数据

function findByConditions() {

    var wherestr = {'username' : 'xiaohei'};

    User.find(wherestr,function (err, res) {

        if(err){

            console.log("Error: " + err);

        }else{

            console.log("Find Res: " + res);

        }

    });

}

findByConditions();