数据库增删改查的封装
小编不容易
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;
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。