MyCat分片全局序列號

數據庫方式

<一>原理

      在數據庫中創建一張表，存放 sequence 名稱(name)，sequence 當前值(current_value)，步長(increment int 類型每次讀取多少sequence，假設爲 K)等信息；

<二>Sequence 獲取步驟 

       1)當初次使用該 sequence 時，根據傳入的 sequence 名稱，從數據庫這張表中讀取 current_value（列）和increment（列）到 MyCat 中，並將數據庫中的current_value（列）設置爲原 current_value 值+increment 值；
       2)MyCat 將讀取到 current_value+increment 做爲本次要使用的 sequence 值，下次使用時，自動加 1，當使用 increment 次後，執行步驟 1)相同的操做.
       MyCat 負責維護這張表，用到哪些 sequence，只須要在這張表中插入一條記錄便可。若某次讀取的sequence 沒有用完，系統就停掉了，則此次讀取的 sequence 剩餘值不會再使用。

<三>具體配置方法

第一步：server.xml

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

注：sequnceHandlerType 須要配置爲 1，表示使用數據庫方式生成 sequence.

第二步：數據庫配置：

1) 建立 MYCAT_SEQUENCE 表

#建立存放 sequence 的表
#name sequence 名稱
#current_value 當前 value
#increment 增加步長! 可理解爲 mycat 在數據庫中一次讀取多少個 sequence. 當這些用完後, 下次再從數據庫中讀取.

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;

#插入一條 sequence
INSERT INTO MYCAT_SEQUENCE(name,current_value,increment) VALUES (‘GLOBAL’, 100000,100);

2) 建立相關 function

#獲取當前 sequence 的值 (返回當前值,增量)

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

#設置 sequence 值

DROP FUNCTION IF EXISTS mycat_seq_setval;
DELIMITER
CREATE FUNCTION mycat_seq_setval(seq_name VARCHAR(50),value INTEGER) 
RETURNS varchar(64) CHARSET utf-8
DETERMINISTIC
BEGIN
UPDATE 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 utf-8
DETERMINISTIC
BEGIN
UPDATE MYCAT_SEQUENCE
SET current_value = current_value + increment WHERE name = seq_name;

RETURN mycat_seq_currval(seq_name);
END
DELIMITER;

 

第三步：sequence_db_conf.properties 相關配置

指定 sequence 相關配置在哪一個節點上：
例如：
USER_SEQ=test_dn1
注意：MYCAT_SEQUENCE 表和以上的 3 個 function，須要放在同一個節點上。function 請直接在具體節點的數據庫上執行。
若是執行的時候報：

you might want to use the less safe log_bin_trust_function_creators variable

須要對數據庫作以下設置：

#windows-->my.ini-->[mysqld]
log_bin_trust_function_creators=1
#linux-->/etc/my.cnf-->[mysqld]
log_bin_trust_function_creators=1

修改完後，便可在 mysql 數據庫中執行上面的函數. 

配置完成！能夠測試了

使用示例：

insert into table1(id,name) values( 10035,‘test’);