slaquerybynodedao.java

sla性能采集

package com.asiainfo.ainx.slaconf.dao;

import java.sql.SQLException;
import java.text.DecimalFormat;
import java.util.ArrayList;

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.SlaConfigVo;

public class SLAQueryByNodeDAO extends DaoBase {

	public static void main(String[] args) {
	}

	public ArrayList getSelectNodeName() {
		ArrayList Res = new ArrayList();
		String sqlCmd = Consts.RES_SEL_NODE_CORD;
		System.out.println(sqlCmd);
		SlaConfigVo rsvo = null;

		try {

			conn = ConnectionPools.getConnection(Consts.SLA_ORACLE);
			stmt = conn.createStatement();

			rs = stmt.executeQuery(sqlCmd);
			while (rs.next()) {
				rsvo = new SlaConfigVo();
				rsvo.setResId(rs.getString(1));
				rsvo.setResName(rs.getString(2));
				Res.add(rsvo);
				DBEncodingUtil.fromDBobj(rsvo);

			}

		} catch (Exception e) {
			System.out.println(e.toString());
		} finally {
			System.out.println("Records : " + Res.size());

			closeConnection(rs, stmt, conn);
		}
		return Res;
	}

	public ArrayList getSelectLinkName() {
		ArrayList Res = new ArrayList();
		String sqlCmd = Consts.RES_SEL_LINK_CORD;
		System.out.println(sqlCmd);
		SlaConfigVo rsvo = null;

		try {

			conn = ConnectionPools.getConnection(Consts.SLA_ORACLE);
			stmt = conn.createStatement();

			rs = stmt.executeQuery(sqlCmd);
			while (rs.next()) {
				rsvo = new SlaConfigVo();
				rsvo.setResId(rs.getString(1));
				rsvo.setResName(rs.getString(2));
				Res.add(rsvo);
				DBEncodingUtil.fromDBobj(rsvo);

			}

		} catch (Exception e) {
			System.out.println(e.toString());
		} finally {
			System.out.println("Records : " + Res.size());

			closeConnection(rs, stmt, conn);
		}
		return Res;
	}

	public ArrayList getAllSysname(String userId) {
		ArrayList alNodes = new ArrayList();
		SlaConfigVo v = null;
		int intUserId = 0;
        if(userId!=null && !userId.equals(""))
        	intUserId = Integer.parseInt(userId);
		try {
			conn = ConnectionPools.getConnection(Consts.SLA_ORACLE);

			sqlCmd = Consts.SELECT_ALL_SYSNAME;
			pstmt = conn.prepareStatement(sqlCmd);
			pstmt.setInt(1, intUserId);
			pstmt.setInt(2, intUserId);
			System.out.println(sqlCmd);
			rs = pstmt.executeQuery();
			while (rs.next()) {
				v = new SlaConfigVo();
				v.setResName(rs.getString("alias"));
				v.setResId(rs.getString("id"));
				DBEncodingUtil.fromDBobj(v);
				alNodes.add(v);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			this.closeConnection(rs, pstmt, conn);
		}
		return alNodes;
	}

	public ArrayList getIfByNode(String sysname) {
		ArrayList alNodes = new ArrayList();
		SlaConfigVo v = null;

		try {
			conn = ConnectionPools.getConnection(Consts.SLA_ORACLE);

			sqlCmd = Consts.SELECT_NODE_BYNAME;
			pstmt = conn.prepareStatement(sqlCmd);
			pstmt.setString(1, "%" + sysname + "%");
			System.out.println(sqlCmd);

			rs = pstmt.executeQuery();
			while (rs.next()) {
				v = new SlaConfigVo();
				v.setResId(rs.getString("id"));
				v.setResName(rs.getString("alias"));
				DBEncodingUtil.fromDBobj(v);
				alNodes.add(v);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			this.closeConnection(rs, pstmt, conn);
		}
		return alNodes;
	}

	public ArrayList getAllLinkName(String userId) {

		ArrayList Res = new ArrayList();
		String sqlCmd = Consts.RES_ALL_LINK_CORD;
		System.out.println(sqlCmd);
		SlaConfigVo rsvo = null;
		int intUserId = 0;
		if(userId!=null && !userId.equals(""))
        	intUserId = Integer.parseInt(userId);
		try {

			conn = ConnectionPools.getConnection(Consts.SLA_ORACLE);
			pstmt = conn.prepareStatement(sqlCmd);
			pstmt.setInt(1, intUserId);
			pstmt.setInt(2, intUserId);
			rs = pstmt.executeQuery();
			while (rs.next()) {
				rsvo = new SlaConfigVo();
				rsvo.setResId(rs.getString(1));
				rsvo.setResName(rs.getString(2));
				Res.add(rsvo);
				DBEncodingUtil.fromDBobj(rsvo);

			}

		} catch (Exception e) {
			System.out.println(e.toString());
		} finally {
			System.out.println("Records : " + Res.size());

			closeConnection(rs, pstmt, conn);
		}
		return Res;
	}

	public ArrayList getLinkByNode(String linkname) {
		ArrayList alNodes = new ArrayList();
		SlaConfigVo v = null;

		try {
			conn = ConnectionPools.getConnection(Consts.SLA_ORACLE);

			sqlCmd = Consts.SELECT_LINK_BYNAME;
			pstmt = conn.prepareStatement(sqlCmd);
			pstmt.setString(1, "%" + linkname + "%");

			rs = pstmt.executeQuery();
			while (rs.next()) {
				v = new SlaConfigVo();
				v.setResId(rs.getString("id"));
				v.setResName(rs.getString("alias"));
				DBEncodingUtil.fromDBobj(v);
				alNodes.add(v);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			this.closeConnection(rs, pstmt, conn);
		}
		return alNodes;
	}

	public String newSlaItems(String keys, String type, String itemtype,
			String up, String low, String uplevel, String lowlevel,String userid) {
		/**
		 * ���ص���ￄ1�7
		 */
		int count = 0;
		String restype = "";
		String[] keyStr = keys.split(",");
		itemtype = itemtype.substring(0, itemtype.lastIndexOf(","));
		System.out.println(itemtype);
		String[] itemStr = itemtype.split(",");
		sqlCmd = Consts.INSERT_INTO_SLA;
		if (type.equals("1")) {
			restype = "5";
		} else {
			restype = "3";
		}
		/**
		 * �����ݿ�l��
		 */
		System.out.println(sqlCmd);

		try {
			conn = ConnectionPools.getConnection(Consts.SLA_ORACLE);
			/**
			 * ================= sql ��䴦�?ʼ ============================
			 */
			/**
			 * ���� sql ��ￄ1�7
			 */
			/**
			 * ��b��ݿ��Ķ��ￄ1�7
			 */
			pstmt = conn.prepareStatement(sqlCmd);
			for (int i = 0; i < keyStr.length; i++) {
				for (int m = 0; m < itemStr.length; m++) {
					pstmt.setInt(1, Integer.parseInt(keyStr[i]));
					pstmt.setInt(2, Integer.parseInt(restype));
					pstmt.setInt(3, Integer.parseInt(itemStr[m]));
					pstmt.setString(4, up);
					pstmt.setString(5, low);
					pstmt.setString(6, uplevel);
					pstmt.setString(7, lowlevel);
					pstmt.setInt(8,Integer.parseInt(userid));
					pstmt.addBatch();
				}
			}

//			pstmt.executeUpdate();
			int[] countall = pstmt.executeBatch();
			count = countall.length;
			System.out.println(count);
			conn.commit();
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			this.closeConnection(rs, pstmt, conn);
		}
		return ";"+count;
	}

}