/*- * ============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.core.nosqldb.util; import org.openecomp.core.utilities.file.FileUtils; import org.openecomp.core.utilities.json.JsonUtil; import java.io.InputStream; import java.util.HashMap; import java.util.Map; public class CassandraUtils { private static final String CASSANDRA_STATEMENT_DEFINITION_FILE = "cassandraStatements.json"; private static Map statementMap = new HashMap<>(); public static String[] getAddresses() { return ConfigurationManager.getInstance().getAddresses(); } public static String getKeySpace() { return ConfigurationManager.getInstance().getKeySpace(); } /** * Gets statement. * * @param statementName the statement name * @return the statement */ public static String getStatement(String statementName) { if (statementMap.size() == 0) { InputStream statementJson = FileUtils.getFileInputStream(CASSANDRA_STATEMENT_DEFINITION_FILE); statementMap = JsonUtil.json2Object(statementJson, Map.class); } return statementMap.get(statementName); } public static String getUser() { return ConfigurationManager.getInstance().getUsername(); } public static String getPassword() { return ConfigurationManager.getInstance().getPassword(); } public static String getTruststore() { return ConfigurationManager.getInstance().getTruststorePath(); } public static String getTruststorePassword() { return ConfigurationManager.getInstance().getTruststorePassword(); } public static int getCassandraPort() { return ConfigurationManager.getInstance().getSslPort(); } public static boolean isSsl() { return ConfigurationManager.getInstance().isSsl(); } public static boolean isAuthenticate() { return ConfigurationManager.getInstance().isAuthenticate(); } }