MyCAT常用分片規則之分片枚舉

MyCAT支持多種分片規則，下麵測試的這種是分片枚舉。適用場景，列值的個數是固定的，譬如省份，月份等。

在這裡，需定義三個值，規則均是在rule.xml中定義。

1. tableRule

2. function

3. mapFile

首先，定義tableRule，

   <tableRule name="sharding-by-intfile-test">
                <rule>
                        <columns>province</columns>
                        <algorithm>hash-int-test</algorithm>
                </rule>
    </tableRule>

其中，sharding-by-intfile-test是規則名，會在schema.xml中用到。

columns指的是對省份進行分片。

algorithm是演算法名，該演算法必須在function中定義。

其次，定義function，

      <function name="hash-int-test"
                class="org.opencloudb.route.function.PartitionByFileMap">
                <property name="mapFile">partition-hash-int-test.txt</property>
                <property name="type">1</property>
                <property name="defaultNode">0</property>
      </function>

其中，mapFile指的是配置文件名

type預設值為0，0表示Integer，非零表示String。因為我接下來的測試是基於省份分片，所以需type指定為1。

defaultNode 預設節點：小於0表示不設置預設節點，大於等於0表示設置預設節點
預設節點的作用：枚舉分片時，如果碰到不識別的枚舉值，就讓它路由到預設節點。如果不配置預設節點（defaultNode值小於0表示不配置預設節點），碰到不識別的枚舉值就會報錯，like this：can’t find datanode for sharding column:column_name val:ffffffff

第三、在rule.xml當前目錄下創建partition-hash-int-test.txt文件，定義枚舉的規則

hubei=0
tianjin=1
guangdong=2

其中，hubei會被分發到第一個節點中，tianjin分發被第二個節點中，guangdong第三個節點中。

現在開始測試，

首先，在shema.xml定義表的分片規則

<table name="t_vote" dataNode="dn2,dn1,dn3" rule="sharding-by-intfile-test" />

登錄MyCAT創建表

# mysql -utest -ptest -h127.0.0.1 -P8066 -DTESTDB

mysql> create table t_vote(id varchar(10),province varchar(10));
Query OK, 0 rows affected (0.04 sec)

mysql> insert into t_vote(id,province) values(database(),'hubei');
Query OK, 1 row affected (0.01 sec)

mysql> insert into t_vote(id,province) values(database(),'tianjin');
Query OK, 1 row affected (0.01 sec)

mysql> insert into t_vote(id,province) values(database(),'guangdong');
Query OK, 1 row affected (0.01 sec)

mysql> insert into t_vote(id,province) values(database(),'shandong');
Query OK, 1 row affected (0.01 sec)

mysql> select * from t_vote;
+------+-----------+
| id   | province  |
+------+-----------+
| db1  | tianjin   |
| db2  | hubei     |
| db2  | shandong  |
| db3  | guangdong |
+------+-----------+
4 rows in set (0.03 sec)

hubei之所以是db2，因為它對應的是第一個節點，而在schema.xml定義t_vote表時，第一個節點即是dn2。

shandong之所以是在db2，因為它並沒有在分片規則中定義，所以會被分到預設節點，預設節點defaultNode的是0，即第一個節點。

總結：

1. 剛開始沒有指定function中type的值，即<property name="type">1</property>。導致insert時報以下錯誤，因為預設的分片類型是integer，而不是string。

mysql> insert into t_vote(id,province) values(database(),'hubei');
ERROR 1064 (HY000): For input string: "hubei"

2. 如果沒有指定function中defaultNode值，則插入不識別的枚舉值時，報以下錯誤：

mysql>  insert into t_vote(id,province) values(database(),'shandong');
ERROR 1064 (HY000): can't find any valid datanode :T_VOTE -> PROVINCE -> shandong

3. MyCAT其實還支持動態載入功能

譬如，我將defaultNode的值定義到partition-hash-int-test.txt中，哈哈，這點也是支持的。當然，前提是註釋掉function中defaultNode值，不然function中的defaultNode值會覆蓋掉partition-hash-int-test.txt中DEFAULT_NODE值。

hubei=0
tianjin=1
guangdong=2
DEFAULT_NODE=2

登錄到MyCAT 9066管理埠

# mysql -utest -ptest -h127.0.0.1 -P9066

mysql> reload @@config;
Query OK, 1 row affected (0.03 sec)
Reload config success

登錄到MyCAT 8066埠

mysql> insert into t_vote(id,province) values(database(),'shanxi');
Query OK, 1 row affected (0.00 sec)

mysql> select * from t_vote;
+------+-----------+
| id   | province  |
+------+-----------+
| db1  | tianjin   |
| db2  | hubei     |
| db2  | shandong  |
| db3  | guangdong |
| db3  | shanxi    |
+------+-----------+
5 rows in set (0.01 sec)

4. 該規則有個問題，如果中途修改了defaultNode的值，譬如，我剛開始設置的是0，插入了shandong這個值，現在修改為2。

mysql> select * from t_vote;
+------+-----------+
| id   | province  |
+------+-----------+
| db1  | tianjin   |
| db3  | guangdong |
| db2  | shanxi    |
| db2  | hubei     |
| db2  | shandong  |
+------+-----------+
5 rows in set (0.01 sec)

mysql> select * from t_vote where province='shandong';
Empty set (0.00 sec)

根據where條件無法檢索出原來插入的值。

日誌中顯示的信息如下：

01/24 15:17:50.028  DEBUG [$_NIOREACTOR-0-RW] (EnchachePool.java:76) -SQLRouteCache  miss cache ,key:TESTDBselect * from t_vote where province='shandong'
01/24 15:17:50.029  DEBUG [$_NIOREACTOR-0-RW] (EnchachePool.java:59) -SQLRouteCache add cache ,key:TESTDBselect * from t_vote where province='shandong' value:select * from t_vote where province='shandong', route={
   1 -> dn3{SELECT *
FROM t_vote
WHERE province = 'shandong'
LIMIT 100}
}

dn3是現在的defaultNode=2所對應的節點。