[SDC] Onboarding 1710 rebase.

[sdc.git] / openecomp-be / lib / openecomp-core-lib / openecomp-zusammen-lib / openecomp-zusammen-plugin / src / main / java / org / openecomp / core / zusammen / plugin / dao / impl / CassandraElementRepository.java

diff --git a/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/dao/impl/CassandraElementRepository.java b/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/dao/impl/CassandraElementRepository.java
index 12fd2da..c19e879 100644 (file)
--- a/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/dao/impl/CassandraElementRepository.java
+++ b/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/dao/impl/CassandraElementRepository.java
@@ -98,6 +98,12 @@ public class CassandraElementRepository implements ElementRepository {
         element.getNamespace().toString());
   }
 
+  @Override
+  public boolean checkHealth(SessionContext context) {
+    ResultSet resultSet = getVersionElementsAccessor(context).checkHealth();
+    return resultSet.getColumnDefinitions().contains("element_ids");
+  }
+
   private String getVersionId(ElementEntityContext elementContext) {
     return elementContext.getChangeRef() == null
         ? elementContext.getVersionId().toString()
@@ -350,6 +356,9 @@ CREATE TABLE IF NOT EXISTS element (
 
     @Query("SELECT element_ids FROM version_elements WHERE space=? AND item_id=? AND version_id=?")
     ResultSet get(String space, String itemId, String versionId);
+
+    @Query("SELECT element_ids FROM version_elements LIMIT 1")
+    ResultSet checkHealth();
   }
 
   private static final class VersionElementsField {