com.impetus.client.cassandra.schemamanager

Class CassandraSchemaManager

java.lang.Object

com.impetus.kundera.configure.schema.api.AbstractSchemaManager

com.impetus.client.cassandra.schemamanager.CassandraSchemaManager

All Implemented Interfaces:

SchemaManager

public class CassandraSchemaManager
extends AbstractSchemaManager
implements SchemaManager

Manages auto schema operation defined in ScheamOperationType.

Author:

Kuldeep.kumar

Nested Class Summary

Nested classes/interfaces inherited from class com.impetus.kundera.configure.schema.api.AbstractSchemaManager

AbstractSchemaManager.SchemaOperationType

Field Summary

Fields inherited from class com.impetus.kundera.configure.schema.api.AbstractSchemaManager

clientFactory, conn, databaseName, dataStore, externalProperties, hosts, kunderaMetadata, operation, password, port, puMetadata, schemas, showQuery, tableInfos, userName

Constructor Summary

Constructors

Constructor and Description
CassandraSchemaManager(String clientFactory, Map<String,Object> puProperties, EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata) Instantiates a new cassandra schema manager.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	create_drop(List<TableInfo> tableInfos) create_drop method creates schema and table for the list of tableInfos.
protected void	create(List<TableInfo> tableInfos) Creates schema and table for the list of tableInfos.
void	dropSchema() drop schema method drop the table from keyspace.
void	exportSchema(String persistenceUnit, List<TableInfo> schemas)
protected boolean	initiateClient() initiate client method initiates the client.
protected void	update(List<TableInfo> tableInfos) update method update schema and table for the list of tableInfos.
protected void	validate(List<TableInfo> tableInfos) validate method validate schema and table for the list of tableInfos.
boolean	validateEntity(Class clazz) validates entity for CounterColumnType.

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraSchemaManager

public CassandraSchemaManager(String clientFactory,
                      Map<String,Object> puProperties,
                      EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata)

Instantiates a new cassandra schema manager.

Parameters:

clientFactory - the configured client clientFactory

puProperties - the pu properties

kunderaMetadata - the kundera metadata

Method Detail

exportSchema

public void exportSchema(String persistenceUnit,
                List<TableInfo> schemas)

Specified by:

exportSchema in interface SchemaManager

Overrides:

exportSchema in class AbstractSchemaManager

dropSchema

public void dropSchema()

drop schema method drop the table from keyspace.

Specified by:

dropSchema in interface SchemaManager

create_drop

protected void create_drop(List<TableInfo> tableInfos)

create_drop method creates schema and table for the list of tableInfos.

Specified by:

create_drop in class AbstractSchemaManager

Parameters:

tableInfos - list of TableInfos.

create

protected void create(List<TableInfo> tableInfos)

Creates schema and table for the list of tableInfos.

Specified by:

create in class AbstractSchemaManager

Parameters:

tableInfos - list of TableInfos.

update

protected void update(List<TableInfo> tableInfos)

update method update schema and table for the list of tableInfos.

Specified by:

update in class AbstractSchemaManager

Parameters:

tableInfos - list of TableInfos.

validate

protected void validate(List<TableInfo> tableInfos)

validate method validate schema and table for the list of tableInfos.

Specified by:

validate in class AbstractSchemaManager

Parameters:

tableInfos - list of TableInfos.

initiateClient

protected boolean initiateClient()

initiate client method initiates the client.

Specified by:

initiateClient in class AbstractSchemaManager

Returns:

boolean value ie client started or not.

validateEntity

public boolean validateEntity(Class clazz)

validates entity for CounterColumnType.

Specified by:

validateEntity in interface SchemaManager

Parameters:

clazz - the clazz

Returns:

true, if successful