超过锁定等待超时尝试重新启动事务
lock wait timeout exceeded try restarting transaction
我必须说我对后端开发和 mysql 编程还很陌生。我刚开始学习如何使用 Node.js 开发后端。要使用 mysql 进行操作，我正在使用 Sequelize。当我调用下面列出的 api 时，我得到一个错误 - lock wait timeout exceeded try restarting transaction 并且代码跳入 catch 块。我认为这应该是由于错误使用最终会调用 innodb 事务的 sequelize 事务导致的错误。但是我无法弄清楚这个问题，我需要你的帮助。
提前致谢
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
所有 table 与 KSUser table.
具有一对一关系
工作代码
感谢Rick James。你是对的。 KSUserCredential table 比其他 table 大得多，因此提交时间太长。所以我添加了另一个事务来处理从 KSUserStatus 到 KSLikeInfo 的插入。它运作良好。但它可能会导致 Rollback 方面的另一个问题。第一个事务提交成功后，如果第二个事务出错，那么将向数据库中插入意外数据，因为第一个事务已经提交。
不使用 2 个事务，另一种方法是不使用 Relation，而是在一个事务中使用所有必需的操作。之后我的代码开始工作。
这是更新后的代码。
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 以便我们，更重要的是，您可以看到交易的边界。
（可能有一百个生成 MySQL 代码的第 3 方包；我没有试图理解所有这些。如果您想进一步讨论，请提供生成的 SQL 代码.)
由于所有异步内容，可能需要打开 MySQL 的“常规日志”以查看 和何时 发出的确切内容。
我必须说我对后端开发和 mysql 编程还很陌生。我刚开始学习如何使用 Node.js 开发后端。要使用 mysql 进行操作，我正在使用 Sequelize。当我调用下面列出的 api 时，我得到一个错误 - lock wait timeout exceeded try restarting transaction 并且代码跳入 catch 块。我认为这应该是由于错误使用最终会调用 innodb 事务的 sequelize 事务导致的错误。但是我无法弄清楚这个问题，我需要你的帮助。
提前致谢
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
所有 table 与 KSUser table.
具有一对一关系工作代码
感谢Rick James。你是对的。 KSUserCredential table 比其他 table 大得多，因此提交时间太长。所以我添加了另一个事务来处理从 KSUserStatus 到 KSLikeInfo 的插入。它运作良好。但它可能会导致 Rollback 方面的另一个问题。第一个事务提交成功后，如果第二个事务出错，那么将向数据库中插入意外数据，因为第一个事务已经提交。
不使用 2 个事务，另一种方法是不使用 Relation，而是在一个事务中使用所有必需的操作。之后我的代码开始工作。
这是更新后的代码。
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以便我们，更重要的是，您可以看到交易的边界。
（可能有一百个生成 MySQL 代码的第 3 方包；我没有试图理解所有这些。如果您想进一步讨论，请提供生成的 SQL 代码.)
由于所有异步内容，可能需要打开 MySQL 的“常规日志”以查看 和何时 发出的确切内容。