init

.gitignore

@@ -1,14 +1,18 @@
-# ---> Java
-*.class
-
-# Mobile Tools for Java (J2ME)
-.mtj.tmp/
-
-# Package Files #
-*.jar
-*.war
-*.ear
-
-# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
-hs_err_pid*
-
+# ---> Java
+*.class
+
+# Mobile Tools for Java (J2ME)
+.mtj.tmp/
+
+# Package Files #
+*.jar
+*.war
+*.ear
+
+# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
+hs_err_pid*
+
+/target/
+.classpath
+.project
+.settings/

pom.xml

@@ -0,0 +1,108 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <groupId>io.shardingsphere</groupId>
+    <version>1.0.0</version>
+    <artifactId>data-mybatis-example</artifactId>
+    
+    <properties>
+        <java.version>1.8</java.version>
+        <maven.version.range>[3.0.4,)</maven.version.range>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <project.build.locale>zh_CN</project.build.locale>
+        
+        <sharding-sphere.version>3.0.0.M3</sharding-sphere.version>
+        
+        <spring-framework.version>4.3.6.RELEASE</spring-framework.version>
+        <spring-boot.version>1.5.0.RELEASE</spring-boot.version>
+        
+        <maven-compiler-plugin.version>3.3</maven-compiler-plugin.version>
+        <maven-resources-plugin.version>2.7</maven-resources-plugin.version>
+        <maven-jar-plugin.version>2.6</maven-jar-plugin.version>
+        <maven-source-plugin.version>2.4</maven-source-plugin.version>
+        <javadocExecutable>${java.home}/../bin/javadoc</javadocExecutable>
+    </properties>
+    
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter</artifactId>
+            <version>1.5.0.RELEASE</version>
+        </dependency>
+        <dependency>
+            <groupId>org.mybatis.spring.boot</groupId>
+            <artifactId>mybatis-spring-boot-starter</artifactId>
+            <version>1.3.0</version>
+        </dependency> 
+        <dependency>
+            <groupId>io.shardingsphere</groupId>
+            <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
+            <version>3.0.0.M3</version>
+        </dependency>
+        <dependency>
+            <groupId>commons-pool</groupId>
+            <artifactId>commons-pool</artifactId>
+            <version>1.6</version>
+        </dependency>
+        
+        <dependency>
+            <groupId>commons-dbcp</groupId>
+            <artifactId>commons-dbcp</artifactId>
+            <version>1.4</version>
+        </dependency>
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <version>5.1.30</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>jcl-over-slf4j</artifactId>
+            <version>1.7.7</version>
+        </dependency>
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+            <version>1.1.6</version>
+        </dependency>
+    </dependencies>
+    
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>${java.version}</source>
+                    <target>${java.version}</target>
+                    <testSource>${java.version}</testSource>
+                    <testTarget>${java.version}</testTarget>
+                </configuration>
+                <version>${maven-compiler-plugin.version}</version>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-resources-plugin</artifactId>
+                <version>${maven-resources-plugin.version}</version>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-jar-plugin</artifactId>
+                <version>${maven-jar-plugin.version}</version>
+            </plugin>
+            <plugin>
+            <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-source-plugin</artifactId>
+                <version>${maven-source-plugin.version}</version>
+                <executions>
+                    <execution>
+                        <id>attach-sources</id>
+                        <phase>verify</phase>
+                        <goals>
+                            <goal>jar-no-fork</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+</project>

src/main/java/com/huojutech/sharding/SpringBootDataMain.java

@@ -0,0 +1,34 @@
+/*
+ * Copyright 2016-2018 shardingsphere.io.
+ * <p>
+ * 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.
+ * </p>
+ */
+
+package com.huojutech.sharding;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.ConfigurableApplicationContext;
+
+import com.huojutech.sharding.service.DemoService;
+
+@SpringBootApplication
+public class SpringBootDataMain {
+    
+    public static void main(final String[] args) {
+        try (ConfigurableApplicationContext applicationContext = SpringApplication.run(SpringBootDataMain.class, args)) {
+            applicationContext.getBean(DemoService.class).demo();
+        }
+    }
+}

src/main/java/com/huojutech/sharding/algorithm/DatabaseShardingAlgorithm.java

@@ -0,0 +1,18 @@
+package com.huojutech.sharding.algorithm;
+
+import java.util.Collection;
+
+import io.shardingsphere.core.api.algorithm.sharding.ShardingValue;
+import io.shardingsphere.core.api.algorithm.sharding.complex.ComplexKeysShardingAlgorithm;
+
+public class DatabaseShardingAlgorithm implements ComplexKeysShardingAlgorithm {
+
+    @Override
+    public Collection<String> doSharding(Collection<String> availableTargetNames, Collection<ShardingValue> shardingValues) {
+        
+        return availableTargetNames;
+    }
+
+    
+
+}

src/main/java/com/huojutech/sharding/algorithm/IDGenerator.java

@@ -0,0 +1,61 @@
+package com.huojutech.sharding.algorithm;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.util.Random;
+
+import io.shardingsphere.core.keygen.DefaultKeyGenerator;
+import io.shardingsphere.core.keygen.KeyGenerator;
+
+public class IDGenerator implements KeyGenerator{
+    
+    public static long ipToLong(String strIp) {
+        String[]ip = strIp.split("\\.");
+        return (Long.parseLong(ip[0]) << 24) + (Long.parseLong(ip[1]) << 16) + (Long.parseLong(ip[2]) << 8) + Long.parseLong(ip[3]);
+    }
+
+    private static long seed = 0;
+
+    public static void main(String[] args) {
+
+        for (int i = 0; i < 202; i++) {
+            System.out.println(new IDGenerator().generateKey());
+        }
+        System.out.println((1&0x0001));
+        System.out.println((2&0x0001));
+        System.out.println((3&0x0001));
+        System.out.println((4&0x0001));
+    }
+    
+    /**
+     * 根据机器IP获取工作进程Id,如果线上机器的IP二进制表示的最后10位不重复,建议使用此种方式
+     * ,列如机器的IP为192.168.1.108,二进制表示:11000000 10101000 00000001 01101100
+     * ,截取最后10位 01 01101100,转为十进制364,设置workerId为364.
+     */
+    static {
+        InetAddress address;
+        try {
+            // 首先得到IP地址，例如192.168.1.108
+            address = InetAddress.getLocalHost();
+            seed = ipToLong(address.getHostAddress());
+        } catch (final UnknownHostException e) {
+            throw new IllegalStateException("Cannot get LocalHost InetAddress, please check your network!");
+        }
+        // IP地址byte[]数组形式，这个byte数组的长度是4，数组0~3下标对应的值分别是192，168，1，108
+        byte[] ipAddressByteArray = address.getAddress();
+        // 由这里计算workerId源码可知，workId由两部分组成：
+        // 第一部分(ipAddressByteArray[ipAddressByteArray.length - 2] & 0B11) << Byte.SIZE：ipAddressByteArray[ipAddressByteArray.length - 2]即取byte[]倒数第二个值，即1，然后&0B11，即只取最后2位（IP段倒数第二个段取2位，IP段最后一位取全部8位，总计10位），然后左移Byte.SIZE，即左移8位（因为这一部分取得的是IP段中倒数第二个段的值）；
+        // 第二部分(ipAddressByteArray[ipAddressByteArray.length - 1] & 0xFF)：ipAddressByteArray[ipAddressByteArray.length - 1]即取byte[]最后一位，即108，然后&0xFF，即通过位运算将byte转为int；
+        // 最后将第一部分得到的值加上第二部分得到的值就是最终的workId
+        DefaultKeyGenerator.setWorkerId((long) (((ipAddressByteArray[ipAddressByteArray.length - 2] & 0B11) << Byte.SIZE) + (ipAddressByteArray[ipAddressByteArray.length - 1] & 0xFF)));
+    }
+
+    /**
+     * 并发高了在换成默认的算法
+     */
+    @Override
+    public Number generateKey() {
+        return System.nanoTime() + new Random(seed + System.nanoTime()).nextInt(10) * 10 + new Random().nextInt(10) + System.currentTimeMillis() * 100;
+    }
+    
+}

src/main/java/com/huojutech/sharding/algorithm/MyPreciseShardingAlgorithm.java

@@ -0,0 +1,65 @@
+package com.huojutech.sharding.algorithm;
+
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.Calendar;
+import java.util.Collection;
+import java.util.Iterator;
+import java.util.List;
+
+import groovy.util.logging.Slf4j;
+import io.shardingsphere.core.api.algorithm.sharding.ListShardingValue;
+import io.shardingsphere.core.api.algorithm.sharding.ShardingValue;
+import io.shardingsphere.core.api.algorithm.sharding.complex.ComplexKeysShardingAlgorithm;
+
+@Slf4j
+public class MyPreciseShardingAlgorithm implements ComplexKeysShardingAlgorithm {
+    
+    @Override
+    public Collection<String> doSharding(Collection<String> availableTargetNames,
+            Collection<ShardingValue> shardingValues) {
+        
+        Collection<Object> orderCodeValues = getShardingValue(shardingValues, "order_code");
+        Collection<Object> dateValues = getShardingValue(shardingValues, "gmt_create");
+        List<String> shardingSuffix = new ArrayList<>();
+        
+        /**例如：根据user_id + order_id 双分片键来进行分表*/
+        //Set<List<Integer>> valueResult = Sets.cartesianProduct(userIdValues, orderIdValues);
+        for (Object orderCode : orderCodeValues) {
+            long code = Long.parseLong(((String)orderCode).substring(16, 20));
+            
+            for (Object date : dateValues) {                
+                Timestamp timestamp = (Timestamp)date;
+                Calendar calendar = Calendar.getInstance();
+                calendar.setTimeInMillis(timestamp.getTime());
+                int year = calendar.get(Calendar.YEAR);
+                String suffix = year + "_" + (code&0x001);
+                
+                availableTargetNames.forEach(x -> {
+                    if (x.endsWith(suffix)) {
+                        shardingSuffix.add(x);
+                    }
+                });
+            }
+        }
+                
+        return shardingSuffix;
+    }
+
+    private Collection<Object> getShardingValue(Collection<ShardingValue> shardingValues, final String key) {
+        Collection<Object> valueSet = new ArrayList<>();
+        Iterator<ShardingValue> iterator = shardingValues.iterator();
+        while (iterator.hasNext()) {
+            ShardingValue next = iterator.next();
+            if (next instanceof ListShardingValue) {
+                ListShardingValue value = (ListShardingValue) next;
+                /**例如：根据user_id + order_id 双分片键来进行分表*/
+                if (value.getColumnName().equals(key)) {
+                    return value.getValues();
+                }
+            }
+        }
+        return valueSet;
+    }
+
+}

src/main/java/com/huojutech/sharding/entity/Order.java

@@ -0,0 +1,78 @@
+/*
+ * Copyright 2016-2018 shardingsphere.io.
+ * <p>
+ * 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.
+ * </p>
+ */
+
+package com.huojutech.sharding.entity;
+
+import java.util.Date;
+
+public final class Order {
+    
+    private long orderId;
+    
+    private String orderCode;
+    
+    private int userId;
+    
+    private String status;
+    
+    private Date gmtCreate;
+    
+    public long getOrderId() {
+        return orderId;
+    }
+    
+    public void setOrderId(final long orderId) {
+        this.orderId = orderId;
+    }
+    
+    public int getUserId() {
+        return userId;
+    }
+    
+    public void setUserId(final int userId) {
+        this.userId = userId;
+    }
+    
+    public String getStatus() {
+        return status;
+    }
+    
+    public void setStatus(final String status) {
+        this.status = status;
+    }
+    
+    @Override
+    public String toString() {
+        return String.format("order_id: %s, user_id: %s, status: %s", orderId, userId, status);
+    }
+
+    public String getOrderCode() {
+        return orderCode;
+    }
+
+    public void setOrderCode(String orderCode) {
+        this.orderCode = orderCode;
+    }
+
+    public Date getGmtCreate() {
+        return gmtCreate;
+    }
+
+    public void setGmtCreate(Date gmtCreate) {
+        this.gmtCreate = gmtCreate;
+    }
+}

src/main/java/com/huojutech/sharding/entity/OrderItem.java

@@ -0,0 +1,66 @@
+/*
+ * Copyright 2016-2018 shardingsphere.io.
+ * <p>
+ * 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.
+ * </p>
+ */
+
+package com.huojutech.sharding.entity;
+
+public final class OrderItem {
+    
+    private long orderItemId;
+    
+    private long orderId;
+    
+    private int userId;
+    
+    private String status;
+    
+    public long getOrderItemId() {
+        return orderItemId;
+    }
+    
+    public void setOrderItemId(final long orderItemId) {
+        this.orderItemId = orderItemId;
+    }
+    
+    public long getOrderId() {
+        return orderId;
+    }
+    
+    public void setOrderId(final long orderId) {
+        this.orderId = orderId;
+    }
+    
+    public int getUserId() {
+        return userId;
+    }
+    
+    public void setUserId(final int userId) {
+        this.userId = userId;
+    }
+    
+    public String getStatus() {
+        return status;
+    }
+    
+    public void setStatus(final String status) {
+        this.status = status;
+    }
+    
+    @Override
+    public String toString() {
+        return String.format("item_id:%s, order_id: %s, user_id: %s, status: %s", orderItemId, orderId, userId, status);
+    }
+}

src/main/java/com/huojutech/sharding/repository/OrderItemRepository.java

@@ -0,0 +1,40 @@
+/*
+ * Copyright 2016-2018 shardingsphere.io.
+ * <p>
+ * 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.
+ * </p>
+ */
+
+package com.huojutech.sharding.repository;
+
+import org.apache.ibatis.annotations.Mapper;
+
+import com.huojutech.sharding.entity.OrderItem;
+
+import java.util.List;
+
+@Mapper
+public interface OrderItemRepository {
+    
+    void createIfNotExistsTable();
+    
+    void truncateTable();
+    
+    Long insert(OrderItem model);
+    
+    void delete(Long orderItemId);
+    
+    List<OrderItem> selectAll();
+    
+    void dropTable();
+}

src/main/java/com/huojutech/sharding/repository/OrderRepository.java

@@ -0,0 +1,36 @@
+/*
+ * Copyright 2016-2018 shardingsphere.io.
+ * <p>
+ * 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.
+ * </p>
+ */
+
+package com.huojutech.sharding.repository;
+
+import org.apache.ibatis.annotations.Mapper;
+
+import com.huojutech.sharding.entity.Order;
+
+@Mapper
+public interface OrderRepository {
+    
+    void createIfNotExistsTable();
+    
+    void truncateTable();
+    
+    Long insert(Order model);
+    
+    void delete(Long orderId);
+    
+    void dropTable();
+}

src/main/java/com/huojutech/sharding/service/DemoService.java

@@ -0,0 +1,77 @@
+/*
+ * Copyright 2016-2018 shardingsphere.io.
+ * <p>
+ * 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.
+ * </p>
+ */
+
+package com.huojutech.sharding.service;
+
+import org.springframework.stereotype.Service;
+
+import com.huojutech.sharding.algorithm.IDGenerator;
+import com.huojutech.sharding.entity.Order;
+import com.huojutech.sharding.entity.OrderItem;
+import com.huojutech.sharding.repository.OrderItemRepository;
+import com.huojutech.sharding.repository.OrderRepository;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+@Service
+public class DemoService {
+    
+    @Resource
+    private OrderRepository orderRepository;
+    
+    @Resource
+    private OrderItemRepository orderItemRepository;
+    
+    public void demo() {
+        orderRepository.createIfNotExistsTable();
+        orderItemRepository.createIfNotExistsTable();
+        orderRepository.truncateTable();
+        orderItemRepository.truncateTable();
+        List<Long> orderIds = new ArrayList<>(10);
+        IDGenerator idGenerator = new IDGenerator();
+        
+        System.out.println("1.Insert--------------");
+        for (int i = 0; i < 10; i++) {
+            Order order = new Order();
+            order.setUserId(i);
+            order.setGmtCreate(new Date());
+            order.setOrderCode("20180" + idGenerator.generateKey().toString());
+            
+            order.setStatus("INSERT_TEST");
+            orderRepository.insert(order);
+            long orderId = order.getOrderId();
+            orderIds.add(orderId);
+            
+//            OrderItem item = new OrderItem();
+//            item.setOrderId(orderId);
+//            item.setUserId(i);
+//            orderItemRepository.insert(item);
+        }
+        System.out.println(orderItemRepository.selectAll());
+        System.out.println("2.Delete--------------");
+//        for (Long each : orderIds) {
+//            orderRepository.delete(each);
+//            orderItemRepository.delete(each);
+//        }
+//        System.out.println(orderItemRepository.selectAll());
+//        orderItemRepository.dropTable();
+//        orderRepository.dropTable();
+    }
+}

src/main/resources/META-INF/mappers/OrderItemMapper.xml

@@ -0,0 +1,48 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="io.shardingsphere.example.spring.boot.mybatis.repository.OrderItemRepository">
+    <resultMap id="baseResultMap" type="io.shardingsphere.example.spring.boot.mybatis.entity.OrderItem">
+        <result column="order_item_id" property="orderItemId" jdbcType="INTEGER" />
+        <result column="order_id" property="orderId" jdbcType="INTEGER" />
+        <result column="user_id" property="userId" jdbcType="INTEGER" />
+    </resultMap>
+    
+    <update id="createIfNotExistsTable">
+        CREATE TABLE IF NOT EXISTS t_order_item 
+        (order_item_id BIGINT AUTO_INCREMENT, order_id BIGINT, user_id INT NOT NULL, 
+        `order_code` varchar(50) NOT NULL,
+        `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
+        PRIMARY KEY (order_item_id));
+    </update>
+    
+    <update id="truncateTable">
+        TRUNCATE TABLE t_order_item;
+    </update>
+    
+    <update id="dropTable">
+        DROP TABLE IF EXISTS t_order_item;
+    </update>
+    
+    <insert id="insert" useGeneratedKeys="true" keyProperty="orderItemId">
+        INSERT INTO t_order_item (
+          order_id, user_id
+        )
+        VALUES (
+        #{orderId,jdbcType=INTEGER},
+        #{userId,jdbcType=INTEGER}
+        )
+    </insert>
+    
+    <delete id="delete">
+        DELETE FROM t_order_item WHERE order_id = #{orderId,jdbcType=INTEGER}
+    </delete>
+    
+    <select id="selectAll" resultMap="baseResultMap">
+        SELECT
+        i.*
+        FROM
+        t_order o, t_order_item i
+        WHERE
+        o.order_id = i.order_id
+    </select>
+</mapper>

src/main/resources/META-INF/mappers/OrderMapper.xml

@@ -0,0 +1,35 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="io.shardingsphere.example.spring.boot.mybatis.repository.OrderRepository">
+    <update id="createIfNotExistsTable">
+        CREATE TABLE IF NOT EXISTS t_order 
+        (order_id BIGINT AUTO_INCREMENT, user_id INT NOT NULL, status VARCHAR(50),
+        `order_code` varchar(50) NOT NULL,
+        `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
+         PRIMARY KEY (order_id));
+    </update>
+    
+    <update id="truncateTable">
+        TRUNCATE TABLE t_order;
+    </update>
+    
+    <update id="dropTable">
+        DROP TABLE IF EXISTS t_order;
+    </update>
+    
+    <insert id="insert" useGeneratedKeys="true" keyProperty="orderId">
+        INSERT INTO t_order (
+          user_id, status,order_code,gmt_create
+        )
+        VALUES (
+        #{userId,jdbcType=INTEGER},
+        #{status,jdbcType=VARCHAR},
+        #{orderCode},
+        #{gmtCreate}
+        )
+    </insert>
+    
+    <delete id="delete">
+        DELETE FROM t_order WHERE order_id = #{orderId,jdbcType=INTEGER}
+    </delete>
+</mapper>

src/main/resources/META-INF/mybatis-config.xml

@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE configuration
+        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-config.dtd">
+<configuration>
+    <!--<settings>-->
+        <!--<setting name="logImpl" value="STDOUT_LOGGING" />-->
+    <!--</settings>-->
+    <typeAliases>
+        <package name="io.shardingsphere.example.spring.boot.mybatis.entity"/>
+    </typeAliases>
+    <mappers>
+        <mapper resource="META-INF/mappers/OrderMapper.xml"/>
+        <mapper resource="META-INF/mappers/OrderItemMapper.xml"/>
+    </mappers>
+</configuration>

src/main/resources/application-sharding.properties

@@ -0,0 +1,35 @@
+sharding.jdbc.datasource.names=ds_0
+
+sharding.jdbc.datasource.ds_0.type=org.apache.commons.dbcp.BasicDataSource
+sharding.jdbc.datasource.ds_0.driver-class-name=com.mysql.jdbc.Driver
+sharding.jdbc.datasource.ds_0.url=jdbc:mysql://localhost:3306/demo_ds_0
+sharding.jdbc.datasource.ds_0.username=root
+sharding.jdbc.datasource.ds_0.password=123456
+
+#sharding.jdbc.config.sharding.default-data-source-name= ds_0
+#sharding.jdbc.config.sharding.default-database-strategy.standard.sharding-column=order_code
+#sharding.jdbc.config.sharding.default-database-strategy.standard.algorithm-class-name=io.shardingsphere.example.spring.boot.mybatis.algorithm.DatabaseShardingAlgorithm
+#sharding.jdbc.config.sharding.default-key-generator-class-name= io.shardingsphere.example.spring.boot.mybatis.service.IDGenerator
+
+sharding.jdbc.config.sharding.tables.t_order.database-strategy.complex.sharding-columns=order_code,gmt_create
+sharding.jdbc.config.sharding.tables.t_order.database-strategy.complex.algorithm-class-name=io.shardingsphere.example.spring.boot.mybatis.algorithm.DatabaseShardingAlgorithm
+sharding.jdbc.config.sharding.tables.t_order.actual-data-nodes=ds_0.t_order_$->{2018..2019}_$->{0..1}
+sharding.jdbc.config.sharding.tables.t_order.table-strategy.complex.sharding-columns=order_code,gmt_create
+sharding.jdbc.config.sharding.tables.t_order.key-generator-column-name=order_id
+sharding.jdbc.config.sharding.tables.t_order.table-strategy.complex.algorithm-class-name=io.shardingsphere.example.spring.boot.mybatis.algorithm.MyPreciseShardingAlgorithm
+
+#sharding.jdbc.config.sharding.tables.t_order_item.actual-data-nodes=ds_$->{0..1}.t_order_item_$->{0..1}
+#sharding.jdbc.config.sharding.tables.t_order_item.table-strategy.inline.sharding-column=order_id
+#sharding.jdbc.config.sharding.tables.t_order_item.table-strategy.inline.algorithm-expression=t_order_item_$->{order_id % 2}
+#sharding.jdbc.config.sharding.tables.t_order_item.key-generator-column-name=order_item_id
+
+sharding.jdbc.config.sharding.tables.t_order_item.database-strategy.complex.sharding-columns=order_code,gmt_create
+sharding.jdbc.config.sharding.tables.t_order_item.database-strategy.complex.algorithm-class-name=io.shardingsphere.example.spring.boot.mybatis.algorithm.DatabaseShardingAlgorithm
+sharding.jdbc.config.sharding.tables.t_order_item.actual-data-nodes=ds_0.t_order_item_$->{2018..2019}_$->{0..1}
+sharding.jdbc.config.sharding.tables.t_order_item.table-strategy.complex.sharding-columns=order_code,gmt_create
+sharding.jdbc.config.sharding.tables.t_order_item.key-generator-column-name=order_item_id
+sharding.jdbc.config.sharding.tables.t_order_item.table-strategy.complex.algorithm-class-name=io.shardingsphere.example.spring.boot.mybatis.algorithm.MyPreciseShardingAlgorithm
+
+sharding.jdbc.config.sharding.binding-tables[0]= t_order,t_order_item
+
+sharding.jdbc.config.sharding.props.sql.show= true

src/main/resources/application.properties

@@ -0,0 +1,32 @@
+spring.jpa.properties.hibernate.hbm2ddl.auto=create
+spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL5Dialect
+spring.jpa.properties.hibernate.show_sql=true
+mybatis.config-location=classpath:META-INF/mybatis-config.xml
+
+spring.profiles.active=sharding
+#spring.profiles.active=sharding-db
+#spring.profiles.active=sharding-tbl
+#spring.profiles.active=masterslave
+#spring.profiles.active=sharding-masterslave
+
+#spring.profiles.active=etcd-sharding-local
+#spring.profiles.active=etcd-sharding-cloud
+#spring.profiles.active=etcd-sharding-db-local
+#spring.profiles.active=etcd-sharding-db-cloud
+#spring.profiles.active=etcd-sharding-tbl-local
+#spring.profiles.active=etcd-sharding-tbl-cloud
+#spring.profiles.active=etcd-masterslave-local
+#spring.profiles.active=etcd-masterslave-cloud
+#spring.profiles.active=etcd-sharding-masterslave-local
+#spring.profiles.active=etcd-sharding-masterslave-cloud
+
+#spring.profiles.active=zookeeper-sharding-local
+#spring.profiles.active=zookeeper-sharding-cloud
+#spring.profiles.active=zookeeper-sharding-db-local
+#spring.profiles.active=zookeeper-sharding-db-cloud
+#spring.profiles.active=zookeeper-sharding-tbl-local
+#spring.profiles.active=zookeeper-sharding-tbl-cloud
+#spring.profiles.active=zookeeper-masterslave-local
+#spring.profiles.active=zookeeper-masterslave-cloud
+#spring.profiles.active=zookeeper-sharding-masterslave-local
+#spring.profiles.active=zookeeper-sharding-masterslave-cloud

src/main/resources/logback.xml

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration>
+    <property name="log.context.name" value="sharding-jdbc-spring-namespace-mybatis-example" />
+    <property name="log.charset" value="UTF-8" />
+    <property name="log.pattern" value="[%-5level] %date --%thread-- [%logger] %msg %n" />
+    <contextName>${log.context.name}</contextName>
+    
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder charset="${log.charset}">
+            <pattern>${log.pattern}</pattern>
+        </encoder>
+    </appender>
+    <root>
+        <level value="INFO" />
+        <appender-ref ref="STDOUT" />
+    </root>
+</configuration>

src/main/resources/manual_schema.sql

@@ -0,0 +1,50 @@
+DROP SCHEMA IF EXISTS demo_ds_0;
+DROP SCHEMA IF EXISTS demo_ds_1;
+DROP SCHEMA IF EXISTS demo_ds_master_0;
+DROP SCHEMA IF EXISTS demo_ds_master_0_slave_0;
+DROP SCHEMA IF EXISTS demo_ds_master_0_slave_1;
+DROP SCHEMA IF EXISTS demo_ds_master_1;
+DROP SCHEMA IF EXISTS demo_ds_master_1_slave_0;
+DROP SCHEMA IF EXISTS demo_ds_master_1_slave_1;
+
+DROP SCHEMA IF EXISTS demo_ds;
+DROP SCHEMA IF EXISTS demo_ds_master;
+DROP SCHEMA IF EXISTS demo_ds_slave_0;
+DROP SCHEMA IF EXISTS demo_ds_slave_1;
+
+CREATE SCHEMA IF NOT EXISTS demo_ds_0;
+CREATE SCHEMA IF NOT EXISTS demo_ds_1;
+CREATE SCHEMA IF NOT EXISTS demo_ds_master_0;
+CREATE SCHEMA IF NOT EXISTS demo_ds_master_0_slave_0;
+CREATE SCHEMA IF NOT EXISTS demo_ds_master_0_slave_1;
+CREATE SCHEMA IF NOT EXISTS demo_ds_master_1;
+CREATE SCHEMA IF NOT EXISTS demo_ds_master_1_slave_0;
+CREATE SCHEMA IF NOT EXISTS demo_ds_master_1_slave_1;
+
+CREATE SCHEMA IF NOT EXISTS demo_ds;
+CREATE SCHEMA IF NOT EXISTS demo_ds_master;
+CREATE SCHEMA IF NOT EXISTS demo_ds_slave_0;
+CREATE SCHEMA IF NOT EXISTS demo_ds_slave_1;
+
+-- Should sync from master-salve automatically
+-- CREATE TABLE IF NOT EXISTS demo_ds_slave_0.t_order (order_id BIGINT NOT NULL AUTO_INCREMENT, user_id INT NOT NULL, status VARCHAR(50), PRIMARY KEY (order_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_slave_1.t_order (order_id BIGINT NOT NULL AUTO_INCREMENT, user_id INT NOT NULL, status VARCHAR(50), PRIMARY KEY (order_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_slave_0.t_order_item (order_item_id BIGINT NOT NULL AUTO_INCREMENT, order_id BIGINT NOT NULL, user_id INT NOT NULL, PRIMARY KEY (order_item_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_slave_1.t_order_item (order_item_id BIGINT NOT NULL AUTO_INCREMENT, order_id BIGINT NOT NULL, user_id INT NOT NULL, PRIMARY KEY (order_item_id));
+
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_0_slave_0.t_order_0 (order_id BIGINT NOT NULL AUTO_INCREMENT, user_id INT NOT NULL, status VARCHAR(50), PRIMARY KEY (order_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_0_slave_0.t_order_1 (order_id BIGINT NOT NULL AUTO_INCREMENT, user_id INT NOT NULL, status VARCHAR(50), PRIMARY KEY (order_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_0_slave_1.t_order_0 (order_id BIGINT NOT NULL AUTO_INCREMENT, user_id INT NOT NULL, status VARCHAR(50), PRIMARY KEY (order_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_0_slave_1.t_order_1 (order_id BIGINT NOT NULL AUTO_INCREMENT, user_id INT NOT NULL, status VARCHAR(50), PRIMARY KEY (order_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_1_slave_0.t_order_0 (order_id BIGINT NOT NULL AUTO_INCREMENT, user_id INT NOT NULL, status VARCHAR(50), PRIMARY KEY (order_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_1_slave_0.t_order_1 (order_id BIGINT NOT NULL AUTO_INCREMENT, user_id INT NOT NULL, status VARCHAR(50), PRIMARY KEY (order_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_1_slave_1.t_order_0 (order_id BIGINT NOT NULL AUTO_INCREMENT, user_id INT NOT NULL, status VARCHAR(50), PRIMARY KEY (order_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_1_slave_1.t_order_1 (order_id BIGINT NOT NULL AUTO_INCREMENT, user_id INT NOT NULL, status VARCHAR(50), PRIMARY KEY (order_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_0_slave_0.t_order_item_0 (order_item_id BIGINT NOT NULL AUTO_INCREMENT, order_id BIGINT NOT NULL, user_id INT NOT NULL, PRIMARY KEY (order_item_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_0_slave_0.t_order_item_1 (order_item_id BIGINT NOT NULL AUTO_INCREMENT, order_id BIGINT NOT NULL, user_id INT NOT NULL, PRIMARY KEY (order_item_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_0_slave_1.t_order_item_0 (order_item_id BIGINT NOT NULL AUTO_INCREMENT, order_id BIGINT NOT NULL, user_id INT NOT NULL, PRIMARY KEY (order_item_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_0_slave_1.t_order_item_1 (order_item_id BIGINT NOT NULL AUTO_INCREMENT, order_id BIGINT NOT NULL, user_id INT NOT NULL, PRIMARY KEY (order_item_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_1_slave_0.t_order_item_0 (order_item_id BIGINT NOT NULL AUTO_INCREMENT, order_id BIGINT NOT NULL, user_id INT NOT NULL, PRIMARY KEY (order_item_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_1_slave_0.t_order_item_1 (order_item_id BIGINT NOT NULL AUTO_INCREMENT, order_id BIGINT NOT NULL, user_id INT NOT NULL, PRIMARY KEY (order_item_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_1_slave_1.t_order_item_0 (order_item_id BIGINT NOT NULL AUTO_INCREMENT, order_id BIGINT NOT NULL, user_id INT NOT NULL, PRIMARY KEY (order_item_id));
+-- CREATE TABLE IF NOT EXISTS demo_ds_master_1_slave_1.t_order_item_1 (order_item_id BIGINT NOT NULL AUTO_INCREMENT, order_id BIGINT NOT NULL, user_id INT NOT NULL, PRIMARY KEY (order_item_id));