From eb6b6dbb35a9f029e0b7d269773685c19fd40976 Mon Sep 17 00:00:00 2001 From: 无关风月 <443237572@qq.com> Date: 星期四, 11 七月 2024 10:47:51 +0800 Subject: [PATCH] 玩湃微信商户认证代码 --- cloud-server-course/src/main/java/com/dsh/config/Sharding_jdbc/ShardingConfig.java | 51 ++++++++++++++++++++++++++++----------------------- 1 files changed, 28 insertions(+), 23 deletions(-) diff --git a/cloud-server-course/src/main/java/com/dsh/config/Sharding_jdbc/ShardingConfig.java b/cloud-server-course/src/main/java/com/dsh/config/Sharding_jdbc/ShardingConfig.java index 0dc7c54..cc0cc02 100644 --- a/cloud-server-course/src/main/java/com/dsh/config/Sharding_jdbc/ShardingConfig.java +++ b/cloud-server-course/src/main/java/com/dsh/config/Sharding_jdbc/ShardingConfig.java @@ -24,7 +24,7 @@ @Bean - public DataSource getDataSource(){ + public DataSource getDataSource() { DataSource dataSource = null; try { Properties properties = new Properties(); @@ -40,6 +40,7 @@ /** * 配置多数据源 + * * @return */ private Map<String, DataSource> createDataSourceMap() { @@ -61,6 +62,7 @@ /** * 分片配置 + * * @return */ private Collection<RuleConfiguration> createShardingRuleConfiguration() { @@ -68,6 +70,7 @@ //分片规则配置 ShardingRuleConfiguration result1 = new ShardingRuleConfiguration(); + result1.getTables().add(getCoursePackagePaymentTableRuleConfiguration()); Properties props1 = new Properties(); props1.setProperty("algorithm-expression", "t_course_package_payment$->{appUserId % 5 + 1}"); @@ -102,14 +105,13 @@ result1.getShardingAlgorithms().put("t_course_package_scheduling-inline", new AlgorithmConfiguration("INLINE", props5)); result1.getKeyGenerators().put("t_course_package_scheduling-snowflake", new AlgorithmConfiguration("SNOWFLAKE", new Properties())); - linkedList.add(result1); - //分片规则配置 - result1.getTables().add(getCoursePackageSchedulingTableRuleConfiguration()); - Properties props5 = new Properties(); - props5.setProperty("algorithm-expression", "t_course_package_scheduling$->{coursePackageId % 5 + 1}"); - result1.getShardingAlgorithms().put("t_course_package_scheduling-inline", new AlgorithmConfiguration("INLINE", props5)); - result1.getKeyGenerators().put("t_course_package_scheduling-snowflake", new AlgorithmConfiguration("SNOWFLAKE", new Properties())); + result1.getTables().add(getCoursePackageOrderTableRuleConfiguration()); + Properties props6 = new Properties(); + props6.setProperty("algorithm-expression", "t_course_package_order$->{appUserId % 5 + 1}"); + result1.getShardingAlgorithms().put("t_course_package_order-inline", new AlgorithmConfiguration("INLINE", props6)); + result1.getKeyGenerators().put("t_course_package_order-snowflake", new AlgorithmConfiguration("SNOWFLAKE", new Properties())); + linkedList.add(result1); return linkedList; @@ -117,6 +119,7 @@ /** * 分片算法配置 + * * @return */ private ShardingTableRuleConfiguration getCoursePackagePaymentTableRuleConfiguration() { @@ -127,9 +130,9 @@ } - /** * 分片算法配置 + * * @return */ private ShardingTableRuleConfiguration getCoursePackageStudentTableRuleConfiguration() { @@ -142,19 +145,7 @@ /** * 分片算法配置 - * @return - */ - private ShardingTableRuleConfiguration getCoursePackageSchedulingTableRuleConfiguration() { - ShardingTableRuleConfiguration result = new ShardingTableRuleConfiguration("t_course_package_scheduling", "m_$->{0}.t_course_package_scheduling$->{1..5}");//30 - result.setTableShardingStrategy(new StandardShardingStrategyConfiguration("coursePackageId", "t_course_package_scheduling-inline")); - result.setKeyGenerateStrategy(new KeyGenerateStrategyConfiguration("id", "t_course_package_scheduling-snowflake")); - return result; - } - - - - /** - * 分片算法配置 + * * @return */ private ShardingTableRuleConfiguration getPostCourseVideoTableRuleConfiguration() { @@ -165,9 +156,9 @@ } - /** * 分片算法配置 + * * @return */ private ShardingTableRuleConfiguration getUserVideoDetailsTableRuleConfiguration() { @@ -180,6 +171,7 @@ /** * 分片算法配置 + * * @return */ private ShardingTableRuleConfiguration getCoursePackageSchedulingTableRuleConfiguration() { @@ -189,4 +181,17 @@ return result; } + + /** + * 分片算法配置 + * + * @return + */ + private ShardingTableRuleConfiguration getCoursePackageOrderTableRuleConfiguration() { + ShardingTableRuleConfiguration result = new ShardingTableRuleConfiguration("t_course_package_order", "m_$->{0}.t_course_package_order$->{1..5}");//30 + result.setTableShardingStrategy(new StandardShardingStrategyConfiguration("appUserId", "t_course_package_order-inline")); + result.setKeyGenerateStrategy(new KeyGenerateStrategyConfiguration("id", "t_course_package_order-snowflake")); + return result; + } + } -- Gitblit v1.7.1