博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
mysql中Sequence实现
阅读量:4180 次
发布时间:2019-05-26

本文共 2278 字,大约阅读时间需要 7 分钟。

最近需要将项目从DB2数据库迁移到MySQL数据库,由于MySQL没有sequence,于是上网找了下MySQL的sequence实现,基本都是基于存储过程和函数实现的,下面第一、二两种实现是从网上看到的,三、四、五三种实现是自己的想法。第五种终极实现亲测可行,但是没有经过高并发检验。

1、创建表用于存储当前序列值

CREATE TABLE `TBL_SEQUENCE_1` (    `sequence_name`  varchar(64) NOT NULL COMMENT '序列名称' ,    `value`  bigint NOT NULL DEFAULT 0 COMMENT '当前值' ,    PRIMARY KEY (`sequence_name`))ENGINE=InnoDBDEFAULT CHARACTER SET=utf8 COLLATE=utf8_general_ci;

第一种实现,不加锁,高并发下可能返回重复值

DELIMITER //CREATE FUNCTION NEXT_VAL(sequence_name varchar(64)) RETURNS bigint BEGIN    declare current_val bigint;    set current_val = 0;    update t_sequence t set t.value = t.value + 1 where t.sequence_name = sequence_name;    select t.value into current_val from t_sequence t where t.sequence_name = sequence_name;    return current_val;END//DELIMITER ;

第二种实现,悲观锁,高并发下能保证返回值唯一,但是可能导致性能急剧下降

DELIMITER //CREATE FUNCTION NEXT_VAL(sequence_name varchar(64)) RETURNS bigint BEGIN    declare current_val bigint;    set current_val = 0;    select t.value into current_val from t_sequence t where t.sequence_name = sequence_name for update;    update t_sequence t set t.value = t.value + 1 where t.sequence_name = sequence_name;    return current_val + 1;END//DELIMITER ;

第三种实现,乐观锁,最多尝试三次(应用需要判断序号是否为0,为0表示获取序号失败)

DELIMITER //CREATE FUNCTION NEXT_VAL(sequence_name VARCHAR(64)) RETURNS BIGINT BEGIN    DECLARE current_val BIGINT;    DECLARE tryTimes INT;    SET tryTimes = 0;    WHILE tryTimes < 3 DO        SELECT t.value INTO current_val FROM TBL_SEQUENCE_1 t WHERE t.sequence_name = sequence_name;        UPDATE TBL_SEQUENCE_1 t SET t.value = t.value + 1 WHERE t.sequence_name = sequence_name AND t.value=current_val;        IF ROW_COUNT() > 0 THEN            RETURN current_val + 1;        END IF;        SET tryTimes = tryTimes + 1;    END WHILE;    RETURN 0;END//DELIMITER ;

第四种实现,通过多条记录分散并发量,减少竞争

--一个序列采用多条记录,每次获取序号的时候随机挑选一条记录进行更新(使用排它锁,多条记录能有效减少锁竞争)--比如使用10条记录,每条记录初始值1-10,增长步长为10

第五种实现,终极实现,不加锁,能保证返回值唯一,且不影响性能

DELIMITER //CREATE FUNCTION NEXT_VAL(sequence_name VARCHAR(64)) RETURNS BIGINT BEGIN    UPDATE TBL_SEQUENCE_1 t, (SELECT @current_val:=`value` FROM TBL_SEQUENCE_1 t2 WHERE t2.sequence_name=sequence_name) t3 SET t.value = t.value + 1 WHERE t.sequence_name =sequence_name AND @current_val=t.value;    RETURN @current_val+1;END//DELIMITER ;

转载地址:http://jgqai.baihongyu.com/

你可能感兴趣的文章
Echarts——使用 dataset 管理数据
查看>>
DES 加解密工具类
查看>>
SpringBoot多模块项目实践(Multi-Module)
查看>>
第一篇: 服务的注册与发现Eureka(Greenwich版)
查看>>
第二篇: 服务消费者(rest+ribbon)(Greenwich版本)
查看>>
第三篇: 服务消费者(Feign)(Greenwich版本)
查看>>
获取客户的真实IP地址
查看>>
第四篇: 熔断器(Ribbon+Feign)(Greenwich版本)
查看>>
Linux的常用命令(一)
查看>>
Linux的常用命令(二)
查看>>
第六篇: 分布式配置中心(Greenwich版本)
查看>>
SpringBoot | 配置logback-spring.xml
查看>>
SpringBoot | 第一章:构建第一个SpringBoot工程
查看>>
SpringBoot | 第二章:配置多环境以及上传文件
查看>>
Spring Data JPA |自定义非实体类的映射
查看>>
SpringBoot | 常用注解记录
查看>>
JavaBean对象转换EntityUtils工具类
查看>>
Maven常用命令
查看>>
SpringBoot | 运行报错,无法加载oracle连接驱动
查看>>
为什么阿里巴巴禁止在 foreach 循环里进行元素的 remove/add 操作
查看>>