MySQL自定义序列数的实现方式

MySQL自定义序列数实现

往往有很多情况下，我们需要使用自己生成的唯一Id或保证不重复的序列号，特别是在高并发的场景下。

为此，很容易想到的实现方式有以下几种：

• 通过原子操作和锁机制使用Java代码实现，在单JVM中维护内存中的序列数，另外需要自己保证持久化到外部存储系统；
• 或者使用能保证分布式高并发下一致性的组件Zookeeper，借助于它的分布式锁很容易实现，缺点是需要在自己的系统或服务中引入Zookeeper的组件依赖，无疑增加了系统复杂度和可维护性（换用Redis也是同理）；
• 另一种容易想到可以利用MySQL的事务操作，存储过程是可以满足事务性的要求，所以这种方式相比于第一种方式更加轻量。

这里介绍采用自定义MySQL序列数的方式来生成唯一Id。

创建序列表

?

1 2 3 4 5 6 7 8 9 10 11

DROP TABLE     IF EXISTS sequence ; CREATE TABLE     sequence     (         name VARCHAR (50) NOT NULL ,         current_value BIGINT NOT NULL ,         increment INT NOT NULL DEFAULT 1,         PRIMARY KEY ( name )     )     ENGINE=InnoDB;

插入定义的序列

?

1 2 3

INSERT INTO sequence VALUES ( 'seq1' , 0, 1); INSERT INTO sequence VALUES ( 'seq2' , 0, 1); ...

自定义函数实现

?

1 2 3 4 5 6 7 8

DROP FUNCTION IF EXISTS `seq`;   DELIMITER $$   CREATE FUNCTION `seq`(seq_name char (20)) returns BIGINT BEGIN    UPDATE sequence SET current_value=last_insert_id(current_value + increment) WHERE name =seq_name;    RETURN last_insert_id(); END $$ DELIMITER ;

MyBatis中调用函数来获取最新序列数

?

1 2 3 4 5

< select id= "getRowkeyByName" parameterType= "java.lang.String" resultType= "long" >     select `seq`(         #{ name }     ) </ select >

MySQL添加自定义的序列

MySQL中也能使用序列，而不是字段的自增长

其实就是自己维护一个表

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57

use aglog;   -- 创建公共的序列表 DROP TABLE IF EXISTS t_common_sequence; CREATE TABLE t_common_sequence (    seq_name VARCHAR (100) NOT NULL COMMENT '序列名称' ,    current_val INT NOT NULL COMMENT '当前值' ,    increment_val INT NOT NULL DEFAULT '1' COMMENT '增长值 默认1' ,    PRIMARY KEY (seq_name) ) ENGINE = InnoDB CHARACTER SET = utf8 COMMENT= '公共的序列表' ;   -- 创建函数，获取指定名称的 当前序列值 DELIMITER // DROP FUNCTION IF EXISTS f_currval; CREATE FUNCTION f_currval(v_seq_name VARCHAR (100)) RETURNS INT BEGIN    DECLARE value INT ;    SET value = 0;    SELECT current_val into value    FROM t_common_sequence    WHERE seq_name = v_seq_name;    RETURN value; END ; // DELIMITER ;   -- 创建函数，获取指定名称的 下一个序列值 DELIMITER // DROP FUNCTION IF EXISTS f_nextval; CREATE FUNCTION f_nextval(v_seq_name VARCHAR (100)) RETURNS INT BEGIN    UPDATE t_common_sequence    SET current_val = current_val + increment_val    WHERE seq_name = v_seq_name;    RETURN f_currval(v_seq_name); END ; // DELIMITER ;   -- 创建函数，修改指定名称的序列值，并返回 DELIMITER // DROP FUNCTION IF EXISTS f_setval; CREATE FUNCTION f_setval(v_seq_name VARCHAR (100), v_new_val INT ) RETURNS INT BEGIN    UPDATE t_common_sequence    SET current_val = v_new_val    WHERE seq_name = v_seq_name;    RETURN f_currval(v_seq_name); END ; // DELIMITER ;

使用实例

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14

insert into t_common_sequence(seq_name,current_val,increment_val) values ( 'seq_job' ,1,1); commit ;     -- 获取当前序列 select f_currval( 'seq_job' );   -- 获取下一个序列 select f_nextval( 'seq_job' );   -- 设置序列值，并返回 select f_setval( 'seq_job' ,10);   select * from t_common_sequence;

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持服务器之家。

原文链接：https://blog.csdn.net/songzehao/article/details/102900940