将获取id数组的地方用java平均拆分成小于1000的数组，然后拼接成
1
2
| id in (1,2,..1000) or id in (1001,1002,..2000)
的形式
|
拆分数组的方法
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
| //break list into a batches
public static <T> List<List<T>> getBatches(List<T> collection, int batchSize){
int i = 0;
List<List<T>> batches = new ArrayList<List<T>>();
while(i<collection.size()){
int nextInc = Math.min(collection.size()-i,batchSize);
List<T> batch = collection.subList(i,i+nextInc);
batches.add(batch);
i = i + nextInc;
}
return batches;
}
public static Date getLastDayOfMonth(int y, int m){
Calendar c = new GregorianCalendar(y,m,1);
c.add(Calendar.DATE,-15);
return c.getTime();
}
public class Test1 {
private static final Log log = LogFactory.getLog(Test1.class);
public static void main(String[] args) throws Exception {
List<Integer> list = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14);
List<List<Integer>> batches = CollectionUtils.getBatches(list, 3);
System.out.println("batches = " + batches);
}
|
改造后的逻辑
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
| public static String getGroupSql(Long parent_id) {
Collection pids = getGroupIds(parent_id);
String conn = "";
if(!CollectionUtils.isEmpty(pids)){
if(pids.size() > 1000){
List<? extends List<?>> batches = CollectionUtils.getBatches((List<String>) pids, 1000);
conn += "( t.parent.id in (-1) ";
for (List<?> batch : batches) {
conn += " or t.parent.id in " + SampleManager.getInstr(batch);
}
conn += ")";
}else{
conn = " t.parent.id in " + SampleManager.getInstr(pids);
}
}else{
conn = " 1=2 " ;
}
return conn;
}
public class Samplemanager {
public static String getInstr(Collection ids) {
StringBuffer sb = new StringBuffer();
sb.append("(-1");
if (ids != null && ids.size() > 0)
for (Iterator iterator = ids.iterator(); iterator.hasNext();) {
sb.append("," + iterator.next());
}
sb.append(")");
return sb.toString();
}
}
|
