重新适配
This commit is contained in:
@@ -19,6 +19,27 @@ const query = sql => new Promise((resolve, reject) => {
|
|||||||
}
|
}
|
||||||
})
|
})
|
||||||
});
|
});
|
||||||
|
const insert = ({table, form}) => {
|
||||||
|
let sql
|
||||||
|
if (form.id) {//编辑
|
||||||
|
let arr = Object.keys(form).filter(e => form[e]).map(e => {
|
||||||
|
if (typeof form[e] == "object") form[e] = JSON.stringify(form[e])
|
||||||
|
return `${e}='${form[e]}'`
|
||||||
|
})
|
||||||
|
sql = `update ${table} set ${arr.join(",")} where id='${form.id}'`
|
||||||
|
} else {//新增
|
||||||
|
let cols = [], arr = []
|
||||||
|
Object.keys(form).map(e => {
|
||||||
|
if (form[e]) {
|
||||||
|
cols.push(e)
|
||||||
|
if (typeof form[e] == "object") form[e] = JSON.stringify(form[e])
|
||||||
|
arr.push(`'${form[e]}'`)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
sql = `insert into ${table} (id,createTime,${cols.join(",")}) values('${uuid()}','${dayjs().format("YYYY-MM-DD HH:mm:ss")}',${arr.join(",")})`
|
||||||
|
}
|
||||||
|
return sql
|
||||||
|
}
|
||||||
module.exports = {
|
module.exports = {
|
||||||
pool: null,
|
pool: null,
|
||||||
init: () => {
|
init: () => {
|
||||||
@@ -48,33 +69,12 @@ module.exports = {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
insert: ({table, form}) => {
|
|
||||||
let sql
|
|
||||||
if (form.id) {//编辑
|
|
||||||
let arr = Object.keys(form).filter(e => form[e]).map(e => {
|
|
||||||
if (typeof form[e] == "object") form[e] = JSON.stringify(form[e])
|
|
||||||
return `${e}='${form[e]}'`
|
|
||||||
})
|
|
||||||
sql = `update ${table} set ${arr.join(",")} where id='${form.id}'`
|
|
||||||
} else {//新增
|
|
||||||
let cols = [], arr = []
|
|
||||||
Object.keys(form).map(e => {
|
|
||||||
if (form[e]) {
|
|
||||||
cols.push(e)
|
|
||||||
if (typeof form[e] == "object") form[e] = JSON.stringify(form[e])
|
|
||||||
arr.push(`'${form[e]}'`)
|
|
||||||
}
|
|
||||||
})
|
|
||||||
sql = `insert into ${table} (id,createTime,${cols.join(",")}) values('${uuid()}','${dayjs().format("YYYY-MM-DD HH:mm:ss")}',${arr.join(",")})`
|
|
||||||
}
|
|
||||||
return sql
|
|
||||||
},
|
|
||||||
batchInsert({table, list}) {
|
batchInsert({table, list}) {
|
||||||
return query(list.map(form => this.insert({table, form})).join(";"))
|
return query(list.map(form => insert({table, form})).join(";"))
|
||||||
},
|
},
|
||||||
addOrUpdate: ({table, form}) => {
|
addOrUpdate: ({table, form}) => {
|
||||||
//新增和更新
|
//新增和更新
|
||||||
const sql = this.insert({table, form})
|
const sql = insert({table, form})
|
||||||
return query(sql)
|
return query(sql)
|
||||||
},
|
},
|
||||||
delete: ({table, ids}) => {
|
delete: ({table, ids}) => {
|
||||||
|
|||||||
Reference in New Issue
Block a user