resstatuslogdao.java

sla性能采集

package com.asiainfo.ainx.slaconf.dao;


import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;

import javax.sql.DataSource;

import org.apache.log4j.*;

import ainx.common.database.ConnectionPools;
import ainx.common.database.DaoBase;

import ainx.common.util.*;
import com.asiainfo.ainx.slaconf.util.DBEncodingUtil;
import com.asiainfo.ainx.slaconf.vo.SlaResStatusLogVO;;
/**
 * 
 * @author zhaotj
 *
 */
public class ResStatusLogDAO extends DaoBase {
	
	private static Logger log = Logger
	.getLogger("com.asiainfo.ainx.slaconf.dao.ResStatusLogDAO");	
	  
	private String LINK_LOGS = "select b.itemid,b.itemname,a.resid,c.alias,c.bandwidth/1000000 as param, " +
			"to_char(a.ALARMTIME,'yyyy-mm-dd hh24:mi:ss') as ALARMTIME," +
			"a.alarmvalue,a.alarmstatus,"+
			"to_char(a.solvetime,'yyyy-mm-dd hh24:mi:ss') as solvetime,"+
			"a.solvevalue from sla_alarm_log a," +
			"item_define b, reslinks c where  a.itemid = b.itemid " +
			"and b.restype = 3 and c.id = a.resid and a.resid=? and a.itemid=?";
	
	private String DEV_LOGS = "select b.itemid,b.itemname,a.resid,c.alias,c.snmpaddr as param, " +
			"to_char(a.ALARMTIME,'yyyy-mm-dd hh24:mi:ss') as ALARMTIME," +
			"a.alarmvalue,a.alarmstatus,"+
			"to_char(a.solvetime,'yyyy-mm-dd hh24:mi:ss') as solvetime,"+
			"a.solvevalue from sla_item_status a," +
			"item_define b, resnodes c whe re  a.itemid = b.itemid " +
			"and b.restype = 5 and c.id = a.resid and a.resid=? and a.itemid=?";
			
	

	public ArrayList getResStatusLogList(String resId,String resType,String itemId) {
		/**
		 * 返回的数据
		 */
		ArrayList Res = new ArrayList();		
        System.out.println("resId="+resId);
        System.out.println("resType="+resType);
        System.out.println("itemId="+itemId);
		SlaResStatusLogVO resVO = null;
        int intResId = 0;
        if(resId!=null&&!resId.equals("")){
        	intResId = Integer.parseInt(resId);
        }
        
        int intItemId = 0;
        if(itemId!=null&&!itemId.equals("")){
        	intItemId = Integer.parseInt(itemId);
        }
		/**
		 * 生成sql语句
		 */
		
		String sqlCmd = LINK_LOGS;
		if(resType.equals("5"))
			sqlCmd = DEV_LOGS;
		
		System.out.println("execut sql:"+sqlCmd);

		try {
			conn = ConnectionPools.getConnection("sla.oracle");			
			
			pstmt = conn.prepareStatement(sqlCmd);
			/**
			 * 执行查询
			 */
			pstmt.setInt(1, intResId);
			pstmt.setInt(2, intItemId);
			
			rs = pstmt.executeQuery();
			while (rs.next()) {
				resVO = new SlaResStatusLogVO();
				
				resVO.setItemName(rs.getString("itemname"));
				resVO.setResName(rs.getString("alias"));
				resVO.setParam(rs.getString("param"));				
				resVO.setAlarmTime(rs.getString("alarmtime"));
				resVO.setAlarmValue(rs.getString("alarmvalue"));
				resVO.setAlarmStatus(rs.getString("alarmstatus"));
				resVO.setResId(rs.getString("resId"));
				resVO.setItemId(rs.getString("itemId"));
				resVO.setSolveValue(rs.getString("solvevalue"));
				resVO.setSolveTime(rs.getString("solvetime"));
				DBEncodingUtil.fromDBobj(resVO);
				Res.add(resVO);

			}

		} catch (Exception e) {
			System.out.println("error in get res status:"+e.toString());
			e.printStackTrace();
		} finally {
			System.out.println("Records : " + Res.size());
			/**
			 * 关闭数据库
			 */
			closeConnection(rs, stmt, conn);
		}
		return Res;

	}

	
	public static void main(String[] args) {
		ResStatusLogDAO aa = new ResStatusLogDAO();
		ArrayList smile = aa.getResStatusLogList("11484","3","6");
		
	} 
}