tempfile.2.tmp

this is example use EJB with jboss.

				        if (!enumK.hasMoreElements()){
				    	    break;
				        }
				        else{
				        	szFieldVal += ",";	
    			        }
				 } 
				 szUpdateSQL = "UPDATE " + tableName + " SET " + szFieldVal +  " 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;
		 try{
		    clearFieldStorer();
		    if (op2 == DBConstants.DBPR_TYPE_ALL){
		    	putfval(BlockVO.BLOCK_ID, pkgvo.getParentID());
		    	putfval(PackageVO.PACKAGE_SLOT, pkgvo.getPackageSlot());
		    	pkgvo.setPackageTypeID(getPackageTypes(PackageTypeVO.PACKAGETYPE_NAME + " LIKE '"
		    							+ pkgvo.getName() + "%'").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 {
			  szQuery = genUpdateCmd(PortVO.PORT_TBL, PortVO.PORT_ID + " = " + pvo.getID());
		 }
		return szQuery;
	}

	/**
	 * Generate a insert/update SQL statement for UserVO
	 * @param uvo 
	 * 			 UserVO 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 UserVO object
	 */
	private String getSQLCmd_InsUpd2UserTbl(UserVO uvo, int op){
		String szQuery = null;
		clearFieldStorer();

		if (op == DBConstants.DBOPR_INSERT){
			putfval(UserVO.USER_NAME, uvo.getName());
			putfval(UserVO.USER_TYPE, uvo.getRole());
			putfval(UserVO.USER_PASS, uvo.getPassword());
			szQuery = genInsertCmd(UserVO.USER_TBL);
		} else {
			putfval(UserVO.USER_TYPE, uvo.getRole());
			String pass = uvo.getPassword();
			if( pass != null){
				 pass = pass.trim();
				if (pass.length()>0){
				    putfval(UserVO.USER_PASS, uvo.getPassword());
				}
			}
			szQuery = genUpdateCmd(UserVO.USER_TBL, UserVO.USER_ID + " = " + uvo.getID());
		}
		return szQuery;
	}
	
	/**
	 * Generate a insert/update SQL statement for PackageConnection
	 * @param pconn 
	 * 			 PackageConnection 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 PackageConnection object
	 */
	private String getSQLCmd_InsUpd2PackageConnectionTbl(PackageConnection pconn, int op){
		String szQuery = null;
		clearFieldStorer();
		putfval(PackageConnection.PACKAGE_CONNECT_ID, pconn.getID());
		putfval(PackageConnection.PACKAGE_ID_1, pconn.getPackageID1());
		putfval(PackageConnection.PACKAGE_ID_2, pconn.getPackageID2());
		putfval(PackageConnection.PACKAGE_CONNECT_COLOR, pconn.getColor());
		putfval(PackageConnection.PACKAGE_CONNECT_DIR, pconn.getDirection());
		if (op == DBConstants.DBOPR_INSERT){
			szQuery = genInsertCmd(PackageConnection.PACKAGE_CONNECT_TBL);
		} else {
			szQuery = genUpdateCmd(PackageConnection.PACKAGE_CONNECT_TBL
						, PackageConnection.PACKAGE_CONNECT_ID + " = " + pconn.getID());
		}
		return szQuery;
	}
	
	/**
	 * Generate a insert/update SQL statement for PPConnection
	 * @param ppConn 
	 * 			 PPConnection 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 PPConnection object
	 */
	private String getSQLCmd_InsUpd2PPConnectionTbl(PPConnection ppConn, int op){
		 String szQuery = null;
		 clearFieldStorer();
		 putfval(PPConnection.PACKAGE_ID1, ppConn.getPackage1());
		 putfval(PPConnection.PACKAGE_ID2, ppConn.getPackage2());
		 putfval(PPConnection.PORT_ID1, ppConn.getPortID1());
		 putfval(PPConnection.PORT_ID2, ppConn.getPortID2());
		 putfval(PPConnection.CONNECT_DIR, ppConn.getDirection());
		 
		 if (op == DBConstants.DBOPR_INSERT){
			szQuery = genInsertCmd(PPConnection.CONNECT_TBL);
		 } else {
			szQuery = genUpdateCmd(PPConnection.CONNECT_TBL, PPConnection.CONNECT_ID + " = " + ppConn.getID());
		 }
		return szQuery;
	}
	
	/**
	 * Generate a insert/update SQL statement for PackageTypeVO
	 * @param ptvo 
	 * 			 PackageTypeVO 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 PackageTypeVO object
	 */
	private String getSQLCmd_InsUpd2PackageTypeTbl(PackageTypeVO ptvo, int op){
		 String szQuery = null;
		 clearFieldStorer();
 		 putfval(PackageTypeVO.PACKAGETYPE_NAME, ptvo.getName());
		 putfval(PackageTypeVO.PACKAGETYPE_PORT, ptvo.getDescPorts());
		 if (op == DBConstants.DBOPR_INSERT){
			 szQuery = genInsertCmd(PackageTypeVO.PACKAGETYPE_TBL);
		 } else {
			 szQuery = genUpdateCmd(PackageTypeVO.PACKAGETYPE_TBL
					 		, PackageTypeVO.PACKAGETYPE_ID + " = " + ptvo.getID());
		 }
		return szQuery;
	}
	
	/**
	 * Generate a insert SQL statement for OperationVO
	 * @param logvo 
	 * 			 OperationVO object
	 *
	 * @return insert SQL statement for OperationVO object
	 */
	private String getSQLCmd_Ins2LogTbl(OperationVO logvo){
		 String szQuery = null;
		 clearFieldStorer();
		 putfval(UserVO.USER_NAME, logvo.getUserName());
		 putfval(OperationVO.OPERATION_TIME, logvo.getTime());
		 putfval(OperationVO.OPERATION_CONTENT, logvo.getContent());
		 szQuery = genInsertCmd(OperationVO.OPERATION_TBL);
		 return szQuery;
	}

	/**
	 * Generate a insert SQL statement for TrapVO
	 * @param tvo 
	 * 			 TrapVO object
	 *
	 * @return insert SQL statement for TrapVO object
	 */
	private String getSQLCmd_Ins2TrapTbl(TrapVO tvo){
		String szQuery = null;
		clearFieldStorer();

		putfval(NodeVO.NODE_NAME, tvo.getNodeName());
		putfval(BlockVO.BLOCK_NAME, tvo.getBlockName());
		putfval(BlockVO.BLOCK_IP, tvo.getBlockIP());
		putfval(PackageTypeVO.PACKAGETYPE_NAME, tvo.getPackageTypeName());
		putfval(TrapVO.TRAP_SLOTNUM, tvo.getSlotNumber());
		putfval(TrapVO.TRAP_TYPE, tvo.getTrapType());
		putfval(TrapVO.TRAP_LEVEL, tvo.getTrapLevel());
		putfval(TrapVO.TRAP_TIME, tvo.getTime());

		szQuery = genInsertCmd(TrapVO.TRAP_TBL);
		return szQuery;
	}
	
	
	/**
	 * Check the package in database that existed or not
	 * @param object
	 * 			PPConnection object
	 * @return a JResult object. Check method isSucceeded() true if existed.
	 */
	private JResult checkPPConnection(PPConnection object){
		 JResult result = new JResult();
		 long pk_id_1 = object.getPackage1();
		 long pk_id_2 = object.getPackage2();
		 long port_id_1 = object.getPortID1();
		 long port_id_2 = object.getPortID2();
		 
		 if ((findObject(DBConstants.PACKAGE_OBJECT, pk_id_1) <= 0)
			  ||(findObject(DBConstants.PACKAGE_OBJECT, pk_id_2) <= 0)){
				//ERROR_OBJECT_NOT_FOUND
			  result.returnCode(JResult.DBOPR_ERROR_PARENT_OBJECT_NOT_FOUND);
			  result.setMessage("The package object with ID specified "+
						   			 "(" + pk_id_1 + " or " + pk_id_2 + ") was not found.");
			  return result;
		 }
		 if ((findObject(DBConstants.PORT_OBJECT, port_id_1) <= 0)
			  ||(findObject(DBConstants.PORT_OBJECT, port_id_2) <= 0)){
				//ERROR_OBJECT_NOT_FOUND
			  result.returnCode(JResult.DBOPR_ERROR_PARENT_OBJECT_NOT_FOUND);
			  result.setMessage("The port object with ID specified " +
				   					 "(" + port_id_1 + " or " + port_id_2 + ") was not found.");
			  return result;
		 }
		 result.returnCode(JResult.DBOPR_SUCCESS);
		 return result;
	}
	
	/**
	 * Check the package and port in PackageConnection object from database that existed or not
	 * @param object
	 * 			PackageConnection object
	 * @return a JResult object. Check method isSucceeded() true if existed.
	 */
	private JResult checkPackagePConnection(PackageConnection object){
		 JResult result = new JResult();
		 long pk_id_1;
	     long pk_id_2;
	     pk_id_1 = object.getPackageID1();
	     pk_id_2 = object.getPackageID2();
	     if (findObject(DBConstants.PACKAGE_OBJECT, pk_id_1) <= 0){
	    	 //ERROR_OBJECT_NOT_FOUND
	    	result.returnCode(JResult.DBOPR_ERROR_PARENT_OBJECT_NOT_FOUND);
	    	result.setMessage("The package object with ID is " + pk_id_1 + " was not found.");
	    	return result;
	     }
	     if (findObject(DBConstants.PACKAGE_OBJECT, pk_id_2) <= 0){
	    	 //ERROR_OBJECT_NOT_FOUND
	    	 result.returnCode(JResult.DBOPR_ERROR_PARENT_OBJECT_NOT_FOUND);
	    	 result.setMessage("The package object with ID is " + pk_id_2 + " was not found.");
		   return result;
	     }
	     result.returnCode(JResult.DBOPR_SUCCESS);
		 return result;
	}
	
	/**
	 *  add new one package into database
	 * @param object
	 * @return a JResult object contains a PackageVO (consists of list ports),
	 * 		   use method getObjectData() of JResult to get this.