基于MyCat1.6.5的同库分表 主从分离 自定义分片规则

<!-- name:显示的表名 sqlMaxLimit:最多查询的数据条数 -->
<schema name="aaadb" checkSQLschema="false" sqlMaxLimit="100">
    <!-- name:逻辑表表名 primaryKey:逻辑表对应真实表的主键 autoIncrement:主键自增长 dataNode:逻辑表所属的dataNode rule:逻辑表使用的规则名字 -->
    <table name="testtb" primaryKey="id" autoIncrement="true" subTables="testtb$1-12" dataNode="dn11" rule="part-by-hour"/>
</schema>

<dataNode name="dn11" dataHost="localhost1" database="aaadb1" />

<!-- balance="3"，所有读请求随机的分发到 wiriterHost 对应的 readhost 执行，writerHost 不负担读压力 -->
<dataHost name="localhost1" maxCon="1000" minCon="10" balance="3" writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
    <!-- 用于和后端数据库进行心跳检查的语句 -->
    <heartbeat>select user()</heartbeat>
    <!-- 写实例 -->
    <writeHost host="hostM1" url="localhost:3306" user="root" password="123456">
        <!-- 读实例 -->
        <readHost host="hostS1" url="localhost:4406" user="root" password="123456" />
    </writeHost>
</dataHost>

<!-- columns: 对应数据库中的字段 algorithm: 下面定义的function的名字 -->
<tableRule name="part-by-hour">
    <rule>
        <columns>create_date</columns>
        <algorithm>part-by-hour</algorithm>
    </rule>
</tableRule>

<!-- class: 分片规则的类 -->
<function name="part-by-hour"
          class="io.mycat.route.function.PartitionByHour">
    <!-- name: 分片规则的类中需要传入的初始化值 -->
    <property name="timeInerval">8</property>
    <property name="partitionNum">12</property>
    <property name="beginDate">2018-08-16 00:00:00</property>
</function>

<user name="root" defaultAccount="true">
    <property name="password">123456</property>
    <property name="schemas">aaadb</property>
</user>

/**
 * PartitionByHour
 *
 * @author MT.LUO
 * 2018/8/18 15:10
 * @Description:  根据初始时间beginDate，每隔timeInerval小时的时间，存储在不同分片，
 *                  超过partitionNum又从0节点开始存储
 */
public class PartitionByHour extends AbstractPartitionAlgorithm implements RuleAlgorithm {
    /**
     * 时间间隔的单位是小时
     */
    private int timeInerval = 1;

    /**
     * 一共有多少个分片
     */
    private int partitionNum = 1;

    /**
     * 开始存储的日期  yyyy-MM-dd HH:mm:ss
     */
    private String beginDate;
    private String dateFormat = "yyyy-MM-dd HH:mm:ss";

    private long tBeginDate;

    private static final long oneHour = 3600000;
    private ThreadLocal<SimpleDateFormat> formatter;

    public void setTimeInerval(int timeInerval) {
        this.timeInerval = timeInerval;
    }

    public void setPartitionNum(int partitionNum) {
        this.partitionNum = partitionNum;
    }

    public void setBeginDate(String beginDate) {
        this.beginDate = beginDate;
    }

    /**
     * 初始化数据，主要是设置起始时间
     */
    @Override
    public void init() {
        try {
            tBeginDate = new SimpleDateFormat(dateFormat).parse(beginDate).getTime();

            formatter = new ThreadLocal<SimpleDateFormat>() {
                @Override
                protected SimpleDateFormat initialValue() {
                    return new SimpleDateFormat(dateFormat);
                }
            };

        } catch (ParseException e) {
            throw new java.lang.IllegalArgumentException(e);
        }
    }

    /**
     * 实际分片计算规则的函数
     * @param columnValue 传入的数据字段值
     * @return 返回dataNode的标号
     */
    @Override
    public Integer calculate(String columnValue) {
        try {
            String tmp = columnValue.substring(0, columnValue.length() - 5) + "00:00";
            System.out.println(".................columnValue: " + columnValue + ", " + tmp);
            long currentTime = new SimpleDateFormat(dateFormat).parse(tmp).getTime();
            System.out.println(".................PartitionByHour: " + tmp + ", " + currentTime);
            if ((currentTime - tBeginDate) >= 0) {
                int count = (int) ((currentTime - tBeginDate) / oneHour);
                System.out.println(".................count: " + count);
                return (count / timeInerval) % partitionNum;

            } else {
                throw new java.lang.IllegalArgumentException("invalid columnValue param: that value should be bigger " +
                        "" + "than " + beginDate);
            }
        } catch (ParseException e) {
            throw new java.lang.IllegalArgumentException("invalid columnValue param: that format should be " +
                    "yyyy-MM-dd" + " HH:mm:ss");
        }
    }

}

<function name="part-by-hour"
          class="io.mycat.route.function.PartitionByHour">
    <property name="timeInerval">8</property>
    <property name="partitionNum">12</property>
    <property name="beginDate">2018-08-16 00:00:00</property>
</function>

Caused by: java.sql.SQLException: No dataNode found ,please check tables defined in schema:aaadb