|
|
|
@ -132,23 +132,7 @@ public class Start extends JFinalConfig {
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
public void configPlugin(Plugins me) {
|
|
|
|
|
DruidPlugin dpMaster = createDruidPlugin(PropKit.get("master_jdbcUrl"), PropKit.get("master_user"), PropKit.get("master_password").trim(), PropKit.get("master_driverClassName"));
|
|
|
|
|
DruidPlugin dpSlave = createDruidPlugin(PropKit.get("slave_jdbcUrl"), PropKit.get("slave_user"), PropKit.get("slave_password").trim(), PropKit.get("slave_driverClassName"));
|
|
|
|
|
|
|
|
|
|
Map<String, DruidPlugin> drudMap = new HashMap<>();
|
|
|
|
|
drudMap.put("ds_master", dpMaster);
|
|
|
|
|
drudMap.put("ds_slave", dpSlave);
|
|
|
|
|
|
|
|
|
|
//负载均衡算法
|
|
|
|
|
LoadBalanceStrategyConfiguration loadBalanceStrategyConfiguration = new LoadBalanceStrategyConfiguration("round_robin");
|
|
|
|
|
MasterSlaveRuleConfiguration masterSlaveRuleConfig =
|
|
|
|
|
new MasterSlaveRuleConfiguration(
|
|
|
|
|
"device_read_write",
|
|
|
|
|
"ds_master",
|
|
|
|
|
Lists.newArrayList("ds_slave"),
|
|
|
|
|
loadBalanceStrategyConfiguration);
|
|
|
|
|
|
|
|
|
|
SlaveDrudPlugin drudPlugin = new SlaveDrudPlugin(masterSlaveRuleConfig, drudMap);
|
|
|
|
|
DruidPlugin drudPlugin = createDruidPlugin(PropKit.get("jdbcUrl"), PropKit.get("user"), PropKit.get("password").trim(), PropKit.get("driverClassName"));
|
|
|
|
|
me.add(drudPlugin);
|
|
|
|
|
|
|
|
|
|
ActiveRecordPlugin arp = new ActiveRecordPlugin("aGroup", drudPlugin);
|
|
|
|
|