MySQL自定義序列數的實現方式

2022-12-29 14:02:06

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;

總結

以上為個人經驗，希望能給大家一個參考，也希望大家多多支援it145.com。

MySQL自定義序列數的實現方式

目錄

MySQL自定義序列數實現

建立序列表

插入定義的序列

自定義函數實現

MyBatis中呼叫函數來獲取最新序列數

MySQL新增自定義的序列

使用範例

總結

熱門文章