summaryrefslogtreecommitdiffstats
path: root/openecomp-be/lib/openecomp-core-lib/openecomp-nosqldb-lib/openecomp-nosqldb-core/src/main/java/org/openecomp/core/nosqldb/util/CassandraUtils.java
diff options
context:
space:
mode:
authorvasraz <vasyl.razinkov@est.tech>2021-03-22 15:33:06 +0000
committerChristophe Closset <christophe.closset@intl.att.com>2021-03-24 06:59:47 +0000
commitd378c37fbd1ecec7b43394926f1ca32a695e07de (patch)
tree5c8a085f8732f980d871d966ac49361644efa698 /openecomp-be/lib/openecomp-core-lib/openecomp-nosqldb-lib/openecomp-nosqldb-core/src/main/java/org/openecomp/core/nosqldb/util/CassandraUtils.java
parenta6ae7294ecd336d7e88f915710b08e2658eaee00 (diff)
Reformat openecomp-be
Signed-off-by: Vasyl Razinkov <vasyl.razinkov@est.tech> Issue-ID: SDC-3449 Change-Id: I13e02322f8e00820cc5a1d85752caaeda9bf10d1
Diffstat (limited to 'openecomp-be/lib/openecomp-core-lib/openecomp-nosqldb-lib/openecomp-nosqldb-core/src/main/java/org/openecomp/core/nosqldb/util/CassandraUtils.java')
-rw-r--r--openecomp-be/lib/openecomp-core-lib/openecomp-nosqldb-lib/openecomp-nosqldb-core/src/main/java/org/openecomp/core/nosqldb/util/CassandraUtils.java120
1 files changed, 53 insertions, 67 deletions
diff --git a/openecomp-be/lib/openecomp-core-lib/openecomp-nosqldb-lib/openecomp-nosqldb-core/src/main/java/org/openecomp/core/nosqldb/util/CassandraUtils.java b/openecomp-be/lib/openecomp-core-lib/openecomp-nosqldb-lib/openecomp-nosqldb-core/src/main/java/org/openecomp/core/nosqldb/util/CassandraUtils.java
index 30bc0a72a3..d6840fedd1 100644
--- a/openecomp-be/lib/openecomp-core-lib/openecomp-nosqldb-lib/openecomp-nosqldb-core/src/main/java/org/openecomp/core/nosqldb/util/CassandraUtils.java
+++ b/openecomp-be/lib/openecomp-core-lib/openecomp-nosqldb-lib/openecomp-nosqldb-core/src/main/java/org/openecomp/core/nosqldb/util/CassandraUtils.java
@@ -7,9 +7,9 @@
* 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.
@@ -17,90 +17,76 @@
* 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.util.HashMap;
import java.util.Map;
+import org.openecomp.core.utilities.file.FileUtils;
+import org.openecomp.core.utilities.json.JsonUtil;
public class CassandraUtils {
+ private static final String CASSANDRA_STATEMENT_DEFINITION_FILE = "cassandraStatements.json";
+ private static Map<String, String> statementMap = new HashMap<>();
- private static final String CASSANDRA_STATEMENT_DEFINITION_FILE = "cassandraStatements.json";
- private static Map<String, String> statementMap = new HashMap<>();
-
- public static String[] getAddresses() {
- return ConfigurationManager.getInstance().getAddresses();
- }
-
- public static Long getReconnectTimeout() {
- return ConfigurationManager.getInstance().getReconnectTimeout();
- }
-
- 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) {
- statementMap = FileUtils.readViaInputStream(CASSANDRA_STATEMENT_DEFINITION_FILE,
- stream -> JsonUtil.json2Object(stream, Map.class));
+ public static String[] getAddresses() {
+ return ConfigurationManager.getInstance().getAddresses();
}
- 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 Long getReconnectTimeout() {
+ return ConfigurationManager.getInstance().getReconnectTimeout();
+ }
- public static String getTruststorePassword() {
- return ConfigurationManager.getInstance().getTruststorePassword();
+ 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) {
+ statementMap = FileUtils.readViaInputStream(CASSANDRA_STATEMENT_DEFINITION_FILE, stream -> JsonUtil.json2Object(stream, Map.class));
+ }
+ return statementMap.get(statementName);
+ }
- public static int getCassandraPort() {
- return ConfigurationManager.getInstance().getCassandraPort();
+ public static String getUser() {
+ return ConfigurationManager.getInstance().getUsername();
+ }
- }
+ public static String getPassword() {
+ return ConfigurationManager.getInstance().getPassword();
+ }
- public static boolean isSsl() {
- return ConfigurationManager.getInstance().isSsl();
+ public static String getTruststore() {
+ return ConfigurationManager.getInstance().getTruststorePath();
+ }
- }
+ public static String getTruststorePassword() {
+ return ConfigurationManager.getInstance().getTruststorePassword();
+ }
- public static boolean isAuthenticate() {
- return ConfigurationManager.getInstance().isAuthenticate();
- }
+ public static int getCassandraPort() {
+ return ConfigurationManager.getInstance().getCassandraPort();
+ }
- public static String getConsistencyLevel() {
+ public static boolean isSsl() {
+ return ConfigurationManager.getInstance().isSsl();
+ }
- return ConfigurationManager.getInstance().getConsistencyLevel();
+ public static boolean isAuthenticate() {
+ return ConfigurationManager.getInstance().isAuthenticate();
+ }
- }
+ public static String getConsistencyLevel() {
+ return ConfigurationManager.getInstance().getConsistencyLevel();
+ }
- public static String getLocalDataCenter() {
- return ConfigurationManager.getInstance().getLocalDataCenter();
- }
+ public static String getLocalDataCenter() {
+ return ConfigurationManager.getInstance().getLocalDataCenter();
+ }
}