SQLStatistic.java 文件源码

@Scheduled(fixedRate = 30 * 1000)
public boolean DelOutTimeSqlLog() {
    if (_sqlMap.size() > 0) {
        Map<String, ArrayList<Integer>> delSqlMap = new Hashtable<>();
        for (Map.Entry<String, Map<Long, SqlStatisticStruct>> ent : _sqlMap.entrySet()) {
            ArrayList<Long> delList = new ArrayList<>();
            if (ent.getValue().size() > 0) {
                for (Map.Entry<Long, SqlStatisticStruct> hourent : ent.getValue().entrySet()) {
                    if (hourent.getKey() >= DateTimeHelper.getCurrentTime() - fieryConfig.getKeepdataday() * 86400) {
                        continue;
                    }
                    delList.add(hourent.getKey());
                    //_sqlMap.get(ent.getKey()).remove(hourent.getKey());
                    //log.info("del out time sql log:" + ent.getKey() + ",log create_time:" + DateTimeHelper.TimeStamp2Date(hourent.getKey().toString(), "yyyy-MM-dd HH:mm:ss"));
                }
            }
            /*if (_sqlMap.get(ent.getKey()).size() == 0) {
                    _sqlMap.remove(ent.getKey());
            }*/
        }
        for (Map.Entry<String, ArrayList<Integer>> sqlent : delSqlMap.entrySet()) {
            for (Integer key : sqlent.getValue()) {
                _sqlMap.get(sqlent.getKey()).remove(key);
                log.info("del out time sql log:" + sqlent.getKey() + ",log create_time:" + DateTimeHelper
                        .TimeStamp2Date(key.toString(), "yyyy-MM-dd HH:mm:ss"));
            }
            if (_sqlMap.get(sqlent.getKey()).size() == 0) {
                _sqlMap.remove(sqlent.getKey());
            }
        }
    }
    return true;
}