Package org.jumpmind.symmetric.io

Class AbstractWriterTest

java.lang.Object

org.jumpmind.symmetric.io.AbstractWriterTest

Direct Known Subclasses:

AbstractBulkDatabaseWriterTest, DatabaseWriterConflictTest, DatabaseWriterTest, TransformWriterTest

public abstract class AbstractWriterTest
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	AbstractWriterTest.TableCsvData

Field Summary

Fields

Modifier and Type	Field	Description
protected static long	batchId
protected boolean	errorExpected
protected IDataWriter	lastDataWriterUsed
protected static IDatabasePlatform	platform
protected static long	sequenceId
protected static final String[]	TEST_COLUMNS
protected static final String[]	TEST_KEYS
protected static final String	TEST_TABLE
protected DatabaseWriterSettings	writerSettings

Constructor Summary

Constructors

Constructor	Description
AbstractWriterTest()

Method Summary

Modifier and Type	Method	Description
protected void	assertEquals(String[] name, String[] expected, Map<String,Object> results)
protected void	assertTestTableEquals(String testTableId, String[] expectedValues)
protected Table	buildSourceTable(String tableName, String[] keyNames, String[] columnNames)
protected long	countRows(String tableName)
protected long	getBatchId()
protected String	getId()
protected long	getNextBatchId()
protected String	getNextId()
protected String	getSelect(String[] columns)
protected String[]	getTestColumns()
protected String[]	getTestKeys()
protected String	getTestTable()
protected String	getWhere(String[] columns)
boolean	isErrorExpected()
protected boolean	isOracle()
protected String	printDatabase()
Map<String,Object>	queryForRow(String id)
void	setErrorExpected(boolean errorExpected)
protected String	translateExpectedCharString(String value, int size, boolean isRequired)
protected String	translateExpectedString(String value, boolean isRequired)
protected long	writeData(BinaryEncoding encoding, AbstractWriterTest.TableCsvData... datas)
protected long	writeData(AbstractWriterTest.TableCsvData... datas)
protected void	writeData(CsvData... data)
protected void	writeData(CsvData data, String[] expectedValues)
protected void	writeData(CsvData data, String[] expectedValues, String[] columnNames)
protected void	writeData(CsvData data, String[] expectedValues, String tableName, String[] keyNames, String[] columnNames)
protected long	writeData(IDataWriter writer, BinaryEncoding encoding, AbstractWriterTest.TableCsvData... datas)
protected long	writeData(IDataWriter writer, AbstractWriterTest.TableCsvData... datas)
protected long	writeData(IDataWriter writer, DataContext context, BinaryEncoding encoding, AbstractWriterTest.TableCsvData... datas)
protected long	writeData(IDataWriter writer, DataContext context, AbstractWriterTest.TableCsvData... datas)

Methods inherited from class java.lang.Object

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

Field Details

platform

protected static IDatabasePlatform platform

errorExpected

protected boolean errorExpected

TEST_TABLE

protected static final String TEST_TABLE

See Also:

• Constant Field Values

TEST_KEYS

protected static final String[] TEST_KEYS

TEST_COLUMNS

protected static final String[] TEST_COLUMNS

batchId

protected static long batchId

sequenceId

protected static long sequenceId

writerSettings

protected DatabaseWriterSettings writerSettings

lastDataWriterUsed

protected IDataWriter lastDataWriterUsed

Constructor Details

AbstractWriterTest

public AbstractWriterTest()

Method Details

getNextBatchId

protected long getNextBatchId()

getBatchId

protected long getBatchId()

getNextId

protected String getNextId()

getId

protected String getId()

buildSourceTable

protected Table buildSourceTable(String tableName,
 String[] keyNames,
 String[] columnNames)

writeData

protected void writeData(CsvData data,
 String[] expectedValues)

getTestTable

protected String getTestTable()

getTestKeys

protected String[] getTestKeys()

getTestColumns

protected String[] getTestColumns()

writeData

protected void writeData(CsvData... data)

writeData

protected void writeData(CsvData data,
 String[] expectedValues,
 String[] columnNames)

writeData

protected void writeData(CsvData data,
 String[] expectedValues,
 String tableName,
 String[] keyNames,
 String[] columnNames)

writeData

protected long writeData(AbstractWriterTest.TableCsvData... datas)

writeData

protected long writeData(BinaryEncoding encoding,
 AbstractWriterTest.TableCsvData... datas)

writeData

protected long writeData(IDataWriter writer,
 AbstractWriterTest.TableCsvData... datas)

writeData

protected long writeData(IDataWriter writer,
 BinaryEncoding encoding,
 AbstractWriterTest.TableCsvData... datas)

writeData

protected long writeData(IDataWriter writer,
 DataContext context,
 AbstractWriterTest.TableCsvData... datas)

writeData

protected long writeData(IDataWriter writer,
 DataContext context,
 BinaryEncoding encoding,
 AbstractWriterTest.TableCsvData... datas)

assertTestTableEquals

protected void assertTestTableEquals(String testTableId,
 String[] expectedValues)

getSelect

protected String getSelect(String[] columns)

getWhere

protected String getWhere(String[] columns)

translateExpectedString

protected String translateExpectedString(String value,
 boolean isRequired)

translateExpectedCharString

protected String translateExpectedCharString(String value,
 int size,
 boolean isRequired)

assertEquals

protected void assertEquals(String[] name,
 String[] expected,
 Map<String,Object> results)

printDatabase

protected String printDatabase()

isOracle

protected boolean isOracle()

setErrorExpected

public void setErrorExpected(boolean errorExpected)

isErrorExpected

public boolean isErrorExpected()

queryForRow

public Map<String,Object> queryForRow(String id)

countRows

protected long countRows(String tableName)