[SDC-29] catalog 1707 rebase commit.

[sdc.git] / catalog-dao / src / main / java / org / openecomp / sdc / be / dao / cassandra / schema / tables / SdcSchemaFilesTableDescription.java

diff --git a/catalog-dao/src/main/java/org/openecomp/sdc/be/dao/cassandra/schema/tables/SdcSchemaFilesTableDescription.java b/catalog-dao/src/main/java/org/openecomp/sdc/be/dao/cassandra/schema/tables/SdcSchemaFilesTableDescription.java
new file mode 100644 (file)
index 0000000..09a01fb
--- /dev/null
+++ b/catalog-dao/src/main/java/org/openecomp/sdc/be/dao/cassandra/schema/tables/SdcSchemaFilesTableDescription.java
@@ -0,0 +1,83 @@
+package org.openecomp.sdc.be.dao.cassandra.schema.tables;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.commons.lang3.tuple.ImmutablePair;
+import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
+import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
+
+import com.datastax.driver.core.DataType;
+
+public class SdcSchemaFilesTableDescription implements ITableDescription {
+       
+       private static final String SDC_RELEASE_NUM = "sdcReleaseNum";
+       private static final String TIMESTAMP = "timestamp";
+       private static final String CONFORMANCE_LEVEL = "conformanceLevel";
+       
+       @Override
+       public List<ImmutablePair<String, DataType>> primaryKeys() {
+               List<ImmutablePair<String, DataType>> keys = new ArrayList<>();
+               keys.add(new ImmutablePair<String, DataType>(SDC_RELEASE_NUM, DataType.varchar()));
+               keys.add(new ImmutablePair<String, DataType>(CONFORMANCE_LEVEL, DataType.varchar()));
+               return keys;
+       }
+       
+       @Override
+       public List<ImmutablePair<String, DataType>> clusteringKeys() {
+               List<ImmutablePair<String, DataType>> keys = new ArrayList<>();
+               keys.add(new ImmutablePair<String, DataType>(TIMESTAMP, DataType.timestamp()));
+               return keys;
+       }
+       
+       @Override
+       public Map<String, ImmutablePair<DataType, Boolean>> getColumnDescription() {
+               Map<String, ImmutablePair<DataType, Boolean>> columns = new HashMap<>();
+
+               for (SdcSchemaFilesFieldsDescription field : SdcSchemaFilesFieldsDescription.values()) {
+                       columns.put(field.getName(), new ImmutablePair<DataType, Boolean>(field.type, field.indexed));
+               }
+
+               return columns;
+       }
+
+       @Override
+       public String getKeyspace() {
+               return AuditingTypesConstants.ARTIFACT_KEYSPACE;
+       }
+
+       @Override
+       public String getTableName() {
+               return "sdcSchemaFiles";  
+       }
+       
+       enum SdcSchemaFilesFieldsDescription {
+               FILE_NAME("fileName", DataType.varchar(), false),
+               PAYLOAD("payload", DataType.blob(), false),
+               CHECKSUM("checksum", DataType.varchar(), false);
+
+               private String name;
+               private DataType type;
+               private boolean indexed;
+
+               SdcSchemaFilesFieldsDescription(String name, DataType type, boolean indexed) {
+                       this.name = name;
+                       this.type = type;
+                       this.indexed = indexed;
+               }
+
+               public String getName() {
+                       return name;
+               }
+
+               public DataType getType() {
+                       return type;
+               }
+
+               public boolean isIndexed() {
+                       return indexed;
+               }
+       }
+}