slaconfigtsdao.java

sla性能采集

package com.asiainfo.ainx.slaconf.dao;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.DecimalFormat;
import java.util.ArrayList;
import java.util.Hashtable;

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

import com.asiainfo.ainx.slaconf.util.Consts;
import com.asiainfo.ainx.slaconf.util.DBEncodingUtil;
import com.asiainfo.ainx.slaconf.vo.SlaConfigLinkVO;
import com.asiainfo.ainx.slaconf.vo.SlaConfigNodeVO;
import com.asiainfo.ainx.slaconf.vo.SlaConfigVo;
import com.asiainfo.ainx.slaconf.vo.SlaItemVO;
/**
 * 
 * @author zhaotj
 *
 */
public class SlaConfigTsDAO extends DaoBase {
	/**
	 * 
	 * @param nodeid
	 * @return
	 */
	public ArrayList getNodeSlaInfoByNodeids(String[] nodeid) {
		/**
		 *
		 */
		ArrayList Res = new ArrayList();
		String subset = "(";
		for (int i = 0; i < nodeid.length - 1; i++) {
			subset += nodeid[i] + ",";
		}
		subset += nodeid[nodeid.length - 1] + ")";
				
		/**
		 * 
		 */
		sqlCmd = Consts.RES_NODE;
		sqlCmd +=subset;
		String subsql = Consts.RES_SLA_BY_ID;
		System.out.println(sqlCmd);
		try {
			SlaConfigNodeVO resVO = null;
			SlaItemVO slaVO = null;

			conn = ConnectionPools.getConnection(Consts.SLA_ORACLE);
			stmt = conn.createStatement();
			/**
			 * 
			 */
			rs = stmt.executeQuery(sqlCmd);
			while (rs.next()) {

				resVO = new SlaConfigNodeVO();
				resVO.setResId(rs.getString("res_id"));
				resVO.setResName(rs.getString("sysname"));
				resVO.setSnmpaddr(rs.getString("snmpaddr"));
				resVO.setAlias(rs.getString("alias"));
				/**
				 *
				 */
				int resid = rs.getInt("res_id");
				ResultSet subrs = null;
				PreparedStatement subpstmt = null;
				Hashtable slatable = null;
				try {
					subpstmt = conn.prepareStatement(subsql);
					subpstmt.setInt(1, resid);
					subrs = subpstmt.executeQuery();
					slatable = new Hashtable();
					while (subrs.next()) {
						slaVO = new SlaItemVO();
						slaVO.setLower(subrs.getString(3));
						System.out.println(subrs.getString(3));
						slaVO.setUpper(subrs.getString(4));
						slaVO.setLowlevel(subrs.getString(5));
						slaVO.setUplevel(subrs.getString(6));
						String id = subrs.getString(2);
						slatable.put(id, slaVO);

					}
				} catch (Exception e) {
					System.out.println(e.toString());
				} finally {
					super.closeRs(subrs);
					super.closePStmt(subpstmt);
				}
				
				/**
				 * 
				 */
				resVO.setSlanodes(slatable);
				DBEncodingUtil.fromDBobj(resVO);
				Res.add(resVO);

			}

		} catch (Exception e) {
			System.out.println(e.toString());
		} finally {
			System.out.println("Records : " + Res.size());
			/**
			 * 
			 */
			closeConnection(rs, stmt, conn);
		}
		return Res;

	}
	public ArrayList getAllNodeSlaInfo(String userid) {
		/**
		 * 
		 */
		ArrayList Res = new ArrayList();
		/**
		 * 
		 */
		sqlCmd = Consts.RES_ALL_NODE;
		String subsql = Consts.RES_SLA_BY_ID;
		System.out.println(sqlCmd);
		int intUserId = 0;
		if(userid != null && !userid.equals(""))
			intUserId = Integer.parseInt(userid);
		try {
			SlaConfigNodeVO resVO = null;
			SlaItemVO slaVO = null;
			conn = ConnectionPools.getConnection(Consts.SLA_ORACLE);
			pstmt = conn.prepareStatement(sqlCmd);
			pstmt.setInt(1, intUserId);
			/**
			 * 
			 */
			rs = pstmt.executeQuery();
			while (rs.next()) {

				resVO = new SlaConfigNodeVO();
				resVO.setResId(rs.getString("res_id"));
				resVO.setResName(rs.getString("sysname"));
				resVO.setSnmpaddr(rs.getString("snmpaddr"));
				resVO.setAlias(rs.getString("alias"));
				/**
				 * 
				 */
				int resid = rs.getInt("res_id");
				ResultSet subrs = null;
				PreparedStatement subpstmt = null;
				Hashtable slatable = null;
				try {
					subpstmt = conn.prepareStatement(subsql);
					subpstmt.setInt(1, resid);
					subpstmt.setInt(2, intUserId);
					subrs = subpstmt.executeQuery();
					slatable = new Hashtable();
					while (subrs.next()) {
						slaVO = new SlaItemVO();
						slaVO.setLower(subrs.getString(3));
						slaVO.setUpper(subrs.getString(4));
						slaVO.setLowlevel(subrs.getString(5));
						slaVO.setUplevel(subrs.getString(6));
						String id = subrs.getString(2);
						slatable.put(id, slaVO);
                        
					}
				} catch (Exception e) {
					System.out.println(e.toString());
				} finally {
					super.closeRs(subrs);
					super.closePStmt(subpstmt);
				}
				
				/**
				 * 
				 */
				resVO.setSlanodes(slatable);
				DBEncodingUtil.fromDBobj(resVO);
				Res.add(resVO);
			}

		} catch (Exception e) {
			System.out.println(e.toString());
		} finally {
			System.out.println("Records : " + Res.size());
			/**
			 * 
			 */
			closeConnection(rs, pstmt, conn);
		}
		return Res;

	}
	public ArrayList getLinkASlaInfoByLink(String[] linkid) {
		/**
		 * 
		 */
		ArrayList Res = new ArrayList();
		String subset = "(";
		for (int i = 0; i < linkid.length - 1; i++) {
			subset += linkid[i] + ",";
		}
		subset += linkid[linkid.length - 1] + ")";
		
		/**
		 * 
		 */
		sqlCmd = Consts.RES_LINK;
		sqlCmd += subset;
		String subsql = Consts.RES_SLA_BY_ID;
		System.out.println(sqlCmd);
		try {
			SlaConfigLinkVO resVO = null;
			SlaItemVO slaVO = null;
			conn = ConnectionPools.getConnection(Consts.SLA_ORACLE);
			stmt = conn.createStatement();
			/**
			 *
			 */
			rs = stmt.executeQuery(sqlCmd);
			while (rs.next()) {

				resVO = new SlaConfigLinkVO();
				resVO.setResId(rs.getString("res_id"));
				resVO.setResName(rs.getString("alias"));
				resVO.setFrom_NodeName(rs.getString("from_sysname"));
				resVO.setFrom_IFname(rs.getString("from_ifname"));
				resVO.setBandWidth(rs.getString("bandwidth"));
				/**
				 * 
				 */
				int resid = rs.getInt("res_id");
				ResultSet subrs = null;
				PreparedStatement subpstmt = null;
				Hashtable slatable = null;
				try {
					subpstmt = conn.prepareStatement(subsql);
					subpstmt.setInt(1, resid);
					subrs = subpstmt.executeQuery();
					slatable = new Hashtable();
					while (subrs.next()) {
						slaVO = new SlaItemVO();
						slaVO.setLower(subrs.getString(3));
						slaVO.setUpper(subrs.getString(4));
						slaVO.setLowlevel(subrs.getString(5));
						slaVO.setUplevel(subrs.getString(6));
						String id = subrs.getString(2);
						slatable.put(id, slaVO);

					}
				} catch (Exception e) {
					System.out.println(e.toString());
				} finally {
					super.closeRs(subrs);
					super.closePStmt(subpstmt);
				}
				
				/**
				 * 
				 */
				resVO.setSlanodes(slatable);
				DBEncodingUtil.fromDBobj(resVO);
				Res.add(resVO);
			}

		} catch (Exception e) {
			System.out.println(e.toString());
		} finally {
			System.out.println("Records : " + Res.size());
			/**
			 *
			 */
			closeConnection(rs, stmt, conn);
		}
		return Res;

	}
	public ArrayList getALLLinkSlaInfo(String userid) {
		/**
		 * 
		 */
		ArrayList Res = new ArrayList();
		

		SlaConfigLinkVO resVO = null;
		SlaItemVO slaVO = null;
		int intUserId = 0;
		if(userid != null && !userid.equals(""))
			intUserId = Integer.parseInt(userid);
		/**
		 * 
		 */
		sqlCmd = Consts.RES_ALL_LINK;
		String subsql = Consts.RES_SLA_BY_ID;
		System.out.println(sqlCmd);
		try {
			conn = ConnectionPools.getConnection(Consts.SLA_ORACLE);
			pstmt = conn.prepareStatement(sqlCmd);
			pstmt.setInt(1, intUserId);
			/**
			 * 
			 */
			rs = pstmt.executeQuery();
			while (rs.next()) {

				resVO = new SlaConfigLinkVO();
				resVO.setResId(rs.getString("res_id"));
				resVO.setResName(rs.getString("name"));
				resVO.setFrom_NodeName(rs.getString("from_sysname"));
				resVO.setFrom_IFname(rs.getString("from_ifname"));
				resVO.setBandWidth(rs.getString("bandwidth"));
				/**
				 * 
				 */
				int resid = rs.getInt("res_id");
				ResultSet subrs = null;
				PreparedStatement subpstmt = null;
				Hashtable slatable = null;
				try {
					subpstmt = conn.prepareStatement(subsql);
					subpstmt.setInt(1, resid);
					subpstmt.setInt(2, intUserId);
					subrs = subpstmt.executeQuery();
					slatable = new Hashtable();
					while (subrs.next()) {
					    System.out.println(resid);
						slaVO = new SlaItemVO();
						slaVO.setLower(subrs.getString(3));
						slaVO.setUpper(subrs.getString(4));
						slaVO.setLowlevel(subrs.getString(5));
						slaVO.setUplevel(subrs.getString(6));
						String id = subrs.getString(2);
						slatable.put(id, slaVO);

					}
				} catch (Exception e) {
					System.out.println(e.toString());
				} finally {
					super.closeRs(subrs);
					super.closePStmt(subpstmt);
				}
				
				/**
				 *
				 */
				resVO.setSlanodes(slatable);
				DBEncodingUtil.fromDBobj(resVO);
				Res.add(resVO);
			}

		} catch (Exception e) {
			System.out.println(e.toString());