jfinal mysql多库查询

public class MyConfig extends JFinalConfig {
    public void configConstant(Constants me) {
        // 其他配置...
    }

    public void configRoute(Routes me) {
        // 路由配置...
    }

    public void configPlugin(Plugins me) {
        DruidPlugin dp1 = new DruidPlugin("jdbc:mysql://localhost:3306/db1", "user1", "password1");
        DruidPlugin dp2 = new DruidPlugin("jdbc:mysql://localhost:3306/db2", "user2", "password2");
        me.add(dp1);
        me.add(dp2);

        ActiveRecordPlugin arp1 = new ActiveRecordPlugin(dp1);
        ActiveRecordPlugin arp2 = new ActiveRecordPlugin(dp2);
        me.add(arp1);
        me.add(arp2);

        arp1.addMapping("table1", "id", Table1.class);
        arp2.addMapping("table2", "id", Table2.class);
    }

    public void configInterceptor(Interceptors me) {
        // 拦截器配置...
    }

    public void configHandler(Handlers me) {
        // 处理器配置...
    }
}

public class MyService {
    public void doSomething() {
        // 使用第一个数据源
        Db.use("db1").find("SELECT * FROM table1");

        // 使用第二个数据源
        Db.use("db2").find("SELECT * FROM table2");
    }
}

public class MyService {
    public void doSomething() {
        Db.use("db1").startTransaction();
        try {
            Db.use("db1").save("table1", data1);
            Db.use("db2").startTransaction();
            try {
                Db.use("db2").save("table2", data2);
                Db.use("db2").commit();
            } catch (Exception e) {
                Db.use("db2").rollback();
                throw e;
            }
            Db.use("db1").commit();
        } catch (Exception e) {
            Db.use("db1").rollback();
            throw e;
        }
    }
}