1 files changed, 124 insertions, 0 deletions
diff --git a/mso-api-handlers/mso-requests-db/src/main/java/org/openecomp/mso/requestsdb/WatchdogServiceModVerIdLookupDb.java b/mso-api-handlers/mso-requests-db/src/main/java/org/openecomp/mso/requestsdb/WatchdogServiceModVerIdLookupDb.java
new file mode 100644
index 0000000000..f081bbf55c
--- /dev/null
+++ b/mso-api-handlers/mso-requests-db/src/main/java/org/openecomp/mso/requestsdb/WatchdogServiceModVerIdLookupDb.java
@@ -0,0 +1,124 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * 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.mso.requestsdb;
+
+
+import java.sql.Timestamp;
+
+import org.hibernate.Query;
+import org.hibernate.Session;
+import org.openecomp.mso.db.AbstractSessionFactoryManager;
+import org.openecomp.mso.logger.MessageEnum;
+import org.openecomp.mso.logger.MsoLogger;
+
+public class WatchdogServiceModVerIdLookupDb {
+
+    protected final AbstractSessionFactoryManager sessionFactoryRequestDB;
+    
+    protected static MsoLogger msoLogger = MsoLogger.getMsoLogger (MsoLogger.Catalog.GENERAL);
+
+    protected static final String         DISTRIBUTION_ID               = "distributionId";
+    protected static final String         SERVICE_MODEL_VERSION_ID  	= "serviceModelVersionId";
+    protected static final String         CREATE_TIME                 	= "startTime";
+    
+
+    public static WatchdogServiceModVerIdLookupDb getInstance() {
+        return new WatchdogServiceModVerIdLookupDb(new RequestsDbSessionFactoryManager ());
+    }
+
+    protected WatchdogServiceModVerIdLookupDb (AbstractSessionFactoryManager sessionFactoryRequest) {
+        sessionFactoryRequestDB = sessionFactoryRequest;
+    }
+
+
+    /**
+     * Insert into WATCHDOG_SERVICE_MOD_VER_ID_LOOKUP.
+     *
+     * @param distributionId
+     * @param serviceModelVersionId
+     * @return void
+     */
+	public void insertWatchdogServiceModVerIdLookup(String distributionId, String serviceModelVersionId ) {
+		long startTime = System.currentTimeMillis ();
+		Timestamp startTimeStamp = new Timestamp (System.currentTimeMillis());
+		msoLogger.debug ("Insert into WatchdogServiceModVerIdLookup for DistributionId: " + distributionId + " and ServiceModelVersionId: " + serviceModelVersionId  );
+		
+		if(getWatchdogServiceModVerId(distributionId) == null){
+
+		Session session = sessionFactoryRequestDB.getSessionFactory ().openSession ();
+		WatchdogServiceModVerIdLookup wdsm = new WatchdogServiceModVerIdLookup ();
+	
+		try {
+			session.beginTransaction ();
+		
+			wdsm.setDistributionId (distributionId);
+			wdsm.setServiceModelVersionId (serviceModelVersionId);
+			wdsm.setCreateTime (startTimeStamp);
+		
+			msoLogger.debug ("About to insert a record into WatchdogServiceModVerIdLookup");
+		
+			session.save (wdsm);
+			session.getTransaction ().commit ();
+		} catch (Exception e) {
+			msoLogger.error (MessageEnum.APIH_DB_INSERT_EXC, "", "", MsoLogger.ErrorCode.SchemaError, "Exception in insertWatchdogServiceModVerIdLookup", e);
+			msoLogger.recordMetricEvent (startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DBAccessError, e.getMessage (), "WatchdogServiceModVerIdLookupDB", "saveRequest", null);
+			if (session != null) {
+				session.close ();
+			}
+			// throw an Exception in the event of a DB insert failure so that the calling routine can exit
+			throw e;
+		} finally {
+			if (session != null && session.isOpen ()) {
+				session.close ();
+		}
+		msoLogger.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "WatchdogServiceModVerIdLookupDB", "insertWatchdogServiceModVerIdLookup", null);
+		}
+	}
+		
+  }
+	
+    /**
+     * Retrieve from WATCHDOG_SERVICE_MOD_VER_ID_LOOKUP.
+     *
+     * @param distributionId
+     * @return WatchdogServiceModVerIdLookup
+     */
+	public String getWatchdogServiceModVerId(String distributionId) {
+		long startTime = System.currentTimeMillis ();
+		msoLogger.debug ("Retrieve WatchdogServiceModVerIdLookup with distributionId: " + distributionId );
+
+		Session session = sessionFactoryRequestDB.getSessionFactory ().openSession ();
+		String serviceModelVersionId = null;
+		try {
+			session.beginTransaction ();
+			Query query = session.createQuery ("Select serviceModelVersionId FROM WatchdogServiceModVerIdLookup WHERE distributionId = :distributionId ");
+			query.setParameter ("distributionId", distributionId);
+			serviceModelVersionId = (String) query.uniqueResult();
+		} finally {
+			if (session != null && session.isOpen ()) {
+				session.close ();
+			}
+			msoLogger.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, 
+										"Successfully", "WatchdogServiceModVerIdLookupDB", "getWatchdogServiceModVerId", null);
+		}
+		return serviceModelVersionId;
+	}
+}