Uses of Class
com.continuent.tungsten.replicator.dbms.OneRowChange.ColumnSpec

Packages that use OneRowChange.ColumnSpec

com.continuent.tungsten.replicator.applier
com.continuent.tungsten.replicator.applier.batch
com.continuent.tungsten.replicator.database
com.continuent.tungsten.replicator.dbms
com.continuent.tungsten.replicator.extractor.mysql
com.continuent.tungsten.replicator.filter
com.continuent.tungsten.replicator.loader
com.continuent.tungsten.replicator.prefetch
com.continuent.tungsten.replicator.thl

Uses of OneRowChange.ColumnSpec in com.continuent.tungsten.replicator.applier

Methods in com.continuent.tungsten.replicator.applier with parameters of type OneRowChange.ColumnSpec

protected void	MySQLDrizzleApplier.setObject(java.sql.PreparedStatement prepStatement, int bindLoc, OneRowChange.ColumnVal value, OneRowChange.ColumnSpec columnSpec)
protected void	MySQLApplier.setObject(java.sql.PreparedStatement prepStatement, int bindLoc, OneRowChange.ColumnVal value, OneRowChange.ColumnSpec columnSpec)
protected void	OracleApplier.setObject(java.sql.PreparedStatement prepStatement, int bindLoc, OneRowChange.ColumnVal value, OneRowChange.ColumnSpec columnSpec)
protected void	PostgreSQLApplier.setObject(java.sql.PreparedStatement prepStatement, int bindLoc, OneRowChange.ColumnVal value, OneRowChange.ColumnSpec columnSpec)
protected void	JdbcApplier.setObject(java.sql.PreparedStatement prepStatement, int bindLoc, OneRowChange.ColumnVal value, OneRowChange.ColumnSpec columnSpec)
protected void	JdbcPrefetcher.setObject(java.sql.PreparedStatement prepStatement, int bindLoc, OneRowChange.ColumnVal value, OneRowChange.ColumnSpec columnSpec)

Method parameters in com.continuent.tungsten.replicator.applier with type arguments of type OneRowChange.ColumnSpec

protected int	JdbcApplier.bindColumnValues(java.sql.PreparedStatement prepStatement, java.util.ArrayList<OneRowChange.ColumnVal> values, int startBindLoc, java.util.ArrayList<OneRowChange.ColumnSpec> specs, boolean skipNulls)
protected int	JdbcPrefetcher.bindValues(java.sql.PreparedStatement prepStatement, java.util.ArrayList<OneRowChange.ColumnVal> values, int startBindLoc, java.util.ArrayList<OneRowChange.ColumnSpec> specs, boolean skipNulls)
protected boolean	JdbcApplier.needNewSQLStatement(int row, java.util.ArrayList<java.util.ArrayList<OneRowChange.ColumnVal>> keyValues, java.util.ArrayList<OneRowChange.ColumnSpec> keySpecs, java.util.ArrayList<java.util.ArrayList<OneRowChange.ColumnVal>> colValues, java.util.ArrayList<OneRowChange.ColumnSpec> colSpecs)
protected boolean	JdbcApplier.needNewSQLStatement(int row, java.util.ArrayList<java.util.ArrayList<OneRowChange.ColumnVal>> keyValues, java.util.ArrayList<OneRowChange.ColumnSpec> keySpecs, java.util.ArrayList<java.util.ArrayList<OneRowChange.ColumnVal>> colValues, java.util.ArrayList<OneRowChange.ColumnSpec> colSpecs)
protected void	JdbcApplier.printColumnSpec(java.lang.StringBuffer stmt, java.util.ArrayList<OneRowChange.ColumnSpec> cols, java.util.ArrayList<OneRowChange.ColumnVal> keyValues, java.util.ArrayList<OneRowChange.ColumnVal> colValues, com.continuent.tungsten.replicator.applier.JdbcApplier.PrintMode mode, java.lang.String separator)
protected void	JdbcPrefetcher.printColumnSpec(java.lang.StringBuffer stmt, java.util.ArrayList<OneRowChange.ColumnSpec> cols, java.util.ArrayList<OneRowChange.ColumnVal> keyValues, com.continuent.tungsten.replicator.applier.JdbcPrefetcher.PrintMode mode, java.lang.String separator)

Uses of OneRowChange.ColumnSpec in com.continuent.tungsten.replicator.applier.batch

Methods in com.continuent.tungsten.replicator.applier.batch with parameters of type OneRowChange.ColumnSpec

protected java.lang.String

SimpleBatchApplier.getCsvString(OneRowChange.ColumnVal columnVal, OneRowChange.ColumnSpec columnSpec) Converts a column value to a suitable String for CSV loading.

Uses of OneRowChange.ColumnSpec in com.continuent.tungsten.replicator.database

Methods in com.continuent.tungsten.replicator.database with parameters of type OneRowChange.ColumnSpec

java.lang.String	GreenplumDatabase.getPlaceHolder(OneRowChange.ColumnSpec col, java.lang.Object colValue)
java.lang.String	MySQLDrizzleDatabase.getPlaceHolder(OneRowChange.ColumnSpec col, java.lang.Object colValue, java.lang.String typeDesc)
java.lang.String	OracleDatabase.getPlaceHolder(OneRowChange.ColumnSpec col, java.lang.Object colValue, java.lang.String typeDesc)
java.lang.String	PostgreSQLDatabase.getPlaceHolder(OneRowChange.ColumnSpec col, java.lang.Object colValue, java.lang.String typeDesc)
java.lang.String	AbstractDatabase.getPlaceHolder(OneRowChange.ColumnSpec col, java.lang.Object colValue, java.lang.String typeDesc)
java.lang.String	Database.getPlaceHolder(OneRowChange.ColumnSpec col, java.lang.Object colValue, java.lang.String typeDesc) Return a place holder in a prepared statement for a column of type ColumnSpec.
java.lang.String	MySQLDatabase.getPlaceHolder(OneRowChange.ColumnSpec col, java.lang.Object colValue, java.lang.String typeDesc)
boolean	MySQLDrizzleDatabase.nullsBoundDifferently(OneRowChange.ColumnSpec col)
boolean	OracleDatabase.nullsBoundDifferently(OneRowChange.ColumnSpec col) Return TRUE IFF NULL values are bound differently in SQL statement from non null values for the given column type.
boolean	PostgreSQLDatabase.nullsBoundDifferently(OneRowChange.ColumnSpec col)
boolean	AbstractDatabase.nullsBoundDifferently(OneRowChange.ColumnSpec col)
boolean	GreenplumDatabase.nullsBoundDifferently(OneRowChange.ColumnSpec col)
boolean	Database.nullsBoundDifferently(OneRowChange.ColumnSpec col) Return TRUE IFF NULL values are bound differently in SQL statement from non null values for the given column type.
boolean	MySQLDatabase.nullsBoundDifferently(OneRowChange.ColumnSpec col)

Uses of OneRowChange.ColumnSpec in com.continuent.tungsten.replicator.dbms

Methods in com.continuent.tungsten.replicator.dbms that return types with arguments of type OneRowChange.ColumnSpec

java.util.ArrayList<OneRowChange.ColumnSpec>	OneRowChange.getColumnSpec()
java.util.ArrayList<OneRowChange.ColumnSpec>	OneRowChange.getKeySpec()

Method parameters in com.continuent.tungsten.replicator.dbms with type arguments of type OneRowChange.ColumnSpec

void	OneRowChange.setColumnSpec(java.util.ArrayList<OneRowChange.ColumnSpec> columnSpec)
void	OneRowChange.setKeySpec(java.util.ArrayList<OneRowChange.ColumnSpec> keySpec)

Constructors in com.continuent.tungsten.replicator.dbms with parameters of type OneRowChange.ColumnSpec

OneRowChange.ColumnSpec(OneRowChange.ColumnSpec spec)

Constructor parameters in com.continuent.tungsten.replicator.dbms with type arguments of type OneRowChange.ColumnSpec

OneRowChange(java.lang.String schemaName, java.lang.String tableName, RowChangeData.ActionType action, java.util.ArrayList<OneRowChange.ColumnSpec> keySpec, java.util.ArrayList<java.util.ArrayList<OneRowChange.ColumnVal>> keyValues, java.util.ArrayList<OneRowChange.ColumnSpec> columnSpec, java.util.ArrayList<java.util.ArrayList<OneRowChange.ColumnVal>> columnValues)

OneRowChange(java.lang.String schemaName, java.lang.String tableName, RowChangeData.ActionType action, java.util.ArrayList<OneRowChange.ColumnSpec> keySpec, java.util.ArrayList<java.util.ArrayList<OneRowChange.ColumnVal>> keyValues, java.util.ArrayList<OneRowChange.ColumnSpec> columnSpec, java.util.ArrayList<java.util.ArrayList<OneRowChange.ColumnVal>> columnValues)

Uses of OneRowChange.ColumnSpec in com.continuent.tungsten.replicator.extractor.mysql

Methods in com.continuent.tungsten.replicator.extractor.mysql with parameters of type OneRowChange.ColumnSpec

protected int

RowsLogEvent.extractValue(OneRowChange.ColumnSpec spec, OneRowChange.ColumnVal value, byte[] row, int rowPos, int type, int meta)

Uses of OneRowChange.ColumnSpec in com.continuent.tungsten.replicator.filter

Method parameters in com.continuent.tungsten.replicator.filter with type arguments of type OneRowChange.ColumnSpec

protected void	SetToStringFilter.transformColumns(java.util.ArrayList<OneRowChange.ColumnSpec> columns, java.util.ArrayList<java.util.ArrayList<OneRowChange.ColumnVal>> columnValues, java.util.HashMap<java.lang.Integer,java.lang.String[]> setDefinitions, java.lang.String typeCaption) Overriding EnumToStringFilter core to transform SET column values to comma separated string representation.
protected void	EnumToStringFilter.transformColumns(java.util.ArrayList<OneRowChange.ColumnSpec> columns, java.util.ArrayList<java.util.ArrayList<OneRowChange.ColumnVal>> columnValues, java.util.HashMap<java.lang.Integer,java.lang.String[]> enumDefinitions, java.lang.String typeCaption)

Uses of OneRowChange.ColumnSpec in com.continuent.tungsten.replicator.loader

Fields in com.continuent.tungsten.replicator.loader with type parameters of type OneRowChange.ColumnSpec

protected java.util.ArrayList<OneRowChange.ColumnSpec>

JdbcLoader.columnDefinitions

Uses of OneRowChange.ColumnSpec in com.continuent.tungsten.replicator.prefetch

Constructor parameters in com.continuent.tungsten.replicator.prefetch with type arguments of type OneRowChange.ColumnSpec

RbrRowImage(RbrRowImage.ImageType type, RbrTableChangeSet changeSet, java.util.List<OneRowChange.ColumnSpec> specs, java.util.List<OneRowChange.ColumnVal> values)
Creates a row image with the minimum effort required.

Uses of OneRowChange.ColumnSpec in com.continuent.tungsten.replicator.thl

Methods in com.continuent.tungsten.replicator.thl with parameters of type OneRowChange.ColumnSpec

static java.lang.String

THLManagerCtrl.formatColumn(OneRowChange.ColumnSpec colSpec, OneRowChange.ColumnVal value, java.lang.String prefix, java.lang.String charset, boolean hex) Formats column and column value for printing.