[AAI-ONAP] Keep the onap updated and remove code

Change-Id: I2eee989cf835d45a84b2edf2d3ec342e9411f1e5
Signed-off-by: Venkata Harish K Kajur <vk250x@att.com>

17 files changed, 970 insertions, 2023 deletions

diff --git a/aai-resources/src/main/java/org/openecomp/aai/config/DmaapConfig.java b/aai-resources/src/main/java/org/openecomp/aai/config/DmaapConfig.java
index aeee99f..e8676ca 100644
--- a/aai-resources/src/main/java/org/openecomp/aai/config/DmaapConfig.java
+++ b/aai-resources/src/main/java/org/openecomp/aai/config/DmaapConfig.java
@@ -5,16 +5,16 @@
  * 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.
+ * 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=========================================================
  */
 
diff --git a/aai-resources/src/main/java/org/openecomp/aai/migration/Enabled.java b/aai-resources/src/main/java/org/openecomp/aai/migration/Enabled.java
new file mode 100644
index 0000000..3534013
--- /dev/null
+++ b/aai-resources/src/main/java/org/openecomp/aai/migration/Enabled.java
@@ -0,0 +1,36 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * org.openecomp.aai
+ * ================================================================================
+ * 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.aai.migration;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+
+/**
+ * Used to enable a migration to be picked up by the {@link com.openecomp.aai.migration.MigrationControllerInternal MigrationController}
+ */
+@Target(ElementType.TYPE)
+@Retention(value = RetentionPolicy.RUNTIME)
+public @interface Enabled {
+
+}
diff --git a/aai-resources/src/main/java/org/openecomp/aai/migration/EventAction.java b/aai-resources/src/main/java/org/openecomp/aai/migration/EventAction.java
index 82b7cad..643af9b 100644
--- a/aai-resources/src/main/java/org/openecomp/aai/migration/EventAction.java
+++ b/aai-resources/src/main/java/org/openecomp/aai/migration/EventAction.java
@@ -20,6 +20,9 @@
 
 package org.openecomp.aai.migration;
 
+/**
+ * Used to describe the type of DMaaP event you would like to create
+ */
 public enum EventAction {
 	CREATE,
 	UPDATE,
diff --git a/aai-resources/src/main/java/org/openecomp/aai/migration/MigrationController.java b/aai-resources/src/main/java/org/openecomp/aai/migration/MigrationController.java
new file mode 100644
index 0000000..024645c
--- /dev/null
+++ b/aai-resources/src/main/java/org/openecomp/aai/migration/MigrationController.java
@@ -0,0 +1,49 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * org.openecomp.aai
+ * ================================================================================
+ * 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.aai.migration;
+
+import org.openecomp.aai.dbmap.AAIGraph;
+
+/**
+ * Wrapper class to allow {@link com.openecomp.aai.migration.MigrationControllerInternal MigrationControllerInternal}
+ * to be run from a shell script
+ */
+public class MigrationController {
+
+	/**
+	 * The main method.
+	 *
+	 * @param args
+	 *            the arguments
+	 */
+	public static void main(String[] args) {
+		
+		MigrationControllerInternal internal = new MigrationControllerInternal();
+		
+		try {
+			internal.run(args);
+		} catch (Exception e) {
+			//ignore
+		}
+		AAIGraph.getInstance().getGraph().close();
+		System.exit(0);
+	}
+}
diff --git a/aai-resources/src/main/java/org/openecomp/aai/migration/MigrationControllerInternal.java b/aai-resources/src/main/java/org/openecomp/aai/migration/MigrationControllerInternal.java
new file mode 100644
index 0000000..a296c76
--- /dev/null
+++ b/aai-resources/src/main/java/org/openecomp/aai/migration/MigrationControllerInternal.java
@@ -0,0 +1,417 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * org.openecomp.aai
+ * ================================================================================
+ * 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.aai.migration;
+
+import java.io.File;
+import java.io.IOException;
+import java.lang.reflect.InvocationTargetException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.List;
+import java.util.Properties;
+import java.util.Set;
+
+import org.apache.activemq.broker.BrokerService;
+import org.apache.commons.configuration.ConfigurationException;
+import org.apache.commons.configuration.PropertiesConfiguration;
+import org.apache.commons.lang.exception.ExceptionUtils;
+import org.apache.tinkerpop.gremlin.structure.io.IoCore;
+import org.openecomp.aai.db.props.AAIProperties;
+import org.openecomp.aai.dbmap.AAIGraph;
+import org.openecomp.aai.dbmap.DBConnectionType;
+import org.openecomp.aai.exceptions.AAIException;
+import org.openecomp.aai.introspection.Loader;
+import org.openecomp.aai.introspection.LoaderFactory;
+import org.openecomp.aai.introspection.ModelType;
+import org.openecomp.aai.introspection.Version;
+import org.openecomp.aai.serialization.engines.QueryStyle;
+import org.openecomp.aai.serialization.engines.TitanDBEngine;
+import org.openecomp.aai.serialization.engines.TransactionalGraphEngine;
+import org.openecomp.aai.util.AAIConstants;
+import org.openecomp.aai.util.FormatDate;
+import org.reflections.Reflections;
+import org.slf4j.MDC;
+
+import com.att.eelf.configuration.Configuration;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+import com.beust.jcommander.JCommander;
+import com.beust.jcommander.Parameter;
+import com.thinkaurelius.titan.core.TitanTransaction;
+
+/**
+ * Runs a series of migrations from a defined directory based on the presence of 
+ * the {@link com.openecomp.aai.migration.Enabled Enabled} annotation
+ * 
+ * It will also write a record of the migrations run to the database.
+ */
+public class MigrationControllerInternal {
+
+	private EELFLogger logger;
+	private final int DANGER_ZONE = 10;
+	private final String vertexType = "migration-list-1707";
+	private final List<String> resultsSummary = new ArrayList<>();
+	private BrokerService broker;
+	private final List<NotificationHelper> notifications = new ArrayList<>();
+	private final String snapshotLocation = AAIConstants.AAI_HOME + AAIConstants.AAI_FILESEP + "logs" + AAIConstants.AAI_FILESEP + "data" + AAIConstants.AAI_FILESEP + "migrationSnapshots";
+	/**
+	 * The main method.
+	 *
+	 * @param args
+	 *            the arguments
+	 */
+	public void run(String[] args) {
+		// Set the logging file properties to be used by EELFManager
+		Properties props = System.getProperties();
+		props.setProperty(Configuration.PROPERTY_LOGGING_FILE_NAME, "migration-logback.xml");
+		props.setProperty(Configuration.PROPERTY_LOGGING_FILE_PATH, AAIConstants.AAI_HOME_ETC_APP_PROPERTIES);
+
+		logger = EELFManager.getInstance().getLogger(MigrationControllerInternal.class.getSimpleName());
+		MDC.put("logFilenameAppender", MigrationController.class.getSimpleName());
+
+		boolean loadSnapshot = false;
+
+		CommandLineArgs cArgs = new CommandLineArgs();
+
+		JCommander jCommander = new JCommander(cArgs, args);
+		jCommander.setProgramName(MigrationController.class.getSimpleName());
+		// Set flag to load from snapshot based on the presence of snapshot and
+		// graph storage backend of inmemory
+		if (cArgs.dataSnapshot != null && !cArgs.dataSnapshot.isEmpty()) {
+			try {
+				PropertiesConfiguration config = new PropertiesConfiguration(cArgs.config);
+				if (config.getString("storage.backend").equals("inmemory")) {
+					loadSnapshot = true;
+					System.setProperty("load.snapshot.file", "true");
+					System.setProperty("snapshot.location", cArgs.dataSnapshot);
+				}
+			} catch (ConfigurationException e) {
+				logAndPrint("ERROR: Could not load titan configuration.\n" + ExceptionUtils.getFullStackTrace(e));
+				return;
+			}
+		}
+		System.setProperty("realtime.db.config", cArgs.config);
+		logAndPrint("\n\n---------- Connecting to Graph ----------");
+		AAIGraph.getInstance();
+
+		logAndPrint("---------- Connection Established ----------");
+		Version version = AAIProperties.LATEST;
+		QueryStyle queryStyle = QueryStyle.TRAVERSAL;
+		ModelType introspectorFactoryType = ModelType.MOXY;
+		Loader loader = LoaderFactory.createLoaderForVersion(introspectorFactoryType, version);
+		TransactionalGraphEngine engine = new TitanDBEngine(queryStyle, DBConnectionType.REALTIME, loader);
+		
+		if (cArgs.help) {
+			jCommander.usage();
+			engine.rollback();
+			return;
+		} else if (cArgs.list) {
+			Reflections reflections = new Reflections("org.openecomp.aai.migration");
+			Set<Class<? extends Migrator>> migratorClasses = findClasses(reflections);
+			List<Migrator> migratorList = createMigratorList(cArgs, migratorClasses);
+
+			sortList(migratorList);
+			engine.startTransaction();
+			System.out.println("---------- List of all migrations ----------");
+			migratorList.forEach(migrator -> {
+				boolean enabledAnnotation = migrator.getClass().isAnnotationPresent(Enabled.class);
+				String enabled = enabledAnnotation ? "Enabled" : "Disabled";
+				StringBuilder sb = new StringBuilder();
+				sb.append(migrator.getClass().getSimpleName() + " " + enabled);
+				sb.append(" ");
+				sb.append("[" + getDbStatus(migrator.getClass().getSimpleName(), engine) + "]");
+				System.out.println(sb.toString());
+			});
+			engine.rollback();
+			System.out.println("---------- Done ----------");
+			return;
+		}
+
+		
+		Reflections reflections = new Reflections("org.openecomp.aai.migration");
+
+		logAndPrint("---------- Looking for migration scripts to be executed. ----------");
+		Set<Class<? extends Migrator>> migratorClasses = findClasses(reflections);
+		List<Migrator> migratorList = createMigratorList(cArgs, migratorClasses);
+
+		sortList(migratorList);
+
+		if (!cArgs.scripts.isEmpty() && migratorList.size() == 0) {
+			logAndPrint("\tERROR: Failed to find migrations " + cArgs.scripts + ".");
+			logAndPrint("---------- Done ----------");
+		}
+
+		logAndPrint("\tFound " + migratorList.size() + " migration scripts.");
+		logAndPrint("---------- Executing Migration Scripts ----------");
+
+		
+		
+		takeSnapshotIfRequired(engine, cArgs, migratorList);
+
+		for (Migrator migratorClass : migratorList) {
+			String name = migratorClass.getClass().getSimpleName();
+			Migrator migrator;
+			if (migratorClass.getClass().isAnnotationPresent(Enabled.class)) {
+				
+				try {
+					engine.startTransaction();
+					if (!cArgs.forced && hasAlreadyRun(name, engine)) {
+						logAndPrint("Migration " + name + " has already been run on this database and will not be executed again. Use -f to force execution");
+						continue;
+					}
+					migrator = migratorClass.getClass().getConstructor(TransactionalGraphEngine.class).newInstance(engine);
+				} catch (InstantiationException | IllegalAccessException | IllegalArgumentException | InvocationTargetException | NoSuchMethodException | SecurityException e) {
+					logAndPrint("EXCEPTION caught initalizing migration class " + migratorClass.getClass().getSimpleName() + ".\n" + ExceptionUtils.getFullStackTrace(e));
+					engine.rollback();
+					continue;
+				}
+				logAndPrint("\tRunning " + migratorClass.getClass().getSimpleName() + " migration script.");
+				logAndPrint("\t\t See " + System.getProperty("AJSC_HOME") + "/logs/migration/" + migratorClass.getClass().getSimpleName() + "/* for logs.");
+				MDC.put("logFilenameAppender", migratorClass.getClass().getSimpleName() + "/" + migratorClass.getClass().getSimpleName());
+	
+				migrator.run();
+		
+				commitChanges(engine, migrator, cArgs);
+			} else {
+				logAndPrint("\tSkipping " + migratorClass.getClass().getSimpleName() + " migration script because it has been disabled.");
+			}
+		}
+		MDC.put("logFilenameAppender", MigrationController.class.getSimpleName());
+		for (NotificationHelper notificationHelper : notifications) {
+			try {
+				notificationHelper.triggerEvents();
+			} catch (AAIException e) {
+				logAndPrint("\tcould not event");
+				logger.error("could not event", e);
+			}
+		}
+		logAndPrint("---------- Done ----------");
+
+		// Save post migration snapshot if snapshot was loaded
+		generateSnapshot(engine, "post");
+		
+		outputResultsSummary();
+	}
+
+	private String getDbStatus(String name, TransactionalGraphEngine engine) {
+		if (hasAlreadyRun(name, engine)) {
+			return "Already executed in this env";
+		}
+		return "Will be run on next execution";
+	}
+
+	private boolean hasAlreadyRun(String name, TransactionalGraphEngine engine) {
+		return engine.asAdmin().getReadOnlyTraversalSource().V().has(AAIProperties.NODE_TYPE, vertexType).has(name, true).hasNext();
+	}
+	private Set<Class<? extends Migrator>> findClasses(Reflections reflections) {
+		Set<Class<? extends Migrator>> migratorClasses = reflections.getSubTypesOf(Migrator.class);
+		migratorClasses.remove(PropertyMigrator.class);
+		return migratorClasses;
+	}
+
+
+	private void takeSnapshotIfRequired(TransactionalGraphEngine engine, CommandLineArgs cArgs, List<Migrator> migratorList) {
+
+		/*int sum = 0;
+		for (Migrator migrator : migratorList) {
+			if (migrator.getClass().isAnnotationPresent(Enabled.class)) {
+				sum += migrator.getDangerRating();
+			}
+		}
+		
+		if (sum >= DANGER_ZONE) {
+			
+			logAndPrint("Entered Danger Zone. Taking snapshot.");
+		}*/
+		
+		//always take snapshot for now
+		generateSnapshot(engine, "pre");
+
+	}
+
+
+	private List<Migrator> createMigratorList(CommandLineArgs cArgs,
+			Set<Class<? extends Migrator>> migratorClasses) {
+		List<Migrator> migratorList = new ArrayList<>();
+
+		for (Class<? extends Migrator> migratorClass : migratorClasses) {
+			if (!cArgs.scripts.isEmpty() && !cArgs.scripts.contains(migratorClass.getSimpleName())) {
+				continue;
+			} else {
+				Migrator migrator;
+				try {
+
+					migrator = migratorClass.getConstructor().newInstance();
+				} catch (InstantiationException | IllegalAccessException | IllegalArgumentException | InvocationTargetException | NoSuchMethodException | SecurityException e) {
+					logAndPrint("EXCEPTION caught initalizing migration class " + migratorClass.getSimpleName() + ".\n" + ExceptionUtils.getFullStackTrace(e));
+					continue;
+				}
+				migratorList.add(migrator);
+			}
+		}
+		return migratorList;
+	}
+
+
+	private void sortList(List<Migrator> migratorList) {
+		Collections.sort(migratorList, new Comparator<Migrator>() {
+			public int compare(Migrator m1, Migrator m2) {
+				try {
+					
+					if (m1.getPriority() > m2.getPriority()) {
+						return 1;
+					} else if (m1.getPriority() < m2.getPriority()) {
+						return -1;
+					} else {
+						return m1.getClass().getSimpleName().compareTo(m2.getClass().getSimpleName());
+					}
+				} catch (Exception e) {
+					return 0;
+				}
+			}
+		});
+	}
+
+	
+	private void generateSnapshot(TransactionalGraphEngine engine, String phase) {
+		
+		FormatDate fd = new FormatDate("yyyyMMddHHmm", "GMT");
+		String dateStr= fd.getDateTime();
+		String fileName = snapshotLocation + File.separator + phase + "Migration." + dateStr + ".graphson";
+		logAndPrint("Saving snapshot of inmemory graph " + phase + " migration to " + fileName);
+		TitanTransaction transaction = null;
+		try {
+			
+			Path pathToFile = Paths.get(fileName);
+			if (!pathToFile.toFile().exists()) {
+				Files.createDirectories(pathToFile.getParent());
+			}
+			transaction = engine.startTransaction();
+			transaction.io(IoCore.graphson()).writeGraph(fileName);
+			engine.rollback();
+		} catch (IOException e) {
+			logAndPrint("ERROR: Could not write in memory graph to " + phase + "Migration file. \n" + ExceptionUtils.getFullStackTrace(e));
+			engine.rollback();
+		} 
+
+		logAndPrint( phase + " migration snapshot saved to " + fileName);
+	}
+	/**
+	 * Log and print.
+	 *
+	 * @param logger
+	 *            the logger
+	 * @param msg
+	 *            the msg
+	 */
+	protected void logAndPrint(String msg) {
+		System.out.println(msg);
+		logger.info(msg);
+	}
+
+	/**
+	 * Commit changes.
+	 *
+	 * @param g
+	 *            the g
+	 * @param migrator
+	 *            the migrator
+	 * @param logger
+	 *            the logger
+	 */
+	protected void commitChanges(TransactionalGraphEngine engine, Migrator migrator, CommandLineArgs cArgs) {
+
+		String simpleName = migrator.getClass().getSimpleName();
+		String message;
+		if (migrator.getStatus().equals(Status.FAILURE)) {
+			message = "Migration " + simpleName + " Failed. Rolling back.";
+			logAndPrint("\t" + message);
+			migrator.rollback();
+		} else if (migrator.getStatus().equals(Status.CHECK_LOGS)) {
+			message = "Migration " + simpleName + " encountered an anomily, check logs. Rolling back.";
+			logAndPrint("\t" + message);
+			migrator.rollback();
+		} else {
+			MDC.put("logFilenameAppender", simpleName + "/" + migrator.getClass().getSimpleName());
+
+			if (cArgs.commit) {
+				if (!engine.asAdmin().getTraversalSource().V().has(AAIProperties.NODE_TYPE, vertexType).hasNext()) {
+					engine.asAdmin().getTraversalSource().addV(AAIProperties.NODE_TYPE, vertexType).iterate();
+				}
+				engine.asAdmin().getTraversalSource().V().has(AAIProperties.NODE_TYPE, vertexType)
+				.property(simpleName, true).iterate();
+				MDC.put("logFilenameAppender", MigrationController.class.getSimpleName());
+				notifications.add(migrator.getNotificationHelper());
+				migrator.commit();
+				message = "Migration " + simpleName + " Succeeded. Changes Committed.";
+				logAndPrint("\t"+ message +"\t");
+			} else {
+				message = "--commit not specified. Not committing changes for " + simpleName + " to database.";
+				logAndPrint("\t" + message);
+				migrator.rollback();
+			}
+
+		}
+		
+		resultsSummary.add(message);
+
+	}
+	
+	private void outputResultsSummary() {
+		logAndPrint("---------------------------------");
+		logAndPrint("-------------Summary-------------");
+		for (String result : resultsSummary) {
+			logAndPrint(result);
+		}
+		logAndPrint("---------------------------------");
+		logAndPrint("---------------------------------");
+	}
+	
+}
+
+class CommandLineArgs {
+
+	@Parameter(names = "--help", help = true)
+	public boolean help;
+
+	@Parameter(names = "-c", description = "location of configuration file")
+	public String config;
+
+	@Parameter(names = "-m", description = "names of migration scripts")
+	public List<String> scripts = new ArrayList<>();
+
+	@Parameter(names = "-l", description = "list the status of migrations")
+	public boolean list = false;
+	
+	@Parameter(names = "-d", description = "location of data snapshot", hidden = true)
+	public String dataSnapshot;
+	
+	@Parameter(names = "-f", description = "force migrations to be rerun")
+	public boolean forced = false;
+	
+	@Parameter(names = "--commit", description = "commit changes to graph")
+	public boolean commit = false;
+
+}
diff --git a/aai-resources/src/main/java/org/openecomp/aai/migration/Migrator.java b/aai-resources/src/main/java/org/openecomp/aai/migration/Migrator.java
new file mode 100644
index 0000000..5ed0213
--- /dev/null
+++ b/aai-resources/src/main/java/org/openecomp/aai/migration/Migrator.java
@@ -0,0 +1,262 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * org.openecomp.aai
+ * ================================================================================
+ * 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.aai.migration;
+
+import java.util.Iterator;
+import java.util.Optional;
+
+import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.__;
+import org.apache.tinkerpop.gremlin.structure.Direction;
+import org.apache.tinkerpop.gremlin.structure.Edge;
+import org.apache.tinkerpop.gremlin.structure.Property;
+import org.apache.tinkerpop.gremlin.structure.Vertex;
+import org.apache.tinkerpop.gremlin.structure.VertexProperty;
+import org.json.JSONException;
+import org.json.JSONObject;
+import org.openecomp.aai.db.props.AAIProperties;
+import org.openecomp.aai.exceptions.AAIException;
+import org.openecomp.aai.introspection.Loader;
+import org.openecomp.aai.introspection.LoaderFactory;
+import org.openecomp.aai.introspection.ModelType;
+import org.openecomp.aai.introspection.Version;
+import org.openecomp.aai.serialization.db.DBSerializer;
+import org.openecomp.aai.serialization.db.EdgeRules;
+import org.openecomp.aai.serialization.db.EdgeType;
+import org.openecomp.aai.serialization.db.exceptions.NoEdgeRuleFoundException;
+import org.openecomp.aai.serialization.engines.TransactionalGraphEngine;
+
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+
+/**
+ * This class defines an A&AI Migration
+ */
+public abstract class Migrator implements Runnable {
+	
+	protected EELFLogger logger = null;
+
+	protected DBSerializer serializer = null;
+	protected Loader loader = null;
+
+	protected TransactionalGraphEngine engine;
+	protected NotificationHelper notificationHelper;
+	
+	public Migrator() {
+		//used for not great reflection implementation
+	}
+	/**
+	 * Instantiates a new migrator.
+	 *
+	 * @param g the g
+	 */
+	public Migrator(TransactionalGraphEngine engine){
+        this.engine = engine;
+        initDBSerializer();
+        this.notificationHelper = new NotificationHelper(loader, serializer, engine, "AAI-MIGRATION", this.getMigrationName());
+		logger = EELFManager.getInstance().getLogger(this.getClass().getSimpleName());
+		logger.info("\tInitilization of " + this.getClass().getSimpleName() + " migration script complete.");
+	}
+
+	/**
+	 * Gets the status.
+	 *
+	 * @return the status
+	 */
+	public abstract Status getStatus();
+
+	/**
+	 * Rollback.
+	 */
+	public void rollback() {
+        engine.rollback();
+	}
+
+	/**
+	 * Commit.
+	 */
+	public void commit() {
+        engine.commit();
+	}
+
+	/**
+	 * Gets the priority.
+	 *
+	 * Lower number has higher priority
+	 * 
+	 * @return the priority
+	 */
+	public abstract int getPriority();
+
+	/**
+	 * The larger the number, the more danger
+	 * 
+	 * Range is 0-10
+	 * 
+	 * @return danger rating
+	 */
+	public abstract int getDangerRating();
+	/**
+	 * As string.
+	 *
+	 * @param v the v
+	 * @return the string
+	 */
+	protected String asString(Vertex v) {
+		final JSONObject result = new JSONObject();
+		Iterator<VertexProperty<Object>> properties = v.properties();
+		Property<Object> pk = null;
+		try {
+			while (properties.hasNext()) {
+				pk = properties.next();
+				result.put(pk.key(), pk.value());
+			}
+		} catch (JSONException e) {
+			logger.error("Warning error reading vertex: " + e);
+		}
+
+		return result.toString();
+	}
+
+	/**
+	 * As string.
+	 *
+	 * @param edge the edge
+	 * @return the string
+	 */
+	protected String asString(Edge edge) {
+		final JSONObject result = new JSONObject();
+		Iterator<Property<Object>> properties = edge.properties();
+		Property<Object> pk = null;
+		try {
+			while (properties.hasNext()) {
+				pk = properties.next();
+				result.put(pk.key(), pk.value());
+			}
+		} catch (JSONException e) {
+			logger.error("Warning error reading edge: " + e);
+		}
+
+		return result.toString();
+	}
+	/**
+	 * Checks for edge between.
+	 *
+	 * @param vertex a
+	 * @param vertex b
+	 * @param direction d
+	 * @param edgeLabel the edge label
+	 * @return true, if successful
+	 */
+	protected boolean hasEdgeBetween(Vertex a, Vertex b, Direction d, String edgeLabel) {
+
+		if (d.equals(Direction.OUT)) {
+			return engine.asAdmin().getReadOnlyTraversalSource().V(a).out(edgeLabel).where(__.otherV().hasId(b)).hasNext();
+		} else {
+			return engine.asAdmin().getReadOnlyTraversalSource().V(a).in(edgeLabel).where(__.otherV().hasId(b)).hasNext();
+		}
+
+	}
+	
+	/**
+	 * Creates the edge
+	 *
+	 * @param edgeType the edge type - COUSIN or TREE
+	 * @param out the out
+	 * @param in the in
+	 * @return the edge
+	 */
+	protected Edge createEdge(EdgeType type, Vertex out, Vertex in) throws AAIException {
+		Edge newEdge = null;
+		try {
+			if (type.equals(EdgeType.COUSIN)){
+				newEdge = EdgeRules.getInstance().addEdge(this.engine.asAdmin().getTraversalSource(), out, in);
+			} else {
+				newEdge = EdgeRules.getInstance().addTreeEdge(this.engine.asAdmin().getTraversalSource(), out, in);
+			}
+		} catch (NoEdgeRuleFoundException e) {
+			throw new AAIException("AAI_6129", e);
+		}
+		return newEdge;
+	}
+
+	/**
+	 * Creates the TREE edge 
+	 *
+	 * @param out the out
+	 * @param in the in
+	 * @return the edge
+	 */
+	protected Edge createTreeEdge(Vertex out, Vertex in) throws AAIException {
+		Edge newEdge = createEdge(EdgeType.TREE, out, in);
+		return newEdge;
+	}
+	
+	/**
+	 * Creates the COUSIN edge 
+	 *
+	 * @param out the out
+	 * @param in the in
+	 * @return the edge
+	 */
+	protected Edge createCousinEdge(Vertex out, Vertex in) throws AAIException {
+		Edge newEdge = createEdge(EdgeType.COUSIN, out, in);
+		return newEdge;
+	}
+
+	protected Edge createCousinEdgeBestEffort(Vertex out, Vertex in) throws AAIException {
+		return EdgeRules.getInstance().addEdgeIfPossible(this.engine.asAdmin().getTraversalSource(), out, in);
+	}
+	private void initDBSerializer() {
+		Version version = AAIProperties.LATEST;
+		ModelType introspectorFactoryType = ModelType.MOXY;
+		loader = LoaderFactory.createLoaderForVersion(introspectorFactoryType, version);
+		try {
+			this.serializer = new DBSerializer(version, this.engine, introspectorFactoryType, this.getMigrationName());
+		} catch (AAIException e) {
+			throw new RuntimeException("could not create seralizer", e);
+		}
+	}
+	
+	/**
+	 * These are the node types you would like your traversal to process
+	 * @return
+	 */
+	public abstract Optional<String[]> getAffectedNodeTypes();
+	
+	/**
+	 * used as the "fromAppId" when modifying vertices
+	 * @return
+	 */
+	public abstract String getMigrationName();
+	
+	/**
+	 * updates all internal vertex properties
+	 * @param v
+	 * @param isNewVertex
+	 */
+	protected void touchVertexProperties(Vertex v, boolean isNewVertex) {
+		this.serializer.touchStandardVertexProperties(v, isNewVertex);
+	}
+	
+	public NotificationHelper getNotificationHelper() {
+		return this.notificationHelper;
+	}
+}
diff --git a/aai-resources/src/main/java/org/openecomp/aai/migration/NotificationHelper.java b/aai-resources/src/main/java/org/openecomp/aai/migration/NotificationHelper.java
index b956705..b00128d 100644
--- a/aai-resources/src/main/java/org/openecomp/aai/migration/NotificationHelper.java
+++ b/aai-resources/src/main/java/org/openecomp/aai/migration/NotificationHelper.java
@@ -28,7 +28,6 @@ import java.util.List;
 import javax.ws.rs.core.Response.Status;
 
 import org.apache.tinkerpop.gremlin.structure.Vertex;
-
 import org.openecomp.aai.exceptions.AAIException;
 import org.openecomp.aai.introspection.Introspector;
 import org.openecomp.aai.introspection.Loader;
@@ -37,9 +36,13 @@ import org.openecomp.aai.rest.ueb.UEBNotification;
 import org.openecomp.aai.serialization.db.DBSerializer;
 import org.openecomp.aai.serialization.engines.TransactionalGraphEngine;
 import org.openecomp.aai.serialization.engines.query.QueryEngine;
+
 import com.att.eelf.configuration.EELFLogger;
 import com.att.eelf.configuration.EELFManager;
 
+/**
+ * Allows for DMaaP notifications from Migrations
+ */
 public class NotificationHelper {
 
 	private static final EELFLogger LOGGER = EELFManager.getInstance().getLogger(NotificationHelper.class);
diff --git a/aai-resources/src/main/java/org/openecomp/aai/migration/PropertyMigrator.java b/aai-resources/src/main/java/org/openecomp/aai/migration/PropertyMigrator.java
new file mode 100644
index 0000000..ccc8aa6
--- /dev/null
+++ b/aai-resources/src/main/java/org/openecomp/aai/migration/PropertyMigrator.java
@@ -0,0 +1,149 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * org.openecomp.aai
+ * ================================================================================
+ * 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.aai.migration;
+
+import java.util.Optional;
+
+import org.apache.tinkerpop.gremlin.process.traversal.P;
+import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversal;
+import org.apache.tinkerpop.gremlin.structure.Vertex;
+import org.openecomp.aai.db.props.AAIProperties;
+import org.openecomp.aai.serialization.engines.TransactionalGraphEngine;
+
+import com.thinkaurelius.titan.core.Cardinality;
+import com.thinkaurelius.titan.core.PropertyKey;
+import com.thinkaurelius.titan.core.schema.TitanManagement;
+
+/**
+ * A migration template for migrating a property from one name to another
+ */
+public abstract class PropertyMigrator extends Migrator {
+
+	protected final String OLD_FIELD;
+	protected final String NEW_FIELD;
+	protected final Class<?> fieldType;
+	protected final Cardinality cardinality;
+	protected final TitanManagement graphMgmt;
+	public PropertyMigrator() {
+		//used for not great reflection implementation
+		super();
+		this.OLD_FIELD = null;
+		this.NEW_FIELD = null;
+		this.fieldType = null;
+		this.cardinality = null;
+		this.graphMgmt = null;
+	}
+	public PropertyMigrator(TransactionalGraphEngine engine, String oldName, String newName, Class<?> type, Cardinality cardinality) {
+		super(engine);
+		this.OLD_FIELD = oldName;
+		this.NEW_FIELD = newName;
+		this.fieldType = type;
+		this.cardinality = cardinality;
+		this.graphMgmt = engine.asAdmin().getManagementSystem();
+	}
+
+	/**
+	 * Do not override this method as an inheritor of this class
+	 */
+	@Override
+	public void run() {
+		
+		modifySchema();
+		executeModifyOperation();
+		
+	}
+
+	protected void modifySchema() {
+		this.addIndex(this.addProperty());
+		graphMgmt.commit();
+	}
+	
+	/**
+	 * This is where inheritors should add their logic
+	 */
+	protected void executeModifyOperation() {
+		changePropertyName();
+	}
+	
+	protected void changePropertyName() {
+		GraphTraversal<Vertex, Vertex> g = this.engine.asAdmin().getTraversalSource().V();
+		if (this.getAffectedNodeTypes().isPresent()) {
+			g.has(AAIProperties.NODE_TYPE, P.within(this.getAffectedNodeTypes().get()));
+		}
+		g.has(OLD_FIELD).sideEffect(t -> {
+			final Vertex v = t.get();
+			final String value = v.value(OLD_FIELD);
+			v.property(OLD_FIELD).remove();
+			v.property(NEW_FIELD, value);
+			this.touchVertexProperties(v, false);
+		}).iterate();
+	}
+	
+	@Override
+	public Status getStatus() {
+		GraphTraversal<Vertex, Vertex> g = this.engine.asAdmin().getTraversalSource().V();
+		if (this.getAffectedNodeTypes().isPresent()) {
+			g.has(AAIProperties.NODE_TYPE, P.within(this.getAffectedNodeTypes().get()));
+		}
+		long result = g.has(OLD_FIELD).count().next();
+		if (result == 0) {
+			return Status.SUCCESS;
+		} else {
+			return Status.FAILURE;
+		}
+	}
+	
+	@Override
+	public int getPriority() {
+		return 0;
+	}
+
+	@Override
+	public int getDangerRating() {
+		return 1;
+	}
+	
+	protected Optional<PropertyKey> addProperty() {
+
+		if (!graphMgmt.containsPropertyKey(this.NEW_FIELD)) {
+			logger.info(" PropertyKey  [" + this.NEW_FIELD + "] created in the DB. ");
+			return Optional.of(graphMgmt.makePropertyKey(this.NEW_FIELD).dataType(this.fieldType).cardinality(this.cardinality)
+					.make());
+		} else {
+			logger.info(" PropertyKey  [" + this.NEW_FIELD + "] already existed in the DB. ");
+			return Optional.empty();
+		}
+
+	}
+	
+	protected void addIndex(Optional<PropertyKey> key) {
+		if (isIndexed() && key.isPresent()) {
+			if (graphMgmt.containsGraphIndex(key.get().name())) {
+				logger.debug(" Index  [" + key.get().name() + "] already existed in the DB. ");
+			} else {
+				logger.info("Add index for PropertyKey: [" + key.get().name() + "]");
+				graphMgmt.buildIndex(key.get().name(), Vertex.class).addKey(key.get()).buildCompositeIndex();
+			}
+		}
+	}
+	public abstract boolean isIndexed();
+	
+}
diff --git a/aai-resources/src/main/java/org/openecomp/aai/migration/Status.java b/aai-resources/src/main/java/org/openecomp/aai/migration/Status.java
new file mode 100644
index 0000000..a681d4d
--- /dev/null
+++ b/aai-resources/src/main/java/org/openecomp/aai/migration/Status.java
@@ -0,0 +1,30 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * org.openecomp.aai
+ * ================================================================================
+ * 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.aai.migration;
+
+/**
+ * Defines the status of the completed migration
+ */
+public enum Status {
+	SUCCESS,
+	CHECK_LOGS,
+	FAILURE
+}
diff --git a/aai-resources/src/main/java/org/openecomp/aai/rest/exceptions/AAIInvalidXMLNamespace.java b/aai-resources/src/main/java/org/openecomp/aai/rest/exceptions/AAIInvalidXMLNamespace.java
index e71e1f2..28d7e94 100644
--- a/aai-resources/src/main/java/org/openecomp/aai/rest/exceptions/AAIInvalidXMLNamespace.java
+++ b/aai-resources/src/main/java/org/openecomp/aai/rest/exceptions/AAIInvalidXMLNamespace.java
@@ -5,16 +5,16 @@
  * 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.
+ * 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=========================================================
  */
 
diff --git a/aai-resources/src/main/java/org/openecomp/aai/util/GetResource.java b/aai-resources/src/main/java/org/openecomp/aai/util/GetResource.java
deleted file mode 100644
index a0a3297..0000000
--- a/aai-resources/src/main/java/org/openecomp/aai/util/GetResource.java
+++ /dev/null
@@ -1,152 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * org.openecomp.aai
- * ================================================================================
- * 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.aai.util;
-
-import java.security.KeyManagementException;
-import java.util.Properties;
-import java.util.UUID;
-
-import org.openecomp.aai.exceptions.AAIException;
-import org.openecomp.aai.logging.ErrorLogHelper;
-import com.att.eelf.configuration.Configuration;
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.sun.jersey.api.client.Client;
-import com.sun.jersey.api.client.ClientResponse;
-
-
-public class GetResource {
-	
-	private static EELFLogger LOGGER;
-	private static final String FROMAPPID = "AAI-TOOLS";
-	private static final String TRANSID   = UUID.randomUUID().toString();
-	private static final String USAGE_STRING = "Usage: getTool.sh <resource-path> \n + "
-			+ "for example: resource-path for a particular customer is business/customers/customer/global-customer-id-1 \n";
-	
-	/**
-	 * The main method.
-	 *
-	 * @param args the arguments
-	 */
-	public static void main(String[] args) {
-
-		// Set the logging file properties to be used by EELFManager
-		Properties props = System.getProperties();
-		props.setProperty(Configuration.PROPERTY_LOGGING_FILE_NAME, AAIConstants.AAI_GETRES_LOGBACK_PROPS);
-		props.setProperty(Configuration.PROPERTY_LOGGING_FILE_PATH, AAIConstants.AAI_HOME_ETC_APP_PROPERTIES);
-		LOGGER = EELFManager.getInstance().getLogger(GetResource.class);
-		String url = null;
-		try {
-			if (args.length < 1) {
-				System.out.println("Nothing to get or Insufficient arguments");
-				System.out.println(USAGE_STRING);
-				System.exit(1);
-			} else { 
-				// Assume the config AAI_SERVER_URL has a last slash so remove if  
-				//  resource-path has it as the first char
-				url = args[0].replaceFirst("^/", "");
-				url = AAIConfig.get(AAIConstants.AAI_SERVER_URL) + url;
-
-				String dmsg = "url=" + url;
-				LOGGER.debug( dmsg );
-				System.out.println( dmsg );
-				
-				getNode(url);
-				System.exit(0);
-			}
-		} catch (AAIException e) {
-			String emsg = "GET failed: " + e.getMessage();
-			System.out.println(emsg);
-			LOGGER.error(emsg);
-			ErrorLogHelper.logException(e);
-			System.exit(1);	
-		} catch (Exception e) {
-			String emsg = "GET failed: " + e.getMessage();
-			System.out.println(emsg);
-			LOGGER.error(emsg);
-			ErrorLogHelper.logError("AAI_7402", e.getMessage());
-			System.exit(1);
-		}
-		
-	}
-	
-	/**
-	 * Gets the node.
-	 *
-	 * @param aaiLogger the aai logger
-	 * @param logline the logline
-	 * @param url the url
-	 * @return the node
-	 * @throws AAIException the AAI exception
-	 */
-	public static void getNode(String url) throws AAIException {		
-		try {
-			String useBasicAuth = AAIConfig.get("aai.tools.enableBasicAuth");
-			Client client = null;
-
-			if("true".equals(useBasicAuth)){
-			    client = HttpsAuthClient.getBasicAuthClient();
-			} else {
-			    client = HttpsAuthClient.getTwoWaySSLClient();
-			}
-			
-			System.out.println("Getting the resource...: " + url);
-		
-			ClientResponse cres = client.resource(url)
-									.header("X-TransactionId", TRANSID)
-									.header("X-FromAppId",  FROMAPPID)
-									.header("Authorization", HttpsAuthClient.getBasicAuthHeaderValue()) 
-
-									.accept("application/json")
-									.get(ClientResponse.class);
-						
-			if (cres.getStatus() == 404) { // resource not found
-				String infmsg = "\nResource does not exist: " + cres.getStatus()
-						+ ":" + cres.getEntity(String.class);
-				System.out.println(infmsg);
-				LOGGER.info(infmsg);
-	            throw new AAIException("AAI_7404", "Resource does not exist");
-			} else if (cres.getStatus() == 200){
-				String msg = cres.getEntity(String.class);
-				ObjectMapper mapper = new ObjectMapper();
-				Object json = mapper.readValue(msg, Object.class);
-				String indented = mapper.writerWithDefaultPrettyPrinter()
-				                               .writeValueAsString(json);
-				System.out.println(indented);
-				LOGGER.info(indented);
-			} else {
-				String emsg = "Getting the Resource failed: " + cres.getStatus()
-												+ ":\n" + cres.getEntity(String.class);
-				System.out.println(emsg);
-				LOGGER.error(emsg);
-	            throw new AAIException("AAI_7402", "Error during GET");
-			}
-		} catch (AAIException e) {
-            throw e;
-		} catch (KeyManagementException e) {
-            throw new AAIException("AAI_7401", e, "Error during GET");
-		}  catch (Exception e) {
-            throw new AAIException("AAI_7402", e, "Error during GET");
-		}
-	}	
-
-}
diff --git a/aai-resources/src/main/java/org/openecomp/aai/util/MergeResource.java b/aai-resources/src/main/java/org/openecomp/aai/util/MergeResource.java
deleted file mode 100644
index 427f65b..0000000
--- a/aai-resources/src/main/java/org/openecomp/aai/util/MergeResource.java
+++ /dev/null
@@ -1,205 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * org.openecomp.aai
- * ================================================================================
- * 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.aai.util;
-
-import java.lang.reflect.Field;
-import java.lang.reflect.Method;
-import java.util.Date;
-
-import com.sun.tools.javac.util.List;
-
-//SWGK - 01/08/2016 - Helper function to deal with concurrency control
-public class MergeResource {
-
-	//Merge Assumptions:
-	//fromresource and toresource are the same resource type and same resource object
-	//fromresource is the latest version from the DB
-	//toresource is the version of the same resource with updates
-	//merging of child elements are complete overwrite of fromresource corresponding child element
-	//merging of relationshiplist is complete overwrite of fromresource corresponding releationship element
-	//In case of supplying the only specific child element update, please specify the child element type (need not be in canonical form)
-    //For parent only update (not involving child or relationship element update), then all the child elements and relationship list will be set as null in the merged object
-	//For setting null to primitive type (including String) you have to do it after the merge is called specifically for parent only copy
-	
-	
-	/**
-	 * Merge.
-	 *
-	 * @param <T> the generic type
-	 * @param fromresource the fromresource
-	 * @param toresource the toresource
-	 * @param bupdateChildren the bupdate children
-	 * @param childNamelist the child namelist
-	 * @param bupdateRelatedLink the bupdate related link
-	 * @return the t
-	 */
-	public static <T> T merge(T fromresource, T toresource, boolean bupdateChildren, String childNamelist[], boolean bupdateRelatedLink)
-	{
-		Field[] fields = fromresource.getClass().getDeclaredFields();
-		if (fields != null)
-		{
-		    for (Field field : fields)
-		    {
-		    	try
-		    	{
-			    	field.setAccessible(true);
-			    	if ( field.getName().equalsIgnoreCase("resourceVersion") )
-			    		continue;
-			    	if ( isValidMergeType(field.getType()) )
-			    	{
-			    		 Object obj = field.get(toresource);
-			    	     // If the updated resource's any property to be set null then one has to set it separately for the merged object
-			    	     if (obj != null)
-			    	       field.set(fromresource, obj);
-			    	     continue;
-			    	}
-			    	else
-			    		// set the child list or relatedTo link to be null so no updates takes place
-			    		field.set(fromresource, null);
-			    	//override situation
-			    	if (bupdateChildren || bupdateRelatedLink)
-			    	{
-			    		if (bupdateRelatedLink && field.getName().equalsIgnoreCase("relationshipList"))
-			    		{
-		    		       Object obj = field.get(toresource);
-				    	   field.set(fromresource, obj);
-				    	   continue;
-			    		}
-			    		if (field.getName().equalsIgnoreCase("relationshipList"))
-			    			if (!bupdateRelatedLink)
-			    				continue;
-			    		// not an efficient as it blindly updates all children - onus is on callee to nullify
-			    		// specific child(ren) that they don't want to update after the merge call.
-			    		// can be optimized to send a list of children class names in canonical form
-			    		// but deferring for next release so that only those children can be merged
-			    		if (bupdateChildren && (childNamelist != null))
-			    		{
-			    		  for (String classStringName : childNamelist)
-			    		  {
-			    			 if ( !classStringName.isEmpty() && field.getType().toString().toLowerCase().endsWith(classStringName.toLowerCase()) )
-			    			 {
-				    		     Object obj = field.get(toresource);
-					    	     field.set(fromresource, obj);
-			    			 }
-			    		  }
-			    		  continue;
-			    		}
-			    		
-			    		if (bupdateChildren && (childNamelist == null))
-			    		{
-			    		   Object obj = field.get(toresource);
-					       field.set(fromresource, obj);
-			    		
-			    		}
-			    	}
-			    	
-		    	}
-		    	catch (Exception e)
-	    		{
-	    		
-	    		}
-		    	
-		    	
-		    }
-		}
-		return fromresource;
-	}
-	
-	
-	/**
-	 * Merge.
-	 *
-	 * @param <T> the generic type
-	 * @param fromresource the fromresource
-	 * @param toresource the toresource
-	 * @return the t
-	 */
-	public static <T> T merge(T fromresource, T toresource)
-	{
-		return merge(fromresource, toresource, false, false);
-	}
-	
-	/**
-	 * Merge.
-	 *
-	 * @param <T> the generic type
-	 * @param fromresource the fromresource
-	 * @param toresource the toresource
-	 * @param bupdateChildren the bupdate children
-	 * @param bupdateRelatedLink the bupdate related link
-	 * @return the t
-	 */
-	public static <T> T merge(T fromresource, T toresource, boolean bupdateChildren, boolean bupdateRelatedLink)
-	{
-		return merge(fromresource, toresource, bupdateChildren, null, bupdateRelatedLink);
-	}
-	
-	/**
-	 * Checks if is valid merge type.
-	 *
-	 * @param fieldType the field type
-	 * @return true, if is valid merge type
-	 */
-	public static boolean isValidMergeType(Class<?> fieldType) {
-        if (fieldType.equals(String.class)) {
-            return true;
-        } else if (Date.class.isAssignableFrom(fieldType)) {
-            return true;
-        } else if (Number.class.isAssignableFrom(fieldType)) {
-            return true;
-        } else if (fieldType.equals(Integer.TYPE)) {
-            return true;
-        } else if (fieldType.equals(Long.TYPE)) {
-            return true;
-        } else if (Enum.class.isAssignableFrom(fieldType)) {
-            return true;
-        } else if (Boolean.class.isAssignableFrom(fieldType)) {
-            return true;
-        }
-        else {
-            return false;
-        }
-    }
-	
-	/**
-	 * Gets the child return type.
-	 *
-	 * @param classname the classname
-	 * @param methodname the methodname
-	 * @return the class
-	 */
-	public static Class<?> GetChildReturnType(String classname, String methodname) 
-	{
-		try {
-		    Class<?> c = Class.forName(classname);
-		    Method[] allMethods = c.getDeclaredMethods();
-		    for (Method m : allMethods) {
-				if (!m.getName().equals(methodname)) {
-				    return m.getReturnType();
-				}
-		    }
-		} catch (ClassNotFoundException x) {
-		   
-		}
-	    
-		return null;
-	}
-}
diff --git a/aai-resources/src/main/java/org/openecomp/aai/util/PostResource.java b/aai-resources/src/main/java/org/openecomp/aai/util/PostResource.java
deleted file mode 100644
index 1caeb09..0000000
--- a/aai-resources/src/main/java/org/openecomp/aai/util/PostResource.java
+++ /dev/null
@@ -1,183 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * org.openecomp.aai
- * ================================================================================
- * 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.aai.util;
-
-import java.io.BufferedReader;
-import java.io.FileReader;
-import java.io.IOException;
-import java.nio.file.Path;
-import java.nio.file.Paths;
-import java.util.Properties;
-import java.util.UUID;
-
-import org.openecomp.aai.exceptions.AAIException;
-import org.openecomp.aai.logging.ErrorLogHelper;
-import com.att.eelf.configuration.Configuration;
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.google.common.base.CaseFormat;
-
-/*
- * Allows to call POST REST API that AAI supports - currently for edge-tag-query
- */
-public class PostResource {
-
-	private static EELFLogger LOGGER;
-	private static final String FROMAPPID = "AAI-TOOLS";
-	private static final String TRANSID = UUID.randomUUID().toString();
-	private static final String USAGE_STRING = "Usage: postTool.sh <resource-path> <filename>\n" +
-			"resource-path for a particular resource or query starting after the aai/<version>\n" +
-			"filename is the path to a file which contains the json input for the payload\n" +
-			"for example: postTool.sh search/edge-tag-query /tmp/query-input.json\n";
-	
-	/**
-	 * The main method.
-	 *
-	 * @param <T> the generic type
-	 * @param args the arguments
-	 */
-	public static <T> void main(String[] args) {
-
-		// Set the logging file properties to be used by EELFManager
-		Properties props = System.getProperties();
-		props.setProperty(Configuration.PROPERTY_LOGGING_FILE_NAME, AAIConstants.AAI_POSTTOOL_LOGBACK_PROPS);
-		props.setProperty(Configuration.PROPERTY_LOGGING_FILE_PATH, AAIConstants.AAI_HOME_ETC_APP_PROPERTIES);
-		LOGGER = EELFManager.getInstance().getLogger(PostResource.class);
-		try {
-			if (args.length < 2) {
-				System.out.println("Insufficient arguments");
-				System.out.println(USAGE_STRING);
-				System.exit(1);
-			}
-			
-			// Assume the config AAI_SERVER_URL has a last slash so remove if  
-			//  resource-path has it as the first char
-			String path = args[0].replaceFirst("^/", "");		
-			Path p = Paths.get(path);
-			
-			// currently , it is for edge-taq-query only
-			String query = p.getName(p.getNameCount() - 1).toString();
-			String resourceClass = null;
-			if (query.equals("edge-tag-query"))
-				resourceClass = "org.openecomp.aai.domain.search." + 
-						CaseFormat.LOWER_HYPHEN.to(CaseFormat.UPPER_CAMEL, query) + "Request";
-			else {
-				ErrorLogHelper.logError("AAI_7403", "Incorrect resource or query");
-				System.exit(1);
-			}
-			
-			String dMsg = "class=" + resourceClass;
-			System.out.println(dMsg);
-			LOGGER.debug(dMsg);
-			
-			dMsg = "path=" + path;
-			System.out.println(dMsg);
-			LOGGER.debug(dMsg);
-			
-			@SuppressWarnings("unchecked")
-			T resJson1 = (T)readJsonFile(Class.forName(resourceClass), args[1]);
-						
-			String response = RestController.<T>Post(resJson1, FROMAPPID, TRANSID, path);
-			ObjectMapper mapper = new ObjectMapper();
-			Object json = mapper.readValue(response, Object.class);
-			
-			String infMsg = " POST succeeded\n";
-			System.out.println(infMsg);
-			LOGGER.info(infMsg);
-			
-			infMsg = "Response = " + mapper.writer().withDefaultPrettyPrinter().writeValueAsString(json);
-			System.out.println(infMsg);
-			LOGGER.info(infMsg);
-			
-			infMsg = "\nDone!!";
-			System.out.println(infMsg);
-			LOGGER.info(infMsg);
-			
-			System.exit(0); 
-
-		} catch (AAIException e) {
-			ErrorLogHelper.logException(e);
-			System.exit(1);	
-		} catch (Exception e) {
-			ErrorLogHelper.logError("AAI_7402", e.getMessage());
-			System.exit(1);
-		}
-	}
-	
-	/**
-	 * Gets the single instance of PostResource.
-	 *
-	 * @param <T> the generic type
-	 * @param clazz the clazz
-	 * @return single instance of PostResource
-	 * @throws IllegalAccessException the illegal access exception
-	 * @throws InstantiationException the instantiation exception
-	 */
-	public static <T> T getInstance(Class<T> clazz) throws IllegalAccessException, InstantiationException
-	{
-		return clazz.newInstance();
-	} 
-	
-	/**
-	 * Read json file.
-	 *
-	 * @param <T> the generic type
-	 * @param clazz the clazz
-	 * @param fName the f name
-	 * @return the t
-	 * @throws AAIException the AAI exception
-	 */
-	public static <T> T  readJsonFile( Class<T> clazz, String fName ) throws AAIException 
-	{    	
-        String jsonData = "";
-        BufferedReader br = null;
-        T t;
-        
-        try {
-            String line;
-            br = new BufferedReader(new FileReader(fName));
-            while ((line = br.readLine()) != null) {
-                jsonData += line + "\n";
-            }
-        } catch (IOException e) {
-            throw new AAIException("AAI_7403", e, "Error opening json file");
-        } finally {
-            try {
-                if (br != null)
-                    br.close();
-            } catch (IOException ex) {
-                ex.printStackTrace();
-                throw new AAIException("AAI_7403", ex, "Error closing json file");
-            }
-        }
-
-        try {	        	
-        	t = MapperUtil.readWithDashesAsObjectOf(clazz, jsonData);
-        }
-        catch (Exception je){
-            throw new AAIException("AAI_7403", je, "Error parsing json file"); 
-        }
-
-        return t;
-
-    }//End readJsonFile()	 
-}
diff --git a/aai-resources/src/main/java/org/openecomp/aai/util/PutResource.java b/aai-resources/src/main/java/org/openecomp/aai/util/PutResource.java
deleted file mode 100644
index ced51cd..0000000
--- a/aai-resources/src/main/java/org/openecomp/aai/util/PutResource.java
+++ /dev/null
@@ -1,432 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * org.openecomp.aai
- * ================================================================================
- * 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.aai.util;
-
-import java.io.BufferedReader;
-import java.io.FileReader;
-import java.io.IOException;
-import java.lang.reflect.Field;
-import java.net.URI;
-import java.nio.file.Path;
-import java.nio.file.Paths;
-import java.security.KeyManagementException;
-import java.util.Properties;
-import java.util.UUID;
-
-import org.openecomp.aai.db.props.AAIProperties;
-import org.openecomp.aai.exceptions.AAIException;
-import org.openecomp.aai.introspection.Loader;
-import org.openecomp.aai.introspection.LoaderFactory;
-import org.openecomp.aai.introspection.ModelType;
-import org.openecomp.aai.logging.ErrorLogHelper;
-import org.openecomp.aai.parsers.uri.URIToObject;
-
-import com.att.eelf.configuration.Configuration;
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
-import com.google.common.base.CaseFormat;
-import com.sun.jersey.api.client.Client;
-import com.sun.jersey.api.client.ClientResponse;
-
-/*
- * SWGK - 09/03/2015 - Added Generics to Put as well as to Get the object that was created/updated
- * by Put to get the Object back.
- */
-public class PutResource {
-	
-	private static EELFLogger LOGGER;
-	private static final String FROMAPPID = "AAI-TOOLS";
-	private static final String TRANSID = UUID.randomUUID().toString();
-	private static final String USAGE_STRING = "Usage: putTool.sh <resource-path> <filename> <UpdatingRelationshiplist> <UpdatingChild> <ChildNameList> <SkipIfExists>\n" +
-			"resource-path for a particular resource starting after the aai/<version>\n" +
-			"filename is the path to a file which contains the json input for the payload\n" +
-			"optional UpdatingRelationshiplist setting 1 for updating the relationship list and if setting 0 relationship list will not be updated.\n" +
-			"optional UpdatingChild setting 1 for updating the child(r)en and if setting 0 child(ren) will not be updated.\n" +
-			"optional ChildNameList is a comma-separated child(ren) name list only applicable if UpdatingChild is set to 1.\n" +
-			"optional SkipIfExisting setting 1 to skip the update if resource exists and if setting 0 put will be done.\n" +
-			"for example 1: putTool.sh cloud-infrastructure/oam-networks/oam-network/test-100-oam /tmp/putoam.json\n" +
-			"for example 2: putTool.sh cloud-infrastructure/pservers/pserver/dpa2r04c009-swgk-009 /tmp/pserver.json 0 1 PInterfaces,LagInterfaces\n" +
-			"for example 2: putTool.sh cloud-infrastructure/pservers/pserver/dpa2r04c009-swgk-009 /tmp/pserver.json 0 1 PInterfaces,LagInterfaces 1\n";
-	
-	/**
-	 * The main method.
-	 *
-	 * @param <T> the generic type
-	 * @param args the arguments
-	 */
-	public static <T> void main(String[] args) {
-
-		// Set the logging file properties to be used by EELFManager
-		Properties props = System.getProperties();
-		props.setProperty(Configuration.PROPERTY_LOGGING_FILE_NAME, AAIConstants.AAI_PUTTOOL_LOGBACK_PROPS);
-		props.setProperty(Configuration.PROPERTY_LOGGING_FILE_PATH, AAIConstants.AAI_HOME_ETC_APP_PROPERTIES);
-		LOGGER = EELFManager.getInstance().getLogger(PutResource.class);
-		Boolean bResVersionEnabled = false;
-		
-		try
-		{
-		    String strEnableResVersion = AAIConfig.get(AAIConstants.AAI_RESVERSION_ENABLEFLAG);
-		    if (strEnableResVersion != null && !strEnableResVersion.isEmpty())
-		       bResVersionEnabled = Boolean.valueOf(strEnableResVersion);
-		}
-		catch (Exception e) {
-		
-		}
-		
-		boolean doPutIfExists = true;
-		if (args.length > 5)
-			if (args[5].equals("1"))
-				doPutIfExists = false;
-		
-		try {
-			if (args.length < 2) {
-				System.out.println("Insufficient arguments");
-				System.out.println(USAGE_STRING);
-				System.exit(1);
-			} 
-				
-			Loader loader = LoaderFactory.createLoaderForVersion(ModelType.MOXY, AAIProperties.LATEST);
-			// Assume the config AAI_SERVER_URL has a last slash so remove if  
-			//  resource-path has it as the first char
-			URI uri = new URI(args[0]);
-			String path = args[0].replaceFirst("^/", "");
-			Path p = Paths.get(path);
-			
-			URIToObject parser = new URIToObject(loader, uri);
-			String resource = parser.getEntityName();
-			
-			String resourceClass = CaseFormat.LOWER_HYPHEN.to(CaseFormat.UPPER_CAMEL, resource);
-			resourceClass = "org.openecomp.aai.domain.yang." + resourceClass;
-			
-			LOGGER.debug("class=" + resourceClass);
-			LOGGER.debug("path=" + path);
-			
-			RestObject<T> restObj = new RestObject<T>();
-			@SuppressWarnings("unchecked")
-			T t2 = (T)getInstance(Class.forName(resourceClass));
-			restObj.set(t2);
-			
-			boolean bExist = true;
-			
-			try
-			{
-				if ( !doPutIfExists ) {
-					
-					String url = AAIConfig.get(AAIConstants.AAI_SERVER_URL) + path;
-
-					LOGGER.debug("url=" + url);
-					if ( nodeExists( url) ) {
-						String infMsg ="PUT succeeded, the resource exists already in the DB. Skipping the put based on the skipIfExists command line parameter.\n";
-						System.out.println(infMsg);
-						LOGGER.info(infMsg);
-						System.exit(0);
-					}
-				}
-			    RestController.<T>Get(t2, FROMAPPID, TRANSID, path, restObj, false);
-			    t2 = restObj.get();
-			    String infMsg = " GET succeeded\n";
-			    System.out.println(infMsg);
-				LOGGER.info(infMsg);
-
-			} catch (AAIException e) {
-				if ( !doPutIfExists ) {
-					System.out.println("Warning - Caught exception while attempting to PUT resource");
-					LOGGER.warn("Caught exception while attempting to PUT resource", e);
-				}
-				bExist = false;
-			}
-			catch (Exception e1)
-			{
-				if ( !doPutIfExists ) {
-					System.out.println("Warning - GET exception ignored with skipExists parameter\n");
-					LOGGER.warn(" GET exception ignored with skipExists parameter\n", e1);
-				}
-				bExist = false;
-			}
-			
-			
-			@SuppressWarnings("unchecked")
-			T resJson1 = (T)readJsonFile(Class.forName(resourceClass), args[1]);
-			String resourceUpdateVersion = GetResourceVersion(resJson1);
-			
-			
-			if (bResVersionEnabled && bExist)
-			{
-
-				String DBresourceVersion = GetResourceVersion(t2);
-				if ( !doPutIfExists ) {
-					String infMsg = "PUT succeeded, the resource exists already in the DB. Skipping the put based on the skipIfExists command line parameter.\n";
-					System.out.println(infMsg);
-					LOGGER.info(infMsg);
-					System.exit(0);
-				}
-				
-				if (resourceUpdateVersion == null || resourceUpdateVersion.isEmpty())
-				{
-					 if ( DBresourceVersion != null && !DBresourceVersion.isEmpty()){
-					    String eMsg = "The resource with version = " +  DBresourceVersion + "  exists already in the DB. Please supply the right resourceVersion in input data file.\n";
-					    System.out.println(eMsg);
-						LOGGER.error(eMsg);
-					 }
-					 else{
-						String eMsg = "The resource exists already in the DB. Please supply the right resourceVersion in input data file.\n";
-						System.out.println(eMsg);
-						LOGGER.error(eMsg);
-					 }
-				     System.exit(1);	
-				 }
-					
-				if ( DBresourceVersion != null && !DBresourceVersion.isEmpty() )
-				{
-					if ( resourceUpdateVersion != null && !resourceUpdateVersion.isEmpty() )
-						 if (!DBresourceVersion.equals(resourceUpdateVersion))
-						 {
-							 String eMsg = "DB version doesn't match current version. Please get the latest version and modify.\n";
-							 System.out.println(eMsg);
-							 LOGGER.error(eMsg);
-						     System.exit(1);	
-						 }
-				}
-			}
-			else //sanity check
-			{
-				if ( bResVersionEnabled && resourceUpdateVersion != null && !resourceUpdateVersion.isEmpty())
-				{
-					String eMsg = "DB doesn't have this resource any more. Please create a new version by taking out the resourceVersion tag from your input resource data file.\n";
-					System.out.println(eMsg);
-					LOGGER.error(eMsg);
-					System.exit(1);
-				}
-				
-			}
-			
-			if (bExist) //merge
-			{
-				boolean bUpdateChildren = false;
-				boolean bUpdateRL = false;
-			
-				if (args.length == 3)
-				{
-					if (args[2].equals("1"))
-						bUpdateRL = true;
-					resJson1 = MergeResource.merge(t2, resJson1, false, bUpdateRL);
-				}
-				else if (args.length == 4)
-				{
-					if (args[2].equals("1"))
-						bUpdateRL = true;
-					if (args[3].equals("1"))
-						bUpdateChildren = true;
-					resJson1 = MergeResource.merge(t2, resJson1, bUpdateChildren, bUpdateRL);
-				}
-				else if (args.length == 5)
-				{
-					if (args[2].equals("1"))
-						bUpdateRL = true;
-					if (args[3].equals("1"))
-						bUpdateChildren = true;
-					String[] strChildArray = args[4].split("\\,");
-					resJson1 = MergeResource.merge(t2, resJson1, bUpdateChildren, strChildArray, bUpdateRL);
-					
-				}
-				else
-					resJson1 = MergeResource.merge(t2, resJson1);
-			
-			}
-			
-			RestController.<T>Put(resJson1, FROMAPPID, TRANSID, path, false);
-			
-			String infMsg = " PUT succeeded";
-			System.out.println(infMsg);
-			LOGGER.info(infMsg);
-			infMsg = "Done!!";
-			System.out.println(infMsg);
-			LOGGER.info(infMsg);
-			
-			System.exit(0); 
-
-		} catch (AAIException e) {
-			if ( !doPutIfExists ) { // ignore 412 failure
-				if ( e.getMessage().equals("AAI_7116")  ) {
-					if ( e.getMessage().indexOf("status=412") > 0) {
-						String infMsg = "PUT succeeded, return 412 ignored\n";
-						System.out.println(infMsg);
-						LOGGER.info(infMsg);
-
-						infMsg = "\nDone!!";
-						System.out.println(infMsg);
-						LOGGER.info(infMsg);
-						System.exit(0);
-					}
-				}
-			}
-			
-			ErrorLogHelper.logException(e);
-			System.exit(1);
-		} catch (Exception e) {
-			ErrorLogHelper.logError("AAI_7402", e.getMessage());
-			System.exit(1);
-		}
-	}
-	
-	/**
-	 * Gets the single instance of PutResource.
-	 *
-	 * @param <T> the generic type
-	 * @param clazz the clazz
-	 * @return single instance of PutResource
-	 * @throws IllegalAccessException the illegal access exception
-	 * @throws InstantiationException the instantiation exception
-	 */
-	public static <T> T getInstance(Class<T> clazz) throws IllegalAccessException, InstantiationException
-	{
-		return clazz.newInstance();
-	} 
-	
-	/**
-	 * Read json file.
-	 *
-	 * @param <T> the generic type
-	 * @param clazz the clazz
-	 * @param fName the f name
-	 * @return the t
-	 * @throws AAIException the AAI exception
-	 */
-	public static <T> T  readJsonFile( Class<T> clazz, String fName ) throws AAIException 
-	{    	
-        String jsonData = "";
-        BufferedReader br = null;
-        T t;
-        
-        try {
-            String line;
-            br = new BufferedReader(new FileReader(fName));
-            while ((line = br.readLine()) != null) {
-                jsonData += line + "\n";
-            }
-        } catch (IOException e) {
-
-            throw new AAIException("AAI_7403", e, "Error opening json file");
-        } finally {
-            try {
-                if (br != null)
-                    br.close();
-            } catch (IOException ex) {
-                throw new AAIException("AAI_7403", ex, "Error closing json file");
-            }
-        }
-
-        try {	        	
-        	t = MapperUtil.readWithDashesAsObjectOf(clazz, jsonData);
-        }
-        catch (Exception je){
-            throw new AAIException("AAI_7403", je, "Error parsing json file"); 
-        }
-
-        return t;
-
-    }//End readJsonFile()	 
-	
-	/**
-	 * Gets the resource version.
-	 *
-	 * @param <T> the generic type
-	 * @param resource the resource
-	 * @return the string
-	 */
-	public static <T> String GetResourceVersion(T resource)
-	{
-		Field[] fields = resource.getClass().getDeclaredFields();
-		if (fields != null)
-		{
-		    for (Field field : fields)
-		    {
-		    	try
-		    	{
-			    	field.setAccessible(true);
-			    	if ( field.getName().equalsIgnoreCase("resourceVersion") )
-			    	{
-			    		Object obj = field.get(resource);
-			    		return (String)obj;
-			    	}
-			    		
-			  
-		    	}
-		    	catch (Exception e)
-	    		{
-	    		
-	    		}
-		    	
-		    	
-		    }
-		}
-		return null;
-	}
-	
-	/**
-	 * Node exists.
-	 *
-	 * @param url the url
-	 * @return true, if successful
-	 * @throws AAIException the AAI exception
-	 */
-	public static boolean nodeExists(String url) throws AAIException {		
-		try{
-			String useBasicAuth = AAIConfig.get("aai.tools.enableBasicAuth");
-			Client client = null;
-
-			if("true".equals(useBasicAuth)){
-			    client = HttpsAuthClient.getBasicAuthClient();
-			} else {
-			    client = HttpsAuthClient.getTwoWaySSLClient();
-			}
-			
-			String infMsg = "Getting the resource...: " + url;
-			System.out.println(infMsg);
-			LOGGER.info(infMsg);
-
-			ClientResponse cres = client.resource(url)
-									.header("X-TransactionId", TRANSID)
-									.header("X-FromAppId",  FROMAPPID)
-									.header("Authorization", HttpsAuthClient.getBasicAuthHeaderValue())
-									.accept("application/json")
-									.get(ClientResponse.class);
-			
-			
-			if (cres.getStatus() == 404) { // resource not found
-				return false;
-			} else if (cres.getStatus() == 200){
-				return true;
-			} else {
-				String eMsg = "Getting the Resource failed: " + cres.getStatus()
-												+ ": " + cres.getEntity(String.class);
-				System.out.println(eMsg);
-				LOGGER.error(eMsg);
-				return false;
-			}
-		} catch (KeyManagementException e) {
-            throw new AAIException("AAI_7401", e, "Error during GET");
-		}  catch (Exception e) {
-            throw new AAIException("AAI_7402", e, "Error during GET");
-		}
-	}	
-
-}
diff --git a/aai-resources/src/main/java/org/openecomp/aai/util/RelationshipPutDel.java b/aai-resources/src/main/java/org/openecomp/aai/util/RelationshipPutDel.java
deleted file mode 100644
index a6a21ca..0000000
--- a/aai-resources/src/main/java/org/openecomp/aai/util/RelationshipPutDel.java
+++ /dev/null
@@ -1,211 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * org.openecomp.aai
- * ================================================================================
- * 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.aai.util;
-
-import java.io.BufferedReader;
-import java.io.FileReader;
-import java.io.IOException;
-import java.security.KeyManagementException;
-import java.util.Properties;
-import java.util.UUID;
-
-import org.openecomp.aai.domain.yang.Relationship;
-import org.openecomp.aai.exceptions.AAIException;
-import com.att.eelf.configuration.Configuration;
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
-import com.sun.jersey.api.client.Client;
-import com.sun.jersey.api.client.ClientResponse;
-
-
-public class RelationshipPutDel {
-	
-	private static final String FROMAPPID = "AAI-TOOLS";
-	private static final String TRANSID = UUID.randomUUID().toString();
-	private static EELFLogger LOGGER;
-	private static final String USAGE_STRING = "Usage: rshipTool.sh <PUT|DELETE> <resource-path> <filename>\n" +
-			"resource-path for a particular resource starting after the aai/<version>, relationship-list/relationship gets added by script\n" +
-			"filename is the path to a file which contains the json input for the relationship payload" +
-			"for example: relTool.sh PUT cloud-infrastructure/oam-networks/oam-network/test-100-oam /tmp/putrship.json\n";
-	
-	/**
-	 * The main method.
-	 *
-	 * @param args the arguments
-	 */
-	public static void main(String[] args) {
-
-		// Set the logging file properties to be used by EELFManager
-		Properties props = System.getProperties();
-		props.setProperty(Configuration.PROPERTY_LOGGING_FILE_NAME, AAIConstants.AAI_RSHIPTOOL_LOGBACK_PROPS);
-		props.setProperty(Configuration.PROPERTY_LOGGING_FILE_PATH, AAIConstants.AAI_HOME_ETC_APP_PROPERTIES);		
-		LOGGER = EELFManager.getInstance().getLogger(RelationshipPutDel.class);
-		String dMsg = "Start processing...";
-		System.out.println(dMsg);
-		LOGGER.debug(dMsg);
-		
-		String rshipURL, resURL = null;
-		Relationship rship = null;
-		
-		try {
-			if ((args.length < 3) || (!args[0].equalsIgnoreCase("PUT") && !args[0].equalsIgnoreCase("DELETE"))) {
-				System.out.println("Insufficient or Invalid arguments");
-				System.out.println(USAGE_STRING);
-				System.exit(1);
-			} 
-			
-			rship = readJsonFile(args[2]);
-			
-			// Assume the config AAI_SERVER_URL has a last slash so remove if  
-			//  resource-path has it as the first char
-			resURL = args[1].replaceFirst("^/", "");
-			resURL = AAIConfig.get(AAIConstants.AAI_SERVER_URL) + resURL;
-			rshipURL = resURL.concat("/relationship-list/relationship");
-
-			dMsg = "Resource URL=" + rshipURL;
-			System.out.println(dMsg);
-			LOGGER.debug(dMsg);
-			
-			PutDelRelationship(rshipURL, rship, args[0]);
-			
-			String infMsg = args[0] + " Relationship succeeded to: " + rship.getRelatedTo() + "\n";
-			System.out.println(infMsg);
-			LOGGER.info(infMsg);
-			
-			GetResource.getNode(resURL);
-			infMsg = "Done!!";
-			System.out.println(infMsg);
-			LOGGER.info(infMsg);
-			
-			System.exit(0);
-
-		} catch (AAIException e) {
-			LOGGER.error(args[0] + " Relationship PUT/DELETE failed", e);
-			System.out.println(args[0] + " Relationship PUT/DELETE failed");
-			System.exit(1);	
-		} catch (Exception e) {
-			LOGGER.error(args[0] + " Relationship PUT/DELETE failed", e);
-			System.out.println(args[0] + " Relationship PUT/DELETE failed");
-			System.exit(1);
-		}
-	}
-	
-	   /**
-   	 * Read json file.
-   	 *
-   	 * @param fName the f name
-   	 * @return the relationship
-   	 * @throws AAIException the AAI exception
-   	 */
-   	public static Relationship readJsonFile( String fName ) throws AAIException { 
-	        String jsonData = "";
-	        BufferedReader br = null;
-	        Relationship rship = new Relationship();
-	        
-	        try {
-	            String line;
-	            br = new BufferedReader(new FileReader(fName));
-	            while ((line = br.readLine()) != null) {
-	                jsonData += line + "\n";
-	            }
-	        } catch (IOException e) {
-                throw new AAIException("AAI_7403", e, "Error opening json file");
-	        } finally {
-	            try {
-	                if (br != null)
-	                    br.close();
-	            } catch (IOException ex) {
-	                throw new AAIException("AAI_7403", ex, "Error closing json file");
-	            }
-	        }
-
-	        try {	        	
-	        	rship = MapperUtil.readWithDashesAsObjectOf(Relationship.class, jsonData);
-	        }
-	        catch (Exception je){
-	            throw new AAIException("AAI_7403", je, "Error parsing json file"); 
-	        }
-
-	        return rship;
-
-	    }//End readJsonFile()
-
-	
-	/**
-	 * Put del relationship.
-	 *
-	 * @param aaiLogger the aai logger
-	 * @param logline the logline
-	 * @param rshipURL the rship URL
-	 * @param rship the rship
-	 * @param action the action
-	 * @throws AAIException the AAI exception
-	 */
-	public static void PutDelRelationship(String rshipURL, 
-											Relationship rship, 
-											String action) throws AAIException{		
-		try {
-			Client client = HttpsAuthClient.getClient();			
-			ClientResponse cres = null;
-		
-			if (action.equalsIgnoreCase("PUT"))
-				 cres = client.resource(rshipURL)
-										.header("X-TransactionId", TRANSID)
-										.header("X-FromAppId",  FROMAPPID)
-										.accept("application/json")
-										.entity(rship)
-										.put(ClientResponse.class);
-			else
-				 cres = client.resource(rshipURL)
-					.header("X-TransactionId", TRANSID)
-					.header("X-FromAppId",  FROMAPPID)
-					.accept("application/json")
-					.entity(rship)
-					.delete(ClientResponse.class);
-			
-			if (cres.getStatus() == 404) { // resource not found				
-				String infMsg = "Resource does not exist...: " + cres.getStatus()
-									+ ":\n" + cres.getEntity(String.class);
-				System.out.println(infMsg);
-				LOGGER.info(infMsg);
-	            throw new AAIException("AAI_7404", "Resource does not exist");
-			} else if ((action.equalsIgnoreCase("PUT") && cres.getStatus() == 200) ||
-					   (action.equalsIgnoreCase("DELETE") && cres.getStatus() == 204)) {
-				String infMsg = action + " Resource status: " + cres.getStatus();
-				System.out.println(infMsg);
-				LOGGER.info(infMsg);
-			} else {
-				String eMsg = action + " Resource failed: " + cres.getStatus()
-						+ ":\n" + cres.getEntity(String.class);
-				System.out.println(eMsg);
-				LOGGER.error(eMsg);
-	            throw new AAIException("AAI_7402", "Error during PutDel");
-			}
-		} catch (AAIException e) {
-            throw e;
-		} catch (KeyManagementException e) {
-            throw new AAIException("AAI_7401", "Error during PutDel");
-		}  catch (Exception e) {
-            throw new AAIException("AAI_7402", "Error during PutDel");
-		}
-	}	
-
-}
diff --git a/aai-resources/src/main/java/org/openecomp/aai/util/RestController.java b/aai-resources/src/main/java/org/openecomp/aai/util/RestController.java
deleted file mode 100644
index e21fd90..0000000
--- a/aai-resources/src/main/java/org/openecomp/aai/util/RestController.java
+++ /dev/null
@@ -1,685 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * org.openecomp.aai
- * ================================================================================
- * 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.aai.util;
-
-import java.net.MalformedURLException;
-import java.net.URI;
-import java.net.URISyntaxException;
-import java.net.URL;
-import java.security.KeyManagementException;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.UUID;
-
-import org.openecomp.aai.exceptions.AAIException;
-import org.openecomp.aai.logging.LoggingContext;
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.fasterxml.jackson.databind.type.TypeFactory;
-import com.sun.jersey.api.client.Client;
-import com.sun.jersey.api.client.ClientHandlerException;
-import com.sun.jersey.api.client.ClientResponse;
-
-public class RestController {
-
-	private static EELFLogger LOGGER = EELFManager.getInstance().getLogger(RestController.class);
-	
-	private static Client client = null;
-	
-	private String restSrvrBaseURL;
-	
-	//To do - Come up with helper function that will automatically
-	//generate the REST API path based on path parameter(s) and query parameter(s)!
-	public static final String REST_APIPATH_COMPLEXES = "cloud-infrastructure/complexes";
-	public static final String REST_APIPATH_COMPLEX = "cloud-infrastructure/complexes/complex/";
-	public static final String REST_APIPATH_PSERVERS = "cloud-infrastructure/pservers";
-	public static final String REST_APIPATH_PSERVER = "cloud-infrastructure/pservers/pserver/";
-	public static final String REST_APIPATH_PHYSICALLINKS = "network/physical-links/";
-	public static final String REST_APIPATH_PHYSICALLINK = "network/physical-links/physical-link/";
-	public static final String REST_APIPATH_PINTERFACES = "network/p-interfaces/";
-	public static final String REST_APIPATH_PINTERFACE = "network/p-interfaces/p-interface/";
-	public static final String REST_APIPATH_VPLSPES = "network/vpls-pes/";
-	public static final String REST_APIPATH_VPLSPE = "network/vpls-pes/vpls-pe/";
-	public static final String REST_APIPATH_UPDATE = "actions/update/";
-	public static final String REST_APIPATH_SEARCH = "search/nodes-query?search-node-type=";
-	
-	public static final String REST_APIPATH_CLOUDREGION = "cloud-infrastructure/cloud-regions/cloud-region/";
-	public static final  String REST_APIPATH_TENANT = "cloud-infrastructure/tenants/tenant/";
-	public static final  String REST_APIPATH_VPE = "network/vpes/vpe/";
-	public static final String REST_APIPATH_VIRTUAL_DATA_CENTER = "cloud-infrastructure/virtual-data-centers/virtual-data-center/";
-	public static final String REST_APIPATH_VIRTUAL_DATA_CENTERS = "cloud-infrastructure/virtual-data-centers/";
-	//network/generic-vnfs/generic-vnf/{vnf-id}
-	public static final String REST_APIPATH_GENERIC_VNF = "network/generic-vnfs/generic-vnf/";
-	public static final String REST_APIPATH_GENERIC_VNFS = "network/generic-vnfs";
-	public static final String REST_APIPATH_L3_NETWORK = "network/l3-networks/l3-network/";
-	public static final String REST_APIPATH_L3_NETWORKS = "network/l3-networks";
-	public static final String REST_APIPATH_INSTANCE_GROUP = "network/instance-groups/instance-group";
-	public static final String REST_APIPATH_INSTANCE_GROUPS = "network/instance-groups";
-	
-	public static final  String REST_APIPATH_VCE = "network/vces/vce/";
-	
-	public static final  String REST_APIPATH_SERVICE = "service-design-and-creation/services/service/";
-	public static final String REST_APIPATH_LOGICALLINKS = "network/logical-links/";
-	public static final String REST_APIPATH_LOGICALLINK = "network/logical-links/logical-link/";
-	
-	/**
-	 * Inits the rest client.
-	 *
-	 * @throws AAIException the AAI exception
-	 */
-	private static void initRestClient() throws AAIException
-	{
-		if (client == null) {
-			try {
-				String useBasicAuth = AAIConfig.get("aai.tools.enableBasicAuth");
-                                if (useBasicAuth != null && useBasicAuth.equals("true")) {
-
-                                        client = HttpsAuthClient.getBasicAuthClient();
-                                } else {
-                                        client = HttpsAuthClient.getTwoWaySSLClient();
-                                }
-
-			}
-			catch (KeyManagementException e){
-				throw new AAIException("AAI_7117", "KeyManagementException in REST call to DB: " + e.toString());
-			} catch (Exception e) {
-				throw new AAIException("AAI_7117", " Exception in REST call to DB: " + e.toString());
-			}
-		}
-	}
-	
-	/**
-	 * Sets the rest srvr base URL.
-	 *
-	 * @param baseURL the base URL
-	 * @throws AAIException the AAI exception
-	 */
-	public void SetRestSrvrBaseURL(String baseURL) throws AAIException
-	{
-		if (baseURL == null)
-			throw new AAIException("AAI_7117", "REST Server base URL cannot be null.");
-		restSrvrBaseURL = baseURL;
-	}
-	
-	/**
-	 * Gets the rest srvr base URL.
-	 *
-	 * @return the rest srvr base URL
-	 */
-	public String getRestSrvrBaseURL() 
-	{
-		return restSrvrBaseURL;
-	}
-	
-	/**
-	 * To do - optimization and automation.  Also make it as generic as possible.
-	 *
-	 * @param <T> the generic type
-	 * @param t the t
-	 * @param sourceID the source ID
-	 * @param transId the trans id
-	 * @param path the path
-	 * @param restObject the rest object
-	 * @param oldserver the oldserver
-	 * @throws AAIException the AAI exception
-	 */
-	@SuppressWarnings("unchecked")
-	public static <T> void Get(T t, String sourceID,  String transId,  String path, RestObject<T> restObject, boolean oldserver) throws AAIException {
-		String methodName = "Get";
-		String url="";
-		transId += ":" + UUID.randomUUID().toString();
-
-		LoggingContext.save();
-		LoggingContext.partnerName(sourceID);
-
-		LOGGER.debug(methodName + " start");
-	
-		restObject.set(t);
-		
-		if (oldserver)
-			url = AAIConfig.get(AAIConstants.AAI_OLDSERVER_URL) + path;
-		else
-			url = AAIConfig.get(AAIConstants.AAI_SERVER_URL) + path;
-		initRestClient();
-		LOGGER.debug(url + " for the get REST API");
-		ClientResponse cres = client.resource(url)
-	         .accept("application/json")
-	         .header("X-TransactionId", transId)
-	         .header("X-FromAppId",  sourceID)
-		 .header("Authorization", HttpsAuthClient.getBasicAuthHeaderValue())
-	         .type("application/json")
-	         .get(ClientResponse.class);
-
-//			System.out.println("cres.EntityInputSream()="+cres.getEntityInputStream().toString());
-//			System.out.println("cres.tostring()="+cres.toString());
-			
-		 if (cres.getStatus() == 200) {
-//		     System.out.println(methodName + ": url=" + url);
-			 t = (T) cres.getEntity(t.getClass());
-			 restObject.set(t);
-			 LOGGER.debug(methodName + "REST api GET was successfull!");		    
-		 } else {
-		 	 LoggingContext.restore();
-//		     System.out.println(methodName + ": url=" + url + " failed with status=" + cres.getStatus());
-		     throw new AAIException("AAI_7116", methodName +" with status="+cres.getStatus()+", url="+url);
-		 }
-
-		 LoggingContext.restore();
-	}
-	
-	
-	/**
-	 *
-	 * @param <T> the generic type
-	 * @param t the t
-	 * @param sourceID the source ID
-	 * @param transId the trans id
-	 * @param path the path
-	 * @param restObject the rest object
-	 * @param apiVersion the api version
-	 * @throws AAIException the AAI exception
-	 */
-	@SuppressWarnings("unchecked")
-	public static <T> void Get(T t, String sourceID,  String transId,  String path, RestObject<T> restObject, String apiVersion) throws AAIException {
-		String methodName = "Get";
-		String url="";
-		transId += ":" + UUID.randomUUID().toString();
-		LOGGER.debug(methodName + " start");
-	
-		restObject.set(t);
-		
-		url = AAIConfig.get(AAIConstants.AAI_SERVER_URL_BASE) + apiVersion + "/"+ path;
-		
-		initRestClient();
-		LOGGER.debug(url + " for the get REST API");
-		ClientResponse cres = client.resource(url)
-	         .accept("application/json")
-	         .header("X-TransactionId", transId)
-	         .header("X-FromAppId",  sourceID)
-		 .header("Authorization", HttpsAuthClient.getBasicAuthHeaderValue())
-	         .type("application/json")
-	         .get(ClientResponse.class);
-
-//			System.out.println("cres.EntityInputSream()="+cres.getEntityInputStream().toString());
-//			System.out.println("cres.tostring()="+cres.toString());
-			
-		 if (cres.getStatus() == 200) {
-//		     System.out.println(methodName + ": url=" + url);
-			 t = (T) cres.getEntity(t.getClass());
-			 restObject.set(t);
-			 LOGGER.debug(methodName + "REST api GET was successfull!");
-		    
-		 } else {
-//		     System.out.println(methodName + ": url=" + url + " failed with status=" + cres.getStatus());
-		     throw new AAIException("AAI_7116", methodName +" with status="+cres.getStatus()+", url="+url);
-		 }
-
-	}
-	
-	/**
-	 * Gets the.
-	 *
-	 * @param <T> the generic type
-	 * @param t the t
-	 * @param requestObj the request obj
-	 * @throws AAIException the AAI exception
-	 */
-	public static <T> void Get(T t, Request<T> requestObj) throws AAIException {
-		String methodName = "Get";
-		String url="";
-		String transId = requestObj.transactionId;
-		transId += ":" + UUID.randomUUID().toString();
-		LOGGER.debug(methodName + " start");
-	
-		requestObj.restObj.set(t);
-		
-		if (requestObj.oldServer)
-			url = AAIConfig.get(AAIConstants.AAI_SERVER_URL_BASE) + "server/" + requestObj.path;
-		else
-			url = AAIConfig.get(AAIConstants.AAI_SERVER_URL_BASE) + requestObj.path;
-		initRestClient();
-		
-	    try {
-		    URL urlObj= new URL(url);
-			URI uri = new URI(urlObj.getProtocol(), urlObj.getUserInfo(), urlObj.getHost(), urlObj.getPort(), urlObj.getPath(), urlObj.getQuery(), urlObj.getRef());
-			url = uri.toASCIIString();
-	    } catch (URISyntaxException | MalformedURLException e) {
-			 throw new AAIException("AAI_7116", "bad URL");
-
-		}
-		LOGGER.debug(url + " for the get REST API");
-		ClientResponse cres = client.resource(url)
-	         .accept("application/json")
-	         .header("X-TransactionId", transId)
-	         .header("X-FromAppId",  requestObj.fromAppId)
-		 .header("Authorization", HttpsAuthClient.getBasicAuthHeaderValue())
-	         .type("application/json")
-	         .get(ClientResponse.class);
-
-//			System.out.println("cres.EntityInputSream()="+cres.getEntityInputStream().toString());
-//			System.out.println("cres.tostring()="+cres.toString());
-			
-		 if (cres.getStatus() == 200) {
-//		     System.out.println(methodName + ": url=" + url);
-			 t = (T) cres.getEntity(t.getClass());
-			 requestObj.restObj.set(t);
-			 LOGGER.debug(methodName + "REST api GET was successfull!");
-		    
-		 } else {
-//		     System.out.println(methodName + ": url=" + url + " failed with status=" + cres.getStatus());
-		     throw new AAIException("AAI_7116", methodName +" with status="+cres.getStatus()+", url="+url);
-		 }
-
-	}
-	
-	/**
-	 * Put.
-	 *
-	 * @param <T> the generic type
-	 * @param t the t
-	 * @param requestObj the request obj
-	 * @throws AAIException the AAI exception
-	 */
-	public static <T> void Put(T t, Request<T> requestObj) throws AAIException {
-		String methodName = "Put";
-		String url="";
-		String transId = requestObj.transactionId;
-		transId += ":" + UUID.randomUUID().toString();
-		LOGGER.debug(methodName + " start");		
-
-		initRestClient();
-		
-		if (requestObj.oldServer)
-			url = AAIConfig.get(AAIConstants.AAI_SERVER_URL_BASE) + "server/" + requestObj.path;
-		else
-			url = AAIConfig.get(AAIConstants.AAI_SERVER_URL_BASE) + requestObj.path;
-		
-	    try {
-		    URL urlObj= new URL(url);
-			URI uri = new URI(urlObj.getProtocol(), urlObj.getUserInfo(), urlObj.getHost(), urlObj.getPort(), urlObj.getPath(), urlObj.getQuery(), urlObj.getRef());
-			url = uri.toASCIIString();
-	    } catch (URISyntaxException | MalformedURLException e) {
-			 throw new AAIException("AAI_7116", "bad URL");
-
-		}
-		ClientResponse cres = client.resource(url)
-	         .accept("application/json")
-	         .header("X-TransactionId", transId)
-	         .header("X-FromAppId",  requestObj.fromAppId)
-		 .header("Authorization", HttpsAuthClient.getBasicAuthHeaderValue())
-	         .type("application/json")
-	         .entity(t)
-	         .put(ClientResponse.class);
-			
-		int statuscode = cres.getStatus();
-		if ( statuscode >= 200 && statuscode <= 299 ) {
-			 LOGGER.debug(methodName+": url=" + url + ", request=" + url);
-		 } else {
-			 throw new AAIException("AAI_7116", methodName +" with status="+statuscode+", url="+url);
-		 }			 
-	}
-	
-	/**
-	 *  Multiple Generic Get.
-	 *
-	 * @param <T> the generic type
-	 * @param t the t
-	 * @param sourceID the source ID
-	 * @param transId the trans id
-	 * @param path the path
-	 * @param oldserver the oldserver
-	 * @return the list
-	 * @throws AAIException the AAI exception
-	 */
-	public static <T> List<T> Get(T t, String sourceID,  String transId,  String path, boolean oldserver) throws AAIException {
-		String methodName = "Get";
-		String url="";
-		transId += ":" + UUID.randomUUID().toString();
-		LOGGER.debug(methodName + " start");
-	
-		List<T> list;
-		
-		try {
-			if (oldserver)
-				url = AAIConfig.get(AAIConstants.AAI_OLDSERVER_URL) + path;
-			else
-				url = AAIConfig.get(AAIConstants.AAI_SERVER_URL) + path;
-			initRestClient();
-			LOGGER.debug(url + " for the get REST API");
-			ClientResponse cres = client.resource(url)
-		         .accept("application/json")
-		         .header("X-TransactionId", transId)
-		         .header("X-FromAppId",  sourceID)
-			 .header("Authorization", HttpsAuthClient.getBasicAuthHeaderValue())
-		         .type("application/json")
-		         .get(ClientResponse.class);
-
-
-			//System.out.println("cres.EntityInputSream()="+cres.getEntityInputStream().toString());
-			//System.out.println("cres.tostring()="+cres.toString());
-			
-			 if (cres.getStatus() == 200) {
-			     //System.out.println(methodName + ": url=" + url);
-			     //list = cres.getEntity(new GenericType<List<T>>() { });
-			     String datainJson = cres.getEntity(String.class);
-			     list = mapJsonToObjectList(t, datainJson, t.getClass());
-	
-				 LOGGER.debug(methodName + "REST api GET was successfull!");
-			     return list;
-				 
-			 } else {
-			     throw new AAIException("AAI_7116", methodName +" with status="+cres.getStatus()+", url="+url);
-			 }
-		} catch (AAIException e) {
-			throw new AAIException("AAI_7116", methodName + " with url="+url+ ", Exception: " + e.toString());
-		} catch (Exception e)
-		{
-			throw new AAIException("AAI_7116", methodName + " with url="+url+ ", Exception: " + e.toString());
-		
-		}
-
-	}
-
-   /**
-    * Map json to object list.
-    *
-    * @param <T> the generic type
-    * @param typeDef the type def
-    * @param json the json
-    * @param clazz the clazz
-    * @return the list
-    * @throws Exception the exception
-    */
-   private static <T> List<T> mapJsonToObjectList(T typeDef,String json, Class clazz) throws Exception
-   {
-      List<T> list;
-      ObjectMapper mapper = new ObjectMapper();
-      System.out.println(json);
-      TypeFactory t = TypeFactory.defaultInstance();
-      list = mapper.readValue(json, t.constructCollectionType(ArrayList.class,clazz));
-
-      return list;
-   }
-	   
-	/**
-	 * Put.
-	 *
-	 * @param <T> the generic type
-	 * @param t the t
-	 * @param sourceID the source ID
-	 * @param transId the trans id
-	 * @param path the path
-	 * @throws AAIException the AAI exception
-	 */
-	public static <T> void Put(T t, String sourceID,  String transId,  String path) throws AAIException {
-		Put( t, sourceID, transId, path, false);
-	}
-
-	/**
-	 * Put.
-	 *
-	 * @param <T> the generic type
-	 * @param t the t
-	 * @param sourceID the source ID
-	 * @param transId the trans id
-	 * @param path the path
-	 * @param oldserver the oldserver
-	 * @throws AAIException the AAI exception
-	 */
-	public static <T> void Put(T t, String sourceID,  String transId,  String path, boolean oldserver) throws AAIException {
-		String methodName = "Put";
-		String url="";
-		transId += ":" + UUID.randomUUID().toString();
-
-		LOGGER.debug(methodName + " start");		
-
-		initRestClient();
-		
-		if (oldserver)
-			url = AAIConfig.get(AAIConstants.AAI_OLDSERVER_URL) + path;
-		else
-			url = AAIConfig.get(AAIConstants.AAI_SERVER_URL) + path;
-		
-		ClientResponse cres = client.resource(url)
-	         .accept("application/json")
-	         .header("X-TransactionId", transId)
-	         .header("X-FromAppId",  sourceID)
-		 .header("Authorization", HttpsAuthClient.getBasicAuthHeaderValue())
-	         .type("application/json")
-	         .entity(t)
-	         .put(ClientResponse.class);
-	
-//			System.out.println("cres.tostring()="+cres.toString());
-		
-		int statuscode = cres.getStatus();
-		if ( statuscode >= 200 && statuscode <= 299 ) {
-			 LOGGER.debug(methodName+": url=" + url + ", request=" + path);
-		 } else {
-			 throw new AAIException("AAI_7116", methodName +" with status="+statuscode+", url="+url + ", msg=" + cres.getEntity(String.class));
-		 }			 
-	}
-	
-	/**
-	 * Delete.
-	 *
-	 * @param requestObj the request obj
-	 * @throws AAIException the AAI exception
-	 */
-	public static void Delete(Request requestObj) throws AAIException {
-		String methodName = "Delete";
-
-		String url="";
-		String transId = requestObj.transactionId;
-		transId += ":" + UUID.randomUUID().toString();
-
-		LOGGER.debug(methodName + " start");		
-
-		initRestClient();
-		
-		if (requestObj.oldServer)
-			url = AAIConfig.get(AAIConstants.AAI_SERVER_URL_BASE) + "servers/" + requestObj.path;
-		else
-			url = AAIConfig.get(AAIConstants.AAI_SERVER_URL_BASE) + requestObj.path;
-		
-	    try {
-		    URL urlObj= new URL(url);
-			URI uri = new URI(urlObj.getProtocol(), urlObj.getUserInfo(), urlObj.getHost(), urlObj.getPort(), urlObj.getPath(), urlObj.getQuery(), urlObj.getRef());
-			url = uri.toASCIIString();
-	    } catch (URISyntaxException | MalformedURLException e) {
-			 throw new AAIException("AAI_7116", "bad URL");
-
-		}
-	
-		ClientResponse cres = client.resource(url)
-		         .accept("application/json")
-		         .header("X-TransactionId", transId)
-		         .header("X-FromAppId",  requestObj.fromAppId)
-			 .header("Authorization", HttpsAuthClient.getBasicAuthHeaderValue())
-		         .type("application/json")
-		         .entity("{}")
-		         .delete(ClientResponse.class);
-			
-		 if (cres.getStatus() == 204) {
-			 LOGGER.debug(methodName+": url=" + url);
-		 } else {
-			 throw new AAIException("AAI_7116", methodName +" with status="+cres.getStatus()+", url="+url);
-		 } 
-
-	}
-	
-	/**
-	 * Delete.
-	 *
-	 * @param sourceID the source ID
-	 * @param transId the trans id
-	 * @param path the path
-	 * @throws AAIException the AAI exception
-	 */
-	public static void Delete(String sourceID,  String transId,  String path) throws AAIException {
-		String methodName = "Delete";
-		String url="";
-		transId += ":" + UUID.randomUUID().toString();
-		LOGGER.debug(methodName + " start");
-		
-		initRestClient();
-		String request = "{}";
-		url = AAIConfig.get(AAIConstants.AAI_SERVER_URL) + path;			
-		ClientResponse cres = client.resource(url)
-		         .accept("application/json")
-		         .header("X-TransactionId", transId)
-		         .header("X-FromAppId",  sourceID)
-			 .header("Authorization", HttpsAuthClient.getBasicAuthHeaderValue())
-		         .type("application/json")
-		         .entity(request)
-		         .delete(ClientResponse.class);
-			
-		if (cres.getStatus() == 404) { // resource not found
-			LOGGER.info("Resource does not exist...: " + cres.getStatus()
-					+ ":" + cres.getEntity(String.class));
-		} else if (cres.getStatus() == 200  || cres.getStatus() == 204){
-			LOGGER.info("Resource " + url + " deleted");
-		} else {
-			LOGGER.error("Deleting Resource failed: " + cres.getStatus()
-				+ ":" + cres.getEntity(String.class));
-            throw new AAIException("AAI_7116", "Error during DELETE");
-		}
-	}
-	
-    /**
-     * Post.
-     *
-     * @param <T> the generic type
-     * @param t the t
-     * @param sourceID the source ID
-     * @param transId the trans id
-     * @param path the path
-     * @return the string
-     * @throws Exception the exception
-     */
-    public static <T> String Post(T t, String sourceID,  String transId,  String path) throws Exception {
-        String methodName = "Post";
-        String url="";
-        transId += ":" + UUID.randomUUID().toString();
-
-        LOGGER.debug(methodName + " start");        
-        
-        try {
-            
-            initRestClient();    
-    
-            url = AAIConfig.get(AAIConstants.AAI_SERVER_URL) + path;
-            
-            ClientResponse cres = client.resource(url)
-                 .accept("application/json")
-                 .header("X-TransactionId", transId)
-                 .header("X-FromAppId",  sourceID)
-		 .header("Authorization", HttpsAuthClient.getBasicAuthHeaderValue())
-                 .type("application/json")
-                 .entity(t)
-                 .post(ClientResponse.class);
-            
-            int statuscode = cres.getStatus();
-    		if ( statuscode >= 200 && statuscode <= 299 ) {    
-                 LOGGER.debug(methodName + "REST api POST was successful!");
-                 return cres.getEntity(String.class);
-             } else {
-                 throw new AAIException("AAI_7116", methodName +" with status="+statuscode+", url="+url + ", msg=" + cres.getEntity(String.class));
-             }    
-        
-        } catch (AAIException e) {
-            throw new AAIException("AAI_7116", methodName + " with url="+url+ ", Exception: " + e.toString());
-        } catch (Exception e)
-        {
-            throw new AAIException("AAI_7116", methodName + " with url="+url+ ", Exception: " + e.toString());
-        
-        }
-    }
-
-	
-    /**
-     * Gets the single instance of RestController.
-     *
-     * @param <T> the generic type
-     * @param clazz the clazz
-     * @return single instance of RestController
-     * @throws IllegalAccessException the illegal access exception
-     * @throws InstantiationException the instantiation exception
-     */
-    public static <T> T getInstance(Class<T> clazz) throws IllegalAccessException, InstantiationException
-	{
-		return clazz.newInstance();
-	} 
-	
-    /**
-     * Does resource exist.
-     *
-     * @param <T> the generic type
-     * @param resourcePath the resource path
-     * @param resourceClassName the resource class name
-     * @param fromAppId the from app id
-     * @param transId the trans id
-     * @return the t
-     */
-    /*
-     *     DoesResourceExist
-     *     
-     *     To check whether a resource exist or get a copy of the existing version of the resource
-     *	
-     *       Resourcepath: should contain the qualified resource path (including encoded unique key identifier value),
-     *       resourceClassName: is the canonical name of the resource class name, 
-     *       fromAppId:
-     *       transId:
-     *       
-     *     Will return null (if the resource doesn’t exist)  (or) 
-     *     Will return the specified resource from the Graph.
-     *     
-     *     Example:
-     *     LogicalLink llink = new LogicalLink();
-     *     String resourceClassName = llink.getClass().getCanonicalName();
-     *     llink = RestController.DoesResourceExist("network/logical-links/logical-link/" + <encoded-link-name>, resourceClassName, fromAppId, transId);
-   */
-	public static <T> T DoesResourceExist(String resourcePath, String resourceClassName, String fromAppId, String transId) {
-					
-		try {
-			
-			RestObject<T> restObj = new RestObject<T>();
-			@SuppressWarnings("unchecked")
-			T resourceObj = (T)getInstance(Class.forName(resourceClassName));
-			restObj.set(resourceObj);
-			RestController.<T>Get(resourceObj, fromAppId, transId, resourcePath, restObj, false);
-			
-			resourceObj = restObj.get();
-			if (resourceObj != null)
-			  return resourceObj;
-
-		} catch (AAIException e) {
-			
-		} catch (ClientHandlerException che) {
-			
-		}catch (Exception e) {
-			
-		}
-		
-		return null;
-	}
-	
-}
diff --git a/aai-resources/src/main/java/org/openecomp/aai/util/UpdateResource.java b/aai-resources/src/main/java/org/openecomp/aai/util/UpdateResource.java
deleted file mode 100644
index 1597a7b..0000000
--- a/aai-resources/src/main/java/org/openecomp/aai/util/UpdateResource.java
+++ /dev/null
@@ -1,134 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * org.openecomp.aai
- * ================================================================================
- * 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.aai.util;
-
-import java.util.Properties;
-import java.util.UUID;
-
-import org.openecomp.aai.domain.yang.Action;
-import org.openecomp.aai.domain.yang.ActionData;
-import org.openecomp.aai.domain.yang.Update;
-import org.openecomp.aai.exceptions.AAIException;
-import org.openecomp.aai.logging.ErrorLogHelper;
-import com.att.eelf.configuration.Configuration;
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
-
-
-public class UpdateResource {
-	
-	private static EELFLogger LOGGER;
-	private static final String FROMAPPID = "AAIUPDT";
-	private static final String TRANSID = UUID.randomUUID().toString();
-	private static final String UPDATE_URL = "actions/update";	
-	private static final String USAGE_STRING = "Usage: updateTool.sh \n" + 
-			"<node type> <update node URI> <property name>:<property value>[,<property name>:<property value]* | \n" + 
-			"where update node uri is the URI path for that node \n" +
-			" for ex. ./updateTool.sh pserver cloud-infrastructure/pservers/pserver/XXX prov-status:NEWSTATUS";
-	
-	/**
-	 * The main method.
-	 *
-	 * @param args the arguments
-	 */
-	public static void main(String[] args) {
-		
-		String nodeType = null;
-		String nodeURI = null;
-		String updValueList = null;
-		
-		// Set the logging file properties to be used by EELFManager
-		Properties props = System.getProperties();
-		props.setProperty(Configuration.PROPERTY_LOGGING_FILE_NAME, AAIConstants.AAI_UPDTOOL_LOGBACK_PROPS);
-		props.setProperty(Configuration.PROPERTY_LOGGING_FILE_PATH, AAIConstants.AAI_HOME_ETC_APP_PROPERTIES);
-		LOGGER = EELFManager.getInstance().getLogger(UpdateResource.class.getName());
-		try {		
-			if (args.length < 3) {
-				System.out.println("Nothing to update or Insufficient arguments");
-				System.out.println(USAGE_STRING);
-				System.exit(1);
-			} else { 
-					nodeType = args[0];
-					nodeURI = args[1];
-					updValueList = args[2];
-					
-					update(nodeType, nodeURI, updValueList);
-			}
-			
-			System.exit(0);
-		
-		} catch (AAIException e) {
-			System.out.println("Error - Update Failed.");
-			ErrorLogHelper.logException(e);
-			System.exit(1);
-		} catch (Exception e) {
-			System.out.println("Error - Update Failed." + e.getMessage());
-			ErrorLogHelper.logError("AAI_7402", "Update failed: " + e.getMessage());
-			System.exit(1);
-		}
-	}
-	
-	/**
-	 * Update.
-	 *
-	 * @param <T> the generic type
-	 * @param aaiLogger the aai logger
-	 * @param logline the logline
-	 * @param nodeType the node type
-	 * @param nodeURI the node URI
-	 * @param updValueList the upd value list
-	 * @throws AAIException the AAI exception
-	 */
-	public static <T> void update(String nodeType, String nodeURI, String updValueList) throws AAIException {		
-		try {
-				Update update = new Update();
-				update.setUpdateNodeType(nodeType);
-				update.setUpdateNodeUri(nodeURI);
-				
-				Action action = new Action();
-				action.setActionType("replace");
-				
-				for (String updValue: updValueList.split(",")) {
-					ActionData data = new ActionData();
-					data.setPropertyName(updValue.substring(0, updValue.indexOf(':')));
-					data.setPropertyValue(updValue.substring(updValue.indexOf(':') + 1));
-					action.getActionData().add(data);
-				}		
-
-				update.getAction().add(action);	
-				
-				String infMsg = "updating the resource... ";
-				System.out.println(infMsg);
-				LOGGER.info(infMsg);
-
-				RestController.<Update>Put(update, FROMAPPID, TRANSID, UPDATE_URL);
-
-				infMsg = "Update Successful";
-				System.out.println(infMsg);
-				LOGGER.info(infMsg);
-
-		} catch (AAIException e) {
-			throw e;
-		}  catch (Exception e) {
-            throw new AAIException("AAI_7402", e, "Error during UPDATE");
-		}
-	}
-}