javascript - 无法解决承诺链
问题描述
我正在尝试编写一个Sequelize
迁移脚本 win,我正在尝试更新我的数据库,但它有许多异步操作(数据库查询,然后使用特定 id 更新数据库)
这是我的代码
return db.organizationEntries
.findAll()
.then((entries) => {
return entries.forEach(entry => {
console.log(entry);
db.organizationEntries
.findAll({
attributes: [
[
db.sequelize.fn(
'MAX',
db.sequelize.col('organizationEntries.serial_number')
),
'maximum_serial_no'
]
],
where: {
organizationId: entry.organizationId
}
})
.then(orgEntry => {
console.log(orgEntry[0].dataValues.maximum_serial_no);
let data = { serialNumber: orgEntry[0].dataValues.maximum_serial_no + 1 };
console.log(data)
//problem
db.organizationEntries.update(data, {
where: {
id: entry.id
}
})
.then((result) => {
console.log(result);
})
});
// promises.push(promise);
});
// return Promise.all(promises);
})
实际上我想要做的是我试图orgEntries
从数据库中获取所有列表,然后我找到最大的序列号,organization_id
然后更新那个特定的 orgEntry 并且像这样循环中的所有这些操作
现在问题来了,所有事情都按顺序进行,但是在发现max_serial_no
它没有更新数据库之后,我无法解决我应该做些什么来使异步调用按此顺序工作
解决方案
我认为您可以通过两种方式解决此问题:
同时承诺
在下面的代码中,我删除了 forEach 以支持Promise.all()
和map()
- 该
map()
方法创建(并返回)一个新数组,其结果是在调用数组中的每个元素上调用提供的函数。
例子:
let numbers = [1, 2, 3]
let doubledNumbers = numbers.map(n => n * 2)
// doubledNumbers [2, 4, 6]
- 该
Promise.all()
方法将 Promise 数组作为参数并返回一个 Promise
例子:
let promise1 = findUserById(5)
let promise2 = findUserFriends(5)
Promise.all([promise1, promise2])
.then(values => {
// values: [user object, list of user friends]
})
结果:
db.organizationEntries.findAll()
.then(entries => {
return Promise.all(entries.map(entry => {
console.log(entry)
return db.organizationEntries.findAll({
where: {
organizationId: entry.organizationId
},
attributes: [
[
db.sequelize.fn('MAX', db.sequelize.col('organizationEntries.serial_number')),
'maximum_serial_no'
]
]
})
.then(orgEntry => {
console.log(orgEntry[0].dataValues.maximum_serial_no)
let data = { serialNumber: orgEntry[0].dataValues.maximum_serial_no + 1 }
console.log(data)
return db.organizationEntries.update(data, { where: { id: entry.id } })
})
}))
})
.then(result => {
// result: Array of updated organizationEntries
console.log(result)
})
一步一步用reduce()
方法承诺
- 该
reduce()
方法对累加器和数组中的每个元素(从左到右)应用一个函数,以将其减少为单个值。(来自 MDN 网络文档)
例子:
let items = [{ name: 'pencil', price: 2 }, { name: 'book', price: 10 }]
let total = items.reduce((total, item) => total += item.price, 0)
// total: 12
结果:
db.organizationEntries.findAll()
.then(entries => {
return entries.reduce((previousPromise, entry) => {
console.log(entry)
return previousPromise
.then(_ => {
return db.organizationEntries.findAll({
where: {
organizationId: entry.organizationId
},
attributes: [
[
db.sequelize.fn('MAX', db.sequelize.col('organizationEntries.serial_number')),
'maximum_serial_no'
]
]
})
})
.then(orgEntry => {
console.log(orgEntry[0].dataValues.maximum_serial_no)
let data = { serialNumber: orgEntry[0].dataValues.maximum_serial_no + 1 }
console.log(data)
return db.organizationEntries.update(data, { where: { id: entry.id } })
})
.then(updatedEntry => {
console.log(updatedEntry)
})
}, Promise.resolve())
})
.then(result => {
// result: Last updated organization entry
console.log('finished')
})
推荐阅读
- qt - 如何使用 QML 从列表视图页面获取单个项目详细信息页面?
- javascript - Strapi 电子邮件返回 AssertionError [ERR_ASSERTION]:无法包装非错误对象
- javascript - 在 bootstrap-table 的 data-formatter 函数中显示 php 数据
- angular - 为什么 Angular 8 CircleCI 构建在执行 ng test --watch-false 时失败,业力配置为 singleRun=true?
- java - Google 在 Appcompactivity - Android 中对 AutoCompleteTextView 进行 api 调用
- mongodb - 使用 $pull 从用户模型中拉出对象,遇到多个对象项的问题
- angular - 如何以角度合并/合并数组内的数组
- prometheus - Prometheus 基于一天中的时间查询
- mysql - 查询特定科目通过或未通过的学生
- excel - 将 mdb 到 accdb 转换为 excel vba