Mycat之主键ID自增长配置方式

不念不忘少年蓝@ 2022-01-23 20:41 789阅读 0赞

### 一.前言 ###

在实现分库分表的情况下，数据库自增主键已无法保证自增主键的全局唯一。为此， MyCat 提供了全局sequence，并且提供了包含本地配置和数据库配置等多种实现方式。

### 二.全局序列的四种方式 ###

##### 1.本地文件 #####

*  缺点  
    在mycat重启后，配置文件中sequence会恢复到初始值，造成下次操作序列重复
 *  优点  
    本地加载，读取速度较快

##### 2. 数据库 #####

*  优点  
    在mycat重启后，sequence值不会被初始化
 *  缺点  
    如果存取sequence的数据库挂了，会遇到单点故障

##### 3. 时间 #####

*  优点  
    不存在上面两种方案因为mycat的重启导致id重复的现象
 *  缺点  
    数据类型太长，建议采用bigint(最大取值18446744073709551615)

##### 4. zookeeper #####

zookeeper自身解决单点和序列问题,建议采用

### 三. 实例分析 ###

##### 1.创建表 #####

先在配置文件schema.xml 下增加 table,配置其主键自增

在mycat下创建表:

create table User(
     id  int(11) NOT NULL AUTO_INCREMENT,
    username varchar(100),
    password varchar(100),
    PRIMARY KEY (id)
    );

此时在3个数据库里面已经创建好此表  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA1MjAxNDY_size_16_color_FFFFFF_t_70]  
此时如果没有进行额外的配置进行添加数据,则会提示

can't find any valid datanode :USER -> ID -> 1134371327843635200

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA1MjAxNDY_size_16_color_FFFFFF_t_70 1]  
下面通过不同方式配置,测试其效果

#### 2.使用本地文件方式 ####

原理：此方式MyCAT将sequence配置到文件中，当使用到sequence中的配置后，MyCAT会更下conf中的sequence\_conf.properties文件中sequence当前的值。

##### 2.1 配置MyCat的Server.xml #####

##### 2.2、配置sequence\_conf.properties #####

编辑该文件添加以下

USER.HISIDS=
    USER.MINID=1001
    USER.MAXID=2000
    USER.CURID=1000

> 其中HISIDS表示使用过的历史分段(一般无特殊需要可不配置)，MINID表示最小ID值，MAXID表示最大ID值，CURID表示当前ID值。

配置完成后,重启mycat startup\_nowrap.bat

此时再次执行插入语句,则发现可以正常插入  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA1MjAxNDY_size_16_color_FFFFFF_t_70 2]  
![在这里插入图片描述][2019053116200039.png]

#### 3.使用数据库方式 ####

原理：在数据库中建立一张表，存放sequence名称(name)，sequence当前值(current\_value)，步长(increment int类型每次读取多少个sequence，假设为K)等信息；

*  第一次使用该sequence时，根据传入的sequence名称，从数据库这张表中读取current\_value，和increment到MyCat中，并将数据库中的current\_value设置为原current\_value值+increment值（实现方式是基于后续的存储函数）
 *  MyCat将读取到current\_value+increment作为本次要使用的sequence值，下次使用时，自动加1，当使用increment次后，执行步骤1)相同的操作.　  
    MyCat负责维护这张表，用到哪些sequence，只需要在这张表中插入一条记录即可。若某次读取的sequence没有用完，系统就停掉了，则这次读取的sequence剩余值不会再使用。

##### 使用流程 #####

以上面使用的User表为例:

###### 1). 创建Mycat生成唯一主键所需表与函数 ######

其中schemal.xml相关配置的如下:

将其表与函数存放在节点node1的mycat库里面

DROP TABLE IF EXISTS MYCAT_SEQUENCE;
    CREATE TABLE MYCAT_SEQUENCE (
    NAME VARCHAR (50) NOT NULL,
    current_value INT NOT NULL,
    increment INT NOT NULL DEFAULT 100,
    PRIMARY KEY (NAME)
    ) ENGINE = INNODB ;
    
    -- 插入表数据
    INSERT INTO MYCAT_SEQUENCE(NAME,current_value,increment) VALUES ('USER', 0, 1);
    
    --创建行数 mycat_seq_currval
    DROP FUNCTION IF EXISTS `mycat_seq_currval`;
    DELIMITER ;;
    CREATE FUNCTION `mycat_seq_currval`(seq_name VARCHAR(50)) 
    RETURNS VARCHAR(64) CHARSET utf8
        DETERMINISTIC
    BEGIN DECLARE retval VARCHAR(64);
            SET retval="-999999999,null";  
            SELECT CONCAT(CAST(current_value AS CHAR),",",CAST(increment AS CHAR) ) INTO retval 
              FROM MYCAT_SEQUENCE WHERE NAME = seq_name;  
            RETURN retval ; 
    END
    ;;
    DELIMITER ;
    
    -- 创建函数 mycat_seq_nextval
    DROP FUNCTION IF EXISTS `mycat_seq_nextval`;
    DELIMITER ;;
    CREATE FUNCTION `mycat_seq_nextval`(seq_name VARCHAR(50)) RETURNS VARCHAR(64)
     CHARSET utf8
        DETERMINISTIC
    BEGIN UPDATE MYCAT_SEQUENCE  
                     SET current_value = current_value + increment 
                      WHERE NAME = seq_name;  
             RETURN mycat_seq_currval(seq_name);  
    END
    ;;
    DELIMITER ;
    
    -- 创建函数  mycat_seq_setval
    DROP FUNCTION IF EXISTS `mycat_seq_setval`;
    DELIMITER ;;
    CREATE FUNCTION `mycat_seq_setval`(seq_name VARCHAR(50), VALUE INTEGER) 
    RETURNS VARCHAR(64) CHARSET utf8
        DETERMINISTIC
    BEGIN UPDATE MYCAT_SEQUENCE  
                       SET current_value = VALUE  
                       WHERE NAME = seq_name;  
             RETURN mycat_seq_currval(seq_name);  
    END
    ;;
    DELIMITER ;

![在这里插入图片描述][20190603093506589.png]  
![在这里插入图片描述][20190603093643653.png]

###### 2). 配置server.xml ######

###### 3). 配置sequence\_db\_conf.properties ######

编辑文件添加需要自增长的表名称

USER=dn1

###### 4). 测试 ######

插入数据,执行多次

INSERT `user`  (username,password) VALUES (112,231)

查看user表  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA1MjAxNDY_size_16_color_FFFFFF_t_70 3]

#### 4.本地时间戳方式获取 ####

以travelrecord表为例

###### 1). 配置schema.xml ######

###### 2). 配置server.xml ######

表示时间戳的方式 ID= 64 位二进制 (42(毫秒)+5(机器 ID)+5(业务编码)+12(重复累加)

###### 3). 测试 ######

插入2条数据

insert into travelrecord(id,name) values(next value for MYCATSEQ_GLOBAL,'123123')

结果  
![在这里插入图片描述][20190603101631622.png]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA1MjAxNDY_size_16_color_FFFFFF_t_70]: /images/20220124/6d7b5c01e1114df19ecf3d193654e1f6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA1MjAxNDY_size_16_color_FFFFFF_t_70 1]: /images/20220124/506b27d998ea48659d4d4c1cdc399b36.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA1MjAxNDY_size_16_color_FFFFFF_t_70 2]: /images/20220124/f7ef561336924add9b4706b7c6ed2b18.png
[2019053116200039.png]: /images/20220124/02c52ebd89d44f62bb54321e19586755.png
[20190603093506589.png]: /images/20220124/71bfc940f89243648965debabd0b9d5f.png
[20190603093643653.png]: /images/20220124/5a3fa83b9cac447181eaa94f2f5c9e42.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA1MjAxNDY_size_16_color_FFFFFF_t_70 3]: /images/20220124/c692af50186c401b86f5419d33910d42.png
[20190603101631622.png]: /images/20220124/14401301e5d74ecc92b8b09238d3875f.png