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

问题描述

尝试通过建立序列表与函数实现，可以正常返回下条序列，但通过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 DETERMINISTICBEGIN DECLARE cur_val bigint(20); SELECTsequence_cur_value INTO cur_val FROMsequence_data WHEREsequence_name = seq_name ; IF cur_val IS NOT NULL THENUPDATE sequence_dataSET 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

问题解答

mysql默认隔离级别是repeatable_read,在你事务提交之前，其他线程读不到你的修改。可以在结尾增加commit提交update的结果。如果还不行就使用行级锁(select * sequence_data from WHERE sequence_name = seq_name for update)，一个线程不提交，其他线程都不允许读，这样就一定可以保证并发安全。