1 files changed, 9 insertions, 0 deletions
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 12fd2dabba..c19e8799d1 100644
--- 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 {