usersbeanfunctionset_789ae0b4.java

j2ee源码

				tempString=(String)inputRecord.get(11);
				if(tempString==null)
					pstmt.setNull(10,java.sql.Types.VARCHAR);
				else
					pstmt.setString(10,tempString);
			}
			// For column CREATE_DTTM
			{
				java.sql.Timestamp tempTimestamp;


				tempTimestamp=(java.sql.Timestamp)inputRecord.get(12);
				if(tempTimestamp==null)
					pstmt.setNull(11,java.sql.Types.TIMESTAMP);
				else
					pstmt.setTimestamp(11,tempTimestamp);
			}
			// For column CREATE_BY
			{
				String tempString;


				tempString=(String)inputRecord.get(13);
				if(tempString==null)
					pstmt.setNull(12,java.sql.Types.VARCHAR);
				else
					pstmt.setString(12,tempString);
			}
			// For column LAST_MODIFY_DTTM
			{
				java.sql.Timestamp tempTimestamp;


				tempTimestamp=(java.sql.Timestamp)inputRecord.get(14);
				if(tempTimestamp==null)
					pstmt.setNull(13,java.sql.Types.TIMESTAMP);
				else
					pstmt.setTimestamp(13,tempTimestamp);
			}
			// For column LAST_MODIFY_BY
			{
				String tempString;


				tempString=(String)inputRecord.get(15);
				if(tempString==null)
					pstmt.setNull(14,java.sql.Types.VARCHAR);
				else
					pstmt.setString(14,tempString);
			}
			if (pstmt.executeUpdate()==0)
				throw new DataStoreAdapterException("DSA_ERROR",new javax.ejb.NoSuchEntityException(), this.getClass());

		}
		catch (SQLException e) {
			throw new DataStoreAdapterException("DSA_ERROR", e ,this.getClass());
		}
		finally {
			try {
				if(pstmt != null) {
					returnPreparedStatement(connection, pstmt);
				}
			}
			catch (SQLException ignored)
			{}
		}
	}
	/**
	 * StoreUsingOCC
	 */
	public void StoreUsingOCC(IndexedRecord inputRecord, Object connection, WSInteractionSpec interactionSpec) throws DataStoreAdapterException {
		PreparedStatement pstmt = null;
		try {
			pstmt = prepareStatement(connection,"UPDATE WKEXS.USERS  SET NAME = ?, PASSWORD = ?, ACTIVE = ?, EMAIL = ?, ROLE_ID = ?, DEPT_ID = ?, POSITION = ?, TELEPHONE = ?, FAX = ?, APPROVAL_PASSWORD = ?, CREATE_DTTM = ?, CREATE_BY = ?, LAST_MODIFY_DTTM = ?, LAST_MODIFY_BY = ? WHERE COMPANY_ID = ? AND USER_ID = ?");

			// For column COMPANY_ID
			{
				String tempString;


				tempString=(String)inputRecord.get(0);
				if(tempString==null)
					pstmt.setNull(15,java.sql.Types.VARCHAR);
				else
					pstmt.setString(15,tempString);
			}
			// For column USER_ID
			{
				String tempString;


				tempString=(String)inputRecord.get(1);
				if(tempString==null)
					pstmt.setNull(16,java.sql.Types.VARCHAR);
				else
					pstmt.setString(16,tempString);
			}
			// For column NAME
			{
				String tempString;


				tempString=(String)inputRecord.get(2);
				if(tempString==null)
					pstmt.setNull(1,java.sql.Types.VARCHAR);
				else
					pstmt.setString(1,tempString);
			}
			// For column PASSWORD
			{
				String tempString;


				tempString=(String)inputRecord.get(3);
				if(tempString==null)
					pstmt.setNull(2,java.sql.Types.VARCHAR);
				else
					pstmt.setString(2,tempString);
			}
			// For column ACTIVE
			{
				String tempString;


				tempString=(String)inputRecord.get(4);
				if(tempString==null)
					pstmt.setNull(3,java.sql.Types.VARCHAR);
				else
					pstmt.setString(3,tempString);
			}
			// For column EMAIL
			{
				String tempString;


				tempString=(String)inputRecord.get(5);
				if(tempString==null)
					pstmt.setNull(4,java.sql.Types.VARCHAR);
				else
					pstmt.setString(4,tempString);
			}
			// For column ROLE_ID
			{
				String tempString;


				tempString=(String)inputRecord.get(6);
				if(tempString==null)
					pstmt.setNull(5,java.sql.Types.VARCHAR);
				else
					pstmt.setString(5,tempString);
			}
			// For column DEPT_ID
			{
				String tempString;


				tempString=(String)inputRecord.get(7);
				if(tempString==null)
					pstmt.setNull(6,java.sql.Types.VARCHAR);
				else
					pstmt.setString(6,tempString);
			}
			// For column POSITION
			{
				String tempString;


				tempString=(String)inputRecord.get(8);
				if(tempString==null)
					pstmt.setNull(7,java.sql.Types.VARCHAR);
				else
					pstmt.setString(7,tempString);
			}
			// For column TELEPHONE
			{
				String tempString;


				tempString=(String)inputRecord.get(9);
				if(tempString==null)
					pstmt.setNull(8,java.sql.Types.VARCHAR);
				else
					pstmt.setString(8,tempString);
			}
			// For column FAX
			{
				String tempString;


				tempString=(String)inputRecord.get(10);
				if(tempString==null)
					pstmt.setNull(9,java.sql.Types.VARCHAR);
				else
					pstmt.setString(9,tempString);
			}
			// For column APPROVAL_PASSWORD
			{
				String tempString;


				tempString=(String)inputRecord.get(11);
				if(tempString==null)
					pstmt.setNull(10,java.sql.Types.VARCHAR);
				else
					pstmt.setString(10,tempString);
			}
			// For column CREATE_DTTM
			{
				java.sql.Timestamp tempTimestamp;


				tempTimestamp=(java.sql.Timestamp)inputRecord.get(12);
				if(tempTimestamp==null)
					pstmt.setNull(11,java.sql.Types.TIMESTAMP);
				else
					pstmt.setTimestamp(11,tempTimestamp);
			}
			// For column CREATE_BY
			{
				String tempString;


				tempString=(String)inputRecord.get(13);
				if(tempString==null)
					pstmt.setNull(12,java.sql.Types.VARCHAR);
				else
					pstmt.setString(12,tempString);
			}
			// For column LAST_MODIFY_DTTM
			{
				java.sql.Timestamp tempTimestamp;


				tempTimestamp=(java.sql.Timestamp)inputRecord.get(14);
				if(tempTimestamp==null)
					pstmt.setNull(13,java.sql.Types.TIMESTAMP);
				else
					pstmt.setTimestamp(13,tempTimestamp);
			}
			// For column LAST_MODIFY_BY
			{
				String tempString;


				tempString=(String)inputRecord.get(15);
				if(tempString==null)
					pstmt.setNull(14,java.sql.Types.VARCHAR);
				else
					pstmt.setString(14,tempString);
			}
			IndexedRecord oldRecord = interactionSpec.getOldRecord();
			if (pstmt.executeUpdate()==0)
				throw new DataStoreAdapterException("DSA_ERROR",new javax.ejb.NoSuchEntityException(), this.getClass());

		}
		catch (SQLException e) {
			throw new DataStoreAdapterException("DSA_ERROR", e ,this.getClass());
		}
		finally {
			try {
				if(pstmt != null) {
					returnPreparedStatement(connection, pstmt);
				}
			}
			catch (SQLException ignored)
			{}
		}
	}
	/**
	 * FindByPrimaryKey
	 */
	public javax.resource.cci.Record FindByPrimaryKey(IndexedRecord inputRecord, Object connection, WSInteractionSpec interactionSpec) throws DataStoreAdapterException {
		PreparedStatement pstmt = null;
		ResultSet result=null;
		try {
			pstmt = prepareStatement(connection,"SELECT T1.COMPANY_ID, T1.USER_ID, T1.NAME, T1.PASSWORD, T1.ACTIVE, T1.EMAIL, T1.ROLE_ID, T1.DEPT_ID, T1.POSITION, T1.TELEPHONE, T1.FAX, T1.APPROVAL_PASSWORD, T1.CREATE_DTTM, T1.CREATE_BY, T1.LAST_MODIFY_DTTM, T1.LAST_MODIFY_BY FROM WKEXS.USERS  T1 WHERE T1.COMPANY_ID = ? AND T1.USER_ID = ?");

			// For column COMPANY_ID
			{
				String tempString;


				tempString=(String)inputRecord.get(0);
				if(tempString==null)
					pstmt.setNull(1,java.sql.Types.VARCHAR);
				else
					pstmt.setString(1,tempString);
			}
			// For column USER_ID
			{
				String tempString;


				tempString=(String)inputRecord.get(1);
				if(tempString==null)
					pstmt.setNull(2,java.sql.Types.VARCHAR);
				else
					pstmt.setString(2,tempString);
			}
			result = pstmt.executeQuery();

		}
		catch (SQLException e) {
			throw new DataStoreAdapterException("DSA_ERROR", e ,this.getClass());
		}
		return createCCIRecord(connection, result);
	}
	/**
	 * FindByPrimaryKeyForUpdate
	 */
	public javax.resource.cci.Record FindByPrimaryKeyForUpdate(IndexedRecord inputRecord, Object connection, WSInteractionSpec interactionSpec) throws DataStoreAdapterException {
		PreparedStatement pstmt = null;
		ResultSet result=null;
		try {
			pstmt = prepareStatement(connection,"SELECT T1.COMPANY_ID, T1.USER_ID, T1.NAME, T1.PASSWORD, T1.ACTIVE, T1.EMAIL, T1.ROLE_ID, T1.DEPT_ID, T1.POSITION, T1.TELEPHONE, T1.FAX, T1.APPROVAL_PASSWORD, T1.CREATE_DTTM, T1.CREATE_BY, T1.LAST_MODIFY_DTTM, T1.LAST_MODIFY_BY FROM WKEXS.USERS  T1 WHERE T1.COMPANY_ID = ? AND T1.USER_ID = ? FOR UPDATE ");

			// For column COMPANY_ID
			{
				String tempString;


				tempString=(String)inputRecord.get(0);
				if(tempString==null)
					pstmt.setNull(1,java.sql.Types.VARCHAR);
				else
					pstmt.setString(1,tempString);
			}
			// For column USER_ID
			{
				String tempString;


				tempString=(String)inputRecord.get(1);
				if(tempString==null)
					pstmt.setNull(2,java.sql.Types.VARCHAR);
				else
					pstmt.setString(2,tempString);
			}
			result = pstmt.executeQuery();

		}
		catch (SQLException e) {
			throw new DataStoreAdapterException("DSA_ERROR", e ,this.getClass());
		}
		return createCCIRecord(connection, result);
	}
	/**
	 * UsersBeanFunctionSet_789ae0b4
	 */
	public UsersBeanFunctionSet_789ae0b4() {
		functionHash=new java.util.HashMap(6);

		functionHash.put("Create",new Integer(0));
		functionHash.put("Remove",new Integer(1));
		functionHash.put("Store",new Integer(2));
		functionHash.put("StoreUsingOCC",new Integer(3));
		functionHash.put("FindByPrimaryKey",new Integer(4));
		functionHash.put("FindByPrimaryKeyForUpdate",new Integer(5));
	}
	/**
	 * execute
	 */
	public Record execute(WSInteractionSpec interactionSpec, IndexedRecord inputRecord, Object connection) throws javax.resource.ResourceException {
		String functionName=interactionSpec.getFunctionName();
		Record outputRecord=null;
		int functionIndex=((Integer)functionHash.get(functionName)).intValue();

		switch (functionIndex) {
		case 0:
			Create(inputRecord,connection,interactionSpec);
			break;
		case 1:
			Remove(inputRecord,connection,interactionSpec);
			break;
		case 2:
			Store(inputRecord,connection,interactionSpec);
			break;
		case 3:
			StoreUsingOCC(inputRecord,connection,interactionSpec);
			break;
		case 4:
			outputRecord=FindByPrimaryKey(inputRecord,connection,interactionSpec);
			break;
		case 5:
			outputRecord=FindByPrimaryKeyForUpdate(inputRecord,connection,interactionSpec);
			break;
		}
		return outputRecord;
	}
}