slaconfigtsdao.java

sla性能采集

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

	}

	public int getSlaCountForLink() {
		/**
		 * 
		 */
		ArrayList Res = new ArrayList();
		

		/**
		 * 
		 */
		String sqlCmd = Consts.RES_COUNT_SLA_LINK;
		System.out.println(sqlCmd);
		int count = 0;

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

				count = rs.getInt(1);

			}

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

	public int getSlaCountForNode() {
		/**
		 * 
		 */
		ArrayList Res = new ArrayList();
		

		/**
		 * 
		 */
		String sqlCmd = Consts.RES_COUNT_SLA_NODE;
		System.out.println(sqlCmd);
		int count = 0;

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

				count = rs.getInt(1);

			}

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

	public String getSlaForLink() {
		/**
		 * 
		 */
		ArrayList Res = new ArrayList();
		

		/**
		 * 
		 */
		String sqlCmd = Consts.RES_SLAS_LINK;
		System.out.println(sqlCmd);
		String result = "";

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

				result += rs.getString(1);

			}

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

	public String getSlaForNode() {
		/**
		 *
		 */
		ArrayList Res = new ArrayList();
		

		/**
		 * 
		 */
		String sqlCmd = Consts.RES_SLAS_NODE;
		System.out.println(sqlCmd);
		String result = "";

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

				result += rs.getString(1);

			}

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

		/**
		 * 
		 */
		String sqlCmd = Consts.RES_ALL_LINK_SLA;
		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));
				rsvo.setItemUnit(rs.getString(3));
				DBEncodingUtil.fromDBobj(rsvo);
				Res.add(rsvo);

			}

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

		/**
		 * 
		 */
		String sqlCmd = Consts.RES_ALL_NODE_SLA;
		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));
				rsvo.setItemUnit(rs.getString(3));
				DBEncodingUtil.fromDBobj(rsvo);
				Res.add(rsvo);

			}

		} catch (Exception e) {
			System.out.println(e.toString());
		} finally {
			System.out.println("Records : " + Res.size());
			/**
			 * 
			 */
			closeConnection(rs, stmt, conn);
		}
		return Res;
	}
    public int updateSlaItems(String[] options,String type)
    {
    	/**
		 * ���ص���ￄ1�7
		 */
		int count = 0;
		sqlCmd = Consts.DELETE_FROM_SLA;
		String sqlInsert = Consts.INSERT_INTO_SLA;
		String resid="";
		String itemid="";
		String restype="";
		String up="";
		String low="";
		String uplevel="";
		String lowlevel="";
		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);
			int intrestype = Integer.parseInt(restype);
			pstmt.setInt(1, intrestype);
			pstmt.executeUpdate();
			
			
			conn.commit();
			/**
			 * insert!
			 */
			if(options == null)
				return 0;
			pstmt = conn.prepareStatement(sqlInsert);
			for (int i = 0; i < options.length; i++) {
               String[] node = options[i].split(";");
               resid=node[0];
               itemid=node[1];
               up=node[2];
               if(up == null || up.equals(""))
            	   continue;
               double dup = Integer.parseInt(up);
               //dup = dup/ 100;
               DecimalFormat df = new DecimalFormat("0.00"); 
			   up = df.format(dup);
               low=node[4];
               double dlow = Integer.parseInt(low);
               //dlow = dlow / 100;
               low = df.format(dlow);
               uplevel=node[3];
               lowlevel=node[5];
               if((!up.equals(""))&&(!low.equals(""))&&(!uplevel.equals("-1"))&&(!lowlevel.equals("-1")))
               {
				pstmt.setString(1, resid);
				pstmt.setString(2, restype);
				pstmt.setString(3, itemid);
				pstmt.setString(4, up);
				pstmt.setString(5, low);
				pstmt.setString(6, uplevel);
				pstmt.setString(7, lowlevel);

				/**
				 * ================= sql ��䴦����� ============================
				 */

				/**
				 * ִ�в�ѯ����
				 */
				count=pstmt.executeUpdate();
				
               }
			}
			
			conn.commit();
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			this.closeConnection(rs, pstmt,conn);
		}
		return count;
    }
	public static void main (String args[])
	{
		SlaConfigTsDAO hi = new SlaConfigTsDAO();
		//hi.getAllNodeSlaInfo();
	}
}