/*- * ============LICENSE_START======================================================= * SDC * ================================================================================ * 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.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.config.ConfigurationManager; import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription; import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants; import com.datastax.driver.core.DataType; import com.datastax.driver.mapping.annotations.Column; public class ResAdminEventTableDescription implements ITableDescription { @Override public List> primaryKeys() { List> keys = new ArrayList<>(); keys.add(new ImmutablePair(TIMEBASED_UUID_FIELD, DataType.timeuuid())); return keys; } @Override public List> clusteringKeys() { List> keys = new ArrayList<>(); keys.add(new ImmutablePair(TIMESTAMP_FIELD, DataType.timestamp())); return keys; } @Override public Map> getColumnDescription() { Map> columns = new HashMap<>(); for (AEFieldsDescription field : AEFieldsDescription.values()) { columns.put(field.getName(), new ImmutablePair(field.type, field.indexed)); } return columns; } @Override public String getKeyspace() { return AuditingTypesConstants.AUDIT_KEYSPACE; } @Override public String getTableName() { return AuditingTypesConstants.RESOURCE_ADMIN_EVENT_TYPE; } enum AEFieldsDescription { REQUEST_ID("request_id", DataType.varchar(), false), SERVICE_INST_ID("service_instance_id", DataType.varchar(), true), INVARIANT_UUID("invariant_UUID", DataType.varchar(), true), ACTION("action", DataType.varchar(), true), STATUS("status", DataType.varchar(), false), DESCRIPTION("description",DataType.varchar(), false), RESOURCE_TYPE("resource_type", DataType.varchar(), false), PREV_VERSION( "prev_version", DataType.varchar(), true), PREV_STATE("prev_state", DataType.varchar(), true), CURR_STATE("curr_state", DataType.varchar(), false), RESOURCE_NAME("resource_name", DataType.varchar(), false), CURR_VERSION("curr_version", DataType.varchar(), true), MODIFIER("modifier", DataType.varchar(), false), PREV_ARTIFACT_UUID("prev_artifact_UUID", DataType.varchar(), false), CURR__ARTIFACT_UUID("curr_artifact_UUID", DataType.varchar(), false), ARTIFACT_DATA("artifact_data", DataType.varchar(), false), DID("did", DataType.varchar(), true), DPREV_STATUS("dprev_status", DataType.varchar(), false), DCURR_STATUS("dcurr_status", DataType.varchar(), false), TOSCA_NODE_TYPE("tosca_node_type", DataType.varchar(), false), COMMENT("comment", DataType.varchar(), false); private String name; private DataType type; private boolean indexed; AEFieldsDescription(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; } } }