1 files changed, 68 insertions, 0 deletions
diff --git a/blueprints-processor/adaptors/data-adaptor-provider/src/main/java/org/onap/ccsdk/config/data/adaptor/dao/ConfigPropertyMapDaoImpl.java b/blueprints-processor/adaptors/data-adaptor-provider/src/main/java/org/onap/ccsdk/config/data/adaptor/dao/ConfigPropertyMapDaoImpl.java
new file mode 100644
index 000000000..84c96a84d
--- /dev/null
+++ b/blueprints-processor/adaptors/data-adaptor-provider/src/main/java/org/onap/ccsdk/config/data/adaptor/dao/ConfigPropertyMapDaoImpl.java
@@ -0,0 +1,68 @@
+/*
+ * Copyright © 2017-2018 AT&T Intellectual Property.
+ * 
+ * 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.
+ */
+
+package org.onap.ccsdk.config.data.adaptor.dao;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+import org.apache.commons.lang3.StringUtils;
+import org.onap.ccsdk.config.data.adaptor.DataAdaptorConstants;
+import org.onap.ccsdk.sli.core.sli.SvcLogicException;
+import org.springframework.jdbc.core.JdbcTemplate;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+import com.google.common.base.Preconditions;
+
+public class ConfigPropertyMapDaoImpl implements ConfigPropertyMapDao {
+    
+    private static EELFLogger logger = EELFManager.getInstance().getLogger(ConfigPropertyMapDaoImpl.class);
+    
+    private JdbcTemplate jdbcTemplate;
+    private Map<String, String> configPropertyMap = new ConcurrentHashMap<>();
+    
+    public ConfigPropertyMapDaoImpl(JdbcTemplate jdbcTemplate) {
+        this.jdbcTemplate = jdbcTemplate;
+        initializeMap();
+        
+        String envType = configPropertyMap.get(DataAdaptorConstants.PROPERTY_ENV_TYPE);
+        if (!(DataAdaptorConstants.PROPERTY_ENV_PROD.equalsIgnoreCase(envType)
+                || DataAdaptorConstants.PROPERTY_ENV_SOLO.equalsIgnoreCase(envType))) {
+            ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
+            Runnable task = () -> {
+                initializeMap();
+            };
+            executor.scheduleWithFixedDelay(task, 60, 15, TimeUnit.MINUTES);
+        }
+    }
+    
+    private void initializeMap() {
+        String getPropQuery = "SELECT * FROM CONFIG_PROPERTY_MAP";
+        jdbcTemplate.queryForList(getPropQuery).forEach(rows -> {
+            String key = StringUtils.trimToEmpty((String) rows.get("reference_key"));
+            String value = StringUtils.trimToEmpty((String) rows.get("reference_value"));
+            configPropertyMap.put(key, value);
+        });
+        logger.trace("loaded configPropertyMap : ({})", configPropertyMap);
+    }
+    
+    @Override
+    public String getConfigPropertyByKey(String key) throws SvcLogicException {
+        Preconditions.checkArgument(StringUtils.isNotBlank(key), "missing property key");
+        return configPropertyMap.get(key);
+    }
+    
+}