package UnitTest; import com.dsideal.QingLong.Start; import com.jfinal.kit.Kv; import com.jfinal.kit.PropKit; import com.jfinal.plugin.activerecord.ActiveRecordPlugin; import com.jfinal.plugin.activerecord.CaseInsensitiveContainerFactory; import com.jfinal.plugin.activerecord.Db; import com.jfinal.plugin.activerecord.SqlPara; import com.jfinal.plugin.activerecord.Record; import com.jfinal.plugin.activerecord.dialect.PostgreSqlDialect; import com.jfinal.plugin.hikaricp.HikariCpPlugin; import java.io.File; import java.net.URISyntaxException; import java.util.ArrayList; import java.util.List; public class TestIn { public static void main(String[] args) throws URISyntaxException { //告之配置文件位置 PropKit.use("application.properties"); HikariCpPlugin hp = new HikariCpPlugin(PropKit.get("jdbcUrl"), PropKit.get("user"), PropKit.get("password").trim(), PropKit.get("driverClassName")); hp.start(); // 配置ActiveRecord插件 ActiveRecordPlugin arp = new ActiveRecordPlugin(hp); //配置默认小写 arp.setContainerFactory(new CaseInsensitiveContainerFactory(true)); arp.setDialect(new PostgreSqlDialect()); //遍历sql目录下所有的sql文件 File sqlDir; String basePath = Start.class.getClassLoader().getResource(".").getPath(); sqlDir = new File(basePath + "/Sql"); File[] sqlFiles = sqlDir.listFiles(); for (File sqlFile : sqlFiles != null ? sqlFiles : new File[0]) { //只加载.sql文件 if (sqlFile.getName().indexOf(".sql") > 0) { arp.addSqlTemplate("/Sql/" + sqlFile.getName()); } } arp.start(); //JFinal的in查询现在太方便了 List idList = new ArrayList<>(); idList.add("A36E0132-625C-4C43-A1B9-8312DD8CCF07"); idList.add("11716B1E-CD95-4E36-9857-296ABE6E4B96"); Kv kv = Kv.by("idList", idList); SqlPara sqlPara = Db.getSqlPara("Test.huanghai_in", kv); List list = Db.find(sqlPara); System.out.println(list); kv = Kv.by("org_name", "第八中学"); sqlPara = Db.getSqlPara("Test.huanghai_like", kv); list = Db.find(sqlPara); System.out.println(list.get(0).getStr("org_name")); } }