Package org.jumpmind.symmetric.service.impl

Class AbstractDataLoaderServiceTest

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractServiceTest

org.jumpmind.symmetric.service.impl.AbstractDataLoaderServiceTest

Direct Known Subclasses:

JdbcDataLoaderServiceTest

@TestMethodOrder(org.junit.jupiter.api.MethodOrderer.MethodName.class)
public abstract class AbstractDataLoaderServiceTest
extends AbstractServiceTest

Field Summary

Fields

Modifier and Type	Field	Description
protected static int	batchId
protected Node	client
protected Node	root
protected static int	sequenceId
protected static final String[]	TEST_COLUMNS
protected static final String[]	TEST_KEYS
protected static final String	TEST_TABLE

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractServiceTest

engine

Constructor Summary

Constructors

Constructor	Description
AbstractDataLoaderServiceTest()

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)
void	cleanup()
protected AbstractBatch.Status	findIncomingBatchStatus(int batchId, String nodeId)
protected String	getBatchId()
protected IDataLoaderService	getDataLoaderService()
protected String	getId()
protected String	getNextBatchId()
protected String	getNextId()
protected String	getSelect(String[] columns)
protected MockTransportManager	getTransportManager()
protected String	getWhere(String[] columns)
protected CsvWriter	getWriter(OutputStream out)
protected void	load(ByteArrayOutputStream out)
void	test01IncomingBatch()
void	test02Statistics()
void	test03UpdateCollision()
void	test04SqlStatistics()
void	test05SkippingResentBatch()
void	test06ErrorWhileSkip()
void	test07DataIntregrityError()
void	test08ErrorWhileParsing()
void	test09ErrorThenSuccessBatch()
void	test10MultipleBatch()
void	test12RegisteredDataWriterFilter()
void	test13NanValue()
protected void	testSimple(String dmlType, String[] values, String[] expectedValues)
protected String	translateExpectedCharString(String value, int size, boolean isRequired)
protected String	translateExpectedDate(String value)
protected String	translateExpectedString(String value, boolean isRequired)
protected String	translateExpectedTimestamp(String value)
protected void	writeTable(CsvWriter writer, String tableName, String[] keys, String[] columns)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractServiceTest

assertEquals, assertEquals, assertFalse, assertFalse, assertNotNull, assertNotNull, assertNotSame, assertNull, assertNull, assertNumberOfLinesThatStartWith, assertNumberOfLinesThatStartWith, assertNumberOfRows, assertTrue, assertTrue, checkForOpenResources, countData, forceRebuildOfTrigers, formatTableName, getClusterService, getConfigurationService, getDataExtractorService, getDataService, getDbDialect, getIncomingBatchService, getNodeService, getOutgoingBatchService, getParameterService, getPlatform, getRegistrationService, getRouterService, getSqlTemplate, getStagingManager, getSymmetricEngine, getTriggerRouterService, logTestComplete, logTestRunning, printDatabase, resetBatches, resetGaps, routeAndCreateGaps, setLoggingLevelForTest, setup

Methods inherited from class java.lang.Object

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

Field Details

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 int batchId

sequenceId

protected static int sequenceId

client

protected Node client

root

protected Node root

Constructor Details

AbstractDataLoaderServiceTest

public AbstractDataLoaderServiceTest()

Method Details

getNextBatchId

protected String getNextBatchId()

getBatchId

protected String getBatchId()

getNextId

protected String getNextId()

getId

protected String getId()

test01IncomingBatch

@Test
public void test01IncomingBatch()
                         throws Exception

Throws:

Exception

test02Statistics

@Test
public void test02Statistics()
                      throws Exception

Throws:

Exception

test03UpdateCollision

@Test
public void test03UpdateCollision()
                           throws Exception

Throws:

Exception

test04SqlStatistics

@Test
public void test04SqlStatistics()
                         throws Exception

Throws:

Exception

test05SkippingResentBatch

@Test
public void test05SkippingResentBatch()
                               throws Exception

Throws:

Exception

test06ErrorWhileSkip

@Test
public void test06ErrorWhileSkip()
                          throws Exception

Throws:

Exception

test07DataIntregrityError

@Test
public void test07DataIntregrityError()
                               throws Exception

Throws:

Exception

test08ErrorWhileParsing

@Test
public void test08ErrorWhileParsing()
                             throws Exception

Throws:

Exception

test09ErrorThenSuccessBatch

@Test
public void test09ErrorThenSuccessBatch()
                                 throws Exception

Throws:

Exception

test10MultipleBatch

@Test
public void test10MultipleBatch()
                         throws Exception

Throws:

Exception

testSimple

protected void testSimple(String dmlType,
 String[] values,
 String[] expectedValues)
                   throws Exception

Throws:

Exception

load

protected void load(ByteArrayOutputStream out)
             throws Exception

Throws:

Exception

findIncomingBatchStatus

protected AbstractBatch.Status findIncomingBatchStatus(int batchId,
 String nodeId)

test12RegisteredDataWriterFilter

@Test
public void test12RegisteredDataWriterFilter()

test13NanValue

@Test
public void test13NanValue()
                    throws Exception

Throws:

Exception

getWriter

protected CsvWriter getWriter(OutputStream out)

getTransportManager

protected MockTransportManager getTransportManager()

writeTable

protected void writeTable(CsvWriter writer,
 String tableName,
 String[] keys,
 String[] columns)
                   throws IOException

Throws:

IOException

assertTestTableEquals

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

assertEquals

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

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)

translateExpectedDate

protected String translateExpectedDate(String value)

translateExpectedTimestamp

protected String translateExpectedTimestamp(String value)

getDataLoaderService

protected IDataLoaderService getDataLoaderService()

cleanup

public void cleanup()