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

Class AbstractBulkDatabaseWriterTest

java.lang.Object

org.jumpmind.symmetric.io.AbstractWriterTest

org.jumpmind.symmetric.io.data.writer.AbstractBulkDatabaseWriterTest

@Tag("integration")
public abstract class AbstractBulkDatabaseWriterTest
extends AbstractWriterTest

Nested Class Summary

Nested classes/interfaces inherited from class org.jumpmind.symmetric.io.AbstractWriterTest

AbstractWriterTest.TableCsvData

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String[]	TEST_COLUMNS

Fields inherited from class org.jumpmind.symmetric.io.AbstractWriterTest

batchId, errorExpected, lastDataWriterUsed, platform, sequenceId, TEST_KEYS, TEST_TABLE, writerSettings

Constructor Summary

Constructors

Constructor	Description
AbstractBulkDatabaseWriterTest()

Method Summary

Modifier and Type	Method	Description
protected void	assertTestTableEquals(String testTableId, String[] expectedValues)
protected void	assertTestTableEquals(String testTableId, BinaryEncoding encoding, String[] expectedValues)
protected abstract AbstractDatabaseWriter	create()
protected String	encodeBase64(int[] bytes)
protected String	encodeBase64(String str)
protected String	encodeHex(int[] bytes)
protected String	getTestTable()
protected void	insertAndVerify(String[] values, BinaryEncoding encoding)
protected void	insertEncodeAndVerify(String[] values, int elementToEncode)
protected void	insertEncodeAndVerify(String[] values, int elementToEncode, int[] bytes)
protected String[]	massageExpectectedResultsForDialect(String[] values)
protected abstract boolean	shouldTestRun(IDatabasePlatform platform)
void	testDuplicateRow()
void	testInsert()
void	testInsertAcrossMaxFlush()
void	testInsertBlobInvalidUnicode()
void	testInsertBlobRandom()
void	testInsertBlobRange()
void	testInsertWithBackslash()
void	testInsertWithCommas()
void	testInsertWithNonEscaped()
void	testInsertWithNull()
void	testInsertWithQuotes()
void	testInsertWithSpecialEscape()
void	testInsertWithUnicode()
protected abstract long	writeData(List<CsvData> data)
protected abstract long	writeData(BinaryEncoding encoding, List<CsvData> data)

Methods inherited from class org.jumpmind.symmetric.io.AbstractWriterTest

assertEquals, buildSourceTable, countRows, getBatchId, getId, getNextBatchId, getNextId, getSelect, getTestColumns, getTestKeys, getWhere, isErrorExpected, isOracle, printDatabase, queryForRow, setErrorExpected, translateExpectedCharString, translateExpectedString, writeData, writeData, writeData, writeData, writeData, writeData, writeData, writeData, writeData, writeData

Methods inherited from class java.lang.Object

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

Field Details

TEST_COLUMNS

protected static final String[] TEST_COLUMNS

Constructor Details

AbstractBulkDatabaseWriterTest

public AbstractBulkDatabaseWriterTest()

Method Details

getTestTable

protected String getTestTable()

Overrides:

getTestTable in class AbstractWriterTest

shouldTestRun

protected abstract boolean shouldTestRun(IDatabasePlatform platform)

encodeBase64

protected String encodeBase64(String str)

encodeBase64

protected String encodeBase64(int[] bytes)

encodeHex

protected String encodeHex(int[] bytes)

insertAndVerify

protected void insertAndVerify(String[] values,
 BinaryEncoding encoding)

insertEncodeAndVerify

protected void insertEncodeAndVerify(String[] values,
 int elementToEncode,
 int[] bytes)

insertEncodeAndVerify

protected void insertEncodeAndVerify(String[] values,
 int elementToEncode)

writeData

protected abstract long writeData(List<CsvData> data)

writeData

protected abstract long writeData(BinaryEncoding encoding,
 List<CsvData> data)

testInsert

@Test
public void testInsert()

testInsertAcrossMaxFlush

@Test
public void testInsertAcrossMaxFlush()

testInsertWithNull

@Test
public void testInsertWithNull()

testInsertWithBackslash

@Test
public void testInsertWithBackslash()

testInsertWithQuotes

@Test
public void testInsertWithQuotes()

testInsertWithCommas

@Test
public void testInsertWithCommas()

testInsertWithNonEscaped

@Test
public void testInsertWithNonEscaped()

testInsertWithSpecialEscape

@Test
public void testInsertWithSpecialEscape()

testInsertWithUnicode

@Test
public void testInsertWithUnicode()

testInsertBlobInvalidUnicode

@Test
public void testInsertBlobInvalidUnicode()

testInsertBlobRange

@Test
public void testInsertBlobRange()

testInsertBlobRandom

@Test
public void testInsertBlobRandom()

testDuplicateRow

@Test
public void testDuplicateRow()

create

protected abstract AbstractDatabaseWriter create()

assertTestTableEquals

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

Overrides:

assertTestTableEquals in class AbstractWriterTest

assertTestTableEquals

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

massageExpectectedResultsForDialect

protected String[] massageExpectectedResultsForDialect(String[] values)