MySQL自定義序列數(shù)的實(shí)現(xiàn)方式

更新時(shí)間：2022年12月28日 11:09:48 作者：DayDayUp丶

這篇文章主要介紹了MySQL自定義序列數(shù)的實(shí)現(xiàn)方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

MySQL自定義序列數(shù)實(shí)現(xiàn)

往往有很多情況下，我們需要使用自己生成的唯一Id或保證不重復(fù)的序列號(hào)，特別是在高并發(fā)的場(chǎng)景下。

為此，很容易想到的實(shí)現(xiàn)方式有以下幾種：

通過(guò)原子操作和鎖機(jī)制使用Java代碼實(shí)現(xiàn)，在單JVM中維護(hù)內(nèi)存中的序列數(shù)，另外需要自己保證持久化到外部存儲(chǔ)系統(tǒng)；
或者使用能保證分布式高并發(fā)下一致性的組件Zookeeper，借助于它的分布式鎖很容易實(shí)現(xiàn)，缺點(diǎn)是需要在自己的系統(tǒng)或服務(wù)中引入Zookeeper的組件依賴(lài)，無(wú)疑增加了系統(tǒng)復(fù)雜度和可維護(hù)性（換用Redis也是同理）；
另一種容易想到可以利用MySQL的事務(wù)操作，存儲(chǔ)過(guò)程是可以滿(mǎn)足事務(wù)性的要求，所以這種方式相比于第一種方式更加輕量。

這里介紹采用自定義MySQL序列數(shù)的方式來(lái)生成唯一Id。

創(chuàng)建序列表

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);
...

自定義函數(shù)實(shí)現(xiàn)

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中調(diào)用函數(shù)來(lái)獲取最新序列數(shù)

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

MySQL添加自定義的序列

MySQL中也能使用序列，而不是字段的自增長(zhǎng)

其實(shí)就是自己維護(hù)一個(gè)表

use aglog;
 
-- 創(chuàng)建公共的序列表
DROP TABLE IF EXISTS t_common_sequence;
CREATE TABLE t_common_sequence (
  seq_name VARCHAR(100) NOT NULL COMMENT '序列名稱(chēng)',
  current_val INT NOT NULL COMMENT '當(dāng)前值',
  increment_val INT NOT NULL DEFAULT '1' COMMENT '增長(zhǎng)值 默認(rèn)1',
  PRIMARY KEY(seq_name)
)
ENGINE = InnoDB
CHARACTER SET = utf8
COMMENT='公共的序列表';
 
-- 創(chuàng)建函數(shù)，獲取指定名稱(chēng)的 當(dāng)前序列值
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 ;
 
-- 創(chuàng)建函數(shù)，獲取指定名稱(chēng)的 下一個(gè)序列值
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 ;
 
-- 創(chuàng)建函數(shù)，修改指定名稱(chēng)的序列值，并返回
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 ;

使用實(shí)例

insert into t_common_sequence(seq_name,current_val,increment_val) values('seq_job',1,1);
commit;
 
 
-- 獲取當(dāng)前序列
select f_currval('seq_job');
 
-- 獲取下一個(gè)序列
select f_nextval('seq_job');
 
-- 設(shè)置序列值，并返回
select f_setval('seq_job',10);
 
select * from t_common_sequence;