2. 程式人生 > >Mycat之資料庫主鍵自增長（資料庫增長的方式）-yellowcong

Mycat之資料庫主鍵自增長（資料庫增長的方式）-yellowcong

阿新 • • 發佈：2019-02-13

我們先來通過mycat實現一個自增長的主鍵，現在有兩個資料庫，mycat和mycat2,然後設定資料庫增長的方式，按照自增長的方式實現。自增長實現步驟：1、建立資料庫，2、建立mycat的自增長函式,3、插入需要自增長策略，4、配置schemal.xml,新增自增長的表，5、配置server.xml，設定主鍵增長策略，6、配置sequence_db_conf.properties，新增需要自增長的表。 如果我們後期想新增自增長的表，只需要進行步驟3、4、6 三個步驟。

資料準備

1、建立資料庫

建立兩個資料庫，並都建立test表

#建立資料庫
create database
 
 mycat;

#新增表
use mycat 
#建立表test
create table test3(id int auto_increment primary key,name varchar(32)) ;

#建立資料庫
create database mycat3;

#新增表
use mycat 2
#建立表test
create table test3(id int auto_increment primary key,name varchar(32)) ;

這裡寫圖片描述

新增後的表資料，看了一下，表示表建立好了
這裡寫圖片描述

2、建立Mycat生成唯一主鍵所需要的函式

我將自增長的函式都建立在了mycat這個db中

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 ('GLOBAL', 100000, 100);

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 ;

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 ;


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 ;

3、測試新增結果

#查詢當前所在db ,這個語句只是想給大家證明，我是在mycat 這個資料庫裡面新增的函式
select database();

#查詢doubi這張表裡面的資料
select mycat_seq_nextval('doubi');

這裡寫圖片描述

4、插入要自增的表名稱到MYCAT_SEQUENC表

插入資料的時候，一定要注意，自己需要插入的表，一定要是大寫的

#設定TEST3表的增長方式為 步進為1 ，
insert into MYCAT_SEQUENCE (name,current_value,increment) values ('TEST3',0,1);

#查詢結果
 select * from MYCAT_SEQUENCE;

這裡寫圖片描述

配置maycat

1、配置schemal.xml

vim conf/schemal.xml， 資料庫的表名稱為test2，設定表的主鍵，這樣mycat好給我們生成主鍵，而且我們是自增長，所以需要配置autoIncrement="true"，這個裡面 type="global" 表示是全域性的表， 每個子節點，都會存在

<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">

        <schema name="yellowcong" checkSQLschema="true" sqlMaxLimit="1000">
                <table name="test3" dataNode="jdbc_node1,jdbc_node2" primaryKey="id" autoIncrement="true"  type="global"/>
        </schema>

        <dataNode name="jdbc_node1" dataHost="localhost" database="mycat" />
        <dataNode name="jdbc_node2" dataHost="localhost" database="mycat2" />

        <dataHost name="localhost" maxCon="1000" minCon="10" balance="0"
                          writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
                <heartbeat>select user()</heartbeat>

                <writeHost host="hostM1" url="127.0.0.1:3306" user="root" password="root" />

        </dataHost>


</mycat:schema>

2、配置server.xml

需要修改sequnceHandlerType 為1，<property name="sequnceHandlerType">1</property>

vim conf/server.xml

0 表示是表示使用本地檔案方式。
1 表示的是根據資料庫來生成，就是我們自己配置的自增長
2 表示時間戳的方式 ID= 64 位二進位制 (42(毫秒)+5(機器 ID)+5(業務編碼)+12(重複累加)
<property name="sequnceHandlerType">1</property>

下面是全部配置

<?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="serverPort">8066</property>
        <property name="useSqlStat">0</property>  <!-- 1為開啟實時統計、0為關閉 -->
        <property name="useGlobleTableCheck">0</property>  <!-- 1為開啟全加班一致性檢測、0為關閉 -->

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

                <!--預設為type 0: DirectByteBufferPool | type 1 ByteBufferArena-->
                <property name="processorBufferPoolType">0</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>

        <user name="root">
                <property name="password">root</property>
                <property name="schemas">yellowcong</property>
        </user>

        <user name="user">
                <property name="password">user</property>
                <property name="schemas">yellowcong</property>
                <property name="readOnly">true</property>
        </user>

</mycat:server>

3、配置sequence_db_conf.properties

#配置預設的表自增長設定
vim ./conf/sequence_db_conf.properties

#新增需要自增長的表名稱
TEST3=jdbc_node1

這裡寫圖片描述

測試插入資料

重啟mycat服務後，連線資料庫，測試插入資料到TEST3表

#連線mycat
mysql -h 127.0.0.1 -P 8066 -u root -proot

#使用yellowocng 資料庫
use yellowcong ;

#查看錶資訊
show tables ;

#插入資料
#插入多條資料
insert into test3 (name) values ('doubi1'),('doubi2'),('doubi3'),('yellowcong');

#查詢資料
select * from test3;

這裡寫圖片描述

查詢資料，結果可以看到，角標的增長很完美。是增長的步進是1.
這裡寫圖片描述

檢視子節點，可以看到對mycat操作後，由於是全域性表，所以每個子節點資料中，都存在表資訊。
這裡寫圖片描述

錯誤集合

ERROR 1064 (HY000): bad insert sql (sharding column:ID not provided,INSERT INTO test2 (NULL, ‘doubi1’)

包這個問題的原因很明顯，就是我們沒有設定mycat中虛擬表的id自增，所以導致沒有獲取到id，所以導致了這個問題。

這裡寫圖片描述

#修改後的語句
insert into test2(name) values('doubi1'),('doubi2'),('doubi3'),('yellowcong');

ERROR 1064 (HY000): insert must provide ColumnList

必須提供新增的列，直接插入，導致了問題，所以我們需要修該插入語句
這裡寫圖片描述

#原來語句
insert into test2 (null,'doubi1'),(null,'doubi2'),(null,'doubi3'),(null,'yellowcong');

#修改後的語句
insert into test2(name) values('doubi1'),('doubi2'),('doubi3'),('yellowcong');

Out of range value for column ‘id’ at row 1

導致這個問題的大致原因可能是由於mycat生成的id和資料庫的字元長度對不上，超過了資料庫配置的預設長度所導致的。解決辦法，就是修改數server.xml，設定id生成策略是根據資料庫生成的。
這裡寫圖片描述

vim conf/server.xml

0 表示是表示使用本地檔案方式。
1 表示的是根據資料庫來生成
2 表示時間戳的方式 ID= 64 位二進位制 (42(毫秒)+5(機器 ID)+5(業務編碼)+12(重複累加)
<property name="sequnceHandlerType">1</property>

這裡寫圖片描述

mycat sequnce err.io.mycat.config.util.ConfigException: can’t find definition for sequence :TEST2

mycat對應sequence_db_conf.properties增加相應設定
這裡寫圖片描述

#配置預設的表自增長設定
vim ./conf/sequence_db_conf.properties

#新增需要自增長的表名稱
TEST3=jdbc_node1

這裡寫圖片描述

mycat sequnce err.java.lang.RuntimeException: can’t fetch sequnce in db,sequnce :TEST2

報錯，說沒辦法獲取到 id，從資料庫中，這個說明我們sequence_db_conf.properties 的配置檔案有問題
這裡寫圖片描述

mycat sequnce err.java.lang.RuntimeException: can’t fetch sequnce in db,sequnce :TEST2 detail:FUNCTION mycat.mycat_seq_nextval does not exist

說沒有mycat.mycat_seq_nextval 這個函式，說明在rule.xml中還需要新增這個配置
這裡寫圖片描述

#新增表
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 ('GLOBAL', 100000, 100);

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 ;

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 ;


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 ;




#插入一條資料，這條資料是我們這個表所需要的。
#必須是大寫的字元，不然就會報錯
#插入需要自增張的表的策略
insert into  MYCAT_SEQUENCE (name,current_value,increment) values ('TEST3',0,1);

參考文章

相關推薦

Mycat之資料庫主鍵自增長（資料庫增長的方式）-yellowcong

我們先來通過mycat實現一個自增長的主鍵，現在有兩個資料庫，mycat和mycat2,然後設定資料庫增長的方式，按照自增長的方式實現。自增長實現步驟：1、建立資料庫，2、建立mycat的自增長函式,3、插入需要自增長策略，4、配置schemal.xml,

Mycat之資料庫主鍵自增長(本地時間戳方式)-yellowcong

本地時間的方式，id自動生成的策略ID= 64 位二進位制 (42(毫秒)+5(機器 ID)+5(業務編碼)+12(重複累加),這個本地時間戳的方式是mycat預設的，所以大家在配置的時候，確認一下自己server.xml中的sequnceHandlerT

db2 資料庫主鍵自增

DBeaver中，主鍵自增無法勾選，可通過建表語句實現自增。 在自增的column後新增如下語句 GENERATED ALWAYS AS IDENTITY (      START WITH&

使用redis生成資料庫主鍵自增

資料庫自增什麼的麻煩死了,尤其是往後還需要考慮到分散式處理,然後偷了個懶,直接redis來搞起... 下面上程式碼 先定義個主鍵生成策略介面,往後方便擴充套件 /** * 定義主鍵生成策略介面,以便修改擴充套件 * @author LeiYong * */ pu

NHibernate學習之二——.cfg.xml配置大全（資料庫連線配置）

一、sql2000/2005.cfg.xml <?xml version="1.0" ?> <hibernate-configuration xmlns="urn:nhibernate-configuration-2.2" > <session

[MySQL]資料庫主鍵設計之思考

資料庫主鍵設計之思考一 1.是否要採用GUID作為主鍵 用GUID作主鍵有它的優勢與不足.優勢是GUID具有唯一性,在任何情況下,可以產生全球唯一的值.這是GUID 最大的優勢,也方便資料匯入,比如要求從另一個系統中把資料匯入進來,那麼,不用擔心,匯入時,會導致主鍵衝突.不足是GU

關於資料庫主鍵和外來鍵（終於弄懂啦）

一、什麼是主鍵、外來鍵： 關係型資料庫中的一條記錄中有若干個屬性，若其中某一個屬性組(注意是組)能唯一標識一條記錄，該屬性組就可以成為一個主鍵比如學生表(學號，姓名，性別，班級) 其中每個學生的學號是唯一的，學號就是一個主鍵課程表(課程編號,課程名,學分) 其中課程編號是

資料庫主鍵、從鍵（易懂版）

什麼是主鍵、外來鍵： 關係型資料庫中的一條記錄中有若干個屬性，若其中某一個屬性組(注意是組)能唯一標識一條記錄，該屬性組就可以成為一個主鍵 比如： 學生表(學號，姓名，性別，班級) 其中每個學生的學號是唯一的，學號就是一個主鍵 課程表(課程編號,課程名,學分) 其中課程編號是唯一的,課程編號就是一個主鍵 成績

(ainusers原創)資料庫主鍵、外來鍵

主鍵 學生表(學號，姓名，性別，班級)  其中每個學生的學號是唯一的，學號就是一個主鍵  聯合主鍵 成績表(學號,課程號,成績)  成績表中一個屬性無法唯一標識一條記錄，學號和課程號組合才可以唯一標識一條記錄，所以 學號和課程號的屬性組是一個主

mysql之資料型別和select語句（group by、 limit）

mysql之資料型別的理解 mysql資料型別之整形 mysql資料型別之浮點型 mysql資料型別之日期時間型 mysql資料型別之字元型 刪除記錄（單表刪除） delete from 表單 where id=5 select

使用Hashids來保護你的資料庫主鍵

為什麼要保護資料庫主鍵? 資料庫主鍵一般是有序自增主鍵，極易被爬蟲抓取資料，作為應用開發者，這是不應該的，你辛辛苦苦收集的資料轉眼之間被其他人給抓取了，是不是很大的損失？ Hashids的介紹 generate short unique ids from integers 理解為數字編碼庫即可，

mycat 完成資料庫主備的切換

資料庫主從： 一臺主資料庫 一臺從資料庫 主資料庫資料改變從也相應變化 主資料庫主要用於寫操作，從資料庫只用於讀資料。 主要應用場景為讀寫分離操作，緩解資料庫壓力 資料庫主備： 兩臺資料庫互為主備 讀寫兩庫資料資料同步 主要應用場景為資料庫容災，防止一臺資

資料庫主鍵和外來鍵及索引

1、主鍵： 若某一個屬性組（注意是組）能唯一標識一條記錄，該屬性組就是一個主鍵。主鍵不能重複，且只能有一個，也不允許為空。定義主鍵主要是為了維護關係資料庫的完整性。 2、外來鍵： 外來鍵用於與另一張表的關聯，是能確定另一張表記錄的欄位。外來鍵是另一個表的主鍵，可以重

Oracle資料庫主鍵值生成的兩種解決方案

解決方案一：使用序列和觸發器實現（推薦） 1、建立資料庫表 設定主鍵 create table Test_Table( 　　id number(10) primary key, /*主鍵，自動增加*

大資料系列之資料倉庫Hive知識整理（四）Hive的嚴格模式，動態分割槽，排序，事務，調優

1.Hive的嚴格模式Hive提供了一個嚴格模式，可以防止使用者執行那些產生意想不到的不好的影響的查詢。想想看在那麼大的資料量的前提下，如果我們在分割槽上表上使用查詢所有，或是使用了笛卡爾積查詢資料等等不良情況，那得花費我們多少時間和資源成本，Hive在預設情況下會開啟一種模

大資料各子專案的環境搭建之建立與刪除軟連線（博主推薦）

 　　建立軟連線，好處可以處理多個版本的需要，方便環境變數的配置。相當於windows下的快捷方式！  　　博主，我這裡以jdk為例，對於大資料的其他子專案的搭建，一樣的操作。方便！這裡我不多贅述。 　　如何建立jdk1.7版本的軟連結？ [[email protect

資料結構實驗之棧四：括號匹配（棧的運用）

#include <stdio.h> #include <stdlib.h> #include <string.h> int main() { int i,j,n,l; char s[150],p[150]; while(gets(s)!=NULL)

資料庫主鍵、唯一鍵、正規化

主鍵: 能夠唯一表示資料表中的每個記錄的【欄位】或者【欄位】的組合就稱為主碼(主鍵)。一個主鍵是唯一識別一個表的每一記錄，但這只是其作用的一部分，主鍵的主要作用是將記錄和存放在其他表中的資料進行關聯。在這一點上，主鍵是不同表中各記錄之間的簡單指標。主鍵約束就是確定表中的每

淺談資料庫主鍵策略

資料庫表的主鍵很多童鞋都非常熟悉了，主鍵就是Primary Key，簡稱PK。 資料庫主鍵的作用是唯一標識一條記錄，所以在同一張表中，任意一條記錄的主鍵都是唯一的，不然，資料庫系統就無法根據主鍵直接定位記錄。 雖然資料庫系統本身對主鍵沒有特別的要求，但是，寫程式的時候，要考慮清楚使用什麼型別的主鍵。正

Hibernate hbm 外來鍵關聯——SSH （Spring+Struts+Hibernate）框架搭建之配置檔案序列六

      hibernate管理資料庫後，bbm.xml的關聯配置很重要，<many-to-one> 與<one-to-many>一定要配置正確             繼