org.cassandraunit.utils

Class EmbeddedCassandraServerHelper

java.lang.Object

org.cassandraunit.utils.EmbeddedCassandraServerHelper

public class EmbeddedCassandraServerHelper
extends Object

Author:

Jeremy Sevellec

Field Summary

Fields

Modifier and Type	Field and Description
static String	CASSANDRA_RNDPORT_YML_FILE Configuration file which starts the embedded cassandra on a random free port
static String	DEFAULT_CASSANDRA_YML_FILE Default configuration file.
static String	DEFAULT_LOG4J_CONFIG_FILE
static long	DEFAULT_STARTUP_TIMEOUT
static String	DEFAULT_TMP_DIR

Constructor Summary

Constructors

Constructor and Description
EmbeddedCassandraServerHelper()

Method Summary

Modifier and Type	Method and Description
static void	cleanDataEmbeddedCassandra(String keyspace, String... excludedTables) truncate data in keyspace, except specified tables
static void	cleanEmbeddedCassandra() drop all keyspaces (expect system)
static com.datastax.driver.core.Cluster	getCluster()
static String	getClusterName() Get the embedded cassandra cluster name
static String	getHost() Get embedded cassandra host.
static int	getNativeTransportPort() Get embedded cassandra native transport port.
static int	getRpcPort() Get embedded cassandra RPC port.
static com.datastax.driver.core.Session	getSession()
static void	mkdirs()
static java.util.function.Predicate<String>	nonSystemKeyspaces()
static void	startEmbeddedCassandra()
static void	startEmbeddedCassandra(File file, long timeout)
static void	startEmbeddedCassandra(File file, String tmpDir, long timeout) Set embedded cassandra up and spawn it in a new thread.
static void	startEmbeddedCassandra(long timeout)
static void	startEmbeddedCassandra(String yamlFile)
static void	startEmbeddedCassandra(String yamlFile, long timeout)
static void	startEmbeddedCassandra(String yamlFile, String tmpDir)
static void	startEmbeddedCassandra(String yamlFile, String tmpDir, long timeout)
static void	stopEmbeddedCassandra() Deprecated.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_STARTUP_TIMEOUT

public static final long DEFAULT_STARTUP_TIMEOUT

See Also:

Constant Field Values

DEFAULT_TMP_DIR

public static final String DEFAULT_TMP_DIR

See Also:

Constant Field Values

DEFAULT_CASSANDRA_YML_FILE

public static final String DEFAULT_CASSANDRA_YML_FILE

Default configuration file. Starts embedded cassandra under the well known ports

See Also:

Constant Field Values

CASSANDRA_RNDPORT_YML_FILE

public static final String CASSANDRA_RNDPORT_YML_FILE

Configuration file which starts the embedded cassandra on a random free port

See Also:

Constant Field Values

DEFAULT_LOG4J_CONFIG_FILE

public static final String DEFAULT_LOG4J_CONFIG_FILE

See Also:

Constant Field Values

Constructor Detail

EmbeddedCassandraServerHelper

public EmbeddedCassandraServerHelper()

Method Detail

nonSystemKeyspaces

public static java.util.function.Predicate<String> nonSystemKeyspaces()

startEmbeddedCassandra

public static void startEmbeddedCassandra()
                                   throws org.apache.thrift.transport.TTransportException,
                                          IOException,
                                          InterruptedException,
                                          org.apache.cassandra.exceptions.ConfigurationException

Throws:

org.apache.thrift.transport.TTransportException

IOException

InterruptedException

org.apache.cassandra.exceptions.ConfigurationException

startEmbeddedCassandra

public static void startEmbeddedCassandra(long timeout)
                                   throws org.apache.thrift.transport.TTransportException,
                                          org.apache.cassandra.exceptions.ConfigurationException,
                                          IOException

Throws:

org.apache.thrift.transport.TTransportException

org.apache.cassandra.exceptions.ConfigurationException

IOException

startEmbeddedCassandra

public static void startEmbeddedCassandra(String yamlFile)
                                   throws org.apache.thrift.transport.TTransportException,
                                          IOException,
                                          org.apache.cassandra.exceptions.ConfigurationException

Throws:

org.apache.thrift.transport.TTransportException

IOException

org.apache.cassandra.exceptions.ConfigurationException

startEmbeddedCassandra

public static void startEmbeddedCassandra(String yamlFile,
                                          long timeout)
                                   throws org.apache.thrift.transport.TTransportException,
                                          IOException,
                                          org.apache.cassandra.exceptions.ConfigurationException

Throws:

org.apache.thrift.transport.TTransportException

IOException

org.apache.cassandra.exceptions.ConfigurationException

startEmbeddedCassandra

public static void startEmbeddedCassandra(String yamlFile,
                                          String tmpDir)
                                   throws org.apache.thrift.transport.TTransportException,
                                          IOException,
                                          org.apache.cassandra.exceptions.ConfigurationException

Throws:

org.apache.thrift.transport.TTransportException

IOException

org.apache.cassandra.exceptions.ConfigurationException

startEmbeddedCassandra

public static void startEmbeddedCassandra(String yamlFile,
                                          String tmpDir,
                                          long timeout)
                                   throws org.apache.thrift.transport.TTransportException,
                                          IOException,
                                          org.apache.cassandra.exceptions.ConfigurationException

Throws:

org.apache.thrift.transport.TTransportException

IOException

org.apache.cassandra.exceptions.ConfigurationException

startEmbeddedCassandra

public static void startEmbeddedCassandra(File file,
                                          long timeout)
                                   throws org.apache.thrift.transport.TTransportException,
                                          IOException,
                                          org.apache.cassandra.exceptions.ConfigurationException

Throws:

org.apache.thrift.transport.TTransportException

IOException

org.apache.cassandra.exceptions.ConfigurationException

startEmbeddedCassandra

public static void startEmbeddedCassandra(File file,
                                          String tmpDir,
                                          long timeout)
                                   throws IOException,
                                          org.apache.cassandra.exceptions.ConfigurationException

Set embedded cassandra up and spawn it in a new thread.

Throws:

org.apache.thrift.transport.TTransportException

IOException

org.apache.cassandra.exceptions.ConfigurationException

stopEmbeddedCassandra

@Deprecated
public static void stopEmbeddedCassandra()

Deprecated.

Now deprecated, previous version was not fully operating. This is now an empty method, will be pruned in future versions.

cleanEmbeddedCassandra

public static void cleanEmbeddedCassandra()

drop all keyspaces (expect system)

cleanDataEmbeddedCassandra

public static void cleanDataEmbeddedCassandra(String keyspace,
                                              String... excludedTables)

truncate data in keyspace, except specified tables

getCluster

public static com.datastax.driver.core.Cluster getCluster()

getSession

public static com.datastax.driver.core.Session getSession()

getClusterName

public static String getClusterName()

Get the embedded cassandra cluster name

Returns:

the cluster name

getHost

public static String getHost()

Get embedded cassandra host.

Returns:

the cassandra host

getRpcPort

public static int getRpcPort()

Get embedded cassandra RPC port.

Returns:

the cassandra RPC port

getNativeTransportPort

public static int getNativeTransportPort()

Get embedded cassandra native transport port.

Returns:

the cassandra native transport port.

mkdirs

public static void mkdirs()