Package org.jumpmind.symmetric.io.data.writer

Class CassandraDatabaseWriter

java.lang.Object

org.jumpmind.symmetric.io.data.writer.AbstractDatabaseWriter

org.jumpmind.symmetric.io.data.writer.DefaultDatabaseWriter

org.jumpmind.symmetric.io.data.writer.DynamicDefaultDatabaseWriter

org.jumpmind.symmetric.io.data.writer.CassandraDatabaseWriter

All Implemented Interfaces:

IDataResource, IDataWriter

public class CassandraDatabaseWriter
extends DynamicDefaultDatabaseWriter

Nested Class Summary

Nested classes/interfaces inherited from class org.jumpmind.symmetric.io.data.writer.AbstractDatabaseWriter

AbstractDatabaseWriter.LoadStatus

Field Summary

Fields

Modifier and Type	Field	Description
protected com.google.gson.Gson	gson
protected Map<String,Map<String,Table>>	metaData
protected com.datastax.driver.core.PreparedStatement	pstmt
protected com.datastax.driver.core.Session	session

Fields inherited from class org.jumpmind.symmetric.io.data.writer.DynamicDefaultDatabaseWriter

tablePrefix, targetPlatform, targetTransaction

Fields inherited from class org.jumpmind.symmetric.io.data.writer.DefaultDatabaseWriter

CUR_DATA, currentDmlStatement, currentDmlValues, hasUncommittedDdl, isCteExpression, logSqlBuilder, platform, transaction

Fields inherited from class org.jumpmind.symmetric.io.data.writer.AbstractDatabaseWriter

batch, CONFLICT_ERROR, CONFLICT_IGNORE, conflictResolver, context, isRequiresSavePointsInTransaction, lastApplyChangesOnly, lastData, lastUseConflictDetection, missingTables, sourceTable, statistics, targetTable, targetTables, TRANSACTION_ABORTED, uncommittedCount, writerSettings

Constructor Summary

Constructors

Constructor	Description
CassandraDatabaseWriter(IDatabasePlatform symmetricPlatform, IDatabasePlatform targetPlatform, String prefix, IDatabaseWriterConflictResolver conflictResolver, DatabaseWriterSettings settings)

Method Summary

Modifier and Type	Method	Description
protected void	allowInsertIntoAutoIncrementColumns(boolean value, Table table)
protected void	bindVariables(com.datastax.driver.core.BoundStatement bstmt, Column[] columns, int[] types, String[] values)
protected boolean	create(CsvData data)
protected int	execute(CsvData data, String[] values)
protected boolean	isUserSendSql(String sql, CsvData data)
protected void	logFailureDetails(Throwable e, CsvData data, boolean logLastDmlDetails)
protected Table	lookupTableAtTarget(Table sourceTable)
protected List	parseList(Column c, String val)
protected Map	parseMap(Column c, String val)
protected Set	parseSet(Column c, String val)
protected void	prepare()
protected void	prepare(String sql, CsvData data)
int	prepareAndExecute(String sql, CsvData data)

Methods inherited from class org.jumpmind.symmetric.io.data.writer.DynamicDefaultDatabaseWriter

close, commit, getPlatform, getPlatform, getPlatform, getTablePrefix, getTargetPlatform, getTargetTransaction, getTransaction, getTransaction, getTransaction, isLoadOnly, isSymmetricTable, isSymmetricTable, open, rollback

Methods inherited from class org.jumpmind.symmetric.io.data.writer.DefaultDatabaseWriter

bindVariables, commit, containsNullLookupKeyDataSinceLastStatement, create, delete, dmlValuesToString, doesColumnNeedUpdated, end, end, getCurData, getCurrentDmlStatement, getSqlStatements, getTableKey, getWriterSettings, insert, isCteExpression, logDataTruncation, lookupTableFromCache, preprocessSqlStatement, putTableInCache, quoteString, replaceCteExpression, requireNewStatement, sql, start, targetTableWasChangedByFilter, update, updateChangedDataIndicator

Methods inherited from class org.jumpmind.symmetric.io.data.writer.AbstractDatabaseWriter

checkForEarlyCommit, filterAfter, filterBefore, filterError, getBatch, getConflictResolver, getContext, getLookupDataMap, getPkDataFor, getRowData, getSourceTable, getStatistics, getTargetTable, hasFilterThatHandlesMissingTable, notifyFiltersBatchCommitted, notifyFiltersBatchComplete, notifyFiltersBatchRolledback, notifyFiltersEarlyCommit, script, setConflictResolver, start, write

Methods inherited from class java.lang.Object

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

Field Details

gson

protected com.google.gson.Gson gson

session

protected com.datastax.driver.core.Session session

metaData

protected Map<String,Map<String,Table>> metaData

pstmt

protected com.datastax.driver.core.PreparedStatement pstmt

Constructor Details

CassandraDatabaseWriter

public CassandraDatabaseWriter(IDatabasePlatform symmetricPlatform,
 IDatabasePlatform targetPlatform,
 String prefix,
 IDatabaseWriterConflictResolver conflictResolver,
 DatabaseWriterSettings settings)

Method Details

prepare

protected void prepare()

Overrides:

prepare in class DefaultDatabaseWriter

prepare

protected void prepare(String sql,
 CsvData data)

Overrides:

prepare in class DefaultDatabaseWriter

isUserSendSql

protected boolean isUserSendSql(String sql,
 CsvData data)

prepareAndExecute

public int prepareAndExecute(String sql,
 CsvData data)

Overrides:

prepareAndExecute in class DefaultDatabaseWriter

execute

protected int execute(CsvData data,
 String[] values)

Overrides:

execute in class DefaultDatabaseWriter

lookupTableAtTarget

protected Table lookupTableAtTarget(Table sourceTable)

Overrides:

lookupTableAtTarget in class DefaultDatabaseWriter

create

protected boolean create(CsvData data)

Overrides:

create in class DefaultDatabaseWriter

logFailureDetails

protected void logFailureDetails(Throwable e,
 CsvData data,
 boolean logLastDmlDetails)

Overrides:

logFailureDetails in class DefaultDatabaseWriter

allowInsertIntoAutoIncrementColumns

protected void allowInsertIntoAutoIncrementColumns(boolean value,
 Table table)

Overrides:

allowInsertIntoAutoIncrementColumns in class DefaultDatabaseWriter

bindVariables

protected void bindVariables(com.datastax.driver.core.BoundStatement bstmt,
 Column[] columns,
 int[] types,
 String[] values)

parseList

protected List parseList(Column c,
 String val)

parseSet

protected Set parseSet(Column c,
 String val)

parseMap

protected Map parseMap(Column c,
 String val)