日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

Mycat探索之旅(3)----Mycat的全局序列号

發布時間:2025/4/16 编程问答 48 豆豆
生活随笔 收集整理的這篇文章主要介紹了 Mycat探索之旅(3)----Mycat的全局序列号 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

一、本地文件方式

原理:此方式MyCAT將sequence配置到文件中,當使用到sequence中的配置后,MyCAT會更下classpath中的sequence_conf.properties文件中

sequence當前的值。

配置方式:

  • sequence_conf.properties中配置:

在sequence_conf.properties文件中做如下配置:

#default global sequence

GLOBAL.HISIDS=

#最小值

GLOBAL.MINID=10001

#最大值

GLOBAL.MAXID=20000

#當前值

GLOBAL.CURID=10000

  • server.xml中配置:
<!--sequnceHandlerType=0表示:使用本地文件的方式配置mycat的全局序列號,對應sequence_conf.properties文件sequnceHandlerType=1表示:使用數據庫表的方式配置mycat的全局序列號--><property name="sequnceHandlerType">0</property>
  • 配置完成后重啟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配置:

<!--sequnceHandlerType=0表示:使用本地文件的方式配置mycat的全局序列號,對應sequence_conf.properties文件sequnceHandlerType=1表示:使用數據庫表的方式配置mycat的全局序列號--><property name="sequnceHandlerType">1</property>

數據庫配置:

1) 創建MYCAT_SEQUENCE表

– 創建存放sequence的表

DROP TABLE IF EXISTS MYCAT_SEQUENCE;

– name sequence名稱

– current_value 當前value

– increment 增長步長! 可理解為mycat在數據庫中一次讀取多少個sequence. 當這些用完后, 下次再從數據庫中讀取.

/*創建存放sequence的表*/CREATE TABLE MYCAT_SEQUENCE (NAME VARCHAR (50),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的值 (返回當前值,增量)

-- ---------------------------- -- 函數結構: `mycat_seq_currval` -- 獲取當前sequence的值(返回當前值,增量) -- ----------------------------DROP FUNCTION IF EXISTS mycat_seq_currval;CREATE FUNCTION `mycat_seq_currval`(seq_name VARCHAR(50)) RETURNS varchar(64) CHARSET latin1DETERMINISTIC BEGINDECLARE retval VARCHAR(64);SET retval="-1,0";SELECT concat(CAST(current_value AS CHAR),",",CAST(increment AS CHAR) ) INTO retval FROM MYCAT_SEQUENCE WHERE name = seq_name;RETURN retval ; END

?

– 設置sequence值

-- ---------------------------- -- 函數結構: `mycat_seq_setval` -- 設置sequence的值 -- ----------------------------DROP FUNCTION IF EXISTS mycat_seq_setval;CREATE FUNCTION `mycat_seq_setval`(seq_name VARCHAR(50), value INTEGER) RETURNS varchar(64) CHARSET latin1DETERMINISTIC BEGINDECLARE retval VARCHAR(64);DECLARE inc INT;SET inc = 0;SELECT increment INTO inc FROM MYCAT_SEQUENCE WHERE name = seq_name;UPDATE MYCAT_SEQUENCE SET current_value = value WHERE name = seq_name;SELECT concat(CAST(value as CHAR),",",CAST(inc as CHAR)) INTO retval;RETURN retval; END

?

– 獲取下一個sequence值

-- ---------------------------- -- 函數結構: `mycat_seq_nextval` -- 獲取下一個sequence的值 -- ---------------------------- DROP FUNCTION IF EXISTS mycat_seq_nextval; CREATE FUNCTION `mycat_seq_nextval`(seq_name VARCHAR(50)) RETURNS varchar(64) CHARSET latin1DETERMINISTIC BEGINDECLARE retval VARCHAR(64);DECLARE val BIGINT;DECLARE inc INT;DECLARE seq_lock INT;set val = -1;set inc = 0;SET seq_lock = -1;SELECT GET_LOCK(seq_name, 15) into seq_lock;if seq_lock = 1 thenSELECT current_value + increment, increment INTO val, inc FROM MYCAT_SEQUENCE WHERE name = seq_name for update;if val != -1 thenUPDATE MYCAT_SEQUENCE SET current_value = val WHERE name = seq_name;end if;SELECT RELEASE_LOCK(seq_name) into seq_lock;end if;SELECT concat(CAST((val - inc + 1) as CHAR),",",CAST(inc as CHAR)) INTO retval;RETURN retval; END

?

3) sequence_db_conf.properties相關配置,指定sequence相關配置在哪個節點上:

這里設置的是dn1節點,那么上面的函數及表都是建立在dn1節點對應的數據庫實例上的

注意:MYCAT_SEQUENCE表和以上的3個function,需要放在同一個節點上。function請直接在具體節點的數據庫上執行

測試:

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

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

在前面的測試中,我添加到MYCAT_SEQUENCE表中的數據設置的步長是100,此處吻合。

轉載于:https://www.cnblogs.com/doctorJoe/p/5259011.html

總結

以上是生活随笔為你收集整理的Mycat探索之旅(3)----Mycat的全局序列号的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。