third_codes/mybatis-plus-join
1
0
Fork 0
mirror of https://gitee.com/best_handsome/mybatis-plus-join synced 2025-07-11 00:02:22 +08:00
Code Issues Packages Projects Releases Wiki Activity

solon

Browse Source
This commit is contained in:
yulichang 2024-01-05 11:17:12 +08:00
parent aee5f54559
commit 26d7ff580b
1 changed files with 36 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
mybatis-plus-join-solon-plugin/src/main/java/com/github/yulichang/mybatisplusjoin/solon/plugin/XPluginImpl.java
View File

@ -21,10 +21,9 @@ import org.noear.solon.core.event.AppLoadEndEvent;
import org.noear.solon.core.util.GenericUtil; import org.noear.solon.core.util.GenericUtil;
import javax.sql.DataSource; import javax.sql.DataSource;
import java.util.Arrays; import java.util.*;
import java.util.List;
import java.util.Map;
import java.util.function.BiPredicate; import java.util.function.BiPredicate;
import java.util.function.Function;
import java.util.stream.Collectors; import java.util.stream.Collectors;
public class XPluginImpl implements Plugin { public class XPluginImpl implements Plugin {
@ -33,7 +32,8 @@ public class XPluginImpl implements Plugin {
public void start(AppContext context) { public void start(AppContext context) {
// MPJSqlInjector // MPJSqlInjector
context.subWrapsOfType(DataSource.class, bw -> context.cfg().putIfAbsent(Utils.isEmpty(bw.name()) ? context.subWrapsOfType(DataSource.class, bw -> context.cfg().putIfAbsent(Utils.isEmpty(bw.name()) ?
"mybatis.globalConfig.sqlInjector" : ("mybatis." + bw.name() + ".globalConfig.sqlInjector"), MPJSqlInjector.class.getName())); "mybatis.globalConfig.sqlInjector" : ("mybatis." + bw.name() + ".globalConfig.sqlInjector"),
MPJSqlInjector.class.getName()));
// setGenericTypeResolver // setGenericTypeResolver
GenericTypeUtils.setGenericTypeResolver(GenericUtil::resolveTypeArguments); GenericTypeUtils.setGenericTypeResolver(GenericUtil::resolveTypeArguments);
// SpringContext兼容 // SpringContext兼容
@ -49,19 +49,19 @@ public class XPluginImpl implements Plugin {
} }
}); });
// 读取配置 // 读取配置
Props prop = context.cfg().getProp("mybatis-plus-join"); Prop prop = new Prop(context.cfg().getProp("mybatis-plus-join"));
ConfigProperties.banner = prop.getBool("banner", ConfigProperties.banner); ConfigProperties.banner = prop.get("banner", Boolean::parseBoolean);
ConfigProperties.subTableLogic = prop.getBool("subTableLogic", ConfigProperties.subTableLogic); ConfigProperties.subTableLogic = prop.get("subTableLogic", Boolean::parseBoolean);
ConfigProperties.msCache = prop.getBool("msCache", ConfigProperties.msCache); ConfigProperties.msCache = prop.get("msCache", Boolean::parseBoolean);
ConfigProperties.tableAlias = prop.get("tableAlias", ConfigProperties.tableAlias); ConfigProperties.tableAlias = prop.get("tableAlias", Function.identity());
ConfigProperties.joinPrefix = prop.get("joinPrefix", ConfigProperties.joinPrefix); ConfigProperties.joinPrefix = prop.get("joinPrefix", Function.identity());
ConfigProperties.logicDelType = prop.getOrDefault("logicDelType", ConfigProperties.logicDelType, val -> ConfigProperties.logicDelType = prop.get("logicDelType", val ->
Arrays.stream(LogicDelTypeEnum.values()).filter(e -> e.name().equalsIgnoreCase(val)).findFirst() Arrays.stream(LogicDelTypeEnum.values()).filter(e -> e.name().equalsIgnoreCase(val)).findFirst()
.orElseThrow(() -> ExceptionUtils.mpe("mybatis-plus-join.logicDelType 配置错误"))); .orElseThrow(() -> ExceptionUtils.mpe("mybatis-plus-join.logicDelType 配置错误")));
ConfigProperties.mappingMaxCount = prop.getInt("mappingMaxCount", ConfigProperties.mappingMaxCount); ConfigProperties.mappingMaxCount = prop.get("mappingMaxCount", Integer::parseInt);
ConfigProperties.ifAbsent = prop.getOrDefault("ifAbsent", ConfigProperties.ifAbsent, val -> ConfigProperties.ifAbsent = prop.get("ifAbsent", val ->
Arrays.stream(IfAbsentEnum.values()).filter(e -> e.name().equalsIgnoreCase(val)).findFirst() Arrays.stream(IfAbsentEnum.values()).filter(e -> e.name().equalsIgnoreCase(val)).findFirst()
.map(m -> (BiPredicate<Object, IfAbsentSqlKeyWordEnum>) (o, ifAbsentSqlKeyWordEnum) -> m.test(o)) .map(m -> (BiPredicate<Object, IfAbsentSqlKeyWordEnum>) (o, enums) -> m.test(o))
.orElseThrow(() -> ExceptionUtils.mpe("mybatis-plus-join.ifAbsent 配置错误"))); .orElseThrow(() -> ExceptionUtils.mpe("mybatis-plus-join.ifAbsent 配置错误")));
// 后续操作 // 后续操作
context.onEvent(AppLoadEndEvent.class, e -> { context.onEvent(AppLoadEndEvent.class, e -> {
@ -71,4 +71,26 @@ public class XPluginImpl implements Plugin {
MappingConfig.init(); MappingConfig.init();
}); });
} }
private static class Prop {
private final Properties props;
public Prop(Props props) {
this.props = new Properties();
props.forEach((k, v) -> this.props.put(k.toString()
.replaceAll("[-_]", "").toUpperCase(Locale.ENGLISH), v));
}
@SuppressWarnings("unchecked")
public <T> T get(String key, Function<String, T> convert) {
try {
return Optional.ofNullable(this.props.get(key.toUpperCase(Locale.ENGLISH)))
.map(v -> convert.apply(v.toString()))
.orElse((T) ConfigProperties.class.getDeclaredField(key).get(null));
} catch (IllegalAccessException | NoSuchFieldException e) {
throw new RuntimeException(e);
}
}
}
} }