package com.sitech.ismp.coll.centercoll;

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

import org.apache.log4j.Logger;

import com.sitech.ismp.coll.CollBase;
import com.sitech.ismp.coll.basic.TblATO_KPIDETAIL;
import com.sitech.util.DES3;
import com.sitech.util.Formater;
import com.sitech.util.upload.RomoteController;
import com.sitech.util.upload.SSHThread;
import com.sitech.util.upload.TelnetThread;

public class CollInformixWithCMD {

	private Logger logger = Logger.getLogger("COLL");
	private String KBP_ID = "10-11-33";
	private String INFORMIXSERVER;
	private String CMD_DIR;
	private String PREFILE_PATH = "";
	private String IP_ADDR;
	private boolean IS_DIR = true;
	// private String OS_Type = "windows";
	private String Version = "9";
	private boolean isConnect;
	private RomoteController tt = null;

	public Vector getConfig(HashMap params) {
		logger.info("into collinformix getConfig");
		initParams(params);
		CollBase collResult = new CollBase();
		String config_PRE_UNITID = this.KBP_ID + "-10";
		collResult.addKPI(config_PRE_UNITID + ":" + this.INFORMIXSERVER + "-total", "CM-00-03-001-01", this.INFORMIXSERVER);
		try {
			if (IS_DIR) {
				// 采集数据库版本和状态 onstat -f
				String informix_version_cmd = PREFILE_PATH + this.CMD_DIR
						+ System.getProperty("file.separator") + "onstat -f";
				Vector version_v = this.execute(informix_version_cmd);
				String vesrion = "unkown";
				String memory = "0";
				if (version_v != null && version_v.size() > 0) {
					System.out.println("size is not 0");
					for (int i = 0; i < version_v.size(); i++) {
						String res = (String) version_v.get(i);
						if (res.indexOf("Version") >= 0) {
							// 
							String[] status = res.split("--");
							if (status != null && status.length > 0) {
								vesrion = status[0];
								memory = status[3];
							}
						}
					}
				} else {
					System.out.println("size is 0");
				}
				// CM-00-03-001-02 数据库版本
				collResult.addKPI(config_PRE_UNITID + ":" + this.INFORMIXSERVER
						+ "-total", "CM-00-03-001-02", vesrion);
				// CM-00-03-002-01 共享内存大小
				collResult.addKPI(config_PRE_UNITID + ":" + this.INFORMIXSERVER
						+ "-total", "CM-00-03-002-01", Integer.parseInt((memory
						.substring(0, memory.length() - 6)).trim())
						/ 1024 + "");
				// CM-00-03-001-11 数据库监听地址
				collResult.addKPI(config_PRE_UNITID + ":" + this.INFORMIXSERVER + "-total", "CM-00-03-001-11", this.IP_ADDR);
			}

			// 未备份逻辑日志数 onstat -l
			try {
				String unbacklognum_cmd = PREFILE_PATH + this.CMD_DIR + System.getProperty("file.separator") + "onstat -l  | grep active";
				Vector unbacklognum_v = this.execute(unbacklognum_cmd);
                //总数
				String totalnum = collResult.split((String) unbacklognum_v.elementAt(0), 0);
                String backlognum_cmd = PREFILE_PATH + this.CMD_DIR + System.getProperty("file.separator") + "onstat -l  | grep 'U-B----'";
                Vector backlognum_v = this.execute(backlognum_cmd);
                //以备份数量
                int backupNum = backlognum_v.size();
				// PM-00-03-005-03 未备份逻辑日志数
                //未备份数量
                String unbackNum = (Integer.parseInt(totalnum)-backupNum)+"";
//                logger.info("totoalNUM"+totalnum);
//                logger.info("unBackNum"+unbackNum);
//                logger.info("BackNum"+backupNum);
				config_PRE_UNITID = this.KBP_ID + "-10";
				collResult.addKPI(config_PRE_UNITID + ":" + this.INFORMIXSERVER + "-total", "PM-00-03-005-03", unbackNum);

                // PM-00-03-005-23 已备份逻辑日志数百分比
                collResult.addKPI(config_PRE_UNITID + ":" + this.INFORMIXSERVER + "-total", "PM-00-03-005-23", Formater.formatDecimalKpivalue(String.valueOf(Formater.getByScale((((float)backupNum / Integer.valueOf(totalnum))*100)+"" ,2))));

			} catch (Exception e) {
				logger.error("coll informix un bakced log number fail, db_server = " + this.INFORMIXSERVER);
				e.printStackTrace();
			}

			// 虚拟段个数 onstat -g seg
			try {
				String informix_seg_cmd = PREFILE_PATH + this.CMD_DIR + System.getProperty("file.separator") + "onstat -g seg";
				Vector seg_v = this.execute(informix_seg_cmd);
				if (seg_v != null && seg_v.size() > 0) {
					int size = 0;
					float rate = 0;
					for (int i = 0; i < seg_v.size(); i++) {
						String res = (String) seg_v.get(i);
						if (res.indexOf(" V ") != -1) {
							size += 1;
						}
						if (res.indexOf("Total:") > -1) {
							String totalsize = split(res, 3);
							String user8k = split(res, 6);
							rate = Float.parseFloat(Formater
									.formatDecimalKpivalue((Float
											.parseFloat(user8k) * 8)
											* 100
											/ Float.parseFloat(totalsize)
											+ ""));
						}
					}

					// PM-00-03-008-06 虚拟段个数
					collResult.addKPI(config_PRE_UNITID + ":"
							+ this.INFORMIXSERVER + "-total",
							"PM-00-03-008-06", "" + size);
					// PM-00-03-009-07 共享内存使用百分比
					collResult.addKPI(config_PRE_UNITID + ":"
							+ this.INFORMIXSERVER + "-total",
							"PM-00-03-009-07", "" + rate);
				} else {
					System.out.println("onstat_g_seg = " + seg_v.size());
				}
			} catch (Exception e) {
				e.printStackTrace();
			}

			// ready队列 onstat -g rea|grep ready
			try {
				config_PRE_UNITID = this.KBP_ID + "-10";
				String informix_rea_cmd = PREFILE_PATH + this.CMD_DIR
						+ System.getProperty("file.separator")
						+ "onstat -g rea";
				Vector rea_v = this.execute(informix_rea_cmd);
				// logger.info("informix_rea_cmd " + informix_rea_cmd);
				// logger.info("onstat_g_rea = " + rea_v.size());
				int num = 0;
				if (rea_v != null && rea_v.size() > 0) {
					for (int i = 0; i < rea_v.size(); i++) {
						String res = (String) rea_v.get(i);
						if (res.indexOf("ready") > -1) {
							num++;
						}
					}
				}
				collResult.addKPI(config_PRE_UNITID + ":" + this.INFORMIXSERVER
						+ "-total", "PM-00-03-008-08", "" + num);
			} catch (Exception e) {
				e.printStackTrace();
			}

			// Chunk down onstat -d|grep PD
			try {
				config_PRE_UNITID = this.KBP_ID + "-10";
				String informix_D_cmd = PREFILE_PATH + this.CMD_DIR
						+ System.getProperty("file.separator") + "onstat -d";
				Vector D_v = this.execute(informix_D_cmd);
				// logger.info("informix_D_cmd " + informix_D_cmd);
				// logger.info("onstat_f = " + D_v.size());
				int num = 0;
				if (D_v != null && D_v.size() > 0) {
					for (int i = 0; i < D_v.size(); i++) {
						String res = (String) D_v.get(i);
						if (res.indexOf("PD") > -1) {
							num++;
						}
					}
				}
				collResult.addKPI(config_PRE_UNITID + ":" + this.INFORMIXSERVER
						+ "-total", "PM-00-03-008-10", "" + num);
			} catch (Exception e) {
				e.printStackTrace();
			}
		} catch (Exception ex) {
			logger.error("get informix error.", ex);
		} finally {
			tt.close();
		}
		return collResult.getKPISet();
	}

	/**
	 * 采集表空间指标 CM-00-03-003-01 表空间名称 CM-00-03-003-02 表空间大小 PM-00-03-003-03
	 * 表空间已使用大小 PM-00-03-904-01 表空间剩余大小 PM-00-03-004-01 表空间使用率
	 * 
	 * @param params
	 * @return
	 */
	public Vector getTabSpace(HashMap params) {
		String config_PRE_UNITID = this.KBP_ID + "-11";
		CollBase collResult = new CollBase();
		initParams(params);
		// 采集表空间 onstat -d
		try {
			String informix_device_cmd = PREFILE_PATH + this.CMD_DIR
					+ System.getProperty("file.separator") + "onstat -d";
			Vector Chunks_v = this.execute(informix_device_cmd);

			int db_size = 0; // 得到dbspace数量大小
			int dbspace_end_index = 0; // dbspace统计到上一行
			int dbspace_begin_index = Chunks_v.size(); // 从下面第2行开始是dbspace数据

			if (Chunks_v != null && Chunks_v.size() > 0) {
				for (int i = 0; i < Chunks_v.size(); i++) {
					String res = (String) Chunks_v.get(i);
					if (res.indexOf("active,") != -1) {
						String db_names_num = split(res, 0);
						try {
							db_size = Integer.parseInt(db_names_num);
						} catch (Exception e) {
							e.printStackTrace();
						}
						dbspace_end_index = i;
						break;
					}
					if (res.indexOf("Dbspaces") != -1) {
						dbspace_begin_index = i + 2;
					}
				}
			}
			logger.info("db_size " + db_size);
			String[][] dbnames = null;
			if (db_size > 0) {
				dbnames = new String[db_size][5];
			}
			int j = 0;
			int dbsize_begin_index = Chunks_v.size();
			logger.info("dbspace_begin_index " + dbspace_begin_index);
			logger.info("dbspace_end_index " + dbspace_end_index);
			if (Chunks_v != null && Chunks_v.size() > 0) {
				for (int i = 0; i < Chunks_v.size(); i++) {
					String res = (String) Chunks_v.get(i);
					// 初始化dbspace name
					if (dbspace_begin_index <= i && i < dbspace_end_index) {
						String dbspace_index = split(res, 1);
						String dbspace_name = "";
						if (this.Version != null && this.Version.equals("9")) {
							dbspace_name = split(res, 8);
						} else if (this.Version != null
								&& this.Version.equals("11")) {
							dbspace_name = split(res, 9);
						} else {
							dbspace_name = split(res, 7);
						}
						dbnames[j][0] = dbspace_index;
						dbnames[j][1] = dbspace_name;
						dbnames[j][2] = "0";
						dbnames[j][3] = "0";
						dbnames[j][4] = "0";
						j += 1;
					}
					// 初始化各个表空间的大小
					logger.info("i " + i);
					if (i > dbspace_end_index) {
						if (res.indexOf("Chunks") != -1) {
							dbsize_begin_index = i + 2;
							logger.info("dbsize_begin_index "
									+ dbsize_begin_index);
						}
						if (i >= dbsize_begin_index) {
							String db_index = split(res, 2);
							String dbchunk_size = split(res, 4);
							String dbchunk_free = split(res, 5);
							String dbchunk_status = split(res, 6);
							this.setChunkSize(dbnames, db_index, dbchunk_size);
							this.setfreeSize(dbnames, db_index, dbchunk_free);
							this.setChunkStatus(dbnames, db_index,
									dbchunk_status);
						}
					}
				}
			}

			for (int i = 0; i < dbnames.length; i++) {
				// CM-00-03-003-01 表空间名称
				collResult
						.addKPI(config_PRE_UNITID + ":" + this.INFORMIXSERVER
								+ "-" + dbnames[i][1], "CM-00-03-003-01",
								dbnames[i][1]);
				// CM-00-03-003-02 表空间大小
				collResult
						.addKPI(config_PRE_UNITID + ":" + this.INFORMIXSERVER
								+ "-" + dbnames[i][1], "CM-00-03-003-02",
								dbnames[i][2]);
				// PM-00-03-904-01 表空间剩余大小
				collResult
						.addKPI(config_PRE_UNITID + ":" + this.INFORMIXSERVER
								+ "-" + dbnames[i][1], "PM-00-03-904-01",
								dbnames[i][3]);
				// FM-00-03-001-02 表空间状态
				collResult
						.addKPI(config_PRE_UNITID + ":" + this.INFORMIXSERVER
								+ "-" + dbnames[i][1], "FM-00-03-001-02",
								dbnames[i][4]);
				try {
					float useRate = ((Float.parseFloat(dbnames[i][2]) - Float
							.parseFloat(dbnames[i][3]))
							/ Float.parseFloat(dbnames[i][2]) * 100);
					// PM-00-03-004-01 表空间使用率
					collResult.addKPI(config_PRE_UNITID + ":"
							+ this.INFORMIXSERVER + "-" + dbnames[i][1],
							"PM-00-03-004-01", Formater
									.formatDecimalKpivalue(String
											.valueOf(useRate)));
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			tt.close();
		}

		return collResult.getKPISet();
	}

	/**
	 * 采集数据库状态
	 * 
	 * @param params
	 * @return
	 */
	public Vector getDbStatus(HashMap params) {
		initParams(params);
		CollBase collResult = new CollBase();
		try {
			// 数据库状态 onstat -p
			String config_PRE_UNITID = this.KBP_ID + "-10";
			String informix_version_cmd = PREFILE_PATH + this.CMD_DIR
					+ System.getProperty("file.separator") + "onstat -p";
			Vector version_v = this.execute(informix_version_cmd);
			String state = "DOWN";
			// logger.info("step 1 ："+state);
			if (version_v != null && version_v.size() > 0) {
				// logger.info("step 2 ："+state);
				for (int i = 0; i < version_v.size(); i++) {
					String res = (String) version_v.get(i);
					if (res.indexOf("Version") >= 0) {
						String[] status = res.split("--");
						if (status != null && status.length > 0) {
							state = status[1].trim();
						}
					}
				}
			}
			// FM-00-03-001-09 (informix)数据库状态
			collResult.addKPI(config_PRE_UNITID + ":" + this.INFORMIXSERVER
					+ "-total", "FM-00-03-001-09", state);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			tt.close();
		}
		return collResult.KPISet;
	}

	public Vector getPerformance(HashMap params) {
		// logger.info("into collinformix getPerformance");
		initParams(params);
		CollBase collResult = new CollBase();
		String config_PRE_UNITID = this.KBP_ID + "-10";
		try {
			if (IS_DIR) {
				// 锁数量 onstat -k
				// PM-00-03-008-01 锁数量
				// PM-00-03-008-02 锁等待数量
				try {
					String locknum_cmd = PREFILE_PATH + this.CMD_DIR
							+ System.getProperty("file.separator")
							+ "onstat -k | grep active";
					// String locknum_cmd = "sh informixbin/locknum.sh " +
					// this.CMD_DIR + " " + this.INFORMIXSERVER;
					// logger.info(locknum_cmd);
					Vector locknum_v = this.execute(locknum_cmd);
					String lockRst = (String) locknum_v.elementAt(0);
					// PM-00-03-008-01 锁数量 这里得到的是active现有活动的锁数量
					collResult.addKPI(config_PRE_UNITID + ":"
							+ this.INFORMIXSERVER + "-perf", "PM-00-03-008-01",
							collResult.split(lockRst, 0));
				} catch (Exception e) {
					logger.error("coll informix lock number fail, db_server = "
							+ this.INFORMIXSERVER);
					e.printStackTrace();
				}

				// 死锁数量 onstat -p
				try {
					String deadlks_cmd = PREFILE_PATH + this.CMD_DIR
							+ System.getProperty("file.separator")
							+ "onstat -p";
					Vector deadlks_v = this.execute(deadlks_cmd);
					String deadlks = "0";
					if (deadlks_v != null && deadlks_v.size() > 0) {
						for (int i = 0; i < deadlks_v.size(); i++) {
							String res = (String) deadlks_v.get(i);
							if (res != null
									&& res.trim().indexOf("deadlks") >= 0) {
								res = (String) deadlks_v.get(i + 1);
								deadlks = split(res, 3);
							}
							if (res.trim().indexOf("dskreads") >= 0) {
								res = (String) deadlks_v.get(i + 1);
								if (res != null) {
									String memory_hit_rate = split(res, 3);
									// PM-00-03-001-02 共享内存读命中率
									collResult.addKPI(config_PRE_UNITID + ":"
											+ this.INFORMIXSERVER + "-total",
											"PM-00-03-001-02", memory_hit_rate);
								}
							}
						}
					}
					// PM-00-03-008-01 死锁数量
					config_PRE_UNITID = this.KBP_ID + "-10";
					collResult.addKPI(config_PRE_UNITID + ":"
							+ this.INFORMIXSERVER + "perf", "PM-00-03-008-07",
							deadlks);
				} catch (Exception e) {
					logger
							.error("coll informix deadlock number fail, db_server = "
									+ this.INFORMIXSERVER);
					e.printStackTrace();
				}

				// session数 onstat -u
				// PM-00-03-009-03 最大会话数量
				try {
					String sessionnum_cmd = PREFILE_PATH + this.CMD_DIR
							+ System.getProperty("file.separator")
							+ "onstat -u | grep active";
					Vector sessionnum_v = this.execute(sessionnum_cmd);
					String sessionnum = collResult.split((String) sessionnum_v
							.elementAt(0), 0);
					// PM-00-03-009-03 session数
					collResult.addKPI(config_PRE_UNITID + ":"
							+ this.INFORMIXSERVER + "-perf", "PM-00-03-009-03",
							"" + sessionnum);
				} catch (Exception e) {
					logger.error("coll informix session fail,db_server = "
							+ this.INFORMIXSERVER, e);
				}

			}
		} catch (Exception ex) {
			logger.info("coll informix performance err.", ex);
		} finally {
			tt.close();
		}
		return collResult.getKPISet();
	}

	/**
	 * 初始化执行命令用到的相关参数 INFORMIXSERVER CMD_DIR informix的bin路径 ID_ADDR（IP_ADDR）
	 * informix数据库的IP VERSION informix数据库版本 11 or 9
	 * 
	 * @param params
	 */
	public void initParams(HashMap params) {
		this.INFORMIXSERVER = (String) params.get("INFORMIXSERVER");
		this.CMD_DIR = (String) params.get("CMDDIR");
		this.IP_ADDR = (String) params.get("IPADDR");
		this.Version = (String) params.get("VERSION");
		this.PREFILE_PATH = (String) params.get("PREFILEPATH");
		String userName = (String) params.get("USERNAME");
		String passWord = (String) params.get("PASSWORD");
		String protocol = (String) params.get("PROTOCOL");
		if (protocol != null && "telnet".equals(protocol)) {
			tt = new TelnetThread(IP_ADDR, 23, userName, passWord);
		} else {
			tt = new SSHThread(IP_ADDR, 22, userName, passWord);
		}
		if (PREFILE_PATH != null && !"".equals(PREFILE_PATH)) {
			PREFILE_PATH = ". " + PREFILE_PATH + ";";
		}
		try {
			tt.initial();
			isConnect = true;
		} catch (Exception e) {
			isConnect = false;
		}

	}

	/**
	 * 执行下发的查询命令
	 */
	private Vector execute(String shellCommand) {
		logger.info("exe remote shell : " + shellCommand);
		Vector result = tt.getResultAsVector(shellCommand);
		logger.info("result : ");
		if (result != null) {
			for (int i = 0; i < result.size(); i++) {
				logger.info("" + result.elementAt(i));
			}
		}
		return result;
	}

	public String split(String str, int pos) {
		StringTokenizer st = new StringTokenizer(str);
		Vector values = new Vector();
		while (st.hasMoreTokens()) {
			values.add(st.nextToken());
		}
		if (pos >= 0 && pos < values.size()) {
			return (String) values.elementAt(pos);
		}
		if (pos == -1) {
			return (String) values.elementAt(values.size() - 1);
		}
		return "";
	}

	public void setChunkSize(String[][] dbnames, String db_index,
			String chunkSzie) {
		int i = 0;
		for (; i < dbnames.length; i++) {
			String index = dbnames[i][0];
			if (index.equals(db_index)) {
				break;
			}
		}
		if (i < dbnames.length) {
			String size = dbnames[i][2];
			try {
				long size_int = Long.parseLong(size);
				long chunkSzie_int = Long.parseLong(chunkSzie) / 1024;
				long total_size = size_int + chunkSzie_int;
				logger.info("size_int chunkSzie_int total_size " + size_int
						+ " " + chunkSzie_int + " " + total_size);
				dbnames[i][2] = "" + total_size;
			} catch (Exception e) {
				logger.info("get chunksize error");
				e.printStackTrace();
			}
		}
	}

	public void setfreeSize(String[][] dbnames, String db_index, String free) {
		int i = 0;
		for (; i < dbnames.length; i++) {
			String index = dbnames[i][0];
			if (index.equals(db_index)) {
				break;
			}
		}
		if (i < dbnames.length) {
			String size = dbnames[i][3];
			try {
				long size_int = Long.parseLong(size);
				long free_int = Long.parseLong(free) / 1024;
				long total_size = size_int + free_int;
				dbnames[i][3] = "" + total_size;
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

	public void setChunkStatus(String[][] dbnames, String db_index,
			String status) {
		int i = 0;
		for (; i < dbnames.length; i++) {
			String index = dbnames[i][0];
			if (index.equals(db_index)) {
				break;
			}
		}
		if (i < dbnames.length) {
			String size = dbnames[i][4];
			try {
				// int size_int = Integer.parseInt(size);
				// int free_int = Integer.parseInt(free);
				// int total_size = size_int + free_int;
				dbnames[i][4] = "" + status;
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

	public Vector getCheckpoint(HashMap params) {
		initParams(params);
		CollBase collResult = new CollBase();
		String config_PRE_UNITID = this.KBP_ID + "-17";
		// checkpoint持续时间，informix5分钟一次，所以监控时间间隔应该小于5分钟 onstat -m
		try {
			String informix_m_cmd = PREFILE_PATH + this.CMD_DIR
					+ System.getProperty("file.separator") + "onstat -m";
			Vector m_v = this.execute(informix_m_cmd);
			if (m_v != null && m_v.size() > 0) {
				String time = "";
				for (int i = 0; i < m_v.size(); i++) {
					String res = (String) m_v.get(i);
					if (this.Version != null && this.Version.equals("11")) {
						if (res.indexOf("Block Time") != -1) {
							time = split(res, 8).substring(0, 5);
						}
					} else {
						if (res.indexOf("Checkpoint Completed:") != -1) {
							time = split(res, 5);
						}
					}

				}
				// PM-00-03-008-05 checkpoint持续时间
				collResult.addKPI(
						config_PRE_UNITID + ":" + this.INFORMIXSERVER,
						"PM-00-03-008-05", time);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return collResult.getKPISet();
	}

	/**
	 * @param args
	 */
	public static void main(String[] args) {
//        String a = Formater.formatDecimalKpivalue(String.valueOf(Formater.getByScale((((float)40 / Integer.valueOf("42"))*100)+"" ,2)) );
//        String b =  Formater.getByScale(((float)(40 / Integer.valueOf("42")))+"" ,2);
//        float c = (float)40/42;
//		System.out.println(a);
//		System.out.println(DES3.encrypt("info123"));

//		HashMap params = new HashMap();
//		params.put("INFORMIXSERVER", args[0]);
//		params.put("CMDDIR", args[1]);
//		params.put("IPADDR", args[2]);
//		params.put("USERNAME", args[3]);
//		params.put("PASSWORD", DES3.encrypt(args[4]));
//		params.put("PROTOCOL", args[5]);
//		params.put("PREFILEPATH", args[6]);
//		params.put("VERSION", args[7]);
//
//		CollInformixWithCMD cmd = new CollInformixWithCMD();
//		Vector v = null;
//		if (args[8].equals("1")) {
//			v = cmd.getConfig(params);
//			if (v != null && v.size() > 0) {
//				for (int i = 0; i < v.size(); i++) {
//					TblATO_KPIDETAIL ato = (TblATO_KPIDETAIL) v.get(i);
//					System.out.println(ato.UNIT_ID + " | " + ato.KPI_ID + " | "
//							+ ato.KPI_VALUE + " | " + ato.CLL_TIME);
//				}
//			}
//		}
//		if (args[8].equals("2")) {
//			v = cmd.getPerformance(params);
//			if (v != null && v.size() > 0) {
//				for (int i = 0; i < v.size(); i++) {
//					TblATO_KPIDETAIL ato = (TblATO_KPIDETAIL) v.get(i);
//					System.out.println(ato.UNIT_ID + " | " + ato.KPI_ID + " | "
//							+ ato.KPI_VALUE + " | " + ato.CLL_TIME);
//				}
//			}
//		}
//
//		if (args[8].equals("3")) {
//			v = cmd.getDbStatus(params);
//			if (v != null && v.size() > 0) {
//				for (int i = 0; i < v.size(); i++) {
//					TblATO_KPIDETAIL ato = (TblATO_KPIDETAIL) v.get(i);
//					System.out.println(ato.UNIT_ID + " | " + ato.KPI_ID + " | "
//							+ ato.KPI_VALUE + " | " + ato.CLL_TIME);
//				}
//			}
//		}
//
//		if (args[8].equals("4")) {
//			v = cmd.getTabSpace(params);
//			if (v != null && v.size() > 0) {
//				for (int i = 0; i < v.size(); i++) {
//					TblATO_KPIDETAIL ato = (TblATO_KPIDETAIL) v.get(i);
//					System.out.println(ato.UNIT_ID + " | " + ato.KPI_ID + " | "
//							+ ato.KPI_VALUE + " | " + ato.CLL_TIME);
//				}
//			}
//		}
//
//		String str = "16:12:32  Checkpoint Statistics - Avg. Txn Block Time 0.000, # Txns blocked 0, Plog used 649, Llog used 216";
//		System.out.println(cmd.split(str, 8).substring(0, 5));
	}

}