mycat 1.6.5 for mysql 8分表攻略

若是你下載已經打包好的mycat 1.6.5壓縮包.tar.gz是永遠也鏈接不了mysql 8的,咱們須要的是mycat 1.6.5的源代碼Mycat-Server-1.6.zip的源代碼,這個能夠自行去下載.下載完以後,第一次加載須要加載他裏面的jar包,這個時間比較漫長.java

打開他的pom文件,咱們須要改動mysql的驅動,改成node

<dependency>
   <groupId>mysql</groupId>
   <artifactId>mysql-connector-java</artifactId>
   <version>8.0.11</version>
</dependency>

修改源代碼class SystemConfig,包爲package io.mycat.config.model;mysql

public static final String[] MySQLVersions = { "5.5", "5.6", "5.7", "8.0" };

加入"8.0"版本,linux

// 是否使用HandshakeV10Packet來與client進行通信, 1:是 , 0:否(使用HandshakePacket)
// 使用HandshakeV10Packet爲的是兼容高版本的jdbc驅動, 後期穩定下來考慮所有采用HandshakeV10Packet來通信
private int useHandshakeV10 = 1;

這個本來是0,改爲1.程序員

而後用maven打包,記得跳過測試.會獲得這樣一些文件.sql

而咱們要的是-linux.tar.gz這個.mongodb

上傳,解壓,修改/conf目錄下的三個文件server.xml,schema.xml,rule.xml數據庫

假如咱們有一個userbetorder表要分紅5張表,如圖express

server.xml的配置爲:apache

<?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="nonePasswordLogin">0</property> <!-- 0爲須要密碼登錄、1爲不須要密碼登錄 ,默認爲0,設置爲1則須要指定默認帳戶-->
    <property name="useHandshakeV10">1</property>
    <property name="useSqlStat">0</property>  <!-- 1爲開啓實時統計、0爲關閉 -->
    <property name="useGlobleTableCheck">0</property>  <!-- 1爲開啓全加班一致性檢測、0爲關閉 -->

        <property name="sequnceHandlerType">2</property>
      <!--  <property name="useCompression">1</property>--> <!--1爲開啓mysql壓縮協議-->
        <!--  <property name="fakeMySQLVersion">5.6.20</property>--> <!--設置模擬的MySQL版本號-->
    <!-- <property name="processorBufferChunk">40960</property> -->
    <!-- 
    <property name="processors">1</property> 
    <property name="processorExecutor">32</property> 
     -->
        <!--默認爲type 0: DirectByteBufferPool | type 1 ByteBufferArena | type 2 NettyBufferPool -->
        <property name="processorBufferPoolType">0</property>
        <!--默認是65535 64K 用於sql解析時最大文本長度 -->
        <!--<property name="maxStringLiteralLength">65535</property>-->
        <!--<property name="sequnceHandlerType">0</property>-->
        <!--<property name="backSocketNoDelay">1</property>-->
        <!--<property name="frontSocketNoDelay">1</property>-->
        <!--<property name="processorExecutor">16</property>-->
        <!--
            <property name="serverPort">8066</property> <property name="managerPort">9066</property> 
            <property name="idleTimeout">300000</property> <property name="bindIp">0.0.0.0</property> 
            <property name="frontWriteQueueSize">4096</property> <property name="processors">32</property> -->
        <!--分佈式事務開關,0爲不過濾分佈式事務,1爲過濾分佈式事務(若是分佈式事務內只涉及全局表,則不過濾),2爲不過濾分佈式事務,可是記錄分佈式事務日誌-->
        <property name="handleDistributedTransactions">0</property>
        
            <!--
            off heap for merge/order/group/limit      1開啓   0關閉
        -->
        <property name="useOffHeapForMerge">0</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">false</property>

        <!-- XA Recovery Log日誌路徑 -->
        <!--<property name="XARecoveryLogBaseDir">./</property>-->

        <!-- XA Recovery Log日誌名稱 -->
        <!--<property name="XARecoveryLogBaseName">tmlog</property>-->

    </system>
    
    <!-- 全局SQL防火牆設置 -->
    <!--白名單能夠使用通配符%或着*-->
    <!--例如<host host="127.0.0.*" user="root"/>-->
    <!--例如<host host="127.0.*" user="root"/>-->
    <!--例如<host host="127.*" user="root"/>-->
    <!--例如<host host="1*7.*" user="root"/>-->
    <!--這些配置狀況下對於127.0.0.1都能以root帳戶登陸-->
    <!--
    <firewall>
       <whitehost>
          <host host="1*7.0.0.*" user="root"/>
       </whitehost>
       <blacklist check="false">
       </blacklist>
    </firewall>
    -->

    <user name="facebook1" defaultAccount="true">
        <property name="password">facebook</property>
        <property name="schemas">game</property>
        
        <!-- 表級 DML 權限設置 -->
        <!--         
        <privileges check="false">
            <schema name="TESTDB" dml="0110" >
                <table name="tb01" dml="0000"></table>
                <table name="tb02" dml="1111"></table>
            </schema>
        </privileges>        
         -->
    </user>

    <user name="facebook2">
        <property name="password">facebook</property>
        <property name="schemas">game</property>
        <property name="readOnly">true</property>
    </user>

</mycat:server>

修改大家本身的

 <user name="facebook1" defaultAccount="true">
        <property name="password">facebook</property>
        <property name="schemas">game</property>

就能夠了schemas的內容要與schema.xml裏面相同

schema.xml配置

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

    <schema name="game" checkSQLschema="true" sqlMaxLimit="100">
        <!-- auto sharding by id (long) -->

        <!-- global table is auto cloned to all defined data nodes ,so can join
            with any table whose sharding node is in the same data node -->
        <!-- random sharding using mod sharind rule -->
        <table name="UserBetOrder" primaryKey="id" autoIncrement="false" dataNode="dn1" subTables="UserBetOrder$1-5"
               rule="mod-long" />
        <!-- <table name="dual" primaryKey="ID" dataNode="dnx,dnoracle2" type="global"
            needAddLimit="false"/> <table name="worker" primaryKey="ID" dataNode="jdbc_dn1,jdbc_dn2,jdbc_dn3"
            rule="mod-long" /> -->
        <!-- <table name="oc_call" primaryKey="ID" dataNode="dn1$0-743" rule="latest-month-calldate"
            /> -->
    </schema>
    <!-- <dataNode name="dn1$0-743" dataHost="localhost1" database="db$0-743"
        /> -->
    <dataNode name="dn1" dataHost="dh1" database="cloud_game" />
    <!--<dataNode name="dn4" dataHost="sequoiadb1" database="SAMPLE" />
     <dataNode name="jdbc_dn1" dataHost="jdbchost" database="db1" />
    <dataNode    name="jdbc_dn2" dataHost="jdbchost" database="db2" />
    <dataNode name="jdbc_dn3"     dataHost="jdbchost" database="db3" /> -->
    <dataHost name="dh1" maxCon="1000" minCon="10" balance="0" maxRetryCount="3"
              writeType="0" dbType="mysql" dbDriver="jdbc" switchType="1"  slaveThreshold="100">
        <heartbeat>select 1</heartbeat>
        <!-- can have multi write hosts -->
        <writeHost host="hostM1" url="jdbc:mysql://192.168.5.182:3307?useSSL=FALSE&amp;serverTimezone=GMT" user="root"
                   password="goalya">
            <!-- can have multi read hosts -->
            <readHost host="hostS2" url="jdbc:mysql://192.168.5.182:3307?useSSL=FALSE&amp;serverTimezone=GMT" user="root" password="goalya" />
        </writeHost>
    <!--    <writeHost host="hostS1" url="localhost:3316" user="root"
                   password="123456" />  -->
        <!-- <writeHost host="hostM2" url="localhost:3316" user="root" password="123456"/> -->
    </dataHost>
    <!--
        <dataHost name="sequoiadb1" maxCon="1000" minCon="1" balance="0" dbType="sequoiadb" dbDriver="jdbc">
        <heartbeat>         </heartbeat>
         <writeHost host="hostM1" url="sequoiadb://1426587161.dbaas.sequoialab.net:11920/SAMPLE" user="jifeng"     password="jifeng"></writeHost>
         </dataHost>

      <dataHost name="oracle1" maxCon="1000" minCon="1" balance="0" writeType="0"     dbType="oracle" dbDriver="jdbc"> <heartbeat>select 1 from dual</heartbeat>
        <connectionInitSql>alter session set nls_date_format='yyyy-mm-dd hh24:mi:ss'</connectionInitSql>
        <writeHost host="hostM1" url="jdbc:oracle:thin:@127.0.0.1:1521:nange" user="base"     password="123456" > </writeHost> </dataHost>

        <dataHost name="jdbchost" maxCon="1000"     minCon="1" balance="0" writeType="0" dbType="mongodb" dbDriver="jdbc">
        <heartbeat>select     user()</heartbeat>
        <writeHost host="hostM" url="mongodb://192.168.0.99/test" user="admin" password="123456" ></writeHost> </dataHost>

        <dataHost name="sparksql" maxCon="1000" minCon="1" balance="0" dbType="spark" dbDriver="jdbc">
        <heartbeat> </heartbeat>
         <writeHost host="hostM1" url="jdbc:hive2://feng01:10000" user="jifeng"     password="jifeng"></writeHost> </dataHost> -->

    <!-- <dataHost name="jdbchost" maxCon="1000" minCon="10" balance="0" dbType="mysql"
        dbDriver="jdbc"> <heartbeat>select user()</heartbeat> <writeHost host="hostM1"
        url="jdbc:mysql://localhost:3306" user="root" password="123456"> </writeHost>
        </dataHost> -->
</mycat:schema>

要改的地方

<table name="UserBetOrder" primaryKey="id" autoIncrement="false" dataNode="dn1" subTables="UserBetOrder$1-5"
               rule="mod-long" />改爲大家本身的邏輯表名和分表名用$1-X表示

<dataNode name="dn1" dataHost="dh1" database="cloud_game" />database後面帶大家的數據庫名.

<writeHost host="hostM1" url="jdbc:mysql://192.168.5.182:3307?useSSL=FALSE&amp;serverTimezone=GMT" user="root"
                   password="goalya">
            <!-- can have multi read hosts -->
            <readHost host="hostS2" url="jdbc:mysql://192.168.5.182:3307?useSSL=FALSE&amp;serverTimezone=GMT" user="root" password="goalya" />
        </writeHost>帶上大家本身的鏈接數據庫的IP,端口,用戶名,密碼

rule.xml裏面只要改一個地方

<function name="mod-long" class="io.mycat.route.function.PartitionByMod">
        <!-- how many data nodes -->
        <property name="count">5</property>
    </function>

這個count裏面改爲你的分表數,我這裏是5.

剩下的就是在/bin目錄下啓動  ./mycat start就能夠了

用你的數據庫鏈接工具鏈接進去,操做一個表,如插入,查找等於操做5個表,每插入一次,他會隨機插入到一個分表中

另外不要使用select * from 邏輯表;來進行查找,必定要帶你設置的索引(group by,order by均可以),不然會一次找出5的倍數來.

最後祝你們程序員節日快樂!

相關文章
相關標籤/搜索