我必须说，我对后端开发和 mysql 编程也很陌生。我刚开始学习如何使用 Node.js 开发后端。为了使用 mysql，我使用 Sequelize。当我调用下面列出的 api 时，出现错误 - 锁定等待超时超过尝试重新启动事务 并且代码跳转到 catch 块。我认为这应该是错误使用 sequelize 事务导致的错误，最终会调用 innodb 事务。但我无法弄清楚这个问题，我需要你的帮助。
先感谢您
const registerUsers = async (req, res) => {
const {
body
} = req;
try {
await db.sequelize.transaction(async (t) => {
await body.users.reduce(async (promise, item) => {
await promise;
const user = await db.KSUser.findOne({
where: {
phoneNum: item.userId,
},
transaction: t
});
if (!user) {
const newUser = await db.KSUser.create({
phoneNum: item.userId,
verifyURL: item.password,
loginType: body.type,
}, {
include: [{
model: db.KSUserCredential,
as: 'credential',
},
{
model: db.KSUserStatus,
as: 'userStatus',
},
{
model: db.KSTrainInfo,
as: 'trainInfo',
},
{
model: db.KSFollowInfo,
as: 'followInfo',
},
{
model: db.KSLikeInfo,
as: 'likeInfo',
},
],
transaction: t
});
await newUser.createCredential({
countryCode: body.countryCode,
}, {
transaction: t
});
await newUser.createUserStatus({ transaction: t });
await newUser.createTrainInfo({ transaction: t });
await newUser.createFollowInfo({ transaction: t });
await newUser.createLikeInfo({ transaction: t });
}
}, Promise.resolve());
return apiResponse.successResponse(
res,
'Successfully registered accounts'
);
});
} catch (err) {
console.log(err);
return apiResponse.ErrorResponse(res, 'Internal server error');
}
};
这是 mysql 打印的一般日志。
2021-01-07T18:10:45.118166Z 13 Query SELECT * FROM ks_db.ksuser
LIMIT 0, 5000
2021-01-07T18:10:45.119052Z 12 Query SHOW INDEX FROM `ks_db`.`ksuser`
2021-01-07T18:10:46.081547Z 13 Query set autocommit=1
2021-01-07T18:11:05.790801Z 34 Connect root@localhost on ks_db using TCP/IP
2021-01-07T18:11:05.791242Z 34 Query SET time_zone = '+00:00'
2021-01-07T18:11:05.792341Z 34 Query START TRANSACTION
2021-01-07T18:11:05.794342Z 34 Query SELECT `id`, `phoneNum`, `verifyURL`, `wbId`, `wbPassword`, `wxId`, `wxPassword`, `qqId`, `qqPassword`, `loginType`, `createdAt` FROM `KSUser` AS `KSUser` WHERE `KSUser`.`phoneNum` = '11111111111' LIMIT 1
2021-01-07T18:11:05.805810Z 34 Prepare INSERT INTO `KSUser` (`id`,`phoneNum`,`verifyURL`,`wbId`,`wbPassword`,`wxId`,`wxPassword`,`qqId`,`qqPassword`,`loginType`,`createdAt`) VALUES (DEFAULT,?,?,?,?,?,?,?,?,?,?)
2021-01-07T18:11:05.806970Z 34 Execute INSERT INTO `KSUser` (`id`,`phoneNum`,`verifyURL`,`wbId`,`wbPassword`,`wxId`,`wxPassword`,`qqId`,`qqPassword`,`loginType`,`createdAt`) VALUES (DEFAULT,'855764823583','http://45.251.242.43:17879/api/1.0.0/message.php?api_key=e74475a6f4bc285e405c524e3fa3091&mobile=855764823583','','','','','','',0,'2021-01-07 18:11:05')
2021-01-07T18:11:05.811604Z 34 Prepare INSERT INTO `KSUserCredential` (`id`,`userId`,`countryCode`,`androidId`,`clientSalt`,`token`,`egId`,`apiSt`,`passToken`,`h5St`,`IMEI`,`deviceId`,`kwaiId`,`user_id`) VALUES (DEFAULT,?,?,?,?,?,?,?,?,?,?,?,?,?)
2021-01-07T18:11:05.812002Z 34 Execute INSERT INTO `KSUserCredential` (`id`,`userId`,`countryCode`,`androidId`,`clientSalt`,`token`,`egId`,`apiSt`,`passToken`,`h5St`,`IMEI`,`deviceId`,`kwaiId`,`user_id`) VALUES (DEFAULT,'','KH','','','','','','','','',-1,'',676)
2021-01-07T18:11:05.815591Z 35 Connect root@localhost on ks_db using TCP/IP
2021-01-07T18:11:05.816038Z 35 Query SET time_zone = '+00:00'
2021-01-07T18:11:05.817191Z 35 Prepare INSERT INTO `KSUserStatus` (`id`,`isPlaying`,`isTrain`,`playingType`,`isActive`,`connectorId`,`isProxy`,`proxyIp`,`proxyPort`,`location`,`user_id`) VALUES (DEFAULT,?,?,?,?,?,?,?,?,?,?)
2021-01-07T18:11:05.817584Z 35 Execute INSERT INTO `KSUserStatus` (`id`,`isPlaying`,`isTrain`,`playingType`,`isActive`,`connectorId`,`isProxy`,`proxyIp`,`proxyPort`,`location`,`user_id`) VALUES (DEFAULT,0,1,0,1,0,0,'',0,'',676)
2021-01-07T18:11:57.067850Z 34 Query ROLLBACK
2021-01-07T18:12:07.120148Z 35 Quit
2021-01-07T18:12:07.120247Z 34 Quit
工作代码
感谢 Rick James 。你是对的。
KSUserCredential 表比其他表大得多，因此提交时间太长。所以我添加了另一个处理从 KSUserStatus 插入到 KSLikeInfo 的事务。它运作良好。但这可能会导致回滚方面的另一个问题。第一个事务提交成功后，如果第二个事务出错，那么意外的数据将插入到数据库中，因为第一个事务已经提交。另一种方法不是使用 2 个事务，而是不使用关系，而是在一个事务中使用所有必需的操作。之后我的代码开始工作。
这是更新的代码。
const registerUsers = async (req, res) => {
const {
body
} = req;
try {
await body.users.reduce(async (promise, item) => {
await promise;
var in_condition;
var query;
switch (body.type) {
case 0:
in_condition = { phoneNum: item.userId };
query = {
phoneNum: item.userId,
verifyURL: item.password,
loginType: body.type,
};
break;
case 1:
in_condition = { wbId: item.userId };
query = {
wbId: item.userId,
wbPassword: item.password,
loginType: body.type,
};
break;
case 2:
in_condition = { wxId: item.userId };
query = {
wxId: item.userId,
wxPassword: item.password,
loginType: body.type,
};
break;
case 3:
in_condition = { qqId: item.userId };
query = {
qqId: item.userId,
qqPassword: item.password,
loginType: body.type,
};
break;
default:
break;
}
await db.sequelize.transaction(async (t) => {
const user = await db.KSUser.findOne({
where: in_condition,
transaction: t
});
if (!user) {
const newUser = await db.KSUser.create(query, {
transaction: t
});
// eslint-disable-next-line no-extra-boolean-cast
if (!!newUser) {
await db.KSUserCredential.create({
countryCode: body.countryCode,
user_id: newUser.id
}, {
transaction: t
});
await db.KSUserStatus.create({user_id: newUser.id}, {transaction: t});
await db.KSTrainInfo.create({user_id: newUser.id}, {transaction: t});
await db.KSFollowInfo.create({user_id: newUser.id}, {transaction: t});
await db.KSLikeInfo.create({user_id: newUser.id}, {transaction: t});
}
}
});
}, Promise.resolve());
return apiResponse.successResponse(
res,
'Successfully registered new accounts'
);
} catch (err) {
console.log(err);
return apiResponse.ErrorResponse(res, 'Internal server error');
}
};
最佳答案
autocommit = 0 ；它导致忘记运行 COMMIT 。相反，提供明确的 BEGIN 和 COMMIT 以便我们，更重要的是，您可以看到交易的边界。 (可能有一百个 3rd 方包生成 MySQL 代码；我没有试图理解它们。如果你想进一步讨论这个，请提供生成的 SQL 代码。)
由于所有异步内容，可能有必要打开 MySQL 的“常规日志”以查看确切发布的内容和时间。
关于mysql - 超过锁定等待超时尝试重新启动事务，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/65609781/