innodb - 如何实现mysql线程安全的nextval()方法

Question

尝试通过建立序列表与函数实现，可以正常返回下条序列，但通过jmeter测试并发100个线程，发现返回的结果中存在重复的记录。

下面是链接中的实现方法

-- 表
CREATE TABLE `sequence_data` (
    `sequence_name` varchar(100) NOT NULL,
    `sequence_increment` int(11) unsigned NOT NULL DEFAULT 1,
    `sequence_min_value` int(11) unsigned NOT NULL DEFAULT 1,
    `sequence_max_value` bigint(20) unsigned NOT NULL DEFAULT 18446744073709551615,
    `sequence_cur_value` bigint(20) unsigned DEFAULT 1,
    `sequence_cycle` boolean NOT NULL DEFAULT FALSE,
    PRIMARY KEY (`sequence_name`)
);
-- 函数
delimiter //
CREATE FUNCTION `nextval` (`seq_name` varchar(100))
RETURNS bigint(20) NOT DETERMINISTIC
BEGIN
    DECLARE cur_val bigint(20);
 
    SELECT
        sequence_cur_value INTO cur_val
    FROM
        sequence_data
    WHERE
        sequence_name = seq_name
    ;
 
    IF cur_val IS NOT NULL THEN
        UPDATE
            sequence_data
        SET
            sequence_cur_value = IF (
                (sequence_cur_value + sequence_increment) > sequence_max_value,
                IF (
                    sequence_cycle = TRUE,
                    sequence_min_value,
                    NULL
                ),
                sequence_cur_value + sequence_increment
            )
        WHERE
            sequence_name = seq_name
        ;
    END IF;
 
    RETURN cur_val;
END

//
delimiter ;

-- insert new sequence
-- INSERT INTO sequence_data (sequence_name) VALUE ('sq_my_sequence');

-- 调用
-- SELECT nextval('sq_my_sequence') as nextval

Answer 1

mysql のデフォルトの分離レベルはrepeatable_readです。トランザクションがコミットされるまで、他のスレッドは変更を読み取ることができません。最後に commit を追加して更新結果を送信できます。それが機能しない場合は、行レベルのロックを使用します (select * sequence_data from WHERE sequence_name = seq_name for update)。1 つのスレッドが送信しない場合、他のスレッドは読み取りを許可されないため、同時実行の安全性が保証されます。