24. 集成和Demo
24.1. Spring集成和Demo
集成提供了Mapper类的自动注入以及SQLManager的自动注入,以及与spring事务集成
<!-- DAO接口所在包名,Spring会自动查找其下的类 -->
<bean name="beetlSqlScannerConfigurer" class="org.beetl.sql.ext.spring4.BeetlSqlScannerConfigurer">
<!-- 哪些类可以自动注入 -->
<property name="basePackage" value="org.beetl.sql.ext.spring4"/>
<!-- 通过类后缀 来自动注入Dao -->
<property name="daoSuffix" value="Dao"/>
<property name="sqlManagerFactoryBeanName" value="sqlManagerFactoryBean"/>
</bean>
<bean id="sqlManagerFactoryBean" class="org.beetl.sql.ext.spring4.SqlManagerFactoryBean">
<property name="cs" >
<bean class="org.beetl.sql.ext.spring4.BeetlSqlDataSource">
<property name="masterSource" ref="dataSource"></property>
</bean>
</property>
<property name="dbStyle">
<bean class="org.beetl.sql.core.db.H2Style"/>
</property>
<property name="sqlLoader">
<bean class="org.beetl.sql.core.ClasspathLoader">
<property name="sqlRoot" value="/sql"></property>
</bean>
</property>
<property name="nc">
<bean class="org.beetl.sql.core.UnderlinedNameConversion"/>
</property>
<property name="interceptors">
<list>
<bean class="org.beetl.sql.ext.DebugInterceptor"></bean>
</list>
</property>
</bean>
- BeetlSqlScannerConfigurer 根据包名和类后缀来自动注入Dao类,如果没有Dao,可以不配置此项
- cs: 指定ConnectionSource,可以用系统提供的DefaultConnectionSource,支持按照CRUD决定主从。例子里只有一个master库
- dbStyle: 数据库类型,目前只支持org.beetl.sql.core.db.MySqlStyle,以及OralceSytle,PostgresStyle,SQLiteStyle,SqlServerStyle,H2Style
- sqlLoader: sql语句加载来源
- nc: 命名转化,有默认的DefaultNameConversion,数据库跟类名一致,还有有数据库下划线的UnderlinedNameConversion,JPANameConversion,
- interceptors:DebugInterceptor 用来打印sql语句,参数和执行时间
注意: 任何使用了Transactional 注解的,将统一使用Master数据源,例外的是@Transactional(readOnly=true),这将让Beetsql选择从数据库。
@Service
public class MyServiceImpl implements MyService {
@Autowired
UserDao dao; // UserDao extends BaseMapper<User>
@Autowired
SQLManager sql;
@Override
@Transactional()
public int total(User user) {
int total = list .size();
dao.deleteById(3);
User u =new User();
u.id = 3;
u.name="hello";
u.age = 12;
dao.insert(u);
return total;
}
}
其他集成配置还包括:
- functions 配置扩展函数
- tagFactorys 配置扩展标签
- configFileResource 扩展配置文件位置,beetlsql将读取此配置文件覆盖beetlsql默认选项
- defaultSchema 数据库访问schema
参考
24.2. SpringBoot集成
未来版本不在使用单数据源集成方式,建议即使你有一个数据源,也采用下一节多数据源集成方式
<dependency>
<groupId>com.ibeetl</groupId>
<artifactId>beetl-framework-starter</artifactId>
<version>1.1.81.RELEASE</version>
</dependency>
@Configuration
public class DataSourceConfig {
@Bean(name="datasource")
public DataSource datasource(Environment env) {
HikariDataSource ds = new HikariDataSource();
ds.setJdbcUrl(env.getProperty("spring.datasource.url"));
ds.setUsername(env.getProperty("spring.datasource.username"));
ds.setPassword(env.getProperty("spring.datasource.password"));
ds.setDriverClassName(env.getProperty("spring.datasource.driver-class-name"));
return ds;
}
}
提供如下配置
beetl-framework-starter 会读取application.properites如下配置
beetlsql.sqlPath,默认为/sql, 作为存放sql文件的根目录,位于/resources/sql目录下
beetlsql.nameConversion: 默认是org.beetl.sql.core.UnderlinedNameConversion,能将下划线分割的数据库命名风格转化为java驼峰命名风格,还有常用的DefaultNameConversion,数据库命名完全和Java命名一直,以及JPA2NameConversion,兼容JPA命名
beetl-beetlsql.dev:默认是true,即向控制台输出执行时候的sql,参数,执行时间,以及执行的位置,每次修改sql文件的时候,自动检测sql文件修改.
beetlsql.daoSuffix:默认为Dao。
beetlsql.basePackage:默认为com,此选项配置beetlsql.daoSuffix来自动扫描com包极其子包下的所有以Dao结尾的Mapper类。以本章例子而言,你可以配置“com.bee.sample.ch5.dao”
beetlsql.dbStyle :数据库风格,默认是org.beetl.sql.core.db.MySqlStyle.对应不同的数据库,其他还有OracleStyle,PostgresStyle,SqlServerStyle,DB2SqlStyle,SQLiteStyle,H2Style
如果你想配置主从或者指定一个已经配置好的数据源,可以自己创建一个 BeetlSqlDataSource的Bean,比如,在你的配置代码里
@Bean
public BeetlSqlDataSource beetlSqlDataSource(@Qualifier("master") DataSource dataSource,@Qualifier("slave") DataSource slave){
BeetlSqlDataSource source = new BeetlSqlDataSource();
source.setMasterSource(dataSource);
source.setSlaves(new DataSource[]{slave});
return source;
}
注意,可以通过Application.properties 配置如下属性禁用BeetlSQL或者禁用Beetl
beetlsql.enabled=false
beetl.enabled=false
如果不满足你要求,你也可以采用java config方式自己配置,或者参考beetl-framework-starter源码,参考 demo ,http://git.oschina.net/xiandafu/springboot_beetl_beetlsql,自己完成
可以实现BeetlSqlCustomize接口来定制BeetlSQL,比如
@Configuration
public MyConfig{
@Bean
public BeetlSqlCustomize beetlSqlCustomize(){
return new BeetlSqlCustomize(){
public void customize(SqlManagerFactoryBean sqlManagerFactoryBean){
//....
}
};
}
}
可以掉用SqlManagerFactoryBean来配置,或者获得SQLManager 进一步配置
24.3. SpringBoot集成多数据源
单数据源情况,BeetlSQL配置方式如上一节所示,BeetlSQL会自动根据单数据源配置好BeetlSQL,多数据源情况下,需要配置指定的多数据源,如下俩个数据源
@Configuration
public class DataSourceConfig {
@Bean(name = "a")
public DataSource datasource(Environment env) {
HikariDataSource ds = new HikariDataSource();
ds.setJdbcUrl(env.getProperty("spring.datasource.a.url"));
ds.setUsername(env.getProperty("spring.datasource.a.username"));
ds.setPassword(env.getProperty("spring.datasource.a.password"));
ds.setDriverClassName(env.getProperty("spring.datasource.a.driver-class-name"));
return ds;
}
@Bean(name = "b")
public DataSource datasourceOther(Environment env) {
HikariDataSource ds = new HikariDataSource();
ds.setJdbcUrl(env.getProperty("spring.datasource.b.url"));
ds.setUsername(env.getProperty("spring.datasource.b.username"));
ds.setPassword(env.getProperty("spring.datasource.b.password"));
ds.setDriverClassName(env.getProperty("spring.datasource.b.driver-class-name"));
return ds;
}
对于数据源a,b,需要配置beetlsql如下配置
beetlsql.ds.a.basePackage=com.bee.sample.ch5.xxxdao.
beetlsql.ds.b.basePackage=com.bee.sample.ch5.yyyydao
beetlsql.mutiple.datasource=a,b
以beetlsql.ds 为前缀,需要分别配置每个数据源的basePackage,nameConversion等配置,如果没有,则使用默认配置,比如beetlsql.ds.a.nameConversion= ….OralceStyle;beetlsql.ds.b.nameConversion= ….MySqlStyle;beetlsql.mutiple.datasource 则配置了多个数据源列表。
如果需要定制每一个SQLManager,需要提供BeetlSqlMutipleSourceCustomize
@Bean
public BeetlSqlMutipleSourceCustomize beetlSqlCustomize() {
return new BeetlSqlMutipleSourceCustomize() {
@Override
public void customize(String dataSource,SQLManager sqlManager) {
//可以在这里添加各种扩展,指定主从等
}
};
}
24.4. JFinal集成和Demo
在configPlugin 里配置BeetlSql
JFinalBeetlSql.init();
默认会采用c3p0 作为数据源,其配置来源于jfinal 配置,如果你自己提供数据源或者主从,可以如下
JFinalBeetlSql.init(master,slaves);
由于使用了Beetlsql,因此你无需再配置 数据库连接池插件,和ActiveRecordPlugin,可以删除相关配置。
在controller里,可以通过JFinalBeetlSql.dao 方法获取到SQLManager
SQLManager dao = JFinalBeetlSql.dao();
BigBlog blog = getModel(BigBlog.class);
dao.insert(BigBlog.class, blog);
如果想控制事物,还需要注册Trans
public void configInterceptor(Interceptors me) {
me.addGlobalActionInterceptor(new Trans());
}
然后业务方法使用
@Before(Trans.class)
public void doXXX(){....}
这样,方法执行完毕才会提交事物,任何RuntimeException将回滚,如果想手工控制回滚.也可以通过
Trans.commit()
Trans.rollback()
如果习惯了JFinal Record模式,建议用户创建一个BaseBean,封装SQLManager CRUD 方法即可。然后其他模型继承此BaseBean
注意
可以通过jfinal属性文件来配置sqlManager,比如 PropKit.use("config.txt", "UTF-8"),然后可以配置 sql.nc,sql.root,sql.interceptor,sql.dbStyle,具体参考源代码
JFinalBeetlSql.initProp
参考
可以参考demo https://git.oschina.net/xiandafu/jfinal_beet_beetsql_btjson
demo https://code.csdn.net/xiandafu/beetlsql_orm_sample/tree/master