From 9f0a4f0b31933cc48ac96dc50b841ce5dcc15914 Mon Sep 17 00:00:00 2001 From: lisy <linlangsur163@163.com> Date: 星期五, 11 八月 2023 11:56:06 +0800 Subject: [PATCH] course模块:上课记录实体增加字段-课包排课记录id;新增课包排课记录实体类 --- cloud-server-course/src/main/java/com/dsh/config/Sharding_jdbc/ShardingConfig.java | 72 ++++++++++++++++++++++++++++++++--- 1 files changed, 65 insertions(+), 7 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 79c5c4c..027c19b 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 @@ -73,16 +73,36 @@ props1.setProperty("algorithm-expression", "t_course_package_payment$->{appUserId % 5 + 1}"); result1.getShardingAlgorithms().put("t_course_package_payment-inline", new AlgorithmConfiguration("INLINE", props1)); result1.getKeyGenerators().put("t_course_package_payment-snowflake", new AlgorithmConfiguration("SNOWFLAKE", new Properties())); + + //分片规则配置 + result1.getTables().add(getCoursePackageStudentTableRuleConfiguration()); + Properties props2 = new Properties(); + props2.setProperty("algorithm-expression", "t_course_package_student$->{appUserId % 5 + 1}"); + result1.getShardingAlgorithms().put("t_course_package_student-inline", new AlgorithmConfiguration("INLINE", props2)); + result1.getKeyGenerators().put("t_course_package_student-snowflake", new AlgorithmConfiguration("SNOWFLAKE", new Properties())); + + //分片规则配置 + result1.getTables().add(getPostCourseVideoTableRuleConfiguration()); + Properties props3 = new Properties(); + props3.setProperty("algorithm-expression", "t_post_course_video$->{coursePackageId % 5 + 1}"); + result1.getShardingAlgorithms().put("t_post_course_video-inline", new AlgorithmConfiguration("INLINE", props3)); + result1.getKeyGenerators().put("t_post_course_video-snowflake", new AlgorithmConfiguration("SNOWFLAKE", new Properties())); + + //分片规则配置 + result1.getTables().add(getUserVideoDetailsTableRuleConfiguration()); + Properties props4 = new Properties(); + props4.setProperty("algorithm-expression", "t_user_video_details$->{appUserId % 5 + 1}"); + result1.getShardingAlgorithms().put("t_user_video_details-inline", new AlgorithmConfiguration("INLINE", props4)); + result1.getKeyGenerators().put("t_user_video_details-snowflake", new AlgorithmConfiguration("SNOWFLAKE", new Properties())); linkedList.add(result1); //分片规则配置 - ShardingRuleConfiguration result2 = new ShardingRuleConfiguration(); - result2.getTables().add(getCoursePackageStudentTableRuleConfiguration()); - Properties props2 = new Properties(); - props2.setProperty("algorithm-expression", "t_course_package_student$->{appUserId % 5 + 1}"); - result2.getShardingAlgorithms().put("t_course_package_student-inline", new AlgorithmConfiguration("INLINE", props2)); - result2.getKeyGenerators().put("t_course_package_student-snowflake", new AlgorithmConfiguration("SNOWFLAKE", new Properties())); - linkedList.add(result2); + 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())); + linkedList.add(result1); return linkedList; } @@ -111,4 +131,42 @@ return result; } + + /** + * 分片算法配置 + * @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() { + ShardingTableRuleConfiguration result = new ShardingTableRuleConfiguration("t_post_course_video", "m_$->{0}.t_post_course_video$->{1..5}");//30 + result.setTableShardingStrategy(new StandardShardingStrategyConfiguration("coursePackageId", "t_post_course_video-inline")); + result.setKeyGenerateStrategy(new KeyGenerateStrategyConfiguration("id", "t_post_course_video-snowflake")); + return result; + } + + + + /** + * 分片算法配置 + * @return + */ + private ShardingTableRuleConfiguration getUserVideoDetailsTableRuleConfiguration() { + ShardingTableRuleConfiguration result = new ShardingTableRuleConfiguration("t_user_video_details", "m_$->{0}.t_user_video_details$->{1..5}");//30 + result.setTableShardingStrategy(new StandardShardingStrategyConfiguration("appUserId", "t_user_video_details-inline")); + result.setKeyGenerateStrategy(new KeyGenerateStrategyConfiguration("id", "t_user_video_details-snowflake")); + return result; + } + } -- Gitblit v1.7.1