MyCat全局序列之数据库方式

一、简介

上一篇文件介绍了MyCat全局序列的本地文件方式，由于 MyCat 重新发布后，配置文件中的 sequence 会恢复到初始值（当这台机器宕机时会出现，序列文件丢失，造成序列冲突问题）,所以在实际项目中并不会采用本地文件生成序列，更多是采用数据库的方式，本文就将对如何在MyCat中使用数据库实现全局序列主键唯一。

二、数据库方式

实现方式：在数据库中建立一张表MYCAT_SEQUENCE ，用于存放序列sequence 名称(name)，sequence 当前值(current_value)，步长(increment int 类型每次读取多少个 sequence。
获取步骤大概如下三个：

初次获取sequence时，根据传入的序列名称，从数据库表中获取current_value,increment到MyCat中，并将数据库中的current_value更新为current_value + increment。
MyCat将读取到的current_value + increment作为本次的序列，在下次使用时，将序列的值 + 1，当使用increment次后，重复第一个步骤。
MyCat负责维护序列表MYCAT_SEQUENCE，当用到序列时，往数据库表中插入一条记录即可。如果某次读取完的序列还没有用完数据库就崩了，那么剩余的没有使用的序列将会被废弃掉。

三、实现方式

环境信息：MySQL5.6.45、Mycat-server-1.6、虚拟机IP地址192.168.1.11，

本文采用一台数据库服务器192.168.1.11里边的两个数据库（testdb_seq1、testdb_seq2）进行测试，详细的实现步骤如下：

【a】在数据库服务器192.168.1.11上面创建数据库（testdb_seq1、testdb_seq2）以及测试表test1。

create database testdb_seq1;
create database testdb_seq2;use testdb_seq1;
create table test1(id int auto_increment primary key,xm varchar(32));use testdb_seq2;
create table test1(id int auto_increment primary key,xm varchar(32));

【b】创建MYCAT_SEQUENCE表(这里使用testdb_seq1数据库(dn1节点)作为生成主键的节点)

注意：MYCAT_SEQUENCE表和以上的3个function，需要放在同一个节点（dn1）上。

DROP TABLE IF EXISTS MYCAT_SEQUENCE;
CREATE TABLE `MYCAT_SEQUENCE` (`NAME` varchar(50) NOT NULL comment  "名称",`current_value` int(11) NOT NULL comment "当前值",`increment` int(11) NOT NULL DEFAULT '100' comment "步长",PRIMARY KEY (`NAME`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

并且在表中初始化一条记录，指定序列名称TESTDBSEQ，序列当前值为100000，每次从数据库中取出100个序列，用完再取。

insert into MYCAT_SEQUENCE(name, current_value, increment) values ('TESTDBSEQ', 100000, 100);
-- 注意这里的TESTDBSEQ要大写，对应上 sequence_db_conf.properties 的配置use testdb_seq1;
select * from MYCAT_SEQUENCE;

【c】创建生成序列的函数（同样在testdb_seq1数据库上面执行）

这里主要有三个函数：

返回当前的sequence的值

DROP FUNCTION IF EXISTS mycat_seq_currval;
DELIMITER $$
CREATE FUNCTION mycat_seq_currval(seq_name VARCHAR(50))RETURNS VARCHAR(64) CHARSET 'utf8'
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 ;

设置sequence的值

DROP FUNCTION IF EXISTS mycat_seq_setval;
DELIMITER $$
CREATE FUNCTION mycat_seq_setval(seq_name VARCHAR(50),VALUE INTEGER) RETURNS VARCHAR(64) CHARSET 'utf8'
BEGINUPDATE MYCAT_SEQUENCE SET current_value = VALUE    WHERE NAME = seq_name;
RETURN mycat_seq_currval(seq_name);
END$$
DELIMITER ;

获取下一个sequence的值

DROP FUNCTION IF EXISTS mycat_seq_nextval;
DELIMITER $$
CREATE FUNCTION mycat_seq_nextval(seq_name VARCHAR(50)) RETURNS VARCHAR(64) CHARSET 'utf8'
BEGIN
UPDATE MYCAT_SEQUENCE SET current_value = current_value + increment
WHERE NAME = seq_name;
RETURN mycat_seq_currval(seq_name);
END$$
DELIMITER ;

【d】server.xml指定序列生成方式为数据库方式

<system><property name="sequnceHandlerType">1</property></system>

【e】配置 sequence_db_conf.properties ：TESTDBSEQ 为全局序列的名称，dn1 表示分片节点

TESTDBSEQ=dn1

注意：MYCAT_SEQUENCE 表和以上的 3 个 function，需要放在同一个节点上，然后重启 mycat服务。

vim sequence_db_conf.properties

【f】配置schema.xml: 配置分片节点、分片规则等

<mycat:schema xmlns:mycat="http://io.mycat/"><schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100"><table name="test1" dataNode="dn1,dn2" primaryKey="id" autoIncrement="true" type="global" /></schema><dataNode name="dn1" dataHost="localhost1" database="testdb_seq1" /><dataNode name="dn2" dataHost="localhost1" database="testdb_seq2" /><dataHost name="localhost1" maxCon="1000" minCon="10" balance="0"writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100"><heartbeat>select user()</heartbeat><!-- can have multi write hosts --><writeHost host="hostM1" url="192.168.1.11:3306" user="root"password="0905"></writeHost></dataHost></mycat:schema>

【g】使用示例：

登录mycat，注意端口是8066

mysql -uroot -p0905 -h192.168.1.11 -P8066

插入语句进行测试：

insert into test1(id,xm) values(next value for MYCATSEQ_TESTDBSEQ,'zhangsan');
insert into test1(id,xm) values(next value for MYCATSEQ_TESTDBSEQ,'lisi');

测试结果：

testdb_seq1数据库：

testdb_seq2数据库：

重启MyCat：

cd /bin./mycat restart

继续插入数据进行测试：

insert into test1(id,xm) values(next value for MYCATSEQ_TESTDBSEQ,'wangwu');

查看 mycat_sequence 数据：发现序列当前值在上次的基础上100100增加了100（即变为100200），重启后的id重100200开始计数。

【h】其他配置server.xml执行逻辑库地址、访问的数据库用户信息等

<?xml version="1.0" encoding="UTF-8"?>
<!-- - - Licensed under the Apache License, Version 2.0 (the "License"); - you may not use this file except in compliance with the License. - You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. -->
<!DOCTYPE mycat:server SYSTEM "server.dtd">
<mycat:server xmlns:mycat="http://io.mycat/"><system><property name="useSqlStat">0</property>  <!-- 1为开启实时统计、0为关闭 --><property name="useGlobleTableCheck">0</property>  <!-- 1为开启全加班一致性检测、0为关闭 --><property name="sequnceHandlerType">1</property><!--  <property name="useCompression">1</property>--> <!--1为开启mysql压缩协议--><!--  <property name="fakeMySQLVersion">5.6.20</property>--> <!--设置模拟的MySQL版本号--><!-- <property name="processorBufferChunk">40960</property> --><!-- <property name="processors">1</property> <property name="processorExecutor">32</property> --><!--默认为type 0: DirectByteBufferPool | type 1 ByteBufferArena--><property name="processorBufferPoolType">0</property><!--默认是65535 64K 用于sql解析时最大文本长度 --><!--<property name="maxStringLiteralLength">65535</property>--><!--<property name="sequnceHandlerType">0</property>--><!--<property name="backSocketNoDelay">1</property>--><!--<property name="frontSocketNoDelay">1</property>--><!--<property name="processorExecutor">16</property>--><!--<property name="serverPort">8066</property> <property name="managerPort">9066</property> <property name="idleTimeout">300000</property> <property name="bindIp">0.0.0.0</property> <property name="frontWriteQueueSize">4096</property> <property name="processors">32</property> --><!--分布式事务开关，0为不过滤分布式事务，1为过滤分布式事务（如果分布式事务内只涉及全局表，则不过滤），2为不过滤分布式事务,但是记录分布式事务日志--><property name="handleDistributedTransactions">0</property><!--off heap for merge/order/group/limit      1开启   0关闭--><property name="useOffHeapForMerge">1</property><!--单位为m--><property name="memoryPageSize">1m</property><!--单位为k--><property name="spillsFileBufferSize">1k</property><property name="useStreamOutput">0</property><!--单位为m--><property name="systemReserveMemorySize">384m</property><!--是否采用zookeeper协调切换  --><property name="useZKSwitch">true</property></system><!-- 全局SQL防火墙设置 --><!-- <firewall> <whitehost><host host="127.0.0.1" user="mycat"/><host host="127.0.0.2" user="mycat"/></whitehost><blacklist check="false"></blacklist></firewall>--><user name="root"><property name="password">0905</property><property name="schemas">TESTDB</property><!-- 表级 DML 权限设置 --><!--        <privileges check="false"><schema name="TESTDB" dml="0110" ><table name="tb01" dml="0000"></table><table name="tb02" dml="1111"></table></schema></privileges>     --></user><user name="user"><property name="password">0905</property><property name="schemas">TESTDB</property><property name="readOnly">true</property></user></mycat:server>

四、总结

以上就是关于在MyCat中怎么使用数据库方式实现全局序列主键，主要需要注意点有：

在数据库中创建全局序列表，并且在同一个数据库中创建三个函数；
server.xml指定全局序列方式为数据库方式（sequnceHandlerType=1）；
配置 sequence_db_conf.properties指定全局序列在哪个数据节点；
如果某次读取完的序列还没有用完数据库就宕机了，那么没有使用的序列将会被废弃掉；

以上就是笔者学习期间的一些实践总结，希望能对大家有所帮助，如有不对之处，还望指点出来。