package com.sitech.ismp.coll.database;

import java.util.HashMap;
import java.util.Vector;

import org.apache.log4j.Logger;

import com.sitech.ismp.coll.basic.TblATO_KPIDETAIL;

public class CollSqlServer2008 implements CollSqlServer2008MBean {
	
	private Logger logger = Logger.getLogger(CollSqlServer2008.class);

	public Vector<TblATO_KPIDETAIL> getSystem(HashMap<String, String> params) {
		Vector<TblATO_KPIDETAIL> result = new Vector<TblATO_KPIDETAIL>();
		CollSqlServer2008BySql sqlServer2008CollHandler = new CollSqlServer2008BySql(params);
		try {
			if (sqlServer2008CollHandler.init()) {
				result.addAll(sqlServer2008CollHandler.getConfig());
			}
		} catch (Exception e) {
			logger.error("Exception while CollSqlServer2008 getConfig", e);
		} finally {
			sqlServer2008CollHandler.destroy();
		}
		return result;
	}

	public Vector<TblATO_KPIDETAIL> getPerform(HashMap<String, String> params) {
		Vector<TblATO_KPIDETAIL> result = new Vector<TblATO_KPIDETAIL>();
		CollSqlServer2008BySql sqlServer2008CollHandler = new CollSqlServer2008BySql(params);
		try {
			if (sqlServer2008CollHandler.init()) {
				result.addAll(sqlServer2008CollHandler.getPerform());
			}
		} catch (Exception e) {
			logger.error("Exception while CollSqlServer2008 getPerform", e);
		} finally {
			sqlServer2008CollHandler.destroy();
		}
		return result;
	}

	/**
	 * jdbc:sqlserver://172.21.1.18:1433;databaseName=VCDB
	 * @param args
	 */
	public static void main(String[] args) {
		for (int i = 0; i < 1; i++) {
			HashMap<String, String> params = new HashMap<String, String>();
			params.put("IP_ADDR", "192.168.4.190");
			params.put("PORT", "1433");
			params.put("SID", "et_074gzgsnsr");
			params.put("USER_NAME", "sa");
			params.put("PASSWORD", "123456");
			CollSqlServer2008 coll = new CollSqlServer2008();
			Vector<TblATO_KPIDETAIL> result = coll.getPerform(params);
			for (TblATO_KPIDETAIL tk : result) {
				System.out.println("[" + tk.UNIT_ID + "][" +tk.KPI_ID + "][" +tk.KPI_VALUE + "][" +tk.CLL_TIME + "]");
//				System.out.println(tk.KPI_VALUE);
			}
			try {
				Thread.sleep(1000 * 60 * 2);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}

}