MYSQL实现序列自增

淩亂°似流年 2022-05-04 09:58 307阅读 0赞

## MYSQL实现Sequence ##

>   由于项目需求，需要实现`Sequence`效果，MYSQL中是不支持`Sequence`，只支持主键自增`Increment`，但也只是自增，而不能设置步长、开始索引、是否循环等，最重要的是一张表只能由一个字段使用自增，但有的时候我们需要两个或两个以上的字段实现自增（单表多字段自增），MYSQL本身是实现不了的，但我们可以用创建一个序列表，使用函数来获取序列的值

#### 数据库构建 ####

**1. 新建序列表**

drop table if exists sequence;     
    create table sequence (         
    seq_name        VARCHAR(50) NOT NULL, -- 序列名称         
    current_val     INT         NOT NULL, -- 当前值         
    increment_val   INT         NOT NULL    DEFAULT 1, -- 步长(跨度)         
    PRIMARY KEY (seq_name)   );

**2. 新增一个序列**

INSERT INTO sequence VALUES ('seq_test1_num1', '0', '1');  
    INSERT INTO sequence VALUES ('seq_test1_num2', '0', '2');

**3. 创建 函数 用于获取序列当前值(v\_seq\_name 参数值 代表序列名称)**

create function currval(v_seq_name VARCHAR(50))     
    returns integer    
    begin        
        declare value integer;         
        set value = 0;         
        select current_val into value  from sequence where seq_name = v_seq_name;   
       return value;   
    end;

**4.查询当前值**

select currval('seq_test1_num1');

**5. 创建 函数 用于获取序列下一个值(v\_seq\_name 参数值 代表序列名称)**

create function nextval (v_seq_name VARCHAR(50))  
        returns integer  
    begin  
        update sequence set current_val = current_val + increment_val  where seq_name = v_seq_name;  
        return currval(v_seq_name);  
    end;

**6. 查询下一个值**

select nextval('seq_test1_num1');

--------------------

#### 并发测试 ####

在这里使用`JAVA`程序进行多线程的并发测试

@Autowired
        private JdbcTemplate jdbcTemplate;
    
        @Test
        public void contextLoads() throws InterruptedException { 
            ExecutorService executorService = Executors.newFixedThreadPool(3);
            CountDownLatch countDownLatch = new CountDownLatch(3);
            log.info("Task start !!!");
            for (int i = 0; i < 3; i++) { 
                executorService.submit(() -> { 
                    for (int t = 0; t < 10000; t++) { 
                        jdbcTemplate.execute("select nextval('seq_test1_num1')");
                    }
                    countDownLatch.countDown();
                });
            }
            countDownLatch.await();
            executorService.shutdown();
            log.info("Task end !!!");
        }

**`注意：`** 使用线程池来模拟并发情况

![在这里插入图片描述][70]

[70]: /images/20220504/2baa56a48f6244ab84c33a8ba95636be.png