增加分库分表示例

elvinshang · Nov 11, 2019 · 00b9bb8 · 00b9bb8
1 parent 6e4f257
commit 00b9bb8
Show file tree

Hide file tree

Showing 22 changed files with 510 additions and 34 deletions.
diff --git a/...tasource-01/src/main/java/cn/iocoder/springboot/lab18/shardingdatasource/Application.java b/...tasource-01/src/main/java/cn/iocoder/springboot/lab18/shardingdatasource/Application.java
@@ -2,10 +2,8 @@
 
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.context.annotation.EnableAspectJAutoProxy;
 
 @SpringBootApplication
-@MapperScan(basePackages = "cn.iocoder.springboot.lab17.dynamicdatasource.mapper")
-@EnableAspectJAutoProxy(exposeProxy = true) // http://www.voidcn.com/article/p-zddcuyii-bpt.html
+@MapperScan(basePackages = "cn.iocoder.springboot.lab18.shardingdatasource.mapper")
 public class Application {
 }
diff --git a/...rc/main/java/cn/iocoder/springboot/lab18/shardingdatasource/dataobject/OrderConfigDO.java b/...rc/main/java/cn/iocoder/springboot/lab18/shardingdatasource/dataobject/OrderConfigDO.java
@@ -0,0 +1,37 @@
+package cn.iocoder.springboot.lab18.shardingdatasource.dataobject;
+
+/**
+ * 订单配置 DO
+ */
+public class OrderConfigDO {
+
+    /**
+     * 编号
+     */
+    private Integer id;
+    /**
+     * 支付超时时间
+     *
+     * 单位：分钟
+     */
+    private Integer payTimeout;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public OrderConfigDO setId(Integer id) {
+        this.id = id;
+        return this;
+    }
+
+    public Integer getPayTimeout() {
+        return payTimeout;
+    }
+
+    public OrderConfigDO setPayTimeout(Integer payTimeout) {
+        this.payTimeout = payTimeout;
+        return this;
+    }
+
+}
diff --git a/...e-01/src/main/java/cn/iocoder/springboot/lab18/shardingdatasource/dataobject/OrderDO.java b/...e-01/src/main/java/cn/iocoder/springboot/lab18/shardingdatasource/dataobject/OrderDO.java
@@ -8,17 +8,17 @@ public class OrderDO {
     /**
      * 订单编号
      */
-    private Integer id;
+    private Long id;
     /**
      * 用户编号
      */
     private Integer userId;
 
-    public Integer getId() {
+    public Long getId() {
         return id;
     }
 
-    public OrderDO setId(Integer id) {
+    public OrderDO setId(Long id) {
         this.id = id;
         return this;
     }

diff --git a/...rc/main/java/cn/iocoder/springboot/lab18/shardingdatasource/mapper/OrderConfigMapper.java b/...rc/main/java/cn/iocoder/springboot/lab18/shardingdatasource/mapper/OrderConfigMapper.java
@@ -0,0 +1,12 @@
+package cn.iocoder.springboot.lab18.shardingdatasource.mapper;
+
+import cn.iocoder.springboot.lab18.shardingdatasource.dataobject.OrderConfigDO;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface OrderConfigMapper {
+
+    OrderConfigDO selectById(@Param("id") Integer id);
+
+}
diff --git a/...e-01/src/main/java/cn/iocoder/springboot/lab18/shardingdatasource/mapper/OrderMapper.java b/...e-01/src/main/java/cn/iocoder/springboot/lab18/shardingdatasource/mapper/OrderMapper.java
@@ -4,9 +4,15 @@
 import org.apache.ibatis.annotations.Param;
 import org.springframework.stereotype.Repository;
 
+import java.util.List;
+
 @Repository
 public interface OrderMapper {
 
     OrderDO selectById(@Param("id") Integer id);
 
+    List<OrderDO> selectListByUserId(@Param("userId") Integer userId);
+
+    void insert(OrderDO order);
+
 }
diff --git a/lab-18/lab-18-sharding-datasource-01/src/main/resources/application.yaml b/lab-18/lab-18-sharding-datasource-01/src/main/resources/application.yaml
@@ -3,39 +3,47 @@ spring:
   shardingsphere:
     datasource:
       # 所有数据源的名字
-      names: ds-orders-00, ds-orders-01
+      names: ds-orders-0, ds-orders-1
       # 订单 orders 数据源配置 00
-      ds-orders-00:
+      ds-orders-0:
         type: com.zaxxer.hikari.HikariDataSource # 使用 Hikari 数据库连接池
         driver-class-name: com.mysql.jdbc.Driver
-        jdbc-url: jdbc:mysql://127.0.0.1:3306/test_orders?useSSL=false&useUnicode=true&characterEncoding=UTF-8
+        jdbc-url: jdbc:mysql://127.0.0.1:3306/lab18_orders_0?useSSL=false&useUnicode=true&characterEncoding=UTF-8
         username: root
         password:
       # 订单 orders 数据源配置 01
-      ds-orders-01:
+      ds-orders-1:
         type: com.zaxxer.hikari.HikariDataSource # 使用 Hikari 数据库连接池
         driver-class-name: com.mysql.jdbc.Driver
-        jdbc-url: jdbc:mysql://47.112.193.81:3306/testb5f4?useSSL=false&useUnicode=true&characterEncoding=UTF-8
-        username: testb5f4
-        password: F4df4db0ed86@11
+        jdbc-url: jdbc:mysql://127.0.0.1:3306/lab18_orders_1?useSSL=false&useUnicode=true&characterEncoding=UTF-8
+        username: root
+        password:
     # 分片规则
     sharding:
       tables:
         # orders 表配置
         orders:
-          actualDataNodes: ds-$->{0..1}.orders_$->{0..7} # 映射到 ds-orders 数据源的 orders 表
+#          actualDataNodes: ds-orders-$->{0..1}.orders_$->{0..4} # 映射到 ds-orders 数据源的 orders 表
+#          actualDataNodes: ds-orders-0.orders_0, ds-orders-0.orders_2, ds-orders-0.orders_4, ds-orders-0.orders_6, ds-orders-1.orders_1, ds-orders-1.orders_3, ds-orders-1.orders_5, ds-orders-1.orders_7
+          actualDataNodes: ds-orders-0.orders_$->{[0,2,4,6]}, ds-orders-1.orders_$->{[1,3,5,7]} # 映射到 ds-orders-0 和 ds-orders-1 数据源的 orders 表们
           key-generator: # 主键生成策略
             column: id
             type: SNOWFLAKE
           database-strategy:
             inline:
-              algorithm-expression: orders_$->{user_id % 2}
+              algorithm-expression: ds-orders-$->{user_id % 2}
               sharding-column: user_id
           table-strategy:
             inline:
               algorithm-expression: orders_$->{user_id % 8}
               sharding-column: user_id
-
+        # order_config 表配置
+        order_config:
+          actualDataNodes: ds-orders-0.order_config # 仅映射到 ds-orders-0 数据源的 order_config 表
+    # 拓展属性配置
+    props:
+      sql:
+        show: true # 打印 SQL
 
 # mybatis 配置内容
 mybatis:

diff --git a/.../src/main/resources/mapper/UserMapper.xml → ...in/resources/mapper/OrderConfigMapper.xml b/.../src/main/resources/mapper/UserMapper.xml → ...in/resources/mapper/OrderConfigMapper.xml
@@ -1,15 +1,15 @@
 <?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="cn.iocoder.springboot.lab17.dynamicdatasource.mapper.UserMapper">
+<mapper namespace="cn.iocoder.springboot.lab18.shardingdatasource.mapper.OrderConfigMapper">
 
     <sql id="FIELDS">
-        id, username
+        id, pay_timeout
     </sql>
 
-    <select id="selectById" parameterType="Integer" resultType="UserDO">
+    <select id="selectById" parameterType="Integer" resultType="OrderConfigDO">
         SELECT
             <include refid="FIELDS" />
-        FROM users
+        FROM order_config
         WHERE id = #{id}
     </select>
 

diff --git a/lab-18/lab-18-sharding-datasource-01/src/main/resources/mapper/OrderMapper.xml b/lab-18/lab-18-sharding-datasource-01/src/main/resources/mapper/OrderMapper.xml
@@ -1,6 +1,6 @@
 <?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="cn.iocoder.springboot.lab17.dynamicdatasource.mapper.OrderMapper">
+<mapper namespace="cn.iocoder.springboot.lab18.shardingdatasource.mapper.OrderMapper">
 
     <sql id="FIELDS">
         id, user_id
@@ -13,4 +13,19 @@
         WHERE id = #{id}
     </select>
 
+    <select id="selectListByUserId" parameterType="Integer" resultType="OrderDO">
+        SELECT
+            <include refid="FIELDS" />
+        FROM orders
+        WHERE user_id = #{userId}
+    </select>
+
+    <insert id="insert" parameterType="OrderDO" useGeneratedKeys="true" keyProperty="id">
+        INSERT INTO orders (
+            user_id
+        ) VALUES (
+            #{userId}
+        )
+    </insert>
+
 </mapper>
diff --git a/lab-18/lab-18-sharding-datasource-01/src/main/resources/sql/db.sql b/lab-18/lab-18-sharding-datasource-01/src/main/resources/sql/db.sql
diff --git a/lab-18/lab-18-sharding-datasource-01/src/main/resources/sql/lab18_orders_0.sql b/lab-18/lab-18-sharding-datasource-01/src/main/resources/sql/lab18_orders_0.sql
@@ -0,0 +1,56 @@
+SET NAMES utf8mb4;
+SET FOREIGN_KEY_CHECKS = 0;
+
+-- ----------------------------
+-- Table structure for orders_0
+-- ----------------------------
+DROP TABLE IF EXISTS `orders_0`;
+CREATE TABLE `orders_0` (
+  `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号',
+  `user_id` int(16) DEFAULT NULL COMMENT '用户编号',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';
+
+-- ----------------------------
+-- Table structure for orders_2
+-- ----------------------------
+DROP TABLE IF EXISTS `orders_2`;
+CREATE TABLE `orders_2` (
+  `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号',
+  `user_id` int(16) DEFAULT NULL COMMENT '用户编号',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';
+
+-- ----------------------------
+-- Table structure for orders_4
+-- ----------------------------
+DROP TABLE IF EXISTS `orders_4`;
+CREATE TABLE `orders_4` (
+  `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号',
+  `user_id` int(16) DEFAULT NULL COMMENT '用户编号',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';
+
+-- ----------------------------
+-- Table structure for orders_6
+-- ----------------------------
+DROP TABLE IF EXISTS `orders_6`;
+CREATE TABLE `orders_6` (
+  `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号',
+  `user_id` int(16) DEFAULT NULL COMMENT '用户编号',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';
+
+
+-- ----------------------------
+-- Table structure for order_config
+-- ----------------------------
+DROP TABLE IF EXISTS `order_config`;
+CREATE TABLE `order_config` (
+  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '编号',
+  `pay_timeout` int(11) DEFAULT NULL COMMENT '支付超时时间;单位：分钟',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4;
+
+SET FOREIGN_KEY_CHECKS = 1;
+
diff --git a/lab-18/lab-18-sharding-datasource-01/src/main/resources/sql/lab18_orders_1.sql b/lab-18/lab-18-sharding-datasource-01/src/main/resources/sql/lab18_orders_1.sql
@@ -0,0 +1,44 @@
+SET NAMES utf8mb4;
+SET FOREIGN_KEY_CHECKS = 0;
+
+-- ----------------------------
+-- Table structure for orders_1
+-- ----------------------------
+DROP TABLE IF EXISTS `orders_1`;
+CREATE TABLE `orders_1` (
+  `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号',
+  `user_id` int(16) DEFAULT NULL COMMENT '用户编号',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB AUTO_INCREMENT=400675304294580226 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';
+
+-- ----------------------------
+-- Table structure for orders_3
+-- ----------------------------
+DROP TABLE IF EXISTS `orders_3`;
+CREATE TABLE `orders_3` (
+  `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号',
+  `user_id` int(16) DEFAULT NULL COMMENT '用户编号',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';
+
+-- ----------------------------
+-- Table structure for orders_5
+-- ----------------------------
+DROP TABLE IF EXISTS `orders_5`;
+CREATE TABLE `orders_5` (
+  `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号',
+  `user_id` int(16) DEFAULT NULL COMMENT '用户编号',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';
+
+-- ----------------------------
+-- Table structure for orders_7
+-- ----------------------------
+DROP TABLE IF EXISTS `orders_7`;
+CREATE TABLE `orders_7` (
+  `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT '订单编号',
+  `user_id` int(16) DEFAULT NULL COMMENT '用户编号',
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='订单表';
+
+SET FOREIGN_KEY_CHECKS = 1;
diff --git a/...est/java/cn/iocoder/springboot/lab18/shardingdatasource/mapper/OrderConfigMapperTest.java b/...est/java/cn/iocoder/springboot/lab18/shardingdatasource/mapper/OrderConfigMapperTest.java
@@ -0,0 +1,24 @@
+package cn.iocoder.springboot.lab18.shardingdatasource.mapper;
+
+import cn.iocoder.springboot.lab18.shardingdatasource.Application;
+import cn.iocoder.springboot.lab18.shardingdatasource.dataobject.OrderConfigDO;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = Application.class)
+public class OrderConfigMapperTest {
+
+    @Autowired
+    private OrderConfigMapper orderConfigMapper;
+
+    @Test
+    public void testSelectById() {
+        OrderConfigDO orderConfig = orderConfigMapper.selectById(1);
+        System.out.println(orderConfig);
+    }
+
+}
diff --git a/.../src/test/java/cn/iocoder/springboot/lab18/shardingdatasource/mapper/OrderMapperTest.java b/.../src/test/java/cn/iocoder/springboot/lab18/shardingdatasource/mapper/OrderMapperTest.java
@@ -8,6 +8,8 @@
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringRunner;
 
+import java.util.List;
+
 @RunWith(SpringRunner.class)
 @SpringBootTest(classes = Application.class)
 public class OrderMapperTest {
@@ -21,4 +23,17 @@ public void testSelectById() {
         System.out.println(order);
     }
 
+    @Test
+    public void testSelectListByUserId() {
+        List<OrderDO> orders = orderMapper.selectListByUserId(1);
+        System.out.println(orders.size());
+    }
+
+    @Test
+    public void testInsert() {
+        OrderDO order = new OrderDO();
+        order.setUserId(1);
+        orderMapper.insert(order);
+    }
+
 }