shardingsphere 默认分片策略

Author: chengxy-nds

pom.xml

@@ -14,7 +14,9 @@
     <packaging>pom</packaging>
 
     <modules>
+        <!-- springboot2.0实战 -->
         <module>springboot101</module>
+        <!-- shardingsphere5.x实战 -->
         <module>shardingsphere101</module>
     </modules>
 
@@ -67,12 +69,6 @@
             <version>1.2.83</version>
         </dependency>
 
-        <!-- thymeleaf 页面模版 -->
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-thymeleaf</artifactId>
-        </dependency>
-
     </dependencies>
 
     <build>

shardingsphere101/README.md

@@ -1,3 +1,5 @@
-快速实现分库分表的两种方式
+本项目的主要内容：
 
-文件链接：[SpringBoot 2 种方式快速实现分库分表，轻松拿捏！](https://mp.weixin.qq.com/s/XdlJK170YZEwof6DzZlbZg)
+1、默认的分库分表策略
+2、广播表
+3、绑定表的使用

shardingsphere101/pom.xml

@@ -17,18 +17,21 @@
     <properties>
         <java.version>8</java.version>
         <shardingsphere.version>5.2.0</shardingsphere.version>
+        <mybatis.plus.version>3.5.3.1</mybatis.plus.version>
     </properties>
 
     <modules>
         <module>shardingsphere-2fastcode</module>
-        <module>shardingsphere-default</module>
+        <module>shardingsphere-default-strategy</module>
     </modules>
 
     <dependencies>
 
+        <!-- MyBatis Plus -->
         <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-data-jpa</artifactId>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+            <version>${mybatis.plus.version}</version>
         </dependency>
 
         <!-- 必须引入的包 mysql -->

shardingsphere101/shardingsphere-2fastcode/pom.xml

@@ -12,8 +12,10 @@
     <name>shardingsphere-2fastcode</name>
 
     <dependencies>
-
-
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-jpa</artifactId>
+        </dependency>
     </dependencies>
 
     <build>

shardingsphere101/shardingsphere-2fastcode/src/main/java/com/shardingsphere_101/conf/ShardingConfiguration.java

@@ -32,8 +32,8 @@ public DataSource getShardingDataSource() throws SQLException {
         // 分片rules规则配置
         ShardingRuleConfiguration shardingRuleConfig = new ShardingRuleConfiguration();
 
+        shardingRuleConfig.setBroadcastTables(Collections.singletonList("t_city_dict"));
         shardingRuleConfig.setShardingAlgorithms(getShardingAlgorithms());
-
         // 配置 t_order 表分片规则
         ShardingTableRuleConfiguration orderTableRuleConfig = new ShardingTableRuleConfiguration("t_order", "db${0..1}.t_order_${0..2}");
         orderTableRuleConfig.setTableShardingStrategy(new StandardShardingStrategyConfiguration("order_id", "table-inline"));

shardingsphere101/shardingsphere-default-strategy/README.md

@@ -0,0 +1 @@
+

shardingsphere101/shardingsphere-default/pom.xml renamed to shardingsphere101/shardingsphere-default-strategy/pom.xml

@@ -7,9 +7,9 @@
         <artifactId>shardingsphere101</artifactId>
         <version>0.0.1-SNAPSHOT</version>
     </parent>
-    <artifactId>shardingsphere-default</artifactId>
+    <artifactId>shardingsphere-default-strategy</artifactId>
     <version>0.0.1-SNAPSHOT</version>
-    <name>shardingsphere-default</name>
+    <name>shardingsphere-default-strategy</name>
 
     <dependencies>
 

shardingsphere101/shardingsphere-default-strategy/sql/CreateTable.sql

@@ -0,0 +1,66 @@
+CREATE TABLE t_city_dict (
+  id BIGINT, -- 城市ID
+  city_name VARCHAR(255) NOT NULL, -- 城市名称
+  province_name VARCHAR(255) NOT NULL, -- 省份名称
+  country_name VARCHAR(255) NOT NULL, -- 国家名称
+  population INT, -- 城市人口数量
+  area FLOAT, -- 城市面积
+  timezone VARCHAR(255), -- 所属时区
+  postal_code VARCHAR(10), -- 邮政编码
+  created_date datetime DEFAULT CURRENT_TIMESTAMP,
+  updated_date datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+  PRIMARY KEY (`id`)
+) ;
+
+
+CREATE TABLE t_order_0 (
+  order_id INT PRIMARY KEY,
+  order_number VARCHAR(20),
+  customer_id INT,
+  order_date DATE,
+  total_amount DECIMAL(10, 2)
+);
+
+
+CREATE TABLE t_order_1 (
+  order_id INT PRIMARY KEY,
+  order_number VARCHAR(20),
+  customer_id INT,
+  order_date DATE,
+  total_amount DECIMAL(10, 2)
+);
+
+CREATE TABLE t_order_2 (
+  order_id INT PRIMARY KEY,
+  order_number VARCHAR(20),
+  customer_id INT,
+  order_date DATE,
+  total_amount DECIMAL(10, 2)
+);
+
+-- 创建 t_order_item 表
+CREATE TABLE t_order_item_0 (
+  item_id INT PRIMARY KEY,
+  order_id INT,
+  product_id INT,
+  quantity INT,
+  unit_price DECIMAL(8, 2)
+);
+
+CREATE TABLE t_order_item_1 (
+  item_id INT PRIMARY KEY,
+  order_id INT,
+  product_id INT,
+  quantity INT,
+  unit_price DECIMAL(8, 2)
+);
+
+CREATE TABLE t_order_item_2 (
+  item_id INT PRIMARY KEY,
+  order_id INT,
+  product_id INT,
+  quantity INT,
+  unit_price DECIMAL(8, 2)
+);
+
+

shardingsphere101/shardingsphere-default/src/main/java/com/shardingsphere_101/Application.java renamed to shardingsphere101/shardingsphere-default-strategy/src/main/java/com/shardingsphere_101/StrategyApplication.java

@@ -4,10 +4,11 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
 @SpringBootApplication
-public class Application {
+public class
+StrategyApplication {
 
     public static void main(String[] args) {
-        SpringApplication.run(Application.class, args);
+        SpringApplication.run(StrategyApplication.class, args);
     }
 
 }

shardingsphere101/shardingsphere-default-strategy/src/main/java/com/shardingsphere_101/controller/OrderController.java

@@ -0,0 +1,48 @@
+package com.shardingsphere_101.controller;
+
+import com.shardingsphere_101.dao.OrderItemMapper;
+import com.shardingsphere_101.dao.OrderMapper;
+import com.shardingsphere_101.entity.Order;
+import com.shardingsphere_101.entity.OrderItem;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 公众号：程序员小富
+ *
+ * @author Jiahai
+ */
+@RestController
+@RequestMapping("/order")
+public class OrderController {
+
+    @Resource
+    private OrderMapper orderMapper;
+
+    @Resource
+    private OrderItemMapper orderItemMapper;
+
+
+    @RequestMapping("/test1")
+    public String test1() {
+        for (int i = 0; i < 3; i++) {
+            Order order = new Order();
+            order.setOrderNumber("WIN000" + i);
+            order.setCustomerId((long) i);
+            order.setOrderDate(new Date());
+            order.setTotalAmount(new BigDecimal("0" + i));
+            orderMapper.insert(order);
+            OrderItem orderItem = new OrderItem();
+            orderItem.setOrderId(order.getOrderId());
+            orderItem.setProductId(i);
+            orderItem.setQuantity(i);
+            orderItem.setUnitPrice(new BigDecimal("0" + i));
+            orderItemMapper.insert(orderItem);
+        }
+        return "ok";
+    }
+}