public void checkQuality() {// 先取得词的历史质量度Map<String, Long> qhmap = getQualityWithAccountidAndKey(needCheckQualityKeys, accountid);// QualityHistory表中能根据groupid-key查到历史质量度.则需要更新keyspend的值.否则什么都不做.if (qhmap != null && qhmap.size() > 0) {List<KeySpend> kslist = new ArrayList<KeySpend>();for (CpcKeyDTO key : needCheckQualityKeys) {if (qhmap.get(key.getKey()) != null) {KeySpend keyspend = new KeySpend();keyspend.setCpcid(key.getCpcid());keyspend.setQuality(qhmap.get(key.getKey()));kslist.add(keyspend);}}//会在server端执行kslist.size()条sql.batchProcessKeySpend(kslist);}}

     if (qhmap != null && qhmap.size() > 0) {HashMap<Long, ArrayList<Long>> keySpendMap = new HashMap<Long, ArrayList<Long>>();//质量度有5个值, 所以每个值对应一条sql. 将来只需要5条sqlfor (CpcKeyDTO key : needCheckQualityKeys) {if (qhmap.get(key.getKey()) != null) {Long degree = qhmap.get(key.getKey());                    ArrayList<Long> list = keySpendMap.get(degree);if(list == null){list = new ArrayList<Long>();keySpendMap.put(degree, list);}list.add(key.getCpcid());                           }}//使用IN进行优化。for(Long degree : keySpendMap.keySet()){auditPersistentService.batchProcessKeySpend(degree, keySpendMap.get(degree));}         }

/* Formatted on 2011-8-2 18:54:00 (QP5 v5.114.809.3010) */
MERGE INTO CPC.CPCPARTNERAUDIT cpa
USING (SELECT ? AS OPID,? AS ACCOUNTID,? AS GROUPID,? AS IDEAID,? AS KEYID,? AS CHECKSTATUS,? AS CREATEDATE,? AS REFUSEREASON, ? AS ADMINUSERID,? AS ADMINUSERNAME,? AS AUDITREASON,? AS BACKUPIDEAID  FROM DUAL) cpai
ON (cpa.keyid=cpai.keyid AND cpa.ideaid=cpai.ideaid)
WHEN NOT MATCHED THEN
INSERT
VALUES (cpai.OPID, cpai.ACCOUNTID, cpai.GROUPID, cpai.IDEAID, cpai.KEYID,
cpai.CHECKSTATUS, cpai.CREATEDATE, cpai.REFUSEREASON, cpai.ADMINUSERID, cpai.ADMINUSERNAME,
cpai.AUDITREASON,cpai.BACKUPIDEAID)

INSERT INTO CPC.CPCPARTNERAUDIT (OPID,ACCOUNTID,GROUPID,IDEAID,KEYID,CHECKSTATUS,CREATEDATE,REFUSEREASON,ADMINUSERID,ADMINUSERNAME,AUDITREASON,BACKUPIDEAID)(SELECT   A.*FROM   (SELECT   GREATEST (I.OPID, C.OPID) AS OPID,I.ACCOUNTID,I.CPCGRPID,I.CPCIDEAID,C.CPCID,1 AS CHECKSTATUS,SYSDATE AS CREATEDATE,'自动审核通过' AS REFUSEREASON,0 AS ADMINUSERID,'自动审核' AS ADMINUSERNAME,'自动审核通过' AS AUDITREASON,NULL AS BACKUPIDEAIDFROM   CPC.CPCIDEA I, CPC.CPC CWHERE       I.CPCGRPID = C.CPCGRPIDAND I.CPCIDEAID = ?AND C.CPCID IN (?)UNION ALLSELECT   GREATEST (I.OPID, C.OPID) AS OPID,C.ACCOUNTID,I.GROUPID,I.AUDITIDEAID AS CPCIDEAID,C.CPCID,1 AS CHECKSTATUS,SYSDATE AS CREATEDATE,'自动审核通过' AS REFUSEREASON,0 AS ADMINUSERID,'自动审核' AS ADMINUSERNAME,'自动审核通过' AS AUDITREASON,I.IDEAID AS BACKUPIDEAIDFROM   CPC.CPCIDEAMODI I, CPC.CPC CWHERE       I.GROUPID = C.CPCGRPIDAND I.AUDITIDEAID = ?AND C.CPCID IN (?)) AWHERE   NOT EXISTS(SELECT   P.KEYID, P.IDEAIDFROM   CPC.CPCPARTNERAUDIT PWHERE   A.CPCIDEAID = P.IDEAID AND A.CPCID = P.KEYID))

．．．．．int group = passedPartners.size() % IDS_PER_BATCH == 0 ? passedPartners                    .size()/ IDS_PER_BATCH                    : (passedPartners.size() / IDS_PER_BATCH + 1);

for (int i = 0; i < group; i++) {final List<CpcPartnerDTO> batchPassedPartners;if ((i + 1) * IDS_PER_BATCH > passedPartners.size()) {                    batchPassedPartners = passedPartners.subList(i* IDS_PER_BATCH, passedPartners.size());                } else {                    batchPassedPartners = passedPartners.subList(i* IDS_PER_BATCH, (i + 1) * IDS_PER_BATCH);                }                doInFacade(batchPassedPartners, AuditElement.PARTNER,                        Action.INS_AUDIT_ELEMENT);            }．．．．．．

......
for (int pageNo = 1; pageNo <= totalPageCount; pageNo++) {
doPage(sql, pageNo, set);
}

......

private void doPage(String sql, int pageNo, Set<String> set) {
long t1 = System.currentTimeMillis();
final int startIndex = PageUtil.getStartOfPage(pageNo, pageSize);
String sqlLimit = PageUtil.getLimitString(sql, true);
Object[] obj = new Object[] { startIndex, startIndex + pageSize };
List<String> list = jdbcTemplateCpc.query(sqlLimit, obj,
new RowMapper() {

@Override
public Object mapRow(ResultSet rs, int arg1)
throws SQLException {
return "" + rs.getString(2) + rs.getString(1);
}

});
set.addAll(list);
long t2 = System.currentTimeMillis();
logger.info("第" + pageNo + "次查询数据量" + list.size() + ",set中现有"
+ set.size() + "条记录，耗时" + ((t2 - t1) / 1000) + "秒");
}