设置视图查询对象最大1000个

o2server/x_query_core_express/src/main/java/com/x/query/core/express/plan/CmsPlan.java

@@ -187,7 +187,7 @@ public class CmsPlan extends Plan {
 						CriteriaBuilder cb = em.getCriteriaBuilder();
 						CriteriaQuery<String> cq = cb.createQuery(String.class);
 						Root<Item> root = cq.from(Item.class);
-						Predicate p = cb.isMember(root.get(Item_.bundle), cb.literal(_batch));
+						Predicate p = root.get(Item_.bundle).in(_batch);
 						p = f.toPredicate(cb, root, this.runtime, p);
 						cq.select(root.get(Item_.bundle)).where(p);
 						List<String> parts = em.createQuery(cq).getResultList();

o2server/x_query_core_express/src/main/java/com/x/query/core/express/plan/Plan.java

@@ -44,7 +44,7 @@ public abstract class Plan extends GsonPropertyObject {
 	public static final String CALCULATE_AVERAGE = "average";
 	public static final String CALCULATE_COUNT = "count";
 
-	protected static final int SQL_STATEMENT_IN_BATCH = 3000;
+	protected static final int SQL_STATEMENT_IN_BATCH = 1000;
 
 	public Runtime runtime;
 

o2server/x_query_core_express/src/main/java/com/x/query/core/express/plan/ProcessPlatformPlan.java

@@ -207,10 +207,8 @@ public class ProcessPlatformPlan extends Plan {
 						CriteriaBuilder cb = em.getCriteriaBuilder();
 						CriteriaQuery<String> cq = cb.createQuery(String.class);
 						Root<Item> root = cq.from(Item.class);
-						Predicate p = cb.isMember(root.get(Item_.bundle), cb.literal(_batch));
+						Predicate p = root.get(Item_.bundle).in(_batch);
 						p = f.toPredicate(cb, root, this.runtime, p);
-						logger.debug("predicate:{}.", p);
-
 						cq.select(root.get(Item_.bundle)).where(p);
 						List<String> parts = em.createQuery(cq).getResultList();
 						return parts.stream().distinct().collect(Collectors.toList());