mysql - 超过锁定等待超时尝试重新启动事务

Question

我必须说，我对后端开发和 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  

所有表都与 KSUser 表具有一对一的关系。
工作代码
感谢 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');
        }
    };

Answer 1

不要编写涉及交易时间超过几秒钟的代码。在我看来，即使这么长也是不明智的。

不要使用 autocommit = 0 ；它导致忘记运行 COMMIT 。相反，提供明确的 BEGIN 和 COMMIT 以便我们，更重要的是，您可以看到交易的边界。

(可能有一百个 3rd 方包生成 MySQL 代码；我没有试图理解它们。如果你想进一步讨论这个，请提供生成的 SQL 代码。)
由于所有异步内容，可能有必要打开 MySQL 的“常规日志”以查看确切发布的内容和时间。