nodejs 封装 mongodb数据库

引入模块

const db = require('fworkMongo')
await db.connect({
    name:'test',
    url:'mongodb://127.0.0.1:27017/',
    model:{ //数据模型 可以为空 针对添加数据和更新数据
        test:{//数据表名 可以为空
            key1: 'String',//数据类型 支持All String、Number、Boolean、Array Object
            key2: 'String'
        }
    }
})

1、插入数据

const res = await db.add('test',data)

1.插入单条数据

const data = {
    "key1": "test1",
    "key2": "test2"
}

添加成功
res = {
	"status": 200,
	"ids": ["62c433c4b083dab65d6cdc89"]
}
添加失败
res = {
	"status": 400,
	"msg": "添加失败！"
}

2.插入多条数据

const data = [
    {
        "key1": "test1",
        "key2": "test2"
    },
    {
        "key3": "test3",
         "key4": "test4"
    }
]

添加成功
res = {
	"status": 200,
	"ids": [
        "62c43637e41ffcb3eb94f711",
        "62c43637e41ffcb3eb94f712"
    ]
}
添加失败
res = {
	"status": 400,
	"msg": "添加失败！"
}

2、删除数据

1.删除多条数据

const data = {
   name: '张三'
}
const res = await db.del('test',data)
const res = await db.remove('test',data)

2.删除单条数据

const res = await db.doc('test').del('6305c5a525350ae1cacd4b41')  //删除

返回成功
res = {
	"status": 200,
	"count": 1  //删除数量
}
返回失败
res = {
	"status": 400,
	"msg": "删除失败!"
}

3、更新数据

1.更新单条数据

const set = {name:'李四'} //更新数据源
const id = '62cd75e6bce3df9417d2714d'
const res = await db.doc('test').upd(id,set)
const res = await db.doc('test').update(id,set)  

2.更新多条数据

const data = {
    where: { _id: '6305c0a66acf306b99b02de0' }, //查找数据源 不得为空或{}
    set: { //更新数据源
        name: '张三',
        ages: 36,
    }
}
const res = await db.update('test',data)

返回成功
res = {
	"status": 200,
	"count": 1  //更新数量
}
返回失败
res = {
	"status": 400,
	"msg": "更新失败!"
}

4、count()根据查询条件获取总条数

const data = {name:'张三'}
const res = await db.count('test',data)

返回成功
res = {
	"status": 200,
	"count": 0  //符合条件总条数
}
返回失败
res = {
	"status": 400,
	"msg": "获取失败!"
}

5、find()条件查询数据

1.根据条件where查询数据

const data = {
    where:{
        "key1": "test1"
    },
    project:{key1:0},//0隐藏 1只返回key1和_id
    skip:0,//跳过指定数目的文档
    sort:{'_id':1},//1升序 -1降序 
    limit:20 //限制20个每页
}
const res = await db.find('test',data)

返回成功
res = {
	"status": 200,
	"count": 1,
	"docs": [
		{
			"_id": "62d00a998f0db7414f0c6285",
			"key1": "test1",
			"key2": "test2"
		}
	]
}
返回失败
res = {
    status: 400,
    msg: '查询失败！'
}

6、聚合查询数据

根据管道查询数据

const data = [
    // {
    //     $lookup: {
    //         from: 'test', // 关联表名
    //         localField: '_id', // 查找表的字段
    //         foreignField: '_id', // 关联表的字段
    //         as: 'key1' // 定义返回数据的字段
    //     }
    // },
    {
        $match:{"key1":"test1"}
    },
    {
        $project:{"key1":0}
    }
]
const res = await db.agg('test',data)

返回成功
res = {
	"status": 200,
	"count": 1,
	"docs": [
		{
			"_id": "62d00a998f0db7414f0c6285",
			"key1": "test1",
			"key2": "test2"
		}
	]
}
返回失败
res = {
    status: 400,
    msg: '查询失败！'
}

7、方法doc 根据id 删除、获取、更新指定文档

1.获取数据

const res = await db.doc('test').get('62d2a65e99d3232cc742c6e0')
返回成功
res = {
	"status": 200,
	"count": 1,
	"docs": [
		{
			"_id": "62d2bd172b39191df29a4db8",
			"key1": "test1",
			"key2": "test2"
		}
	]
}
返回失败
res = {
    status: 400,
    msg: '获取失败！'
}

2.删除数据

const res = await db.doc('test').del('62d2a65e99d3232cc742c6e0')
const res = await db.doc('test').remove('62d2a65e99d3232cc742c6e0')
返回成功
res = {
	"status": 200,
	"count": 1
}
返回失败
res = {
    status: 400,
    msg: '删除失败！'
}

3.更新数据

const res = await db.doc('test').upd('62d2a65e99d3232cc742c6e0',{name:李四})
const res = await db.doc('test').update('62d2a65e99d3232cc742c6e0',{name:李四})
返回成功
res = {
	"status": 200,
	"count": 1
}
返回失败
res = {
    status: 400,
    msg: '更新失败！'
}