|
|
@@ -15,11 +15,11 @@ public class BaseMyBatisConfiguration { |
|
|
|
|
|
|
|
protected MyBatisItercepters allIntercepters() { |
|
|
|
MyBatisItercepters intercepters = new MyBatisItercepters(); |
|
|
|
// List<MyBatisPlus> plugins = new ArrayList<MyBatisPlus>(); |
|
|
|
List<MyBatisPlus> plugins = new ArrayList<MyBatisPlus>(); |
|
|
|
// plugins.add(multiTenancy()); |
|
|
|
// plugins.add(baseShardingSpherePlugin()); |
|
|
|
plugins.add(baseShardingSpherePlugin()); |
|
|
|
// |
|
|
|
// intercepters.setPlugins(plugins); |
|
|
|
intercepters.setPlugins(plugins); |
|
|
|
return intercepters; |
|
|
|
} |
|
|
|
|
|
|
@@ -49,315 +49,11 @@ public class BaseMyBatisConfiguration { |
|
|
|
|
|
|
|
ShardingSphere wxCouponrSharding = new ShardingSphere(); |
|
|
|
wxCouponrSharding.setColumn("tenant_id"); |
|
|
|
wxCouponrSharding.setTableName("wx_coupon"); |
|
|
|
wxCouponrSharding.setTableName("wx_pay_order"); |
|
|
|
wxCouponrSharding.setCount(100); |
|
|
|
wxCouponrSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxCouponrSharding); |
|
|
|
|
|
|
|
ShardingSphere ttPoiTakeRateSharding = new ShardingSphere(); |
|
|
|
ttPoiTakeRateSharding.setColumn("tenant_id"); |
|
|
|
ttPoiTakeRateSharding.setTableName("tt_poi_take_rate"); |
|
|
|
ttPoiTakeRateSharding.setCount(100); |
|
|
|
ttPoiTakeRateSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(ttPoiTakeRateSharding); |
|
|
|
|
|
|
|
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"); |
|
|
|
wxCUserSharding.setCount(100); |
|
|
|
wxCUserSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxCUserSharding); |
|
|
|
|
|
|
|
ShardingSphere ttCUserSharding = new ShardingSphere(); |
|
|
|
ttCUserSharding.setColumn("tenant_id"); |
|
|
|
ttCUserSharding.setTableName("tt_c_user"); |
|
|
|
ttCUserSharding.setCount(100); |
|
|
|
ttCUserSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(ttCUserSharding); |
|
|
|
|
|
|
|
ShardingSphere wxMemberCardSharding = new ShardingSphere(); |
|
|
|
wxMemberCardSharding.setColumn("final_tenant_id"); |
|
|
|
wxMemberCardSharding.setTableName("wx_member_card"); |
|
|
|
wxMemberCardSharding.setCount(100); |
|
|
|
wxMemberCardSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxMemberCardSharding); |
|
|
|
|
|
|
|
ShardingSphere basicInfoSharding = new ShardingSphere(); |
|
|
|
basicInfoSharding.setColumn("final_tenant_id"); |
|
|
|
basicInfoSharding.setTableName("wx_c_user_basic_info"); |
|
|
|
basicInfoSharding.setCount(100); |
|
|
|
basicInfoSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(basicInfoSharding); |
|
|
|
|
|
|
|
ShardingSphere basicInfoAddressSharding = new ShardingSphere(); |
|
|
|
basicInfoAddressSharding.setColumn("final_tenant_id"); |
|
|
|
basicInfoAddressSharding.setTableName("user_basic_info_address"); |
|
|
|
basicInfoAddressSharding.setCount(100); |
|
|
|
basicInfoAddressSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(basicInfoAddressSharding); |
|
|
|
|
|
|
|
ShardingSphere mallCooUserInfoSharding = new ShardingSphere(); |
|
|
|
mallCooUserInfoSharding.setColumn("tenant_id"); |
|
|
|
mallCooUserInfoSharding.setTableName("mall_coo_user_info"); |
|
|
|
mallCooUserInfoSharding.setCount(100); |
|
|
|
mallCooUserInfoSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(mallCooUserInfoSharding); |
|
|
|
|
|
|
|
ShardingSphere basicSignSharding = new ShardingSphere(); |
|
|
|
basicSignSharding.setColumn("tenant_id"); |
|
|
|
basicSignSharding.setTableName("wx_c_user_basic_sign"); |
|
|
|
basicSignSharding.setCount(100); |
|
|
|
basicSignSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(basicSignSharding); |
|
|
|
|
|
|
|
ShardingSphere wxbasicChildSharding = new ShardingSphere(); |
|
|
|
wxbasicChildSharding.setColumn("tenant_id"); |
|
|
|
wxbasicChildSharding.setTableName("wx_c_user_basic_child"); |
|
|
|
wxbasicChildSharding.setCount(100); |
|
|
|
wxbasicChildSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxbasicChildSharding); |
|
|
|
|
|
|
|
ShardingSphere wxCUserFromSharding = new ShardingSphere(); |
|
|
|
wxCUserFromSharding.setColumn("tenant_id"); |
|
|
|
wxCUserFromSharding.setTableName("wx_c_user_from"); |
|
|
|
wxCUserFromSharding.setCount(100); |
|
|
|
wxCUserFromSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxCUserFromSharding); |
|
|
|
|
|
|
|
ShardingSphere wxBusinessCircleOrderSharding = new ShardingSphere(); |
|
|
|
wxBusinessCircleOrderSharding.setColumn("tenant_id"); |
|
|
|
wxBusinessCircleOrderSharding.setTableName("wx_business_circle_order"); |
|
|
|
wxBusinessCircleOrderSharding.setCount(100); |
|
|
|
wxBusinessCircleOrderSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxBusinessCircleOrderSharding); |
|
|
|
|
|
|
|
ShardingSphere aliBusinessCircleOrderSharding = new ShardingSphere(); |
|
|
|
aliBusinessCircleOrderSharding.setColumn("tenant_id"); |
|
|
|
aliBusinessCircleOrderSharding.setTableName("ali_business_circle_order"); |
|
|
|
aliBusinessCircleOrderSharding.setCount(100); |
|
|
|
aliBusinessCircleOrderSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(aliBusinessCircleOrderSharding); |
|
|
|
|
|
|
|
ShardingSphere wxThirdPartyOrdersSharding = new ShardingSphere(); |
|
|
|
wxThirdPartyOrdersSharding.setColumn("tenant_id"); |
|
|
|
wxThirdPartyOrdersSharding.setTableName("wx_third_party_orders"); |
|
|
|
wxThirdPartyOrdersSharding.setCount(100); |
|
|
|
wxThirdPartyOrdersSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxThirdPartyOrdersSharding); |
|
|
|
|
|
|
|
ShardingSphere wxOrderSharding = new ShardingSphere(); |
|
|
|
wxOrderSharding.setColumn("tenant_id"); |
|
|
|
wxOrderSharding.setTableName("wx_order"); |
|
|
|
wxOrderSharding.setCount(100); |
|
|
|
wxOrderSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxOrderSharding); |
|
|
|
|
|
|
|
ShardingSphere orderCpsSharding = new ShardingSphere(); |
|
|
|
orderCpsSharding.setColumn("tenant_id"); |
|
|
|
orderCpsSharding.setTableName("order_cps"); |
|
|
|
orderCpsSharding.setCount(100); |
|
|
|
orderCpsSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(orderCpsSharding); |
|
|
|
|
|
|
|
ShardingSphere orderSnapshotSharding = new ShardingSphere(); |
|
|
|
orderSnapshotSharding.setColumn("tenant_id"); |
|
|
|
orderSnapshotSharding.setTableName("order_snapshot"); |
|
|
|
orderSnapshotSharding.setCount(100); |
|
|
|
orderSnapshotSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(orderSnapshotSharding); |
|
|
|
|
|
|
|
ShardingSphere wxPayOrderSharding = new ShardingSphere(); |
|
|
|
wxPayOrderSharding.setColumn("tenant_id"); |
|
|
|
wxPayOrderSharding.setTableName("wx_pay_order"); |
|
|
|
wxPayOrderSharding.setCount(100); |
|
|
|
wxPayOrderSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxPayOrderSharding); |
|
|
|
|
|
|
|
ShardingSphere wxCouponOrderSharding = new ShardingSphere(); |
|
|
|
wxCouponOrderSharding.setColumn("tenant_id"); |
|
|
|
wxCouponOrderSharding.setTableName("wx_coupon_order"); |
|
|
|
wxCouponOrderSharding.setCount(100); |
|
|
|
wxCouponOrderSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxCouponOrderSharding); |
|
|
|
|
|
|
|
// ShardingSphere wxCouponSendSharding = new ShardingSphere(); |
|
|
|
// wxCouponSendSharding.setColumn("tenant_id"); |
|
|
|
// wxCouponSendSharding.setTableName("wx_coupon_send"); |
|
|
|
// wxCouponSendSharding.setCount(100); |
|
|
|
// wxCouponSendSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
// shardingList.add(wxCouponSendSharding); |
|
|
|
|
|
|
|
ShardingSphere wxOrderGroupSharding = new ShardingSphere(); |
|
|
|
wxOrderGroupSharding.setColumn("tenant_id"); |
|
|
|
wxOrderGroupSharding.setTableName("wx_order_group"); |
|
|
|
wxOrderGroupSharding.setCount(100); |
|
|
|
wxOrderGroupSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxOrderGroupSharding); |
|
|
|
|
|
|
|
ShardingSphere wxOrderPressSharding = new ShardingSphere(); |
|
|
|
wxOrderPressSharding.setColumn("tenant_id"); |
|
|
|
wxOrderPressSharding.setTableName("wx_order_press"); |
|
|
|
wxOrderPressSharding.setCount(100); |
|
|
|
wxOrderPressSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxOrderPressSharding); |
|
|
|
|
|
|
|
ShardingSphere wxPosOrderSharding = new ShardingSphere(); |
|
|
|
wxPosOrderSharding.setColumn("tenant_id"); |
|
|
|
wxPosOrderSharding.setTableName("pos_order"); |
|
|
|
wxPosOrderSharding.setCount(100); |
|
|
|
wxPosOrderSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxPosOrderSharding); |
|
|
|
|
|
|
|
ShardingSphere wxPosPayOrderSharding = new ShardingSphere(); |
|
|
|
wxPosPayOrderSharding.setColumn("tenant_id"); |
|
|
|
wxPosPayOrderSharding.setTableName("pos_pay_order"); |
|
|
|
wxPosPayOrderSharding.setCount(100); |
|
|
|
wxPosPayOrderSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxPosPayOrderSharding); |
|
|
|
|
|
|
|
//TODO ,逻辑待处理,tenant_id未和basic_info的final_tenant_id对应,去掉parent_tenant_id |
|
|
|
ShardingSphere wxScoreHistorySharding = new ShardingSphere(); |
|
|
|
wxScoreHistorySharding.setColumn("tenant_id"); |
|
|
|
wxScoreHistorySharding.setTableName("wx_score_history"); |
|
|
|
wxScoreHistorySharding.setCount(100); |
|
|
|
wxScoreHistorySharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxScoreHistorySharding); |
|
|
|
|
|
|
|
//TODO ,逻辑待处理,tenant_id未和basic_info的final_tenant_id对应,去掉parent_tenant_id |
|
|
|
ShardingSphere wxCreditHistorySharding = new ShardingSphere(); |
|
|
|
wxCreditHistorySharding.setColumn("tenant_id"); |
|
|
|
wxCreditHistorySharding.setTableName("wx_credit_history"); |
|
|
|
wxCreditHistorySharding.setCount(100); |
|
|
|
wxCreditHistorySharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
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(); |
|
|
|
wxCarCmdLogSharding.setColumn("tenant_id"); |
|
|
|
wxCarCmdLogSharding.setTableName("wx_car_cmd_log"); |
|
|
|
wxCarCmdLogSharding.setCount(100); |
|
|
|
wxCarCmdLogSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxCarCmdLogSharding); |
|
|
|
|
|
|
|
ShardingSphere wxMerchantSubsidySharding = new ShardingSphere(); |
|
|
|
wxMerchantSubsidySharding.setColumn("tenant_id"); |
|
|
|
wxMerchantSubsidySharding.setTableName("wx_merchant_subsidy"); |
|
|
|
wxMerchantSubsidySharding.setCount(100); |
|
|
|
wxMerchantSubsidySharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxMerchantSubsidySharding); |
|
|
|
|
|
|
|
ShardingSphere wxProfitSharingOrderSharding = new ShardingSphere(); |
|
|
|
wxProfitSharingOrderSharding.setColumn("tenant_id"); |
|
|
|
wxProfitSharingOrderSharding.setTableName("wx_profit_sharing_order"); |
|
|
|
wxProfitSharingOrderSharding.setCount(100); |
|
|
|
wxProfitSharingOrderSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxProfitSharingOrderSharding); |
|
|
|
|
|
|
|
ShardingSphere wxCouponActionLogSharding = new ShardingSphere(); |
|
|
|
wxCouponActionLogSharding.setColumn("tenant_id"); |
|
|
|
wxCouponActionLogSharding.setTableName("wx_coupon_action_log"); |
|
|
|
wxCouponActionLogSharding.setCount(100); |
|
|
|
wxCouponActionLogSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxCouponActionLogSharding); |
|
|
|
|
|
|
|
ShardingSphere wxCarJSOrderSharding = new ShardingSphere(); |
|
|
|
wxCarJSOrderSharding.setColumn("car_number"); |
|
|
|
wxCarJSOrderSharding.setTableName("wx_car_js_order"); |
|
|
|
wxCarJSOrderSharding.setCount(100); |
|
|
|
wxCarJSOrderSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxCarJSOrderSharding); |
|
|
|
|
|
|
|
ShardingSphere wxCashOutSharding = new ShardingSphere(); |
|
|
|
wxCashOutSharding.setColumn("tenant_id"); |
|
|
|
wxCashOutSharding.setTableName("wx_cash_out"); |
|
|
|
wxCashOutSharding.setCount(100); |
|
|
|
wxCashOutSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxCashOutSharding); |
|
|
|
|
|
|
|
ShardingSphere alipayCUserSharding = new ShardingSphere(); |
|
|
|
alipayCUserSharding.setColumn("tenant_id"); |
|
|
|
alipayCUserSharding.setTableName("alipay_c_user"); |
|
|
|
alipayCUserSharding.setCount(100); |
|
|
|
alipayCUserSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(alipayCUserSharding); |
|
|
|
|
|
|
|
ShardingSphere wxComposeOrderSharding = new ShardingSphere(); |
|
|
|
wxComposeOrderSharding.setColumn("tenant_id"); |
|
|
|
wxComposeOrderSharding.setTableName("wx_batch_order"); |
|
|
|
wxComposeOrderSharding.setCount(100); |
|
|
|
wxComposeOrderSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxComposeOrderSharding); |
|
|
|
|
|
|
|
ShardingSphere wxPressBatchSharding = new ShardingSphere(); |
|
|
|
wxPressBatchSharding.setColumn("tenant_id"); |
|
|
|
wxPressBatchSharding.setTableName("wx_press_batch"); |
|
|
|
wxPressBatchSharding.setCount(100); |
|
|
|
wxPressBatchSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxPressBatchSharding); |
|
|
|
|
|
|
|
ShardingSphere wxPressBatchItemSharding = new ShardingSphere(); |
|
|
|
wxPressBatchItemSharding.setColumn("tenant_id"); |
|
|
|
wxPressBatchItemSharding.setTableName("wx_press_batch_item"); |
|
|
|
wxPressBatchItemSharding.setCount(100); |
|
|
|
wxPressBatchItemSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxPressBatchItemSharding); |
|
|
|
|
|
|
|
ShardingSphere wxCouponMallSharding = new ShardingSphere(); |
|
|
|
wxCouponMallSharding.setColumn("tenant_id"); |
|
|
|
wxCouponMallSharding.setTableName("wx_coupon_mall"); |
|
|
|
wxCouponMallSharding.setCount(100); |
|
|
|
wxCouponMallSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxCouponMallSharding); |
|
|
|
|
|
|
|
ShardingSphere wxCarPayOrderSharding = new ShardingSphere(); |
|
|
|
wxCarPayOrderSharding.setColumn("tenant_id"); |
|
|
|
wxCarPayOrderSharding.setTableName("wx_car_pay_order"); |
|
|
|
wxCarPayOrderSharding.setCount(100); |
|
|
|
wxCarPayOrderSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxCarPayOrderSharding); |
|
|
|
|
|
|
|
ShardingSphere wxCouponBatchSharding = new ShardingSphere(); |
|
|
|
wxCouponBatchSharding.setColumn("tenant_id"); |
|
|
|
wxCouponBatchSharding.setTableName("wx_coupon_batch"); |
|
|
|
wxCouponBatchSharding.setCount(100); |
|
|
|
wxCouponBatchSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxCouponBatchSharding); |
|
|
|
|
|
|
|
ShardingSphere wxCouponBatchItemSharding = new ShardingSphere(); |
|
|
|
wxCouponBatchItemSharding.setColumn("tenant_id"); |
|
|
|
wxCouponBatchItemSharding.setTableName("wx_coupon_batch_item"); |
|
|
|
wxCouponBatchItemSharding.setCount(100); |
|
|
|
wxCouponBatchItemSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxCouponBatchItemSharding); |
|
|
|
|
|
|
|
ShardingSphere wxBusinessSharding = new ShardingSphere(); |
|
|
|
wxBusinessSharding.setColumn("final_tenant_id"); |
|
|
|
wxBusinessSharding.setTableName("wx_business"); |
|
|
|
wxBusinessSharding.setCount(100); |
|
|
|
wxBusinessSharding.setRule(EnumShardingRule.HASH.getCode()); |
|
|
|
shardingList.add(wxBusinessSharding); |
|
|
|
|
|
|
|
//初始化 |
|
|
|
shardingSpherePlugin.setShardingSpheres(shardingList); |
|
|
|
Properties properties = new Properties(); |
|
|
|