Package org.jumpmind.db.platform.cassandra

Class CassandraPlatform

java.lang.Object

org.jumpmind.db.platform.AbstractDatabasePlatform

org.jumpmind.db.platform.cassandra.CassandraPlatform

All Implemented Interfaces:

IDatabasePlatform

public class CassandraPlatform
extends AbstractDatabasePlatform

Field Summary

Fields

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

Fields inherited from class org.jumpmind.db.platform.AbstractDatabasePlatform

clearCacheModelTimeoutInMs, ddlBuilder, ddlReader, defaultCatalog, defaultSchema, log, metadataIgnoreCase, MODEL_DEFAULT_NAME, PERMISSION_TEST_TABLE_NAME, REQUIRED_FIELD_NULL_SUBSTITUTE, settings, sourceNodeId, storesLowerCaseIdentifiers, storesMixedCaseIdentifiers, storesUpperCaseIdentifiers, supportsMultiThreadedTransactions, supportsTransactions, supportsTruncate, tableCache, useMultiThreadSyncTriggers, ZERO_DATE_STRING

Constructor Summary

Constructors

Constructor	Description
CassandraPlatform(SqlTemplateSettings settings, String contactPoint)

Method Summary

Modifier and Type	Method	Description
protected final void	buildMetaData()
DmlStatement	createDmlStatement(DmlStatementOptions options)
<T> T	getDataSource()
IDdlBuilder	getDdlBuilder()	Returns a new ddl builder for the this platform.
IDdlReader	getDdlReader()	Returns the ddl reader (which reads a database model from a live database) for this platform.
String	getDefaultCatalog()
String	getDefaultSchema()
protected int	getMappedTypeCode(String dataType)
Map<String,Map<String,Table>>	getMetaData()
String	getName()
com.datastax.driver.core.Session	getSession()
ISqlTemplate	getSqlTemplate()
ISqlTemplate	getSqlTemplateDirty()
boolean	isLob(int type)
void	setMetaData(Map<String,Map<String,Table>> metaData)
void	setSession(com.datastax.driver.core.Session session)

Methods inherited from class org.jumpmind.db.platform.AbstractDatabasePlatform

allowsUniqueIndexDuplicatesWithNulls, alterCaseToMatchDatabaseDefaultCase, alterCaseToMatchDatabaseDefaultCase, alterCaseToMatchDatabaseDefaultCase, alterCaseToMatchDatabaseDefaultCase, alterCaseToMatchDatabaseDefaultCase, alterDatabase, alterDatabase, alterTables, alterTables, appendString, canColumnBeUsedInWhereClause, checkSymTablePermissions, cleanNumber, cleanTextForTextBasedColumns, createArray, createDatabase, createDmlStatement, createDmlStatement, createDmlStatement, createTables, dropDatabase, dropTables, getAlterSymTablePermission, getCharSetName, getClearCacheModelTimeoutInMs, getCreateSymFunctionPermission, getCreateSymRoutinePermission, getCreateSymTablePermission, getCreateSymTriggerPermission, getCsvStringValue, getDatabaseInfo, getDateTimeStringValue, getDeleteSql, getDropSymTablePermission, getDropSymTriggerPermission, getEstimatedRowCount, getExecuteSymPermission, getLobColumns, getLogMinePermission, getObjectValue, getObjectValues, getObjectValues, getObjectValues, getObjectValues, getPermissionTableDefinition, getSliceTableSql, getSqlScriptReplacementTokens, getStringValues, getTableFromCache, getTableFromCache, getTimestampStringValue, getTimestampTzStringValue, getTimeZone, getTransactions, getTruncateSql, hasMatchingPlatform, isBlob, isClob, isMetadataIgnoreCase, isStoresLowerCaseIdentifiers, isStoresMixedCaseQuotedIdentifiers, isStoresUpperCaseIdentifiers, isUseMultiThreadSyncTriggers, logFailedResults, makeAllColumnsPrimaryKeys, makePlatformSpecific, massageForLimitOffset, massageForObjectAlreadyExists, massageForObjectDoesNotExist, parseBigDecimal, parseBigInteger, parseDate, parseFloat, parseInteger, parseQualifiedTableName, parseTimestamp, prefixColumnNames, prefixDatabase, prefixForeignKeys, prefixIndexes, readDatabase, readDatabaseFromXml, readDatabaseFromXml, readFromDatabase, readTableFromDatabase, readTableFromDatabase, readTableFromDatabaseAllowException, resetCachedTableModel, scrubSql, setClearCacheModelTimeoutInMs, setMetadataIgnoreCase, supportsLimitOffset, supportsMultiThreadedTransactions, supportsParametersInSelect, supportsSliceTables, supportsTransactions

Methods inherited from class java.lang.Object

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

Field Details

session

protected com.datastax.driver.core.Session session

cluster

protected com.datastax.driver.core.Cluster cluster

Constructor Details

CassandraPlatform

public CassandraPlatform(SqlTemplateSettings settings,
 String contactPoint)

Method Details

getName

public String getName()

Returns:

a constant that represents this database type from DatabaseNamesConstants

See Also:

• DatabaseNamesConstants

getDefaultSchema

public String getDefaultSchema()

getDefaultCatalog

public String getDefaultCatalog()

getDataSource

public <T> T getDataSource()

isLob

public boolean isLob(int type)

Specified by:

isLob in interface IDatabasePlatform

Overrides:

isLob in class AbstractDatabasePlatform

getDdlBuilder

public IDdlBuilder getDdlBuilder()

Description copied from interface: IDatabasePlatform

Returns a new ddl builder for the this platform.

Specified by:

getDdlBuilder in interface IDatabasePlatform

Overrides:

getDdlBuilder in class AbstractDatabasePlatform

getDdlReader

public IDdlReader getDdlReader()

Description copied from interface: IDatabasePlatform

Returns the ddl reader (which reads a database model from a live database) for this platform.

Specified by:

getDdlReader in interface IDatabasePlatform

Overrides:

getDdlReader in class AbstractDatabasePlatform

Returns:

The model reader

getSqlTemplate

public ISqlTemplate getSqlTemplate()

Specified by:

getSqlTemplate in interface IDatabasePlatform

Specified by:

getSqlTemplate in class AbstractDatabasePlatform

getSqlTemplateDirty

public ISqlTemplate getSqlTemplateDirty()

Specified by:

getSqlTemplateDirty in interface IDatabasePlatform

Specified by:

getSqlTemplateDirty in class AbstractDatabasePlatform

createDmlStatement

public DmlStatement createDmlStatement(DmlStatementOptions options)

Specified by:

createDmlStatement in interface IDatabasePlatform

Overrides:

createDmlStatement in class AbstractDatabasePlatform

getSession

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

setSession

public void setSession(com.datastax.driver.core.Session session)

getMetaData

public Map<String,Map<String,Table>> getMetaData()

setMetaData

public void setMetaData(Map<String,Map<String,Table>> metaData)

buildMetaData

protected final void buildMetaData()

getMappedTypeCode

protected int getMappedTypeCode(String dataType)