表更新

This commit is contained in:
lvyuankang 2024-08-02 15:27:44 +08:00
parent 1d14f2bf7d
commit 2a78525e42

View File

@ -83,8 +83,10 @@ function sqlInsertCommonFn(tableName, resultArr, context?, delFlag = true) {
}, map[tableName], context); }, map[tableName], context);
accountTable.getRdbStore(() => { accountTable.getRdbStore(() => {
accountTable.query('0', async (result) => { accountTable.query('0', async (result) => {
console.log('sqlsqlinsertresult',JSON.stringify(result))
// console.log('表长度',result.length,tableName) // console.log('表长度',result.length,tableName)
if (result.length == 0) { if (result.length == 0) {
console.log('sqlsqlinsert00000')
let INSERT_SQL = "INSERT INTO " + tableName let INSERT_SQL = "INSERT INTO " + tableName
+ " (" + map[tableName].ACCOUNT_TABLE.columns.toString() + ") VALUES " + " (" + map[tableName].ACCOUNT_TABLE.columns.toString() + ") VALUES "
@ -105,6 +107,7 @@ function sqlInsertCommonFn(tableName, resultArr, context?, delFlag = true) {
} }
INSERT_SQL += str INSERT_SQL += str
}) })
console.log('sqlsqlinsertINSERT_SQLINSERT_SQL', INSERT_SQL)
accountTable.sqlOperate(INSERT_SQL, tableName, (val) => { accountTable.sqlOperate(INSERT_SQL, tableName, (val) => {
console.log('sqlsqlinsert,', val, 'tableName', tableName) console.log('sqlsqlinsert,', val, 'tableName', tableName)
resolve(val) resolve(val)
@ -113,6 +116,9 @@ function sqlInsertCommonFn(tableName, resultArr, context?, delFlag = true) {
else { else {
if (delFlag) { if (delFlag) {
await delSyncTable(tableName, context) await delSyncTable(tableName, context)
const result = await sqlInsertCommonFn(tableName, resultArr, context)
resolve(result)
return
} }
const result = await sqlInsertCommonFn(tableName, resultArr, context) const result = await sqlInsertCommonFn(tableName, resultArr, context)
resolve(result) resolve(result)
@ -159,7 +165,11 @@ export async function getDataBaseTable(params, reqParam) {
//依据数组和表名更新sql表 //依据数组和表名更新sql表
export async function upDateTableByArray(tableName, arr) { export async function upDateTableByArray(tableName, arr) {
sqlInsertCommonFn(tableName, arr) return new Promise(async (reslove,reject)=>{
const data =await sqlInsertCommonFn(tableName, arr)
console.log('sqlsqlinsertsqlsqlinsertkkk',data)
reslove(data)
})
} }
//更新双中心表 //更新双中心表