赵冬冬 преди 3 години
родител
ревизия
f25a8a6003
променени са 2 файла, в които са добавени 65 реда и са изтрити 38 реда
  1. 27 27
      src/main/java/com/xin/shardingspherejdbcdemo/config/task/RunJob.java
  2. 38 11
      src/main/resources/application-dev.yml

+ 27 - 27
src/main/java/com/xin/shardingspherejdbcdemo/config/task/RunJob.java

@@ -1,27 +1,27 @@
-package com.xin.shardingspherejdbcdemo.config.task;
-
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.boot.ApplicationArguments;
-import org.springframework.boot.ApplicationRunner;
-import org.springframework.stereotype.Component;
-
-@Component
-@Slf4j
-public class RunJob implements ApplicationRunner {
-
-
-//    @Autowired
-//    private DbMapper dbMapper;
-
-
-
-    @Override
-    public void run(ApplicationArguments args) {
-        log.info("执行数据同步开始!");
-//        int i = dbMapper.selectUserTable("2021");
-//        if(i==0){
-//            dbMapper.creatUserTable("2021");
-//        }
-
-    }
-}
+//package com.xin.shardingspherejdbcdemo.config.task;
+//
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.boot.ApplicationArguments;
+//import org.springframework.boot.ApplicationRunner;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//@Slf4j
+//public class RunJob implements ApplicationRunner {
+//
+//
+////    @Autowired
+////    private DbMapper dbMapper;
+//
+//
+//
+//    @Override
+//    public void run(ApplicationArguments args) {
+//        log.info("执行数据同步开始!");
+////        int i = dbMapper.selectUserTable("2021");
+////        if(i==0){
+////            dbMapper.creatUserTable("2021");
+////        }
+//
+//    }
+//}

+ 38 - 11
src/main/resources/application-dev.yml

@@ -15,12 +15,19 @@ mybatis:
 
 mydbinfo:
   list:
-    - shardingDbName: sharding-user
+    - shardingDbName: sharding0
       ip: 47.108.115.128
       port: 3306
-      dbname: sharding
-      username: sharding
-      password: TpTX2s47fNHF5EpG
+      dbname: sharding0
+      username: root
+      password: zdd755
+      tables: t_user_,t_order_
+    - shardingDbName: sharding1
+      ip: 47.108.115.128
+      port: 3306
+      dbname: sharding1
+      username: root
+      password: zdd755
       tables: t_user_,t_order_
 
 spring:
@@ -32,24 +39,44 @@ spring:
   shardingsphere:
     datasource:
       #数据库别名
-      names: sharding-user
-      sharding-user:
+      names: sharding0,sharding1
+      sharding0:
+        type: com.alibaba.druid.pool.DruidDataSource
+        driver-class-name: com.mysql.cj.jdbc.Driver
+        url: jdbc:mysql://47.108.115.128:3306/sharding0?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
+        username: root
+        password: zdd755
+      sharding1:
         type: com.alibaba.druid.pool.DruidDataSource
         driver-class-name: com.mysql.cj.jdbc.Driver
-        url: jdbc:mysql://47.108.115.128:3306/sharding?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
-        username: sharding
-        password: TpTX2s47fNHF5EpG
+        url: jdbc:mysql://47.108.115.128:3306/sharding1?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
+        username: root
+        password: zdd755
     sharding:
       tables:
         #逻辑表名
         t_user_:
-          actual-data-nodes: sharding-user.t_user_$->{2022}
+          actual-data-nodes: sharding$->{0..1}.t_user_$->{2022..2023}
+#          key-generator:
+#            column: id
+#            type: SNOWFLAKE
+          databaseStrategy:
+            inline:
+              shardingColumn: id
+              algorithmExpression: sharding${id % 2}
           table-strategy:
             standard:
               sharding-column: year
               precise-algorithm-class-name: com.xin.shardingspherejdbcdemo.config.sharding.TableShardingAlgorithm
         t_order_:
-          actual-data-nodes: sharding-user.t_order_$->{2022}
+          actual-data-nodes: sharding$->{0..1}.t_order_$->{2022..2023}
+#          key-generator:
+#            column: id
+#            type: SNOWFLAKE
+          databaseStrategy:
+            inline:
+              shardingColumn: id
+              algorithmExpression: sharding${id % 2}
           table-strategy:
             standard:
               sharding-column: year