[POLICY-71] replace openecomp for policy-common

Change-Id: I3241f5d1f0234043b4dff718eda1ffdc48052276
Signed-off-by: Guo Ruijing <ruijing.guo@intel.com>
Signed-off-by: Pamela Dragosh <pdragosh@research.att.com>

1 files changed, 0 insertions, 739 deletions

diff --git a/integrity-audit/src/main/java/org/openecomp/policy/common/ia/DbDAO.java b/integrity-audit/src/main/java/org/openecomp/policy/common/ia/DbDAO.java
deleted file mode 100644
index 5ab16d58..00000000
--- a/integrity-audit/src/main/java/org/openecomp/policy/common/ia/DbDAO.java
+++ /dev/null
@@ -1,739 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * Integrity Audit
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.common.ia;
-
-import java.util.Date;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Properties;
-
-import javax.persistence.EntityManager;
-import javax.persistence.EntityManagerFactory;
-import javax.persistence.EntityTransaction;
-import javax.persistence.LockTimeoutException;
-import javax.persistence.Persistence;
-import javax.persistence.PersistenceUnitUtil;
-import javax.persistence.Query;
-import javax.persistence.TypedQuery;
-import javax.persistence.criteria.CriteriaBuilder;
-import javax.persistence.criteria.CriteriaQuery;
-import javax.persistence.criteria.Root;
-import javax.persistence.metamodel.ManagedType;
-import javax.persistence.metamodel.Metamodel;
-
-//import org.apache.log4j.Logger;
-
-import org.openecomp.policy.common.ia.jpa.IntegrityAuditEntity;
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger; 
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-
-/**
- * class DbDAO provides the inteface to the DBs for the purpose of audits.
- * 
- */
-public class DbDAO {
-	private static final Logger logger = FlexLogger.getLogger(DbDAO.class.getName());
-	private String resourceName;
-	private String persistenceUnit;
-	private String dbDriver;
-	private String dbUrl;
-	private String dbUser;
-	private String dbPwd;
-	private String siteName;
-	private String nodeType;
-	private Properties properties=null;
-	
-	private EntityManagerFactory emf;
-	
-	/*
-	 * Supports designation serialization.
-	 */
-    private static final Object lock = new Object();
-
-	
-	/**
-	 * DbDAO Constructor
-     * @param resourceName
-     * @param persistenceUnit
-     * @param properties
-     * @throws Exception
-     */
-	public DbDAO(String resourceName, String persistenceUnit, Properties properties) throws Exception {
-		logger.debug("DbDAO contructor: enter");
-		
-		validateProperties(resourceName, persistenceUnit, properties);
-		
-		emf = Persistence.createEntityManagerFactory(persistenceUnit, properties);
-		
-		register();
-		
-		logger.debug("DbDAO contructor: exit");
-	}
-	
-	/**
-	 * validateProperties will validate the properties
-	 * @param resourceName
-	 * @param persistenceUnit
-	 * @param properties
-	 * @throws IntegrityAuditPropertiesException
-	 */
-	private void validateProperties(String resourceName, String persistenceUnit, Properties properties) throws IntegrityAuditPropertiesException{
-		String badparams="";
-		if(IntegrityAudit.parmsAreBad(resourceName, persistenceUnit, properties, badparams)){
-			String msg = "DbDAO: Bad parameters: badparams" + badparams;
-			throw new IntegrityAuditPropertiesException(msg);
-		}
-		this.resourceName = resourceName;
-		this.persistenceUnit = persistenceUnit;
-		this.dbDriver = properties.getProperty(IntegrityAuditProperties.DB_DRIVER).trim();
-		this.dbUrl = properties.getProperty(IntegrityAuditProperties.DB_URL).trim();
-		this.dbUser = properties.getProperty(IntegrityAuditProperties.DB_USER).trim();
-		this.dbPwd = properties.getProperty(IntegrityAuditProperties.DB_PWD).trim();
-		this.siteName = properties.getProperty(IntegrityAuditProperties.SITE_NAME).trim();
-		this.nodeType = properties.getProperty(IntegrityAuditProperties.NODE_TYPE).trim();
-		this.properties = properties;
-		logger.debug("DbDAO.assignProperties: exit:" 
-				+ "\nresourceName: " + this.resourceName
-				+ "\npersistenceUnit: " + this.persistenceUnit
-				+ "\nproperties: " + this.properties);
-	}
-	
-	/**
-	 * getAllMyEntries gets all the DB entries for a particular class
-	 * @param className
-	 * @return
-	 */
-	public HashMap<Object, Object> getAllMyEntries(String className) {
-		logger.debug("getAllMyEntries: Entering, className="
-				+ className);
-		HashMap<Object, Object> resultMap = new HashMap<Object,Object>();
-		EntityManager em = emf.createEntityManager();
-		try{
-			CriteriaBuilder cb = em.getCriteriaBuilder();
-			CriteriaQuery<Object> cq = cb.createQuery();
-			Root<?> rootEntry = cq.from(Class.forName(className));
-			CriteriaQuery<Object> all = cq.select(rootEntry);
-			TypedQuery<Object> allQuery = em.createQuery(all);
-			List<Object> objectList = allQuery.getResultList();
-			//Now create the map
-
-			PersistenceUnitUtil util = emf.getPersistenceUnitUtil();
-			for (Object o: objectList){
-				Object key = util.getIdentifier(o);
-				resultMap.put(key, o);
-			}
-		}catch(Exception e){
-			String msg = "getAllEntries encountered exception: " + e;
-			logger.error(msg);
-			System.out.println(new Date());
-			e.printStackTrace();
-		}
-		em.close();
-		logger.debug("getAllMyEntries: Exit, resultMap.keySet()=" + resultMap.keySet());
-		return resultMap;		
-	}
-	
-	/**
-	 * getAllMyEntries gets all entries for a class
-	 * @param className
-	 * @param keySet
-	 * @return
-	 */
-	public HashMap<Object, Object> getAllMyEntries(String className, HashSet<Object> keySet){
-		logger.debug("getAllMyEntries: Entering, className="
-				+ className + ",\n keySet=" + keySet);
-
-		HashMap<Object, Object> resultMap = new HashMap<Object,Object>();
-		EntityManager em = emf.createEntityManager();
-		try{
-			Class<?> clazz = Class.forName(className);
-			for(Object key : keySet){
-				Object entry = em.find(clazz, key);
-				resultMap.put(key, entry);
-			}
-		}catch(Exception e){
-			String msg = "getAllMyEntries encountered exception: " + e;
-			logger.error(msg);
-			System.out.println(new Date());
-			e.printStackTrace();
-		}
-		em.close();
-
-		logger.debug("getAllMyEntries: Returning resultMap, size=" + resultMap.size());
-		return resultMap;
-	}
-	
-	/**
-	 * getAllEntries gets all entriesfor a particular persistence unit adn className
-	 * @param persistenceUnit
-	 * @param properties
-	 * @param className
-	 * @return
-	 */
-	public HashMap<Object,Object> getAllEntries(String persistenceUnit, Properties properties, String className){
-		
-		logger.debug("getAllEntries: Entering, persistenceUnit="
-				+ persistenceUnit + ",\n className=" + className);
-		HashMap<Object, Object> resultMap = new HashMap<Object,Object>();
-
-		EntityManagerFactory theEmf = Persistence.createEntityManagerFactory(persistenceUnit, properties);
-		EntityManager em = theEmf.createEntityManager();
-		try{
-			CriteriaBuilder cb = em.getCriteriaBuilder();
-			CriteriaQuery<Object> cq = cb.createQuery();
-			Root<?> rootEntry = cq.from(Class.forName(className));
-			CriteriaQuery<Object> all = cq.select(rootEntry);
-			TypedQuery<Object> allQuery = em.createQuery(all);
-			List<Object> objectList = allQuery.getResultList();
-
-			PersistenceUnitUtil util = theEmf.getPersistenceUnitUtil();
-			for (Object o: objectList){
-				Object key = util.getIdentifier(o);
-				resultMap.put(key, o);
-			}
-		}catch(Exception e){
-			String msg = "getAllEntries encountered exception:" + e;
-			logger.error(msg);
-			System.out.println(new Date());
-			e.printStackTrace();
-		}
-		em.close();
-		
-		logger.debug("getAllEntries: Returning resultMap, size=" + resultMap.size());
-		
-		return resultMap;		
-	}
-	
-
-	/**
-	 * getAllEntries gest all entries for a persistence unit
-	 * @param persistenceUnit
-	 * @param properties
-	 * @param className
-	 * @param keySet
-	 * @return
-	 */
-
-	public HashMap<Object,Object> getAllEntries(String persistenceUnit, Properties properties, String className, HashSet<Object> keySet){
-		logger.debug("getAllEntries: Entering, persistenceUnit="
-				+ persistenceUnit + ",\n properties= " + properties + ",\n className=" + className + ",\n keySet= " + keySet);
-		EntityManagerFactory theEmf = Persistence.createEntityManagerFactory(persistenceUnit, properties);
-		EntityManager em = theEmf.createEntityManager();
-		HashMap<Object, Object> resultMap = new HashMap<Object,Object>();
-		try{
-			Class<?> clazz = Class.forName(className);
-			for(Object key : keySet){
-				Object entry = em.find(clazz, key);
-				resultMap.put(key, entry);
-			}
-		}catch(Exception e){
-			String msg = "getAllEntries encountered exception: " + e;
-			logger.error(msg);
-			System.out.println(new Date());
-			e.printStackTrace();
-		}
-		em.close();
-		logger.debug("getAllEntries: Exit, resultMap, size=" + resultMap.size());
-		return resultMap;	
-	}
-	
-	/**
-	 * getIntegrityAuditEntities() Get all the IntegrityAuditEntities for a particular persistence unit
-	 * and node type
-	 * @param persistenceUnit
-	 * @param nodeType
-	 * @return
-	 * @throws DbDaoTransactionException
-	 */
-	@SuppressWarnings("unchecked")
-	public List<IntegrityAuditEntity> getIntegrityAuditEntities(String persistenceUnit, String nodeType) throws DbDaoTransactionException {
-		logger.debug("getIntegrityAuditEntities: Entering, persistenceUnit="
-				+ persistenceUnit + ",\n nodeType= " + nodeType);
-		try{
-			EntityManager em = emf.createEntityManager();
-			// Start a transaction
-			EntityTransaction et = em.getTransaction();
-
-			et.begin();
-
-			// if IntegrityAuditEntity entry exists for resourceName and PU, update it. If not found, create a new entry
-			Query iaequery = em.createQuery("Select i from IntegrityAuditEntity i where i.persistenceUnit=:pu and i.nodeType=:nt");
-			iaequery.setParameter("pu", persistenceUnit);
-			iaequery.setParameter("nt", nodeType);
-
-			List<IntegrityAuditEntity> iaeList = iaequery.getResultList();
-
-			// commit transaction
-			et.commit();
-			em.close();
-			logger.debug("getIntegrityAuditEntities: Exit, iaeList=" + iaeList);
-			return iaeList;
-		}catch (Exception e){
-			String msg = "DbDAO: " + "getIntegrityAuditEntities() " + "ecountered a problem in execution: ";
-			logger.error(msg + e);
-			System.out.println(new Date());
-			e.printStackTrace();
-			throw new DbDaoTransactionException(e);
-		}
-		
-	}
-	
-	/**
-	 * getMyIntegrityAuditEntity() gets my IntegrityAuditEntity
-	 * @return
-	 * @throws DbDaoTransactionException
-	 */
-	public IntegrityAuditEntity getMyIntegrityAuditEntity() throws DbDaoTransactionException{
-		try{
-			EntityManager em = emf.createEntityManager();
-
-			// Start a transaction
-			EntityTransaction et = em.getTransaction();
-
-			et.begin();
-
-			// if IntegrityAuditEntity entry exists for resourceName and PU, retrieve it
-			Query iaequery = em.createQuery("Select i from IntegrityAuditEntity i where i.resourceName=:rn and i.persistenceUnit=:pu");
-			iaequery.setParameter("rn", this.resourceName);
-			iaequery.setParameter("pu", this.persistenceUnit);
-
-			@SuppressWarnings("rawtypes")
-			List iaeList = iaequery.getResultList();
-			IntegrityAuditEntity iae = null;
-
-			if(!iaeList.isEmpty()){
-				//ignores multiple results
-				iae = (IntegrityAuditEntity) iaeList.get(0);
-				// refresh the object from DB in case cached data was returned
-				em.refresh(iae);
-				logger.info("Resource: " + this.resourceName + " with PersistenceUnit: " + this.persistenceUnit
-						+ " exists");
-			}else{
-				// If it does not exist, log an error
-				logger.error("Attempting to setLastUpdated"
-						+ " on an entry that does not exist:"
-						+" resource " + this.resourceName + " with PersistenceUnit: " + this.persistenceUnit);
-			}
-
-			// close the transaction
-			et.commit();
-			// close the EntityManager
-			em.close();
-			
-			return iae;
-		}catch (Exception e){
-			String msg = "DbDAO: " + "setLastUpdated() " + "ecountered a problem in execution: ";
-			logger.error(msg + e);
-			System.out.println(new Date());
-			e.printStackTrace();
-			throw new DbDaoTransactionException(e);
-		}	
-	}
-
-	
-	/**
-	 * getIntegrityAuditEntity() gets the IntegrityAuditEntity with a particular ID
-	 * @param id
-	 * @return
-	 * @throws DbDaoTransactionException
-	 */
-	public IntegrityAuditEntity getIntegrityAuditEntity(long id) throws DbDaoTransactionException{
-		try{
-			EntityManager em = emf.createEntityManager();
-
-			// Start a transaction
-			EntityTransaction et = em.getTransaction();
-
-			et.begin();
-
-			IntegrityAuditEntity iae = em.find(IntegrityAuditEntity.class, id);
-
-			et.commit();
-			em.close();
-
-			return iae;
-		}catch (Exception e){
-			String msg = "DbDAO: " + "getIntegrityAuditEntity() " + "ecountered a problem in execution: ";
-			logger.error(msg + e);
-			System.out.println(new Date());
-			e.printStackTrace();
-			throw new DbDaoTransactionException(e);
-		}
-	}
-	
-	/**
-	 * getPersistenceClassNames() gets all the persistence class names.
-	 * @return
-	 */
-	public HashSet<String> getPersistenceClassNames(){
-		logger.debug("DbDAO: getPersistenceClassNames() entry");
-		HashSet<String> returnList = new HashSet<String>();
-		final Metamodel mm = emf.getMetamodel();
-		logger.debug("\n" + persistenceUnit +" persistence unit classes:");
-		for (final ManagedType<?> managedType : mm.getManagedTypes()) {
-			Class<?> c = managedType.getJavaType();
-			logger.debug("    " + c.getSimpleName());
-			returnList.add(c.getName()); //the full class name needed to make a query using jpa
-		}
-		logger.debug("DbDAO: getPersistenceClassNames() exit");
-		return returnList;
-	}
-	
-	/**
-	 * Register the IntegrityAudit instance
-	 */
-	private void register() throws DbDaoTransactionException {
-		try{
-			EntityManager em = emf.createEntityManager();
-
-			// Start a transaction
-			EntityTransaction et = em.getTransaction();
-
-			et.begin();
-
-			// if IntegrityAuditEntity entry exists for resourceName and PU, update it. If not found, create a new entry
-			Query iaequery = em.createQuery("Select i from IntegrityAuditEntity i where i.resourceName=:rn and i.persistenceUnit=:pu");
-			iaequery.setParameter("rn", this.resourceName);
-			iaequery.setParameter("pu", this.persistenceUnit);
-
-			@SuppressWarnings("rawtypes")
-			List iaeList = iaequery.getResultList();
-			IntegrityAuditEntity iae = null;
-
-			//If it already exists, we just want to update the properties and lastUpdated date
-			if(!iaeList.isEmpty()){
-				//ignores multiple results
-				iae = (IntegrityAuditEntity) iaeList.get(0);
-				// refresh the object from DB in case cached data was returned
-				em.refresh(iae);
-				logger.info("Resource: " + this.resourceName + " with PersistenceUnit: " + this.persistenceUnit 
-						+ " exists and entry be updated");
-			}else{
-				// If it does not exist, we also must add teh resourceName, persistenceUnit and designated values
-				logger.info("Adding resource " + resourceName + " with PersistenceUnit: " + this.persistenceUnit
-						+ " to IntegrityAuditEntity table");  	
-				iae = new IntegrityAuditEntity();
-				iae.setResourceName(this.resourceName);
-				iae.setPersistenceUnit(this.persistenceUnit);
-				iae.setDesignated(false);
-			}
-			//update/set properties in entry
-			iae.setSite(this.siteName);
-			iae.setNodeType(this.nodeType);
-			iae.setLastUpdated(new Date());
-			iae.setJdbcDriver(this.dbDriver);
-			iae.setJdbcPassword(this.dbPwd);
-			iae.setJdbcUrl(dbUrl);
-			iae.setJdbcUser(dbUser);
-
-			em.persist(iae);
-			// flush to the DB
-			em.flush();
-
-			// commit transaction
-			et.commit();
-			em.close();
-		}catch (Exception e){
-			String msg = "DbDAO: " + "register() " + "ecountered a problem in execution: ";
-			logger.error(msg + e);
-			System.out.println(new Date());
-			e.printStackTrace();
-			throw new DbDaoTransactionException(e);
-		}
-
-	}
-	
-	public void setDesignated(boolean designated) throws DbDaoTransactionException{
-		setDesignated(this.resourceName, this.persistenceUnit, designated);
-	}
-	
-
-	public void setDesignated(String rName, String pUnit, boolean desig) throws DbDaoTransactionException{
-		logger.debug("setDesignated: enter, resourceName: " + rName + ", persistenceUnit: " 
-				+ pUnit + ", designated: " + desig);
-		try{
-
-			EntityManager em = emf.createEntityManager();
-
-			// Start a transaction
-			EntityTransaction et = em.getTransaction();
-
-			et.begin();
-
-			// if IntegrityAuditEntity entry exists for resourceName and PU, update it. If not found, create a new entry
-			Query iaequery = em.createQuery("Select i from IntegrityAuditEntity i where i.resourceName=:rn and i.persistenceUnit=:pu");
-			iaequery.setParameter("rn", rName);
-			iaequery.setParameter("pu", pUnit);
-
-			@SuppressWarnings("rawtypes")
-			List iaeList = iaequery.getResultList();
-			IntegrityAuditEntity iae = null;
-
-			if(!iaeList.isEmpty()){
-				//ignores multiple results
-				iae = (IntegrityAuditEntity) iaeList.get(0);
-				// refresh the object from DB in case cached data was returned
-				em.refresh(iae);
-				logger.info("Resource: " + rName + " with PersistenceUnit: " + pUnit 
-						+ " exists and designated be updated");
-				iae.setDesignated(desig);
-
-				em.persist(iae);
-				// flush to the DB
-				em.flush();
-			}else{
-				// If it does not exist, log an error
-				logger.error("Attempting to setDesignated("
-						+ desig + ") on an entry that does not exist:"
-						+" resource " + rName + " with PersistenceUnit: " + pUnit);
-			}
-
-			// close the transaction
-			et.commit();
-			// close the EntityManager
-			em.close();
-		}catch (Exception e){
-			String msg = "DbDAO: " + "setDesignated() " + "ecountered a problem in execution: ";
-			logger.error(msg + e);
-			System.out.println(new Date());
-			e.printStackTrace();
-			throw new DbDaoTransactionException(e);
-		}
-
-	}
-	
-	public void setLastUpdated() throws DbDaoTransactionException{
-		logger.debug("setLastUpdated: enter, resourceName: " + this.resourceName + ", persistenceUnit: " 
-				+ this.persistenceUnit);
-		try{
-			EntityManager em = emf.createEntityManager();
-
-			// Start a transaction
-			EntityTransaction et = em.getTransaction();
-
-			et.begin();
-
-			// if IntegrityAuditEntity entry exists for resourceName and PU, update it. If not found, create a new entry
-			Query iaequery = em.createQuery("Select i from IntegrityAuditEntity i where i.resourceName=:rn and i.persistenceUnit=:pu");
-			iaequery.setParameter("rn", this.resourceName);
-			iaequery.setParameter("pu", this.persistenceUnit);
-
-			@SuppressWarnings("rawtypes")
-			List iaeList = iaequery.getResultList();
-			IntegrityAuditEntity iae = null;
-
-			if(!iaeList.isEmpty()){
-				//ignores multiple results
-				iae = (IntegrityAuditEntity) iaeList.get(0);
-				// refresh the object from DB in case cached data was returned
-				em.refresh(iae);
-				logger.info("Resource: " + this.resourceName + " with PersistenceUnit: " + this.persistenceUnit
-						+ " exists and lastUpdated be updated");
-				iae.setLastUpdated(new Date());
-
-				em.persist(iae);
-				// flush to the DB
-				em.flush();
-			}else{
-				// If it does not exist, log an error
-				logger.error("Attempting to setLastUpdated"
-						+ " on an entry that does not exist:"
-						+" resource " + this.resourceName + " with PersistenceUnit: " + this.persistenceUnit);
-			}
-
-			// close the transaction
-			et.commit();
-			// close the EntityManager
-			em.close();
-		}catch (Exception e){
-			String msg = "DbDAO: " + "setLastUpdated() " + "ecountered a problem in execution: ";
-			logger.error(msg + e);
-			System.out.println(new Date());
-			e.printStackTrace();
-			throw new DbDaoTransactionException(e);
-		}
-
-	}
-	
-	/**
-	 * Normally this method should only be used in a JUnit test environment.
-	 * Manually deletes all PDP records in droolspdpentity table.
-	 */
-	public int deleteAllIntegrityAuditEntities() throws DbDaoTransactionException {
-		
-		try{
-			
-			if (!IntegrityAudit.isUnitTesting) {
-				String msg = "DbDAO: " + "deleteAllIntegrityAuditEntities() " + "should only be invoked during JUnit testing";
-				logger.error(msg);
-				throw new DbDaoTransactionException(msg);
-			}
-			
-			EntityManager em = emf.createEntityManager();
-			// Start a transaction
-			EntityTransaction et = em.getTransaction();
-
-			et.begin();
-
-			// if IntegrityAuditEntity entry exists for resourceName and PU, update it. If not found, create a new entry
-			Query iaequery = em.createQuery("Delete from IntegrityAuditEntity");
-
-			int returnCode = iaequery.executeUpdate();
-
-			// commit transaction
-			et.commit();
-			em.close();
-			
-			logger.info("deleteAllIntegrityAuditEntities: returnCode=" + returnCode);
-
-			return returnCode;
-
-		}catch (Exception e){
-			String msg = "DbDAO: " + "deleteAllIntegrityAuditEntities() " + "encountered a problem in execution: ";
-			logger.error(msg + e);
-			System.out.println(new Date());
-			e.printStackTrace();
-			throw new DbDaoTransactionException(e);
-		}
-		
-	}
-	
-	/**
-	 * Changes designation to specified resourceName
-	 * 
-	 * static lock object in conjunction with synchronized keyword ensures that
-	 * designation changes are done serially within a resource. I.e. static lock
-	 * ensures that multiple instantiations of DbDAO don't interleave
-	 * changeDesignated() invocations and potentially produce simultaneous
-	 * designations.
-	 * 
-	 * Optimistic locking (the default, versus pessimistic) is sufficient to
-	 * avoid simultaneous designations from interleaved changeDesignated()
-	 * invocations from different resources (entities), because it prevents
-	 * "dirty" and "non-repeatable" reads.
-	 * 
-	 * See http://www.objectdb.com/api/java/jpa/LockModeType
-	 * 
-	 * and
-	 * 
-	 * http://stackoverflow.com/questions/2120248/how-to-synchronize-a-static-
-	 * variable-among-threads-running-different-instances-o
-	 */
-	public void changeDesignated(String resourceName, String persistenceUnit,
-			String nodeType) throws DbDaoTransactionException {
-
-		if (logger.isDebugEnabled()) {
-			logger.debug("changeDesignated: Entering, resourceName="
-					+ resourceName + ", persistenceUnit=" + persistenceUnit
-					+ ", nodeType=" + nodeType);
-		}
-
-		long startTime = System.currentTimeMillis();
-
-		synchronized (lock) {
-
-			EntityManager em = null;
-			try {
-
-				em = emf.createEntityManager();
-				em.getTransaction().begin();
-
-				/*
-				 * Define query
-				 */
-				Query query = em
-						.createQuery("Select i from IntegrityAuditEntity i where i.persistenceUnit=:pu and i.nodeType=:nt");
-				query.setParameter("pu", persistenceUnit);
-				query.setParameter("nt", nodeType);
-
-				/*
-				 * Execute query using pessimistic write lock.  This ensures that if anyone else is currently reading
-				 * the records we'll throw a LockTimeoutException.
-				 */
-				@SuppressWarnings("unchecked")
-				List<IntegrityAuditEntity> integrityAuditEntityList = (List<IntegrityAuditEntity>) query
-						.getResultList();
-				for (Object o : integrityAuditEntityList) {
-					if (o instanceof IntegrityAuditEntity) {
-						IntegrityAuditEntity integrityAuditEntity = (IntegrityAuditEntity) o;
-						if (integrityAuditEntity.getResourceName().equals(
-								resourceName)) {
-							if (logger.isDebugEnabled()) {
-								logger.debug("changeDesignated: Designating resourceName="
-										+ integrityAuditEntity
-												.getResourceName());
-							}
-							integrityAuditEntity.setDesignated(true);
-						} else {
-							if (logger.isDebugEnabled()) {
-								logger.debug("changeDesignated: Removing designation from resourceName="
-										+ integrityAuditEntity
-												.getResourceName());
-							}
-							integrityAuditEntity.setDesignated(false);
-						}
-					}
-				}
-				
-				if (logger.isDebugEnabled()) {
-					logger.debug("changeDesignated: Committing designation to resourceName="
-							+ resourceName);
-				}
-				em.getTransaction().commit();
-
-				/*
-				 * If we get a LockTimeoutException, no harm done really. We'll
-				 * probably be successful on the next attempt. The odds of
-				 * another DbDAO instance on this entity or another entity
-				 * attempting a simultaneous IntegrityAuditEntity table
-				 * read/update are pretty slim (we're only in this method for
-				 * two or three milliseconds)
-				 */
-			} catch (LockTimeoutException e) {
-				em.getTransaction().rollback();
-				String msg = "DbDAO: " + "changeDesignated() "
-						+ "caught LockTimeoutException, message=" + e.getMessage();
-				logger.error(msg + e);
-				System.out.println(new Date());
-				e.printStackTrace();
-				throw new DbDaoTransactionException(msg, e);
-			} catch (Exception e) {
-				em.getTransaction().rollback();
-				String msg = "DbDAO: " + "changeDesignated() "
-						+ "caught Exception, message=" + e.getMessage();
-				logger.error(msg + e);
-				System.out.println(new Date());
-				e.printStackTrace();
-				throw new DbDaoTransactionException(msg, e);
-			}
-
-		} // end synchronized block
-
-		if (logger.isDebugEnabled()) {
-			logger.debug("changeDesignated: Exiting; time expended="
-					+ (System.currentTimeMillis() - startTime) + "ms");
-		}
-
-	}
-
-
-}