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

目录

• MySQL自定义序列数实现
• 创建序列表
• 插入定义的序列
• 自定义函数实现
• MyBatis中调用函数来获取最新序列数
• MySQL添加自定义的序列
• 使用实例
• 总结

MySQL自定义序列数实现

往往有很多情况下，我们需要使用自己生成的唯一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;

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持我们。