MySQL 自定义序列号生成方案：序列表与函数实现

周叙

发布时间：2026-10-15| 4人浏览过

原创

在高并发或分布式场景中，确保唯一 Id 或生成连续不重复的序列号是常见需求。本文介绍基于 MySQL 数据库原生特性的两种自定义序列号实现方案：一种是轻量级的单函数增量模式，另一种是通过多个辅助函数实现的完整序列管理模块。这两种方案均避免了引入 ZooKeeper 或 Redis 等外部依赖，利用数据库事务保证并发环境下的数据一致性。

为何选择 MySQL 内置序列方案

在需要生成唯一标识符的业务逻辑中，常见的解决思路包括：通过 Java 代码结合内存锁实现（需处理持久化问题），或者借助 Zookeeper、Redis 等中间件获取分布式锁（增加系统复杂度）。相比之下，利用 MySQL 的事务隔离特性和原子的 SQL 操作来实现序列数生成，既保持了系统的轻量性，又能有效防止并发冲突。

第 1 步：创建序列表结构

首先需要在数据库中创建一个专门用于维护序列状态的表。该表通常包含序列名称、当前值和每次递增的数量。

目的：建立存储序列状态的数据实体。
操作：执行以下 SQL 脚本创建 sequence 表。

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;

第 2 步：初始化序列数据

根据需要定义的序列名称，向表中插入初始记录。若未指定步长，默认增量为 1。

INSERT INTO sequence VALUES ('seq1', 0, 1);
INSERT INTO sequence VALUES ('seq2', 0, 1); -- 示例：可在此处插入更多序列定义

第 3 步：定义获取序列值的函数

创建一个自定义函数 seq，该函数利用 MySQL 的 last_insert_id() 特性实现原子性的更新与读取，确保多线程并发时不会返回重复的值。

DROP FUNCTION IF EXISTS `seq`;
DELIMITER $$
CREATE FUNCTION `seq`(seq_name char(20)) RETURNS BIGINT
BEGIN
    -- 利用 last_insert_id 的特性保证并发安全
    UPDATE sequence SET current_value=last_insert_id(current_value + increment) WHERE name=seq_name;
    RETURN last_insert_id();
END $$
DELIMITER ;

第 4 步：应用层调用实例

在 MyBatis 或其他 ORM 框架中，可以直接通过 Select 语句调用上述函数来获取最新生成的序列号。

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

进阶方案：完整的序列管理函数集

除了单一的增加取值函数外，实际生产中往往还需要支持查询当前值、设置特定值等功能。以下是一个更通用的公共序列管理方案，适用于需要灵活控制序列起点的场景。

第 1 步：定义公共序列表

创建名为 t_common_sequence 的表，字段设计包含注释以便于维护。注意根据实际需求调整 INT 类型是否为 BIGINT 以支撑更大的数值范围。

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='公共的序列表';

第 2 步：构建辅助函数

分别创建三个核心函数：f_currval（取当前值）、f_nextval（取下一个值）和 f_setval（重置/设置新值）。

f_currval：仅查询而不修改状态。
f_nextval：先执行递增更新，再返回最新值。
f_setval：将值设定为指定数字，并返回设定后的值。

-- 获取指定名称的当前序列值
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 ;

第 3 步：测试与管理序列

完成上述部署后，可以通过标准 SQL 命令进行日常运维和管理。建议在执行关键修改前对数据进行备份。

初始化序列：插入一个新的序列项。
查询状态：验证函数返回值是否符合预期。

-- 1. 插入序列配置（从 1 开始，每次加 1）
INSERT INTO t_common_sequence(seq_name,current_val,increment_val) VALUES('seq_job',1,1);
COMMIT;

-- 2. 获取当前值
SELECT f_currval('seq_job');

-- 3. 获取下一个值（此时内部表会被更新）
SELECT f_nextval('seq_job');

-- 4. 重置序列值为 10
SELECT f_setval('seq_job',10);

-- 5. 查看最终状态
SELECT * FROM t_common_sequence;

排错与维护注意事项

权限问题：创建自定义函数需要用户拥有 CREATE ROUTINE 权限。如果执行时报错，请联系 DBA 授予相应权限。
数据类型溢出：如果序列预计会超过 INT 的最大范围（约 21 亿），请在建表和函数定义时将类型改为 BIGINT，避免隐式转换导致的截断或报错。
并发竞争：虽然上述函数利用了 MySQL 的行级锁机制，但在极高并发下，频繁调用函数仍可能造成数据库连接压力，建议结合业务逻辑适当增加缓存。