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)
}
网友评论