在MySQL中创建实现自增的序列（Sequence）的教程

数据库 2024/12/28 佚名

3 1 2

项目应用中，曾有以下一个场景：
接口中要求发送一个int类型的流水号，由于多线程模式，如果用时间戳，可能会有重复的情况(当然概率很小)。
所以想到了利用一个独立的自增的sequence来解决该问题。
当前数据库为：mysql
由于mysql和oracle不太一样，不支持直接的sequence，所以需要创建一张table来模拟sequence的功能，理由sql语句如下：
第一步：创建--Sequence 管理表

DROP TABLE IF EXISTS sequence; 
CREATE TABLE sequence ( 
     name VARCHAR(50) NOT NULL, 
     current_value INT NOT NULL, 
     increment INT NOT NULL DEFAULT 1, 
     PRIMARY KEY (name) 
) ENGINE=InnoDB;

第二步：创建--取当前值的函数

DROP FUNCTION IF EXISTS currval; 
DELIMITER $ 
CREATE FUNCTION currval (seq_name VARCHAR(50)) 
     RETURNS INTEGER 
     LANGUAGE SQL 
     DETERMINISTIC 
     CONTAINS SQL 
     SQL SECURITY DEFINER 
     COMMENT '' 
BEGIN 
     DECLARE value INTEGER; 
     SET value = 0; 
     SELECT current_value INTO value 
          FROM sequence 
          WHERE name = seq_name; 
     RETURN value; 
END 
$ 
DELIMITER ;

第三步：创建--取下一个值的函数

DROP FUNCTION IF EXISTS nextval; 
DELIMITER $ 
CREATE FUNCTION nextval (seq_name VARCHAR(50)) 
     RETURNS INTEGER 
     LANGUAGE SQL 
     DETERMINISTIC 
     CONTAINS SQL 
     SQL SECURITY DEFINER 
     COMMENT '' 
BEGIN 
     UPDATE sequence 
          SET current_value = current_value + increment 
          WHERE name = seq_name; 
     RETURN currval(seq_name); 
END 
$ 
DELIMITER ;

第四步：创建--更新当前值的函数

DROP FUNCTION IF EXISTS setval; 
DELIMITER $ 
CREATE FUNCTION setval (seq_name VARCHAR(50), value INTEGER) 
     RETURNS INTEGER 
     LANGUAGE SQL 
     DETERMINISTIC 
     CONTAINS SQL 
     SQL SECURITY DEFINER 
     COMMENT '' 
BEGIN 
     UPDATE sequence 
          SET current_value = value 
          WHERE name = seq_name; 
     RETURN currval(seq_name); 
END 
$ 
DELIMITER ;

第五步：测试函数功能
当上述四步完成后，可以用以下数据设置需要创建的sequence名称以及设置初始值和获取当前值和下一个值。

INSERT INTO sequence VALUES ('TestSeq', 0, 1);----添加一个sequence名称和初始值，以及自增幅度
SELECT SETVAL('TestSeq', 10);---设置指定sequence的初始值
SELECT CURRVAL('TestSeq');--查询指定sequence的当前值
SELECT NEXTVAL('TestSeq');--查询指定sequence的下一个值

在java代码中，可直接创建sql语句查询下一个值，这样就解决了流水号唯一的问题。
贴出部分代码（已测试通过）

public void testGetSequence() { 
  Connection conn = JDBCUtils.getConnection(url, userName, password); 
  String sql = "SELECT CURRVAL('TestSeq');"; 
  PreparedStatement ptmt = null; 
  ResultSet rs = null; 
  try { 
    ptmt = conn.prepareStatement(sql); 
    rs = ptmt.executeQuery(); 
    int count = 0; 
    while (rs.next()) { 
      count = rs.getInt(1); 
    } 
    System.out.println(count); 
  } catch (SQLException e) { 
    e.printStackTrace(); 
  } finally { 
    JDBCUtils.close(rs, ptmt, conn); 
  } 
}

ps：在应用中，还有一种用java代码去实现模拟自增sequence的方式，具体思路是创建一张存放sequence的table，然后通过java调用sql语句去查询和修改这个table中指定sequence名称的值，这种方式请加上synchronized。具体代码这里就不上传了，因为实现了，未去测试过。

在 oracle 中， sequence 提供多表多字段可共用一个不重复值。 Mysql 中存在自增列，基本可以满足 PK 的要求。但自增列存在限制：

a. 只能用于表中的一个字段，一张不能同时存在两个以上的自增列 ;

b. 自增列必须被定义为 key （ PK 或 FK ） ;

c. 自增列不能被多个表共用 ;

d. 当 insert 语句不包括自增字段或将其值设置为 NULL 时，该值会自动填上。

在不要求字段顺序递增的情况下，可以在 Mysql 中实现序列，再来看下面一个例子：

DROP TABLE IF EXISTS sequence; 
 
-- 建sequence表，指定seq列为无符号大整型，可支持无符号值：0(default)到18446744073709551615（0到2^64–1）。
CREATE TABLE sequence (
   name       VARCHAR(50) NOT NULL, 
     current_value   BIGINT UNSIGNED NOT NULL DEFAULT 0, 
     increment     INT NOT NULL DEFAULT 1, 
     PRIMARY KEY (name)  -- 不允许重复seq的存在。
) ENGINE=InnoDB; 
 
 
DELIMITER / 
 
DROP FUNCTION IF EXISTS currval /
 
CREATE FUNCTION currval(seq_name VARCHAR(50)) 
RETURNS BIGINT
BEGIN
     DECLARE value BIGINT;
     SELECT current_value INTO value
     FROM sequence
     WHERE upper(name) = upper(seq_name); -- 大小写不区分.
     RETURN value;
END;
/
 
DELIMITER ; 
 
 
DELIMITER /
 
DROP FUNCTION IF EXISTS nextval /
 
CREATE FUNCTION nextval (seq_name VARCHAR(50)) 
RETURNS BIGINT 
BEGIN 
     DECLARE value BIGINT;
     UPDATE sequence 
     SET current_value = current_value + increment 
     WHERE upper(name) = upper(seq_name);
     RETURN currval(seq_name); 
END;
/
 
DELIMITER ; 
 
DELIMITER /
 
DROP FUNCTION IF EXISTS setval / 
 
CREATE FUNCTION setval (seq_name VARCHAR(50), value BIGINT) 
RETURNS BIGINT
BEGIN 
     UPDATE sequence 
     SET current_value = value 
     WHERE upper(name) = upper(seq_name); 
     RETURN currval(seq_name); 
END;
/
 
DELIMITER ;

在 SQL 中使用序列：
创建序列，往sequence表插入值即可：

mysql> insert into sequence set name='myseq';

查看当前已建序列：

mysql> select * from sequence;

+-------+---------------+-----------+
| name | current_value | increment |
+-------+---------------+-----------+
| myseq |       0 |     1 |
+-------+---------------+-----------+
1 row in set (0.00 sec)

获得序列的下一个值，第一次使用，因此值为1：

mysql> select nextval('myseq');

+------------------+
| nextval('myseq') |
+------------------+
|        1 |
+------------------+
1 row in set (0.00 sec)

MySQL,自增,序列,教程,MySQL教程

风云阁资源网 Design By www.bgabc.com

广告合作：本站广告合作请联系QQ：858582 申请时备注：广告合作（否则不回）
免责声明：本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除！

风云阁资源网 Design By www.bgabc.com

评论“在MySQL中创建实现自增的序列（Sequence）的教程”

暂无评论...

www.bgabc.com 风云阁资源网

120,135影音资源

344,641技术资源

22,817软件资源

435,032站长资源

在MySQL中创建实现自增的序列（Sequence）的教程

MySQL中Binary Log二进制日志文件的基本操作命令小结

MySQL索引之主键索引

评论“在MySQL中创建实现自增的序列（Sequence）的教程”

RTX 5090要首发性能要翻倍！三星展示GDDR7显存

更新日志

友情链接

在MySQL中创建实现自增的序列（Sequence）的教程

MySQL中Binary Log二进制日志文件的基本操作命令小结

MySQL索引之主键索引

评论“在MySQL中创建实现自增的序列（Sequence）的教程”

RTX 5090要首发 性能要翻倍！三星展示GDDR7显存

更新日志

友情链接

RTX 5090要首发性能要翻倍！三星展示GDDR7显存