Просмотр исходного кода

添加分表

release_toaliyun_real
xiaohanzi 5 лет назад
Родитель
Сommit
2707b4dc22
2 измененных файлов: 2733 добавлений и 0 удалений
  1. +2723
    -0
      mallinkAdmin/src/main/resources/db/migration/V202010141441_sharing.sql
  2. +10
    -0
      mallinkService/src/main/java/com/iformall/config/BaseMyBatisConfiguration.java

+ 2723
- 0
mallinkAdmin/src/main/resources/db/migration/V202010141441_sharing.sql
Разница между файлами не показана из-за своего большого размера
Просмотреть файл


+ 10
- 0
mallinkService/src/main/java/com/iformall/config/BaseMyBatisConfiguration.java Просмотреть файл

@@ -103,6 +103,7 @@ public class BaseMyBatisConfiguration {
wxPosPayOrderSharding.setRule(EnumShardingRule.HASH.getCode()); wxPosPayOrderSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxPosPayOrderSharding); shardingList.add(wxPosPayOrderSharding);
//TODO ,逻辑待处理,tenant_id未和basic_info的final_tenant_id对应,去掉parent_tenant_id
ShardingSphere wxScoreHistorySharding = new ShardingSphere(); ShardingSphere wxScoreHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id"); wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_score_history"); wxScoreHistorySharding.setTableName("wx_score_history");
@@ -110,6 +111,7 @@ public class BaseMyBatisConfiguration {
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode()); wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxScoreHistorySharding); shardingList.add(wxScoreHistorySharding);
//TODO ,逻辑待处理,tenant_id未和basic_info的final_tenant_id对应,去掉parent_tenant_id
ShardingSphere wxCreditHistorySharding = new ShardingSphere(); ShardingSphere wxCreditHistorySharding = new ShardingSphere();
wxScoreHistorySharding.setColumn("tenant_id"); wxScoreHistorySharding.setColumn("tenant_id");
wxScoreHistorySharding.setTableName("wx_credit_history"); wxScoreHistorySharding.setTableName("wx_credit_history");
@@ -117,6 +119,14 @@ public class BaseMyBatisConfiguration {
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode()); wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCreditHistorySharding); shardingList.add(wxCreditHistorySharding);
//TODO ,打标签定时任务。逻辑待处理,
ShardingSphere wxCUserTagsSharding = new ShardingSphere();
wxCUserTagsSharding.setColumn("tenant_id");
wxCUserTagsSharding.setTableName("wx_c_user_tags");
wxCUserTagsSharding.setCount(100);
wxCUserTagsSharding.setRule(EnumShardingRule.HASH.getCode());
shardingList.add(wxCUserTagsSharding);
ShardingSphere wxCarCmdLogSharding = new ShardingSphere(); ShardingSphere wxCarCmdLogSharding = new ShardingSphere();
wxCarCmdLogSharding.setColumn("tenant_id"); wxCarCmdLogSharding.setColumn("tenant_id");
wxCarCmdLogSharding.setTableName("wx_car_cmd_log"); wxCarCmdLogSharding.setTableName("wx_car_cmd_log");


Загрузка…
Отмена
Сохранить