2. 程式人生 > >mycat高可用 ER分片的2種場景詳細分析

mycat高可用 ER分片的2種場景詳細分析

阿新 • • 發佈：2019-01-30

1，ER分片關係簡介

有一類業務，例如訂單（ORDER）跟訂單明細表（ORDER_DETAIL）,明細表會依賴二訂單，就是該會存在表的主從關係，這類似業務的切分可以抽象出合適的切分規則，比如根據使用者ID切分,其它相關的表都依賴於使用者ID，再或者根據訂單ID進行切分，總之部分業務總會可以抽象出父子關係的表。這類表適用於ER分片表，子表的記錄與所關聯的父表記錄存放在同一個資料分片上，避免資料Join跨庫操作，以order與order_detail例子為例，schema.xml中定義合適的分片配置,order,order_detail 根據order_id迕行資料切分，保證相同order_id的資料分到同一個分片上，在進行資料插入操作時，Mycat會獲取order所在的分片，然後將order_detail也插入到order所在的分片。

2， 父表按照主鍵ID分片，字表的分片欄位與主表ID關聯，配置為ＥＲ分片

2.1 在schema.xml新增如下配置配置檔案修改

<table name="ORDER1" dataNode="dn21,dn22" rule="mod-long"> <childTable name="ORDER_DETAIL" primaryKey="ID" joinKey="ORDER_ID" parentKey="ID" /> </table>

在rule.xml裡面設定分片規則

    <tableRule name="mod-long">
 

                <rule>
                        <columns>id</columns>
                        <algorithm>mod-long</algorithm>
                </rule>
    </tableRule>

然後重啟mycat或者重新載入mycat

2.2 先建表， ORDER 和 ORDER_DETAIL 表，有主外來鍵關係

    CREATE TABLE ORDER1(ID INT NOT
 
 NULL AUTO_INCREMENT PRIMARY KEY,SN VARCHAR(64),CREATE_TIME DATETIME);

    CREATE TABLE ORDER_DETAIL(ID INT AUTO_INCREMENT PRIMARY KEY, ORDER_ID INT,ORD_STATUS CHAR(1),ADDRESS VARCHAR(128),CREATE_TIME DATETIME,CONSTRAINT FK_ORDID11 FOREIGN KEY (ORDER_ID) REFERENCES ORDER1 (ID));



    mysql> CREATE TABLE ORDER1(ID INT NOT NULL AUTO_INCREMENT PRIMARY KEY,SN VARCHAR(64),CREATE_TIME DATETIME);
    Query OK, 0 rows affected (0.06 sec)

    mysql> 
    mysql> CREATE TABLE ORDER_DETAIL(ID INT AUTO_INCREMENT PRIMARY KEY, ORDER_ID INT,ORD_STATUS CHAR(1),ADDRESS VARCHAR(128),CREATE_TIME DATETIME,CONSTRAINT FK_ORDID FOREIGN KEY (ORDER_ID) REFERENCES ORDER1 (ID));
    Query OK, 0 rows affected (0.02 sec)

    mysql>

3.3 錄入資料：

    mysql> 
    mysql> explain INSERT INTO ORDER1(SN,CREATE_TIME) VALUES('BJ0001',NOW());
    ERROR 1064 (HY000): bad insert sql (sharding column:ID not provided,INSERT INTO ORDER1 (SN, CREATE_TIME)
    VALUES ('BJ0001', NOW())
    mysql> explain INSERT INTO ORDER1(SN,CREATE_TIME) VALUES('BJ0001',NOW());
    ERROR 1064 (HY000): bad insert sql (sharding column:ID not provided,INSERT INTO ORDER1 (SN, CREATE_TIME)
    VALUES ('BJ0001', NOW())
    mysql> INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(1,'BJ0001',NOW());
    Query OK, 1 row affected (0.03 sec)

    mysql>

錄入資料，一組組錄入，涉及到外來鍵關係：
第一組北京的訂單

    mysql> INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(1,'BJ0001',NOW());
    Query OK, 1 row affected (0.03 sec)

    mysql> 

    mysql> INSERT INTO ORDER_DETAIL(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (1,1,'1','test data  of ORDER1(ID=1,BJ001) ',NOW());
    Query OK, 1 row affected (0.00 sec)

    mysql>

第二組上海的訂單：

    mysql> INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(3,'SHH001',NOW());
    Query OK, 1 row affected (0.01 sec)

    mysql> INSERT INTO ORDER_DETAIL(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (3,3,'1','test data  of ORDER1(ID=3,SHH001) ',NOW());

    mysql>

第三組廣州的訂單：

    mysql> INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(4,'GZH004',NOW());
    Query OK, 1 row affected (0.01 sec)

    mysql> INSERT INTO ORDER_DETAIL(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (4,4,'1','test data  of ORDER1(ID=4,GZH004) ',NOW());
    mysql>

第四組 武漢的訂單，這裡故意將order_id設定成4，看看效果，是否隨id為4的廣州的那組分片：

    mysql> INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(5,'WUHAN005',NOW());
    ERROR 1064 (HY000): Index: 2, Size: 2
    mysql> INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(6,'WUHAN006',NOW());
    Query OK, 1 row affected (0.02 sec)

    mysql> INSERT INTO ORDER_DETAIL(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (6,4,'1','test data  of ORDER1(ID=6,WUHAN005) ',NOW());

2.4 驗證子表是否隨父表分片，果然驗證如下，大家看到訂單詳細表ORDER_DETAIL的資料的分片都是隨ORDER_ID所在外來鍵的父表的分片：

    [[email protected]_1_11logs]# /usr/local/mysql56s1/bin/mysql -uroot -p -P3317 --socket=/usr/local/mysql56s1/mysql.sock -e "select @@port;select * from db3.ORDER1; select * from db3.ORDER_DETAIL";
    Enter password: 
    +--------+
    | @@port |
    +--------+
    |   3327 |
    +--------+
    +----+--------+---------------------+
    | ID | SN     | CREATE_TIME         |
    +----+--------+---------------------+
    |  1 | BJ0001 | 2016-02-11 22:54:26 |
    |  4 | GZH004 | 2016-02-11 22:57:49 |
    +----+--------+---------------------+
    +----+----------+------------+--------------------------------------+---------------------+
    | ID | ORDER_ID | ORD_STATUS | ADDRESS                              | CREATE_TIME         |
    +----+----------+------------+--------------------------------------+---------------------+
    |  1 |        1 | 1          | test data  of ORDER1(ID=1,BJ001)     | 2016-02-11 23:07:05 |
    |  4 |        4 | 1          | test data  of ORDER1(ID=4,GZH004)    | 2016-02-11 23:09:48 |
    |  6 |        4 | 1          | test data  of ORDER1(ID=6,WUHAN005)  | 2016-02-11 23:10:18 |
    +----+----------+------------+--------------------------------------+---------------------+
    [[email protected]_1_11logs]# 
    [[email protected]_1_11logs]# 
    [[email protected]_1_11logs]# /usr/local/mysql56s1/bin/mysql -uroot -p -P3327 --socket=/usr/local/mysql56m1/mysql.sock -e "select @@port;select * from db3.ORDER1; select * from db3.ORDER_DETAIL";
    Enter password: 
    +--------+
    | @@port |
    +--------+
    |   3317 |
    +--------+
    +----+----------+---------------------+
    | ID | SN       | CREATE_TIME         |
    +----+----------+---------------------+
    |  3 | SHH001   | 2016-02-11 22:57:26 |
    |  6 | WUHAN006 | 2016-02-11 23:04:39 |
    +----+----------+---------------------+
    +----+----------+------------+------------------------------------+---------------------+
    | ID | ORDER_ID | ORD_STATUS | ADDRESS                            | CREATE_TIME         |
    +----+----------+------------+------------------------------------+---------------------+
    |  3 |        3 | 1          | test data  of ORDER1(ID=3,SHH001)  | 2016-02-11 23:09:02 |
    +----+----------+------------+------------------------------------+---------------------+
    [[email protected]_1_11logs]#

2.5 有日誌為列，看到SHH001這個訂單的資料錄入都在埠為3317的分片mysql例項上，如下驗證：

[[email protected]_1_11logs]# more mycat.log|grep SHH001
    02/11 22:56:58.477  DEBUG [$_NIOREACTOR-3-RW] (ServerQueryHandler.java:56) -ServerConnection [id=1, schema=TESTDB, host=127.0.0.1, user=test,txIsolation=3, autocommit=true, schema=TESTDB]INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(2,'SHH001',NOW())
    02/11 22:56:58.478   WARN [$_NIOREACTOR-3-RW] (ServerConnection.java:209) -ServerConnection [id=1, schema=TESTDB, host=127.0.0.1, user=test,txIsolation=3, autocommit=true, schema=TESTDB]INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(2,'SHH001',NOW()) err:java.lang.IndexOutOfBoundsException: Index: 2, Size: 2
    02/11 22:57:22.476  DEBUG [$_NIOREACTOR-3-RW] (ServerQueryHandler.java:56) -ServerConnection [id=1, schema=TESTDB, host=127.0.0.1, user=test,txIsolation=3, autocommit=true, schema=TESTDB]INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(2,'SHH001',NOW())
    02/11 22:57:22.477   WARN [$_NIOREACTOR-3-RW] (ServerConnection.java:209) -ServerConnection [id=1, schema=TESTDB, host=127.0.0.1, user=test,txIsolation=3, autocommit=true, schema=TESTDB]INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(2,'SHH001',NOW()) err:java.lang.IndexOutOfBoundsException: Index: 2, Size: 2
    02/11 22:57:26.988  DEBUG [$_NIOREACTOR-3-RW] (ServerQueryHandler.java:56) -ServerConnection [id=1, schema=TESTDB, host=127.0.0.1, user=test,txIsolation=3, autocommit=true, schema=TESTDB]INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(3,'SHH001',NOW())
    02/11 22:57:26.989  DEBUG [$_NIOREACTOR-3-RW] (NonBlockingSession.java:113) -ServerConnection [id=1, schema=TESTDB, host=127.0.0.1, user=test,txIsolation=3, autocommit=true, schema=TESTDB]INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(3,'SHH001',NOW()), route={
       1 -> dn21{INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(3,'SHH001',NOW())}
    02/11 22:57:26.999  DEBUG [$_NIOREACTOR-0-RW] (NonBlockingSession.java:229) -release connection MySQLConnection [id=4, lastTime=1455202646984, user=root, schema=db3, old shema=db3, borrowed=true, fromSlaveDB=false, threadId=91, charset=latin1, txIsolation=3, autocommit=true, attachment=dn21{INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(3,'SHH001',NOW())}, respHandler=SingleNodeHandler [node=dn21{INSERT INTO ORDER1(ID,SN,CREATE_TIME) VALUES(3,'SHH001',NOW())}, packetId=0], host=12.23.2.11, port=3317, statusSync=null, writeQueue=0, modifiedSQLExecuted=true]
    02/11 23:09:02.690  DEBUG [$_NIOREACTOR-3-RW] (ServerQueryHandler.java:56) -ServerConnection [id=1, schema=TESTDB, host=127.0.0.1, user=test,txIsolation=3, autocommit=true, schema=TESTDB]INSERT INTO ORDER_DETAIL(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (3,3,'1','test data  of ORDER1(ID=3,SHH001) ',NOW())
    VALUES (3, 3, '1', 'test data  of ORDER1(ID=3,SHH001) ', NOW())
    02/11 23:09:02.692  DEBUG [$_NIOREACTOR-3-RW] (NonBlockingSession.java:113) -ServerConnection [id=1, schema=TESTDB, host=127.0.0.1, user=test,txIsolation=3, autocommit=true, schema=TESTDB]INSERT INTO ORDER_DETAIL(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (3,3,'1','test data  of ORDER1(ID=3,SHH001) ',NOW()), route={
    VALUES (3, 3, '1', 'test data  of ORDER1(ID=3,SHH001) ', NOW())}
    VALUES (3, 3, '1', 'test data  of ORDER1(ID=3,SHH001) ', NOW())}, respHandler=SingleNodeHandler [node=dn21{INSERT INTO ORDER_DETAIL (ID, ORDER_ID, ORD_STATUS, ADDRESS, CREATE_TIME)
    VALUES (3, 3, '1', 'test data  of ORDER1(ID=3,SHH001) ', NOW())}, packetId=0], host=12.23.2.11, port=3317, statusSync=null, writeQueue=0, modifiedSQLExecuted=true]
    [[email protected]_1_11logs]#

【】看到直接22:57:26.988時間點處有資料錄入，22:57:26.989處有路由分配 route={dn21了，直接走父表的路由了**

2.6 查詢路由

mycat命令列裡面執行：

    mysql> explain select t1.*,t2.* from ORDER1 t1,ORDER_DETAIL t2 where t2.ORD_STATUS='1' and t2.ID=1 and t1.ID=t2.ORDER_ID;
    +-----------+-----------------------------------------------------------------------------------------------------------+
    | DATA_NODE | SQL                                                                                                       |
    +-----------+-----------------------------------------------------------------------------------------------------------+
    | dn21      | select t1.*,t2.* from ORDER1 t1,ORDER_DETAIL t2 where t2.ORD_STATUS='1' and t2.ID=1 and t1.ID=t2.ORDER_ID |
    | dn22      | select t1.*,t2.* from ORDER1 t1,ORDER_DETAIL t2 where t2.ORD_STATUS='1' and t2.ID=1 and t1.ID=t2.ORDER_ID |
    +-----------+-----------------------------------------------------------------------------------------------------------+
    2 rows in set (0.00 sec)

    mysql>  select t1.*,t2.* from ORDER1 t1,ORDER_DETAIL t2 where t2.ORD_STATUS='1' and t2.ID=1 and t1.ID=t2.ORDER_ID;
    +----+--------+---------------------+----+----------+------------+-----------------------------------+---------------------+
    | ID | SN     | CREATE_TIME         | ID | ORDER_ID | ORD_STATUS | ADDRESS                           | CREATE_TIME         |
    +----+--------+---------------------+----+----------+------------+-----------------------------------+---------------------+
    |  1 | BJ0001 | 2016-02-12 17:51:24 |  1 |        1 | 1          | test data  of ORDER1(ID=1,BJ001)  | 2016-02-12 17:51:30 |
    +----+--------+---------------------+----+----------+------------+-----------------------------------+---------------------+
    1 row in set (0.01 sec)

    mysql>

【】mycat.log後臺日誌debug資訊，看到走的route路由是dn21和dn22，所有的節點路由都走了：

    02/12 18:22:51.444  DEBUG [$_NIOREACTOR-2-RW] (ServerQueryHandler.java:56) -ServerConnection [id=3, schema=TESTDB, host=127.0.0.1, user=test,txIsolation=3, autocommit=true, schema=TESTDB]explain select t1.*,t2.* from ORDER1 t1,ORDER_DETAIL t2 where t2.ORD_STATUS='1' and t2.ID=1 and t1.ID=t2.ORDER_ID
    02/12 18:22:51.444  DEBUG [$_NIOREACTOR-2-RW] (EnchachePool.java:76) -SQLRouteCache  miss cache ,key:TESTDB select t1.*,t2.* from ORDER1 t1,ORDER_DETAIL t2 where t2.ORD_STATUS='1' and t2.ID=1 and t1.ID=t2.ORDER_ID
    02/12 18:22:51.448  DEBUG [$_NIOREACTOR-2-RW] (EnchachePool.java:59) -SQLRouteCache add cache ,key:TESTDB select t1.*,t2.* from ORDER1 t1,ORDER_DETAIL t2 where t2.ORD_STATUS='1' and t2.ID=1 and t1.ID=t2.ORDER_ID value:select t1.*,t2.* from ORDER1 t1,ORDER_DETAIL t2 where t2.ORD_STATUS='1' and t2.ID=1 and t1.ID=t2.ORDER_ID, route={
       1 -> dn21{select t1.*,t2.* from ORDER1 t1,ORDER_DETAIL t2 where t2.ORD_STATUS='1' and t2.ID=1 and t1.ID=t2.ORDER_ID}
       2 -> dn22{select t1.*,t2.* from ORDER1 t1,ORDER_DETAIL t2 where t2.ORD_STATUS='1' and t2.ID=1 and t1.ID=t2.ORDER_ID}
    }
    02/12 18:23:01.214  DEBUG [Timer0] (ConnectionHeartBeatHandler.java:52) -do heartbeat for con MySQLConnection [id=18, lastTime=1455272581207, user=root, schema=db2, old shema=db2, borrowed=true, fromSlaveDB=false, threadId=18, charset=latin1, txIsolation=0, autocommit=true, attachment=null, respHandler=null, host=12.23.2.11, port=3317, statusSync=null, writeQueue=0, modifiedSQLExecuted=false]
    02/12 18:23:01.215  DEBUG [Timer0] (ConnectionHeartBeatHandler.java:52) -do heartbeat for con MySQLConnection [id=22, lastTime=1455272581207, user=root, schema=db2, old shema=db2, borrowed=true, fromSlaveDB=false, threadId=21, charset=latin1, txIsolation=0, autocommit=true, attachment=null, respHandler=null, host=12.23.2.11, port=3317, statusSync=null, writeQueue=0, modifiedSQLExecuted=false]

這裡寫圖片描述
圖片1.jpg

2.7 總結：當子表與父表的關聯欄位正好是父表的分片欄位時，子表直接根據父表規則進行分片，在資料錄入的時候子表直接放在父表的分片上面，在進行關聯查詢join的時候，走的是

3 .父表的分片欄位為其他欄位，以PROVINCE欄位分片，字表的分片欄位與主表ID關聯，配置為ＥＲ分片

3.1 各種配置

在schema.xml裡面新增表配置

     <table name="ORDER2" primaryKey="ID" dataNode="dn21,dn22" rule="province-str"> <childTable name="ORDER_DETAIL2" primaryKey="ID" joinKey="ORDER_ID" parentKey="ID" /> </table>

在rule.xml裡面設定分片規則

        <tableRule name="province-str">
                 <rule>
                         <columns>PROVINCE</columns>
                          <algorithm>province-str-split</algorithm>
                </rule>
         </tableRule>    </tableRule>
        <function name="province-str-split" class="org.opencloudb.route.function.PartitionByFileMap">
                <property name="type">1</property>
                <property name="mapFile">partition-hash-str-pro.txt</property>
                <property name="defaultNode">0</property>
        </function>

新新增partition-hash-str-pro.txt

    [root@test_1_11conf]# more partition-hash-str-pro.txt
    beijing=0
    shanghai=1
    tianjing=2
    [root@test_1_11conf]#

然後重啟mycat或者重新載入mycat

3.2 建表

    CREATE TABLE ORDER2(ID INT NOT NULL AUTO_INCREMENT PRIMARY KEY,PROVINCE VARCHAR(16),SN VARCHAR(64),CREATE_TIME DATETIME);

    CREATE TABLE ORDER_DETAIL2(ID INT AUTO_INCREMENT PRIMARY KEY, ORDER_ID INT,ORD_STATUS CHAR(1),ADDRESS VARCHAR(128),CREATE_TIME DATETIME,CONSTRAINT FK_ORDID21 FOREIGN KEY (ORDER_ID) REFERENCES ORDER2 (ID));
    mysql> CREATE TABLE ORDER2(ID INT NOT NULL AUTO_INCREMENT PRIMARY KEY,SN VARCHAR(64),CREATE_TIME DATETIME);
    Query OK, 0 rows affected (0.05 sec)

    mysql> CREATE TABLE ORDER_DETAIL2(ID INT AUTO_INCREMENT PRIMARY KEY, ORDER_ID INT,ORD_STATUS CHAR(1),ADDRESS VARCHAR(128),CREATE_TIME DATETIME,CONSTRAINT FK_ORDID21 FOREIGN KEY (ORDER_ID) REFERENCES ORDER2 (ID));
    Query OK, 0 rows affected (0.02 sec)

    mysql>

3.2 錄入資料，一組組錄入，涉及到外來鍵關係：

    INSERT INTO ORDER2(ID,PROVINCE,SN,CREATE_TIME) VALUES(1,'beijing','2BJ0001',NOW());
    INSERT INTO ORDER_DETAIL2(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (1,1,'1','test data  of ORDER1(ID=1,2BJ0001) ',NOW());
    mysql> INSERT INTO ORDER2(ID,PROVINCE,SN,CREATE_TIME) VALUES(1,'beijing','2BJ0001',NOW());
    Query OK, 1 row affected (0.01 sec)

    mysql> INSERT INTO ORDER_DETAIL2(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (1,1,'1','test data  of ORDER1(ID=1,2BJ0001) ',NOW());
    Query OK, 1 row affected (0.21 sec)

    mysql>  
    INSERT INTO ORDER2(ID,PROVINCE,SN,CREATE_TIME) VALUES(3,'shanghai','2SHH001',NOW());
    INSERT INTO ORDER_DETAIL2(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (3,3,'1','test data  of ORDER1(ID=3,2SHH001) ',NOW());
    mysql> INSERT INTO ORDER2(ID,PROVINCE,SN,CREATE_TIME) VALUES(3,'shanghai','2SHH001',NOW());
    Query OK, 1 row affected (0.01 sec)

    mysql> INSERT INTO ORDER_DETAIL2(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (3,3,'1','test data  of ORDER1(ID=3,2SHH001) ',NOW());
    Query OK, 1 row affected (0.41 sec)

    mysql> 
    INSERT INTO ORDER2(ID,PROVINCE,SN,CREATE_TIME) VALUES(4,'beijing','2GZH004',NOW());
    INSERT INTO ORDER_DETAIL2(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (4,4,'1','test data  of ORDER1(ID=4,2GZH004) ',NOW());
    mysql> INSERT INTO ORDER2(ID,PROVINCE,SN,CREATE_TIME) VALUES(4,'beijing','2GZH004',NOW());
    Query OK, 1 row affected (0.00 sec)

    mysql> INSERT INTO ORDER_DETAIL2(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (4,4,'1','test data  of ORDER1(ID=4,2GZH004) ',NOW());
    Query OK, 1 row affected (0.21 sec)

    mysql>
    INSERT INTO ORDER2(ID,PROVINCE,SN,CREATE_TIME) VALUES(6,'shanghai','2WUHAN006',NOW());
    INSERT INTO ORDER_DETAIL2(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (6,4,'1','test data  of ORDER1(ID=6,2WUHAN006) ',NOW());
    mysql> INSERT INTO ORDER2(ID,PROVINCE,SN,CREATE_TIME) VALUES(6,'shanghai','2WUHAN006',NOW());
    Query OK, 1 row affected (0.02 sec)

    mysql> INSERT INTO ORDER_DETAIL2(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (6,4,'1','test data  of ORDER1(ID=6,2WUHAN006) ',NOW());
    Query OK, 1 row affected (0.22 sec)

    mysql>  
    mysql> INSERT INTO ORDER_DETAIL2(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (6,9,'1','test data  of ORDER1(ID=6,2WUHAN006) ',NOW());
    ERROR 1064 (HY000): can't find (root) parent sharding node for sql:INSERT INTO ORDER_DETAIL2(ID,ORDER_ID,ORD_STATUS,ADDRESS,CREATE_TIME) VALUES (6,9,'1','test data  of ORDER1(ID=6,2WUHAN006) ',NOW())
    mysql>

3.3 資料驗證

    [[email protected]_1_11~]# /usr/local/mysql56s1/bin/mysql -uroot -p --socket=/usr/local/mysql56s1/mysql.sock -e "select @@port;select * from db3.ORDER2; select * from db3.ORDER_DETAIL2";
    Enter password: 
    +--------+
    | @@port |
    +--------+
    |   3327 |
    +--------+
    +----+----------+-----------+---------------------+
    | ID | PROVINCE | SN        | CREATE_TIME         |
    +----+----------+-----------+---------------------+
    |  3 | shanghai | 2SHH001   | 2016-02-12 17:24:00 |
    |  6 | shanghai | 2WUHAN006 | 2016-02-12 17:24:14 |
    +----+----------+-----------+---------------------+
    +----+----------+------------+-------------------------------------+---------------------+
    | ID | ORDER_ID | ORD_STATUS | ADDRESS                             | CREATE_TIME         |
    +----+----------+------------+-------------------------------------+---------------------+
    |  3 |        3 | 1          | test data  of ORDER1(ID=3,2SHH001)  | 2016-02-12 17:24:04 |
    +----+----------+------------+-------------------------------------+---------------------+
    [[email protected]_1_11~]#     
    [[email protected]_1_11~]# /usr/local/mysql56s1/bin/mysql -uroot -p --socket=/usr/local/mysql56m1/mysql.sock -e "select @@port;select * from db3.ORDER2; select * from db3.ORDER_DETAIL2";
    Enter password: 
    +--------+
    | @@port |
    +--------+
    |   3317 |
    +--------+
    +----+----------+---------+---------------------+
    | ID | PROVINCE | SN      | CREATE_TIME         |
    +----+----------+---------+---------------------+
    |  1 | beijing  | 2BJ0001 | 2016-02-12 17:23:46 |
    |  4 | beijing  | 2GZH004 | 2016-02-12 17:24:07 |
    +----+----------+---------+---------------------+
    +----+----------+------------+---------------------------------------+---------------------+
    | ID | ORDER_ID | ORD_STATUS | ADDRESS                               | CREATE_TIME         |
    +----+----------+------------+---------------------------------------+---------------------+
    |  1 |        1 | 1          | test data  of ORDER1(ID=1,2BJ0001)    | 2016-02-12 17:23:50 |
    |  4 |        4 | 1          | test data  of ORDER1(ID=4,2GZH004)    | 2016-02-12 17:24:11 |
    |  6 |        4 | 1          | test data  of ORDER1(ID=6,2WUHAN006)  | 2016-02-12 17:24:17 |
    +----+----------+------------+---------------------------------------+---------------------+
    [[email protected]_1_11~]#

3.4 mycat.log中debug日誌顯示，通過關鍵字2BJ0001來檢索父子資料記錄的錄入情況

vim mycat.log

    02/12 17:23:50.530  DEBUG [$_NIOREACTOR-2-RW] (RouterUtil.java:1188) -find root parent's node sql select order2.id from order2 where  order2.id=1
    02/12 17:23:50.531  DEBUG [BusinessExecutor3] (EnchachePool.java:76) -ER_SQL2PARENTID  miss cache ,key:TESTDB:select order2.id from order2 where  order2.id=1
    02/12 17:23:50.531  DEBUG [BusinessExecutor3] (FetchStoreNodeOfChildTableHandler.java:73) -find child node with sql:select order2.id from order2 where  order2.id=1
    02/12 17:23:50.531  DEBUG [BusinessExecutor3] (FetchStoreNodeOfChildTableHandler.java:81) -execute in datanode dn21
    02/12 17:23:50.531  DEBUG [BusinessExecutor3] (PhysicalDBPool.java:452) -select read source hostM2 for dataHost:m1
    02/12 17:23:50.532  DEBUG [$_NIOREACTOR-0-RW] (FetchStoreNodeOfChildTableHandler.java:154) -received rowResponse response,1 from  MySQLConnection [id=8, lastTime=1455269030515, user=root, schema=db3, old shema=db3, borrowed=true, fromSlaveDB=false, threadId=15, charset=latin1, txIsolation=0, autocommit=true, attachment=dn21, respHandler=org.opencloudb.mysql.nio.handler[email protected], host=12.23.2.11, port=3317, statusSync=null, writeQueue=0, modifiedSQLExecuted=false]
    02/12 17:23:50.533  DEBUG [$_NIOREACTOR-0-RW] (PhysicalDatasource.java:403) -release channel MySQLConnection [id=8, lastTime=1455269030515, user=root, schema=db3, old shema=db3, borrowed=true, fromSlaveDB=false, threadId=15, charset=latin1, txIsolation=0, autocommit=true, attachment=null, respHandler=null, host=12.23.2.11, port=3317, statusSync=null, writeQueue=0, modifiedSQLExecuted=false]
    02/12 17:23:50.732  DEBUG [BusinessExecutor4] (RouterUtil.java:

相關推薦

mycat高可用 ER分片的2種場景詳細分析

1，ER分片關係簡介 有一類業務，例如訂單（ORDER）跟訂單明細表（ORDER_DETAIL）,明細表會依賴二訂單，就是該會存在表的主從關係，這類似業務的切分可以抽象出合適的切分規則，比如根據使用者ID切分,其它相關的表都依賴於使用者ID，再或者根據訂單ID

【架構】Heartbeat高可用服務（2）

agents 可用 分享 ont .com war 集群 需求 spa Heartbeat高可用服務 【13】Heartbeat發展情況及分支軟件介紹 　　有關Heartbeat分3個分支的說明 　　　　自2.1.4版本後，Linux-HA將Heartbeat分包

HaProxy+Keepalived+Mycat高可用群集配置

HaProxy+Keepalived+M概述 本章節主要介紹配置HaProxy+Keepalived高可用群集，Mycat的配置就不在這裏做介紹，可以參考我前面寫的幾篇關於Mycat的文章。 部署圖： 配置 HaProxy安裝181和179兩臺服務器安裝haproxy的步驟一致--創建haproxy用戶

高可用之KeepAlived(2)：keepalived+lvs

不用 eset 修改 == server sent image .html cnblogs KeepAlived系列文章：http://www.cnblogs.com/f-ck-need-u/p/7576137.html 本文目錄：1. keepalived+lv

阿里雲ECS伺服器下的Mycat高可用方案介紹與實戰

前言 最近在做系統架構升級，其中之一是讓mycat叢集化，達到高可用的目的,不然單點故障這把達克摩斯之劍懸在頭頂，晚上都睡不安穩。 以下為調研的幾套方案。 方案分析 HaProxy+Keepalived 這套方案是mycat官方推薦的方案。 構造虛擬ip，keep

Redis高可用及分片叢集

一、主從複製 使用非同步複製 一個伺服器可以有多個從伺服器 從伺服器也可以有自己的從伺服器 複製功能不會阻塞主伺服器 可以通過服務功能來上主伺服器免於持久化操作，由從伺服器去執行持久化操作即可。 以下是關於Redis複製功能的幾個重要方面： Redis使用非同步複製。從Redis

LVS+Keepalived搭建MyCAT高可用負載均衡叢集

LVS+Keepalived 介紹 LVS LVS是Linux Virtual Server的簡寫，意即Linux虛擬伺服器，是一個虛擬的伺服器集群系統。本專案在1998年5月由章文嵩博士成立，是中國國內最早出現的自由軟體專案之一。目前有三種IP負載均衡技術（VS/NAT、VS/TUN和VS/DR），十種

SQL Server中的高可用性（2）----檔案與檔案組

    在談到SQL Server的高可用性之前，我們首先要談一談單例項的高可用性。在單例項的高可用性中，不可忽略的就是檔案和檔案組的高可用性。SQL Server允許在某些檔案損壞或離線的情況下，允許資料庫依然保持部分線上，從而保證了高可用性。 檔案和檔案組     有關檔案和檔案組的基本概念，有很

zabbix3.0.2 監控oracle高可用dataguard的standby庫狀態詳細過程

1，判斷standby複製實時的標準判斷標準是，通過sqlplus執行select sequence#,applied from v$archived_log order by sequence#;如果全是YES則表明standby庫已經實時複製了，primary和stand

keepalived實現mycat高可用問題排查；道路坎坷，布滿荊棘，定讓你大吃一驚!

查詢信息 情況 sbin 使用 str 說明 pen at命令 搶占 前言 　　開心一刻 　　　　醫院裏，一母親帶著小女孩打針。小女孩：“媽媽我不想打針，疼！”媽媽：“寶貝兒聽話，這裏這麽多護士阿姨，咱們找個打針不疼的。”

Mongodb 3.4配置搭建高可用叢集（2）

環境準備Centos6.5 三臺伺服器： 10.68.17.106、10.68.17.109、10.68.17.110 埠分配： mongos:20000、config:21000、shard1:27001、shard2:27002、shard3:27003 分別為每臺機器

網路流 dicnic sap 2種演算法詳細解釋

Secret Milking Machine Time Limit: 1000MS Memory Limit: 65536K Total Submissions: 8189 Accepted: 2485 Description Farmer Jo

HTTP 2.0 原理詳細分析

target all src coo rime 導致 -a charset afa HTTP 2.0是在SPDY（An experimental protocol for a faster web, The Chromium Projects）基礎上形成的下一代互聯網通信協

Android中IPC的幾種方式詳細分析與優缺點分析

Android程序間通訊(IPC:Inter-Process Communication)的幾種主要方式如下 1.使用Bundle   ----> 用於android四大元件間的程序間通訊 android的四大元件都可使用Bundle傳遞資料  所以如果要實現四大元

Android中實現IPC的幾種方式詳細分析及比較

1.使用Bundle   ----> 用於android四大元件間的程序間通訊android的四大元件都可使用Bundle傳遞資料  所以如果要實現四大元件間的程序間通訊 完全可以使用Bundle來實現 簡單方便  2.使用檔案共享  ---->用於單執行緒讀寫

Hibernate物件三種狀態詳細分析（轉自http://blog.csdn.net/redarmy_chen/article/details/7069482）

在hibernate中有三種狀態：瞬時態(Transient)、 持久態(Persistent)、脫管態(Detached)。處於持久態的物件也稱為PO(Persistence Object)，瞬時物件和脫管物件也稱為VO（Value Object）。通過自己在網上的搜尋，

MySQL 高可用：mysql+mycat實現數據庫分片（分庫分表）

native 分布 for 成功 img 問題 represent apache 新一代 本文引用於http://blog.csdn.net/kk185800961/article/details/51147029 MySQL 高可用：mysql+mycat實現數據庫分片（

MySQL 高可用：mysql+mycat實現資料庫分片（分庫分表）

什麼是MYCAT： 一個徹底開源的，面向企業應用開發的大資料庫叢集 支援事務、ACID、可以替代MySQL的加強版資料庫 一個可以視為MySQL叢集的企業級資料庫，用來替代昂貴的Oracle叢集 一個融合記憶體快取技術、NoSQL技術、HDFS大資料的新型SQL Se

Kubernetes-5-2：Harbor倉庫的幾種高可用方案與搭建

高可用Harbor搭建  思路及介紹 Harbor官方有推出主從架構和雙主架構來實現Harbor的高可用及資料備份。   一、主從架構：  說白了，就是往一臺Harbor倉庫中push映象，然後再通過這臺Harbor分散下發至所有的從Harbor，類似下圖： 這個方法保證了資

搭建高可用mongodb集群（四）—— 分片

tor cat address pad 業務 [] 日誌信息 ast mongo 搭建高可用mongodb集群（四）—— 分片 按照上一節中《搭建高可用mongodb集群（三）—— 深入副本集》搭建後還有兩個問題沒有解決： 從節點每個上面的數據都是對數據庫全量拷貝，