admin/mybatis-flex
1
0
Fork 0
mirror of https://gitee.com/mybatis-flex/mybatis-flex.git synced 2025-12-07 00:58:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

增加RowMapperInvoker可注入；增加FlexGlobalConfig可事件扩展

Browse Source
This commit is contained in:
noear 2023-05-21 16:56:05 +08:00
parent 028f2c58bd
commit b415491a4b
2 changed files with 19 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
mybatis-flex-solon-plugin/src/main/java/com/mybatisflex/solon/integration/MybatisAdapterFlex.java
View File

@ -4,13 +4,15 @@ import com.mybatisflex.core.FlexGlobalConfig;
import com.mybatisflex.core.datasource.FlexDataSource;
import com.mybatisflex.core.mybatis.FlexConfiguration;
import com.mybatisflex.core.mybatis.FlexSqlSessionFactoryBuilder;
import com.mybatisflex.core.row.RowMapperInvoker;
import org.apache.ibatis.mapping.Environment;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.solon.integration.MybatisAdapterDefault;
import org.noear.solon.Utils;
import org.noear.solon.core.BeanWrap;
import org.noear.solon.core.Props;
import org.noear.solon.core.VarHolder;
import org.apache.ibatis.solon.integration.MybatisAdapterDefault;
import org.noear.solon.core.event.EventBus;
import javax.sql.DataSource;
@ -84,6 +86,9 @@ public class MybatisAdapterFlex extends MybatisAdapterDefault {
globalConfig.setConfiguration(config);
FlexGlobalConfig.setConfig(environment.getId(), globalConfig, false);
//增加事件扩展机制
EventBus.push(globalConfig);
}
/**
@ -102,14 +107,25 @@ public class MybatisAdapterFlex extends MybatisAdapterDefault {
return factory;
}
RowMapperInvoker rowMapperInvoker;
@Override
public void injectTo(VarHolder varH) {
super.injectTo(varH);
//@Db("db1") SqlSessionFactory factory;
//@Db("db1") FlexGlobalConfig globalConfig;
if (FlexGlobalConfig.class.isAssignableFrom(varH.getType())) {
varH.setValue(this.getGlobalConfig());
return;
}
//@Db("db1") RowMapperInvoker rowMapper;
if (RowMapperInvoker.class.equals(varH.getType())) {
if (rowMapperInvoker == null) {
rowMapperInvoker = new RowMapperInvoker(getFactory());
}
varH.setValue(rowMapperInvoker);
return;
}
}
}

2
pom.xml
View File

@ -65,7 +65,7 @@
<spring.version>5.3.25</spring.version>
<spring-boot.version>2.7.10</spring-boot.version>
<solon.version>2.2.10</solon.version>
<solon.version>2.2.14</solon.version>
<junit.version>4.13.2</junit.version>
</properties>