MongoDB的增删查改示例代码

let mongoose = require("mongoose");

let User = require("./pojo/user");

// 指定数据库连接的地址, 如果端口号是27017,可以不写

// test表示的是数据库的名字

mongoose.connect("mongodb://localhost/test", {useNewUrlParser: true})

// 获取一个连接

let connection = mongoose.connection;

connection.on("error", (err) => {

    if (err) {

        throw err;

    }

});

connection.once("open", () => {

    console.log("连接成功")

    testQuery();

})

async function testQuery() {

    // 指定条件,进行查询

    // let result = await User.find({address: "shenzhen"});

    // 不指定条件,查询所有

    // let result = await User.find();

    // skip : 跳过多少条数据, limit : 每一页显示多少条数据

    //  偏移量 =  (page-1)*size

    // let result = await User.find().skip(2).limit(1);

    // 指定要返回的列

    let result = await User.find().select("name age address");

    // 升序,从小到大

    // let result = await User.find().sort("age")

    // let result = await User.find().sort({age:1})

    // 倒序,从大到小

    // let result = await User.find().sort({age:-1})

    // let result = await User.find().sort("-age");

    // greater than : 大于

    // less than : 小于

    // equal  : 等于

//  let result = await User.find({age: {$lt: 18}});

    console.log(result)

}

// 添加

async function testInsert() {

    let result = await User.create([{

        name: "lisi",

        age: 28,

        address: "shenzhen"

    }, {

        name: "wangwu",

        age: 12,

        address: "beijing"

    }, {

        name: "zhaoliu",

        age: 19,

        address: "guangzhou"

    }]);

    console.log(result)

}

// 更新数据

async function testUpdate() {

    // 两个参数,都是对象

    // 参数1 : 查询条件

    // 参数2 : 更新后的值

    let result = await User.update({_id: "5bc1a29fd46478433870fbcf"}, {name: "zhangsan"});

    console.log(result)

}

// 删除数据

async function testDelete() {

    // 两个参数,都是对象

    // 参数1 : 查询条件

    // 参数2 : 更新后的值

    let result = await User.deleteOne({_id: "5bc1a29fd46478433870fbcf"});

    console.log(result)

}