org.openecomp.sdc.ci.tests.utils.cassandra

Class CassandraUtils

java.lang.Object

org.openecomp.sdc.ci.tests.utils.cassandra.CassandraUtils

public final class CassandraUtils
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static com.datastax.driver.core.Cluster	cluster
protected static com.datastax.driver.core.Session	session

Constructor Summary

Constructors

Constructor and Description
CassandraUtils()

Method Summary

Modifier and Type	Method and Description
static void	close()
static List<com.datastax.driver.core.Row>	fetchFromTable(String keyspace, String tableName, List<org.javatuples.Pair<AuditingFieldsKeysEnum,String>> fields)
static List<com.datastax.driver.core.Row>	fetchFromTableQuery(String keyspace, String tableName, List<org.javatuples.Pair<String,String>> fields)
protected static void	initConnection(String keyspace)
static void	truncateAllKeyspaces()
static void	truncateAllTables(String keyspace)
static void	truncateTable(String keyspace, String tableName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

cluster

protected static com.datastax.driver.core.Cluster cluster

session

protected static com.datastax.driver.core.Session session

Constructor Detail

CassandraUtils

public CassandraUtils()

Method Detail

initConnection

protected static void initConnection(String keyspace)
                              throws FileNotFoundException

Throws:

FileNotFoundException

truncateTable

public static void truncateTable(String keyspace,
                                 String tableName)
                          throws FileNotFoundException

Throws:

FileNotFoundException

close

public static void close()

truncateAllKeyspaces

public static void truncateAllKeyspaces()
                                 throws FileNotFoundException

Throws:

FileNotFoundException

truncateAllTables

public static void truncateAllTables(String keyspace)
                              throws FileNotFoundException

Throws:

FileNotFoundException

fetchFromTable

public static List<com.datastax.driver.core.Row> fetchFromTable(String keyspace,
                                                                String tableName,
                                                                List<org.javatuples.Pair<AuditingFieldsKeysEnum,String>> fields)
                                                         throws FileNotFoundException

Throws:

FileNotFoundException

fetchFromTableQuery

public static List<com.datastax.driver.core.Row> fetchFromTableQuery(String keyspace,
                                                                     String tableName,
                                                                     List<org.javatuples.Pair<String,String>> fields)
                                                              throws FileNotFoundException

Throws:

FileNotFoundException