MySQL自定义序列数的实现方式
DayDayUp丶 人气:0MySQL自定义序列数实现
往往有很多情况下,我们需要使用自己生成的唯一Id或保证不重复的序列号,特别是在高并发的场景下。
为此,很容易想到的实现方式有以下几种:
- 通过原子操作和锁机制使用Java代码实现,在单JVM中维护内存中的序列数,另外需要自己保证持久化到外部存储系统;
- 或者使用能保证分布式高并发下一致性的组件Zookeeper,借助于它的分布式锁很容易实现,缺点是需要在自己的系统或服务中引入Zookeeper的组件依赖,无疑增加了系统复杂度和可维护性(换用Redis也是同理);
- 另一种容易想到可以利用MySQL的事务操作,存储过程是可以满足事务性的要求,所以这种方式相比于第一种方式更加轻量。
这里介绍采用自定义MySQL序列数的方式来生成唯一Id。
创建序列表
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;
插入定义的序列
INSERT INTO sequence VALUES ('seq1', 0, 1); INSERT INTO sequence VALUES ('seq2', 0, 1); ...
自定义函数实现
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中调用函数来获取最新序列数
<select id="getRowkeyByName" parameterType="java.lang.String" resultType="long"> select `seq`( #{name} ) </select>
MySQL添加自定义的序列
MySQL中也能使用序列,而不是字段的自增长
其实就是自己维护一个表
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 ;
使用实例
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;
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持。
加载全部内容