我使用事务outta knexjs在2个表中插入值(1.结果,2。结果详细信息)。当在表2(resultdetail)中插入值时,我有一个对象数组,其大小随每个条目而变化(基于主题数)。
{
"name": "Sally",
"fathername": "John",
"rollno": "85a76",
"classname": "class1",
"detail": [
{
"subject": "History",
"marksobt": "50",
"totalmarks": "100"
},
{
"subject": "French",
"marksobt": "75",
"totalmarks": "75"
}
]
}
我正在尝试使用代码来执行此操作。 (同样,“细节”数组的大小因主题数而异)
const { name, fathername, rollno, classname } = req.body;
db.transaction(trx => {
db.insert({
name: name,
fathername: fathername,
rollno: rollno,
classname: classname
}).into('results')
.transacting(trx)
.returning('rollno')
.then(roll_no => {
req.body.detail.map(result => {
return trx('resultdetail')
.returning('*')
.insert({
rollno: roll_no[0],
subject: result.subject,
marksobt: result.marksobt,
totalmarks: result.totalmarks
}).then(console.log)
})
})
.then(trx.commit)
.catch(trx.rollback)
})
.catch(err => res.status(400).json(err))
Unhandled rejection Error: Transaction query already complete, run with DEBUG=knex:tx for more info
insertedRows = await knex('results').returning('*').insert([
{
"subject": "History",
"marksobt": "50",
"totalmarks": "100"
},
{
"subject": "French",
"marksobt": "75",
"totalmarks": "75"
}
]);
但主要是你的问题是你同时启动多个查询+提交而不等待早期的查询准备就绪......
当您向第二个表添加内容时,它应该是这样的:
.then(roll_no => {
let resultsToAdd = req.body.detail.map(result => {
return {
rollno: roll_no[0],
subject: result.subject,
marksobt: result.marksobt,
totalmarks: result.totalmarks
};
});
return return trx('resultdetail')
.returning('*')
.insert(resultsToAdd);
})