From a0596153b171dd27ea113ae834d4daf1f2bcd35d Mon Sep 17 00:00:00 2001 From: xiaohanzi Date: Fri, 11 Sep 2020 11:17:49 +0800 Subject: [PATCH] fix shard --- .../config/BaseMyBatisConfiguration.java | 21 +++++++++++++++++++ 1 file changed, 21 insertions(+) diff --git a/mallinkService/src/main/java/com/iformall/config/BaseMyBatisConfiguration.java b/mallinkService/src/main/java/com/iformall/config/BaseMyBatisConfiguration.java index 3d7a6db37..f1b794027 100644 --- a/mallinkService/src/main/java/com/iformall/config/BaseMyBatisConfiguration.java +++ b/mallinkService/src/main/java/com/iformall/config/BaseMyBatisConfiguration.java @@ -19,6 +19,27 @@ public class BaseMyBatisConfiguration { List shardingList = new ArrayList(); shardingSpherePlugin.setShardingSpheres(shardingList); + ShardingSphere wxCouponrSharding = new ShardingSphere(); + wxCouponrSharding.setColumn("tenant_id"); + wxCouponrSharding.setTableName("wx_coupon"); + wxCouponrSharding.setCount(100); + wxCouponrSharding.setRule(EnumShardingRule.HASH.getCode()); + shardingList.add(wxCouponrSharding); + + ShardingSphere wxCouponrMerchantSharding = new ShardingSphere(); + wxCouponrMerchantSharding.setColumn("tenant_id"); + wxCouponrMerchantSharding.setTableName("wx_coupon_merchant"); + wxCouponrMerchantSharding.setCount(100); + wxCouponrMerchantSharding.setRule(EnumShardingRule.HASH.getCode()); + shardingList.add(wxCouponrMerchantSharding); + + ShardingSphere wxCouponrChannelSharding = new ShardingSphere(); + wxCouponrChannelSharding.setColumn("tenant_id"); + wxCouponrChannelSharding.setTableName("wx_coupon_channel"); + wxCouponrChannelSharding.setCount(100); + wxCouponrChannelSharding.setRule(EnumShardingRule.HASH.getCode()); + shardingList.add(wxCouponrChannelSharding); + ShardingSphere wxCUserSharding = new ShardingSphere(); wxCUserSharding.setColumn("tenant_id"); wxCUserSharding.setTableName("wx_c_user");