数据库增删改查的封装
小编不容易
const sql = {
insert: function (Collection,insertData) {
return new Promise((resolve,reject) => {
Collection.insertMany(insertData,(err) => {
if (err) throw err;
resolve()
})
})
},find (Collection,whereObj,showObj) {
// return new Promise(function (resolve,reject) {})
// return new Promise(function (resolve,reject) { // 异步操作})
// return new Promise(function (resolve,reject) { // 异步操作 - reslove(data)})
return new Promise(function (resolve,reject) {
Collection.find(whereObj,showObj).exec((err,data) => {
if (err) throw err;
resolve(data)
})
})
},sort: function * (Collection,showObj,sortObj) {
return new Promise(function (resolve,showObj).sort(sortObj).exec((err,data) => {
if (err) throw err;
resolve(data)
})
})
},update (Collection,updateObj,updateType) {
// Collection['updateOne']() <===> Collection.updateOne()
// style.width = '100px' style['width'] = '100px';
return new Promise((resolve,reject) => {
updateType = updateType || 'updateOne'
Collection[updateType](whereObj,(err) => {
if (err) throw err;
resolve();
})
})
},delete (Collection,deleteType) {
return new Promise((resolve,reject) => {
deleteType = deleteType || 'deleteOne';
Collection[deleteType](whereObj,distinct(Collection,type) {
return new Promise((resolve,reject) => {
Collection.distinct(type).exec((err,data) => {
if (err) throw err;
resolve(data)
})
})
}
}
module.exports = sql;