com.impetus.client.cassandra.common

Class CassandraUtilities

java.lang.Object

com.impetus.client.cassandra.common.CassandraUtilities

public class CassandraUtilities
extends Object

Provides utilities methods

Author:

amresh.singh

Constructor Summary

Constructors

Constructor and Description
CassandraUtilities()

Method Summary

Methods

Modifier and Type	Method and Description
static StringBuilder	appendColumns(StringBuilder builder, List<String> columns, String selectQuery, CQLTranslator translator) Append columns.
static String	getIdColumnName(EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata, EntityMetadata m, Map<String,Object> externalProperties, boolean isCql3Enabled) Return name if Idcolumn for cql, returns if user opted for otherwise returns JPAColumnName of id attribute.
static String	getKeyspace(EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata, String persistenceUnit)
static net.dataforte.cassandra.pool.PoolConfiguration	setPoolConfigPolicy(CassandraHost cassandraHost, net.dataforte.cassandra.pool.PoolConfiguration prop) Gets the pool config policy.
static byte[]	toBytes(Object value)
static ByteBuffer	toBytes(Object value, Class<?> clazz)
static ByteBuffer	toBytes(Object value, Field f)
static String	toUTF8(byte[] value)
static boolean	verifyConnection(String host, int port)

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraUtilities

public CassandraUtilities()

Method Detail

toUTF8

public static String toUTF8(byte[] value)

getKeyspace

public static String getKeyspace(EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata,
                 String persistenceUnit)

toBytes

public static ByteBuffer toBytes(Object value,
                 Field f)

toBytes

public static byte[] toBytes(Object value)

toBytes

public static ByteBuffer toBytes(Object value,
                 Class<?> clazz)

Parameters:

value -

f -

Returns:

appendColumns

public static StringBuilder appendColumns(StringBuilder builder,
                          List<String> columns,
                          String selectQuery,
                          CQLTranslator translator)

Append columns.

Parameters:

builder - the builder

columns - the columns

selectQuery - the select query

translator - the translator

getIdColumnName

public static String getIdColumnName(EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata,
                     EntityMetadata m,
                     Map<String,Object> externalProperties,
                     boolean isCql3Enabled)

Return name if Idcolumn for cql, returns if user opted for otherwise returns JPAColumnName of id attribute.

Parameters:

m -

externalProperties -

Returns:

verifyConnection

public static boolean verifyConnection(String host,
                       int port)

Parameters:

host -

port -

Returns:

setPoolConfigPolicy

public static net.dataforte.cassandra.pool.PoolConfiguration setPoolConfigPolicy(CassandraHost cassandraHost,
                                                                 net.dataforte.cassandra.pool.PoolConfiguration prop)

Gets the pool config policy.

Parameters:

persistenceUnitMetadata - the persistence unit metadata

puProperties -

Returns:

the pool config policy