四种分片策略

chengxy-nds · chengxy-nds · commit 0e3fea077c3c · 2020-10-30T18:44:59.000+08:00
diff --git a/springboot-sharding-jdbc/pom.xml b/springboot-sharding-jdbc/pom.xml
@@ -77,13 +77,28 @@
 			<artifactId>fastjson</artifactId>
 			<version>1.2.49</version>
 		</dependency>
+
+		<!-- devtools热部署依赖 -->
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-devtools</artifactId>
+			<!-- 防止将依赖传递到其他模块中 -->
+			<optional>true</optional>
+			<!-- 只在运行时起作用，打包时不打进去（防止线上执行打包后的程序，启动文件监听线程File Watcher，耗费大量的内存资源） -->
+			<scope>runtime</scope>
+		</dependency>
+
 	</dependencies>
 
 	<build>
 		<plugins>
 			<plugin>
 				<groupId>org.springframework.boot</groupId>
 				<artifactId>spring-boot-maven-plugin</artifactId>
+				<configuration>
+					<!-- devtools依赖此配置（否则，devtools不生效）。 -->
+					<fork>true</fork>
+				</configuration>
 			</plugin>
 
 			<plugin>
diff --git a/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/MyPreciseShardingAlgorithm.java b/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/MyPreciseShardingAlgorithm.java
diff --git a/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/dbAlgorithm/MyDBComplexKeysShardingAlgorithm.java b/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/dbAlgorithm/MyDBComplexKeysShardingAlgorithm.java
@@ -1,4 +1,4 @@
-package com.xiaofu.sharding.algorithm;
+package com.xiaofu.sharding.algorithm.dbAlgorithm;
 
 
 import org.apache.shardingsphere.api.sharding.complex.ComplexKeysShardingAlgorithm;
@@ -7,7 +7,7 @@
 import java.util.Collection;
 
 
-public class MyComplexKeysShardingAlgorithm implements ComplexKeysShardingAlgorithm<Long> {
+public class MyDBComplexKeysShardingAlgorithm implements ComplexKeysShardingAlgorithm<Long> {
 
     @Override
     public Collection<String> doSharding(Collection<String> collection, ComplexKeysShardingValue<Long> complexKeysShardingValue) {
diff --git a/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/dbAlgorithm/MyDBHintShardingAlgorithm.java b/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/dbAlgorithm/MyDBHintShardingAlgorithm.java
@@ -1,4 +1,4 @@
-package com.xiaofu.sharding.algorithm;
+package com.xiaofu.sharding.algorithm.dbAlgorithm;
 
 
 import org.apache.shardingsphere.api.sharding.hint.HintShardingAlgorithm;
@@ -9,7 +9,7 @@
 import java.util.List;
 
 
-public class MyHintShardingAlgorithm implements HintShardingAlgorithm {
+public class MyDBHintShardingAlgorithm implements HintShardingAlgorithm {
 
 	@Override
 	public Collection<String> doSharding(Collection tableNames, HintShardingValue hintShardingValue) {
diff --git a/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/dbAlgorithm/MyDBPreciseShardingAlgorithm.java b/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/dbAlgorithm/MyDBPreciseShardingAlgorithm.java
@@ -0,0 +1,33 @@
+package com.xiaofu.sharding.algorithm.dbAlgorithm;
+
+
+import org.apache.shardingsphere.api.sharding.standard.PreciseShardingAlgorithm;
+import org.apache.shardingsphere.api.sharding.standard.PreciseShardingValue;
+
+import java.util.Collection;
+
+/**
+ * @author xiaofu 公众号【程序员内点事】
+ * @description 自定义标准分库策略
+ * @date 2020/10/30 13:48
+ */
+public class MyDBPreciseShardingAlgorithm implements PreciseShardingAlgorithm<Long> {
+
+    @Override
+    public String doSharding(Collection<String> databaseNames, PreciseShardingValue<Long> shardingValue) {
+
+        /**
+         * databaseNames 所有分片库的集合
+         * shardingValue 为分片属性，其中 logicTableName 为逻辑表，columnName 分片健（字段），value 为从 SQL 中解析出的分片健的值
+         */
+        for (String databaseName : databaseNames) {
+            String value = shardingValue.getValue() % databaseNames.size() + "";
+            if (databaseName.endsWith(value)) {
+                return databaseName;
+            }
+        }
+        throw new IllegalArgumentException();
+    }
+}
+
+
diff --git a/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/dbAlgorithm/MyDBRangeShardingAlgorithm.java b/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/dbAlgorithm/MyDBRangeShardingAlgorithm.java
@@ -0,0 +1,32 @@
+package com.xiaofu.sharding.algorithm.dbAlgorithm;
+
+
+import com.google.common.collect.Range;
+import org.apache.shardingsphere.api.sharding.standard.RangeShardingAlgorithm;
+import org.apache.shardingsphere.api.sharding.standard.RangeShardingValue;
+
+import java.util.Collection;
+import java.util.LinkedHashSet;
+import java.util.Set;
+
+
+public class MyDBRangeShardingAlgorithm implements RangeShardingAlgorithm<Integer> {
+
+
+    @Override
+    public Collection<String> doSharding(Collection<String> databaseNames, RangeShardingValue<Integer> rangeShardingValue) {
+        Set<String> result = new LinkedHashSet<>();
+
+        if (Range.closed(1000000000, 2000000000).encloses(rangeShardingValue.getValueRange())) {
+            for (String databaseName : databaseNames) {
+                if (databaseName.endsWith("0")) {
+                    result.add(databaseName);
+                }
+            }
+        }
+        return result;
+    }
+
+}
+
+
diff --git a/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/tableAlgorithm/MyTableComplexKeysShardingAlgorithm.java b/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/tableAlgorithm/MyTableComplexKeysShardingAlgorithm.java
@@ -0,0 +1,21 @@
+package com.xiaofu.sharding.algorithm.tableAlgorithm;
+
+
+import org.apache.shardingsphere.api.sharding.complex.ComplexKeysShardingAlgorithm;
+import org.apache.shardingsphere.api.sharding.complex.ComplexKeysShardingValue;
+
+import java.util.Collection;
+
+
+public class MyTableComplexKeysShardingAlgorithm implements ComplexKeysShardingAlgorithm<Long> {
+
+    @Override
+    public Collection<String> doSharding(Collection<String> collection, ComplexKeysShardingValue<Long> complexKeysShardingValue) {
+
+//        Collection<Integer> ids = getShardingValue(shardingValues, "id");
+//        Collection<Integer> usernames = getShardingValue(shardingValues, "username");
+        return null;
+    }
+}
+
+
diff --git a/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/tableAlgorithm/MyTableHintShardingAlgorithm.java b/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/tableAlgorithm/MyTableHintShardingAlgorithm.java
@@ -0,0 +1,24 @@
+package com.xiaofu.sharding.algorithm.tableAlgorithm;
+
+
+import org.apache.shardingsphere.api.sharding.hint.HintShardingAlgorithm;
+import org.apache.shardingsphere.api.sharding.hint.HintShardingValue;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+
+
+public class MyTableHintShardingAlgorithm implements HintShardingAlgorithm {
+
+	@Override
+	public Collection<String> doSharding(Collection tableNames, HintShardingValue hintShardingValue) {
+		List<String> shardingResult = new ArrayList<>();
+		for (Object targetName : tableNames) {
+
+		}
+		return shardingResult;
+	}
+}
+
+
diff --git a/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/tableAlgorithm/MyTablePreciseShardingAlgorithm.java b/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/tableAlgorithm/MyTablePreciseShardingAlgorithm.java
@@ -0,0 +1,36 @@
+package com.xiaofu.sharding.algorithm.tableAlgorithm;
+
+
+import org.apache.shardingsphere.api.sharding.standard.PreciseShardingAlgorithm;
+import org.apache.shardingsphere.api.sharding.standard.PreciseShardingValue;
+
+import java.util.Collection;
+
+/**
+ * @author xiaofu 公众号【程序员内点事】
+ * @description 自定义标准分表策略
+ * @date 2020/10/30 13:48
+ */
+public class MyTablePreciseShardingAlgorithm implements PreciseShardingAlgorithm<Long> {
+
+    @Override
+    public String doSharding(Collection<String> tableNames, PreciseShardingValue<Long> shardingValue) {
+
+        /**
+         * tableNames 对应分片库中所有分片表的集合
+         * shardingValue 为分片属性，其中 logicTableName 为逻辑表，columnName 分片健（字段），value 为从 SQL 中解析出的分片健的值
+         */
+        for (String tableName : tableNames) {
+            /**
+             * 取模算法，分片健 % 表数量
+             */
+            String value = shardingValue.getValue() % tableNames.size() + "";
+            if (tableName.endsWith(value)) {
+                return tableName;
+            }
+        }
+        throw new IllegalArgumentException();
+    }
+}
+
+
diff --git a/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/tableAlgorithm/MyTableRangeShardingAlgorithm.java b/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/algorithm/tableAlgorithm/MyTableRangeShardingAlgorithm.java
@@ -1,4 +1,4 @@
-package com.xiaofu.sharding.algorithm;
+package com.xiaofu.sharding.algorithm.tableAlgorithm;
 
 
 import com.google.common.collect.Range;
@@ -10,7 +10,7 @@
 import java.util.Set;
 
 
-public class MyRangeShardingAlgorithm implements RangeShardingAlgorithm<Integer> {
+public class MyTableRangeShardingAlgorithm implements RangeShardingAlgorithm<Integer> {
 
     @Override
     public Collection<String> doSharding(Collection<String> tableNames, RangeShardingValue<Integer> rangeShardingValue) {
diff --git a/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/contoller/TestController.java b/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/contoller/TestController.java
@@ -99,27 +99,10 @@ public Object list() {
         return orderRepository.selectList(new QueryWrapper<>());
     }
 
-
-    @GetMapping(value = "/selectOrderAndItemByOrderIdPage")
-    @ResponseBody
-    public String selectOrderAndItemByOrderIdPage(String orderId, Integer pageNo, Integer pageSize) {
-        TOrderDto tOrder = new TOrderDto();
-        if (!StringUtils.isEmpty(orderId)) {
-            tOrder.setOrderId(Long.parseLong(orderId));
-        }
-        Page<TOrderDto> tOrderPage = new Page<>(pageNo, pageSize);
-        tOrderPage.setDesc("o.price");
-        return JSON.toJSONString(orderRepository.selectOrderAndItemByOrderIdPage(tOrderPage, pageNo, pageSize, tOrder.getOrderId()));
-    }
-
-
     @GetMapping(value = "/selectOrderListPage")
     @ResponseBody
     public List<TOrderDto> selectOrderListPage(String orderId, Integer pageNo, Integer pageSize) {
-        TOrderDto tOrder = new TOrderDto();
-        if (!StringUtils.isEmpty(orderId)) {
-            tOrder.setOrderId(Long.parseLong(orderId));
-        }
-        return orderRepository.selectOrderListPage(pageNo, pageSize, tOrder.getOrderId());
+
+        return orderRepository.selectOrderListPage();
     }
 }
diff --git a/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/mapper/OrderRepository.java b/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/mapper/OrderRepository.java
@@ -2,8 +2,6 @@
 
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.baomidou.mybatisplus.core.metadata.IPage;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.xiaofu.sharding.model.TOrder;
 import com.xiaofu.sharding.model.TOrderDto;
 import org.apache.ibatis.annotations.Mapper;
@@ -18,9 +16,8 @@ public interface OrderRepository extends BaseMapper<TOrder> {
 
     List<TOrderDto> selectOrderAndItemByOrderId(TOrderDto tOrder);
 
-    IPage<TOrderDto> selectOrderAndItemByOrderIdPage(Page<TOrderDto> page, @Param("pageNo") Integer pageNo,
-                                                     @Param("pageSize") Integer pageSize, @Param("orderId") Long orderId);
-
     List<TOrderDto> selectOrderListPage(@Param("pageNo") Integer pageNo, @Param("pageSize") Integer pageSize, @Param("orderId") Long orderId);
+
+    List<TOrderDto> selectOrderListPage();
 }
 
diff --git a/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/model/TOrderDto.java b/springboot-sharding-jdbc/src/main/java/com/xiaofu/sharding/model/TOrderDto.java
@@ -1,9 +1,11 @@
 package com.xiaofu.sharding.model;
 
 import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
 
 import java.math.BigDecimal;
 
+@Data
 public class TOrderDto {
 
     @TableId(value = "order_id")
@@ -15,55 +17,9 @@ public class TOrderDto {
 
     private BigDecimal price;
 
+    private Long userId;
+
     private Long itemId;
 
     private String itemName;
-
-    public Long getOrderId() {
-        return orderId;
-    }
-
-    public void setOrderId(Long orderId) {
-        this.orderId = orderId;
-    }
-
-    public String getOrderNo() {
-        return orderNo;
-    }
-
-    public void setOrderNo(String orderNo) {
-        this.orderNo = orderNo;
-    }
-
-    public String getCreateName() {
-        return createName;
-    }
-
-    public void setCreateName(String createName) {
-        this.createName = createName;
-    }
-
-    public BigDecimal getPrice() {
-        return price;
-    }
-
-    public void setPrice(BigDecimal price) {
-        this.price = price;
-    }
-
-    public Long getItemId() {
-        return itemId;
-    }
-
-    public void setItemId(Long itemId) {
-        this.itemId = itemId;
-    }
-
-    public String getItemName() {
-        return itemName;
-    }
-
-    public void setItemName(String itemName) {
-        this.itemName = itemName;
-    }
 }
diff --git a/springboot-sharding-jdbc/src/main/resources/application.properties b/springboot-sharding-jdbc/src/main/resources/application.properties
diff --git a/springboot-sharding-jdbc/src/main/resources/mapping/TOrderMapper.xml b/springboot-sharding-jdbc/src/main/resources/mapping/TOrderMapper.xml
