dbfunctionsmanager.java

this is example use EJB with jboss.

				isTimerRunning = true;
				LogWriter.getDBLogger().info("Started Timer to check user timed out. " +
												"Prior " + userTimeout * 1000 + "(ms)");
			}
		} catch (Exception e){
			LogWriter.getDBLogger().error("Create threads <Verify user timeout detecter> " +
														"has been failed ! " + e.getMessage());
		}
	}

	/**
	 * Set the IP address of current user. This value is assigned when EJB
	 * client connect to server
	 * 
	 * @param userIP
	 *            address in string such as "192.168.0.1"
	 */
	public void setUserIP(String userIP) {
		this.userIP = userIP;
	}

	/**
	 * Get the IP address of current user
	 * 
	 * @return IP address
	 */
	public String getUserIP() {
		return this.userIP;
	}

	/**
	 * Check alarm type is loaded or not.
	 * 
	 * @return true if alarm type was loaded, otherwise false.
	 */
	public static boolean isLoadedAlarmType() {
		return isLoadedAlarmType;
	}

	public static void setLoadedAlarmType(boolean value) {
		isLoadedAlarmType = value;
	}

	/**
	 * Get table name corresponding for each object in database
	 * @param obj
	 * 			Type of object. Specify by DBConstants.UserVO for example.	
	 * @return
	 * 		 Name of database table 
	 */
	public String getTableName(int obj) {
		switch (obj) {
		case DBConstants.NODE_OBJECT:
			return NodeVO.NODE_TBL;
		case DBConstants.FUNCBLOCK_OBJECT:
			return BlockVO.BLOCK_TBL;
		case DBConstants.PACKAGE_OBJECT:
			return PackageVO.PACKAGE_TBL;
		case DBConstants.PORT_OBJECT:
			return PortVO.PORT_TBL;
		case DBConstants.USER_OBJECT:
			return UserVO.USER_TBL;
		case DBConstants.TRAP_OBJECT:
			return TrapVO.TRAP_TBL;
		case DBConstants.OPERATION_OBJECT:
			return OperationVO.OPERATION_TBL;
		case DBConstants.PACKAGE_PACKAGE_OBJECT:
			return PackageConnection.PACKAGE_CONNECT_TBL;
		case DBConstants.PACKAGE_PORT_OBJECT:
			return PPConnection.CONNECT_TBL;
		case DBConstants.PACKAGETYPE_OBJECT:
			return PackageTypeVO.PACKAGETYPE_TBL;
		default:
			return "";
		}
	}

	/**
	 * Get ID field name in database table
	 * 
	 * @param obj
	 *            Type of object.
	 * @return ID field name
	 */
	private String getIDName(int obj) {
		switch (obj) {
		case DBConstants.NODE_OBJECT:
			return NodeVO.NODE_ID;
		case DBConstants.FUNCBLOCK_OBJECT:
			return BlockVO.BLOCK_ID;
		case DBConstants.PACKAGE_OBJECT:
			return PackageVO.PACKAGE_ID;
		case DBConstants.PORT_OBJECT:
			return PortVO.PORT_ID;
		case DBConstants.USER_OBJECT:
			return UserVO.USER_ID;
		case DBConstants.TRAP_OBJECT:
			return TrapVO.TRAP_ID;
		case DBConstants.OPERATION_OBJECT:
			return OperationVO.OPERATION_ID;
		case DBConstants.PACKAGE_PACKAGE_OBJECT:
			return PackageConnection.PACKAGE_CONNECT_ID;
		case DBConstants.PACKAGE_PORT_OBJECT:
			return PPConnection.CONNECT_ID;
		case DBConstants.PACKAGETYPE_OBJECT:
			return PackageTypeVO.PACKAGETYPE_ID;
		default:
			return "";
		}
	}
	
	/**
	 * Get ID field name in database table
	 * 
	 * @param obj
	 *            Type of object.
	 * @return ID field name
	 */
	private String getObjectName(int obj) {
		switch (obj) {
		case DBConstants.NODE_OBJECT:
			return "Node";
		case DBConstants.FUNCBLOCK_OBJECT:
			return "Block";
		case DBConstants.PACKAGE_OBJECT:
			return "Package";
		case DBConstants.PORT_OBJECT:
			return "Port";
		case DBConstants.USER_OBJECT:
			return "User";
		case DBConstants.TRAP_OBJECT:
			return "Trap history ";
		case DBConstants.OPERATION_OBJECT:
			return "Operation history";
		case DBConstants.PACKAGE_PACKAGE_OBJECT:
			return "Package-Package connection";
		case DBConstants.PACKAGE_PORT_OBJECT:
			return "Package-Port connection";
		case DBConstants.PACKAGETYPE_OBJECT:
			return "Package type";
		default:
			return "";
		}
	}

	/**
	 * Put key <-> field name and value <-> field data into hash table
	 * 
	 * @param field
	 *            Column name of table object in database
	 * @param value
	 *            Value of column
	 */
	private void putfval(Object field, Object value) {
		if (htblPutField != null) {
			htblPutField.put(field, value);
		}
	}

	/**
	 * Clear all fields contained in hash table
	 */
	private void clearFieldStorer() {
		if (htblPutField != null){
			htblPutField.clear();
		} else {
			LogWriter.getDBLogger().error("Null pointer at call method clearFieldStorer()");
		}
	}

	/**
	 * Generate a insert SQL statement that depend on input field
	 * 
	 * @param tableName
	 *            : table name in database
	 * @return
	 */
	private String genInsertCmd(String tableName) {
		String szInsSQL = null;
		try {
			if ((htblPutField != null) && (!htblPutField.isEmpty())) {
				String szFields = "";
				String szValues = "";
				Enumeration<Object> enumV = htblPutField.elements();
				Enumeration<Object> enumK = htblPutField.keys();
				while (enumK.hasMoreElements()) {
					szFields += enumK.nextElement();
					szValues += enumV.nextElement();
					if (!enumK.hasMoreElements()) {
						break;
					} else {
						szFields += ",";
						szValues += "','";
					}
				}
				szInsSQL = "INSERT INTO " + tableName + "(" + szFields + ") " +
						   "VALUES('" + szValues + "')";
				if (htblPutField != null) {
					htblPutField.clear();
				}
				return szInsSQL;
			}
		} catch (Exception e) {
			e.printStackTrace();
			return null;
		}
		return szInsSQL;
	}

	/**
	 * Generate a update SQL statement that depend on input field
	 * 
	 * @param tableName
	 *            : table name in database
	 * @return
	 */
	private String genUpdateCmd(String tableName, String szCondition) {
		String szUpdateSQL = null;
		try {
			if ((htblPutField != null) && (!htblPutField.isEmpty())) {
				String szFieldVal = "";
				Enumeration<Object> enumV = htblPutField.elements();
				Enumeration<Object> enumK = htblPutField.keys();
				while (enumK.hasMoreElements()) {
					szFieldVal += enumK.nextElement() + "='" + enumV.nextElement() + "'";
					if (!enumK.hasMoreElements()) {
						break;
					} else {
						szFieldVal += ",";
					}
				}
				szUpdateSQL = "UPDATE "	+ tableName	+ " SET " + szFieldVal +
							  ((szCondition == null) ? "": (" WHERE " + szCondition));
				if (htblPutField != null) {
					htblPutField.clear();
				}
				return szUpdateSQL;
			}
		} catch (Exception e) {
			e.printStackTrace();
			return null;
		}
		return szUpdateSQL;
	}

	/**
	 * Generate a insert/update SQL statement for NodeVO
	 * 
	 * @param nvo
	 *            NodeVO object
	 * @param op1
	 *            equal DBConstants.DBOPR_INSERT if operation for "insert"
	 *            otherwise for "update" (specify is DBConstants.DBOPR_UPDATE).
	 * @param op2
	 *            equal DBConstants.DBPR_TYPE_ALL insert/update all fields of
	 *            the object or specify DBConstants.DBPR_TYPE_POS if only
	 *            position.
	 * @return insert/update SQL statement for NodeVO object
	 */
	private String getSQLCmd_InsUpd2NodeTbl(NodeVO nvo, int op1, int op2) {
		String szQuery = null;
		clearFieldStorer();
		if (op2 == DBConstants.DBPR_TYPE_ALL) {
			putfval(NodeVO.NODE_NAME, nvo.getName());
			putfval(NodeVO.NODE_ADDR, nvo.getAddress());
		}
		putfval(NodeVO.NODE_POS_X, nvo.getPosX());
		putfval(NodeVO.NODE_POS_Y, nvo.getPosY());
		putfval(NodeVO.NODE_POS_W, nvo.getWidth());
		putfval(NodeVO.NODE_POS_H, nvo.getHeigh());
		if (op1 == DBConstants.DBOPR_INSERT) {
			szQuery = genInsertCmd(NodeVO.NODE_TBL);
		} else {
			szQuery = genUpdateCmd(NodeVO.NODE_TBL, NodeVO.NODE_ID + " = "
					+ nvo.getID());
		}
		return szQuery;
	}

	/**
	 * Generate a insert/update SQL statement for BlockVO
	 * 
	 * @param fbvo
	 *            BlockVO object
	 * @param op1
	 *            equal DBConstants.DBOPR_INSERT if operation for "insert"
	 *            otherwise for "update" (specify is DBConstants.DBOPR_UPDATE).
	 * @param op2
	 *            equal DBConstants.DBPR_TYPE_ALL insert/update all fields of
	 *            the object or specify DBConstants.DBPR_TYPE_POS if only
	 *            position.
	 * @return insert/update SQL statement for BlockVO object
	 */
	private String getSQLCmd_InsUpd2BlockTbl(BlockVO fbvo, int op1, int op2) {
		String szQuery = null;
		clearFieldStorer();

		if (op2 == DBConstants.DBPR_TYPE_ALL) {
			putfval(NodeVO.NODE_ID, fbvo.getParentID());
			putfval(BlockVO.BLOCK_NAME, fbvo.getName());
			putfval(BlockVO.BLOCK_IP, fbvo.getIP());
			putfval(BlockVO.BLOCK_TYPE, fbvo.getType());
			//putfval(BlockVO.BLOCK_ALARM, fbvo.getAlarm());
		}
		putfval(BlockVO.BLOCK_POS_X, fbvo.getPosX());
		putfval(BlockVO.BLOCK_POS_Y, fbvo.getPosY());
		putfval(BlockVO.BLOCK_POS_W, fbvo.getWidth());
		putfval(BlockVO.BLOCK_POS_H, fbvo.getHeigh());

		if (op1 == DBConstants.DBOPR_INSERT) {
			szQuery = genInsertCmd(BlockVO.BLOCK_TBL);
		} else {
			szQuery = genUpdateCmd(BlockVO.BLOCK_TBL, BlockVO.BLOCK_ID + " = "
									+ fbvo.getID());
		}

		return szQuery;
	}

	/**
	 * Generate a insert/update SQL statement for PackageVO
	 * 
	 * @param pkgvo
	 *            PackageVO object
	 * @param op1
	 *            equal DBConstants.DBOPR_INSERT if operation for "insert"
	 *            otherwise for "update" (specify is DBConstants.DBOPR_UPDATE).
	 * @param op2
	 *            equal DBConstants.DBPR_TYPE_ALL insert/update all fields of
	 *            the object or specify DBConstants.DBPR_TYPE_POS if only
	 *            position.
	 * @return insert/update SQL statement for PackageVO object
	 */
	private String getSQLCmd_InsUpd2PackageTbl(PackageVO pkgvo, int op1, int op2)
																throws Exception {
		String szQuery   = null;
		String condition = null; 
		try {
			clearFieldStorer();
			if (op2 == DBConstants.DBPR_TYPE_ALL) {
				putfval(BlockVO.BLOCK_ID, pkgvo.getParentID());
				putfval(PackageVO.PACKAGE_SLOT, pkgvo.getPackageSlot());
				condition = PackageTypeVO.PACKAGETYPE_NAME + " LIKE '"
													+ pkgvo.getName() + "%'";
				pkgvo.setPackageTypeID(getPackageTypes(condition).get(0).getID());
				putfval(PackageTypeVO.PACKAGETYPE_ID, pkgvo.getPackageTypeID());
				//putfval(PackageVO.PACKAGE_ALARM_1, pkgvo.getAlarm1());
				//putfval(PackageVO.PACKAGE_ALARM_2, pkgvo.getAlarm2());
			}
			putfval(PackageVO.PACKAGE_POS_X, pkgvo.getPosX());
			putfval(PackageVO.PACKAGE_POS_Y, pkgvo.getPosY());
			putfval(PackageVO.PACKAGE_POS_W, pkgvo.getWidth());
			putfval(PackageVO.PACKAGE_POS_H, pkgvo.getHeigh());

			if (op1 == DBConstants.DBOPR_INSERT) {
				szQuery = genInsertCmd(PackageVO.PACKAGE_TBL);
			} else {
				szQuery = genUpdateCmd(PackageVO.PACKAGE_TBL,
									   PackageVO.PACKAGE_ID + " = " + pkgvo.getID());
			}
		} catch (Exception e) {
			throw (new Exception("The package's name was not found."));
		}
		return szQuery;
	}

	/**
	 * Generate a insert/update SQL statement for PortVO
	 * 
	 * @param pvo
	 *            PortVO object
	 * @param op
	 *            equal DBConstants.DBOPR_INSERT if operation for "insert"
	 *            otherwise for "update" (specify is DBConstants.DBOPR_UPDATE).
	 * 
	 * @return insert/update SQL statement for PortVO object
	 */
	private String getSQLCmd_InsUpd2PortTbl(PortVO pvo, int op) {
		String szQuery = null;
		clearFieldStorer();
		putfval(PackageVO.PACKAGE_ID, pvo.getParentID());
		putfval(PortVO.PORT_NAME, pvo.getName());

		if (op == DBConstants.DBOPR_INSERT) {
			szQuery = genInsertCmd(PortVO.PORT_TBL);
		} else {