gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

refactor(sj_1.2.0-beta1): 系统已经不再支持动态tablePrefix。

Browse Source
This commit is contained in:
dhb52 2024-08-07 00:05:24 +08:00
parent ab9b96db47
commit a5aad6d852
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
snail-job-datasource/snail-job-datasource-template/src/main/java/com/aizuda/snailjob/template/datasource/config/SnailJobTemplateAutoConfiguration.java
View File

@ -89,13 +89,12 @@ public class SnailJobTemplateAutoConfiguration {
@Bean @Bean
public MybatisPlusInterceptor mybatisPlusInterceptor(Environment environment) { public MybatisPlusInterceptor mybatisPlusInterceptor(Environment environment) {
MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
String tablePrefix = Optional.ofNullable(environment.getProperty("mybatis-plus.global-config.db-config.table-prefix")).orElse(StrUtil.EMPTY); interceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor());
interceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor(tablePrefix));
interceptor.addInnerInterceptor(new PaginationInnerInterceptor()); interceptor.addInnerInterceptor(new PaginationInnerInterceptor());
return interceptor; return interceptor;
} }
public DynamicTableNameInnerInterceptor dynamicTableNameInnerInterceptor(String tablePrefix) { public DynamicTableNameInnerInterceptor dynamicTableNameInnerInterceptor() {
DynamicTableNameInnerInterceptor dynamicTableNameInnerInterceptor = new DynamicTableNameInnerInterceptor(); DynamicTableNameInnerInterceptor dynamicTableNameInnerInterceptor = new DynamicTableNameInnerInterceptor();
dynamicTableNameInnerInterceptor.setTableNameHandler((sql, tableName) -> { dynamicTableNameInnerInterceptor.setTableNameHandler((sql, tableName) -> {
if (TABLES_WITH_PARTITION.contains(tableName)) { if (TABLES_WITH_PARTITION.contains(tableName)) {
@ -104,7 +103,7 @@ public class SnailJobTemplateAutoConfiguration {
tableName = tableName + StrUtil.UNDERLINE + partition; tableName = tableName + StrUtil.UNDERLINE + partition;
} }
return tableName.startsWith(tablePrefix) ? tableName : tablePrefix + tableName; return tableName;
}); });
return dynamicTableNameInnerInterceptor; return dynamicTableNameInnerInterceptor;