让JFinal的ActiveRecord支持多数据源。

比较喜欢JFinal简单的设计。但是我们的不少项目都需要连接至少两个数据库&＃xff0c;而JFinal的ActiveRecord对多数据源支持比较若。周末断断续续花了一天的时间对JFinal进行的ActiveRecord做改造。

设计目标如下&＃xff1a;
1&＃xff09;既有的单数据源的JFinal代码不用修改一行代码就可以自然支持。
2&＃xff09;Model&＃xff0c;Record都支持多数据源&＃xff0c;而且改动量要小。
3&＃xff09;性能不能很大损失。

实现思路&＃xff1a;
1&＃xff09;一个数据源即一个分组&＃xff08;group&＃xff09;&＃xff0c;多个数据源既有多个分组&＃xff0c;每个Mode只能属于一个分组。Record不限制分组。
2&＃xff09;default是一个默认分组&＃xff0c;当不指定分组名师&＃xff0c;默认采用default分组。这个用来解决兼容问题。
3&＃xff09;尽量启动时计算一下&＃xff0c;减少每次请求的计算。

实现结果&＃xff1a;
1&＃xff09;原来的JFinal方式兼容&＃xff0c;但是删除掉了Model和Record中关于DataSource为参数的操作&＃xff0c;给位group
多数据源方式&＃xff1a;

&＃64;Override
public void configPlugin(Plugins me) {//从配置文件中获取数据库配置项PropertyConfig config &＃61; PropertyConfig.me();//a数据源DruidPlugin aDruidPlugin &＃61; new DruidPlugin(config.getProperty("a.dataSource.url"), config.getProperty("a.dataSource.userName"), config.getProperty("a.dataSource.password"), config.getProperty("a.dataSource.driverClass"));aDruidPlugin.setInitialSize(3).setMaxActive(10);//b数据源DruidPlugin bDruidPlugin &＃61; new DruidPlugin(config.getProperty("b.dataSource.url"), config.getProperty("b.dataSource.userName"), config.getProperty("b.dataSource.password"), config.getProperty("b.dataSource.driverClass"));bDruidPlugin.setInitialSize(3).setMaxActive(10);//加载数据库连接池插件me.add(aDruidPlugin);me.add(bDruidPlugin);//分组a&＃xff0c;数据源bActiveRecordPlugin aArp &＃61; new ActiveRecordPlugin("aGroup",aDruidPlugin);aArp.setShowSql(true);aArp.addMapping("t_admin_user", AdminUser.class);aArp.addMapping("t_charge_history", ChargeHistory.class);aArp.addMapping("t_sms_api_user", SmsApiUser.class);me.add(aArp);//分组b&＃xff0c;数据源bActiveRecordPlugin bArp &＃61; new ActiveRecordPlugin("bGroup",bDruidPlugin);bArp.setDialect(new PostgreSqlDialect());bArp.setShowSql(true);bArp.addMapping("t_send_message_history", SendMessageHistory.class);me.add(bArp);
}

差异在于ActiveRecordPlugin多了一个构造函数。Model的写法和以前一样。不用改变。

如果要在Controller上配置事务&＃xff08;TX系列拦截器&＃xff09;拦截器&＃xff0c;configRoute(Routes me) 函数也得做一定改变。若不用事务拦截器&＃xff0c;则还和原来一样。使用拦截器的话代码如下&＃xff1a;

public void configRoute(Routes me) {me.addWithGroup("aGroup","/", IndexController.class);me.addWithGroup("aGroup","/au",AdminUserController.class);me.addWithGroup("aGroup","/sau", SmsApiUserController.class);me.addWithGroup("bGroup","/smh",SendMessageHistoryController.class);
}