Package org.jumpmind.symmetric.io.data

Class CsvData

java.lang.Object

org.jumpmind.symmetric.io.data.CsvData

Direct Known Subclasses:

Data

public class CsvData
extends Object

Holder for references to both parsed and unparsed CSV data.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ATTRIBUTE_CHANNEL_ID
static final String	ATTRIBUTE_CREATE_TIME
static final String	ATTRIBUTE_DATA_ID
static final String	ATTRIBUTE_EXTERNAL_DATA
static final String	ATTRIBUTE_NODE_LIST
static final String	ATTRIBUTE_SOURCE_NODE_ID
static final String	ATTRIBUTE_TABLE_ID
static final String	ATTRIBUTE_TABLE_NAME
static final String	ATTRIBUTE_TX_ID
protected boolean[]	changedDataIndicators
protected DataEventType	dataEventType
static final int	MAX_DATA_SIZE_TO_PRINT_TO_LOG
static final String	OLD_DATA
static final String	PK_DATA
static final String	RESOLVE_DATA
static final String	ROW_DATA

Constructor Summary

Constructors

Constructor	Description
CsvData()
CsvData(DataEventType dataEventType)
CsvData(DataEventType dataEventType, String[] rowData)
CsvData(DataEventType dataEventType, String[] pkData, String[] rowData)
CsvData(DataEventType dataEventType, String[] rowData, String[] oldData, String[] resolveData)

Method Summary

Modifier and Type	Method	Description
boolean	contains(String key)
CsvData	copyWithoutOldData()
<T> T	getAttribute(String attributeName)
Map<String,Object>	getAttributes()
boolean[]	getChangedDataIndicators()
String	getCsvData(String key)
DataEventType	getDataEventType()
String[]	getParsedData(String key)
String[]	getPkData(Table table)
long	getSizeInBytes()
boolean	isNoBinaryOldData()
void	putAttribute(String attributeName, Object attributeValue)
void	putCsvData(String key, String data)
final void	putParsedData(String key, String[] data)
void	removeAllData(String key)
void	removeCsvData(String key)
void	removeParsedData(String key)
boolean	requiresTable()
void	setAttributes(Map<String,Object> attributes)
void	setDataEventType(DataEventType dataEventType)
void	setNoBinaryOldData(boolean noBinaryOldData)
Map<String,String>	toColumnNameValuePairs(String[] keyNames, String key)
Map<String,String>	toKeyColumnValuePairs(Table table)
void	writeCsvDataDetails(StringBuilder message)

Methods inherited from class java.lang.Object

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

Field Details

MAX_DATA_SIZE_TO_PRINT_TO_LOG

public static final int MAX_DATA_SIZE_TO_PRINT_TO_LOG

See Also:

• Constant Field Values

OLD_DATA

public static final String OLD_DATA

See Also:

• Constant Field Values

ROW_DATA

public static final String ROW_DATA

See Also:

• Constant Field Values

PK_DATA

public static final String PK_DATA

See Also:

• Constant Field Values

RESOLVE_DATA

public static final String RESOLVE_DATA

See Also:

• Constant Field Values

ATTRIBUTE_TABLE_NAME

public static final String ATTRIBUTE_TABLE_NAME

See Also:

• Constant Field Values

ATTRIBUTE_CHANNEL_ID

public static final String ATTRIBUTE_CHANNEL_ID

See Also:

• Constant Field Values

ATTRIBUTE_TABLE_ID

public static final String ATTRIBUTE_TABLE_ID

See Also:

• Constant Field Values

ATTRIBUTE_TX_ID

public static final String ATTRIBUTE_TX_ID

See Also:

• Constant Field Values

ATTRIBUTE_SOURCE_NODE_ID

public static final String ATTRIBUTE_SOURCE_NODE_ID

See Also:

• Constant Field Values

ATTRIBUTE_EXTERNAL_DATA

public static final String ATTRIBUTE_EXTERNAL_DATA

See Also:

• Constant Field Values

ATTRIBUTE_NODE_LIST

public static final String ATTRIBUTE_NODE_LIST

See Also:

• Constant Field Values

ATTRIBUTE_DATA_ID

public static final String ATTRIBUTE_DATA_ID

See Also:

• Constant Field Values

ATTRIBUTE_CREATE_TIME

public static final String ATTRIBUTE_CREATE_TIME

See Also:

• Constant Field Values

dataEventType

protected DataEventType dataEventType

changedDataIndicators

protected boolean[] changedDataIndicators

Constructor Details

CsvData

public CsvData(DataEventType dataEventType)

CsvData

public CsvData(DataEventType dataEventType,
 String[] pkData,
 String[] rowData)

CsvData

public CsvData(DataEventType dataEventType,
 String[] rowData)

CsvData

public CsvData(DataEventType dataEventType,
 String[] rowData,
 String[] oldData,
 String[] resolveData)

CsvData

public CsvData()

Method Details

contains

public boolean contains(String key)

setDataEventType

public void setDataEventType(DataEventType dataEventType)

getDataEventType

public DataEventType getDataEventType()

putAttribute

public void putAttribute(String attributeName,
 Object attributeValue)

getAttribute

public <T> T getAttribute(String attributeName)

removeCsvData

public void removeCsvData(String key)

removeParsedData

public void removeParsedData(String key)

removeAllData

public void removeAllData(String key)

putCsvData

public void putCsvData(String key,
 String data)

getCsvData

public String getCsvData(String key)

getChangedDataIndicators

public boolean[] getChangedDataIndicators()

putParsedData

public final void putParsedData(String key,
 String[] data)

getParsedData

public String[] getParsedData(String key)

toKeyColumnValuePairs

public Map<String,String> toKeyColumnValuePairs(Table table)

getPkData

public String[] getPkData(Table table)

toColumnNameValuePairs

public Map<String,String> toColumnNameValuePairs(String[] keyNames,
 String key)

requiresTable

public boolean requiresTable()

isNoBinaryOldData

public boolean isNoBinaryOldData()

setNoBinaryOldData

public void setNoBinaryOldData(boolean noBinaryOldData)

copyWithoutOldData

public CsvData copyWithoutOldData()

writeCsvDataDetails

public void writeCsvDataDetails(StringBuilder message)

getSizeInBytes

public long getSizeInBytes()

getAttributes

public Map<String,Object> getAttributes()

setAttributes

public void setAttributes(Map<String,Object> attributes)