Package org.jumpmind.symmetric.service.impl

Class AbstractTriggerRouterServiceTest

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractServiceTest

org.jumpmind.symmetric.service.impl.AbstractTriggerRouterServiceTest

Direct Known Subclasses:

JdbcTriggerRouterServiceTest

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

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CREATE_ORACLE_BINARY_TYPE
static final String	CREATE_POSTGRES_BINARY_TYPE
static final String	DROP_POSTGRES_BINARY_TYPE
static final String	EXPECTED_INSERT_ORALCE_BINARY_TYPE_1
static final String	EXPECTED_INSERT_POSTGRES_BINARY_TYPE_1
static final String	EXPECTED_INSERT1_CSV_ENDSWITH
static final String	EXPECTED_INSERT2_CSV_ENDSWITH
static final String	INSERT
static final String	INSERT_ORACLE_BINARY_TYPE_1
static final String	INSERT_POSTGRES_BINARY_TYPE_1
static final int[]	INSERT_TYPES
static final Object[]	INSERT1_VALUES
static final Object[]	INSERT2_VALUES
static final Object[]	INSERT3_VALUES
static final String	insertSyncIncomingBatchSql
static final String	TEST_TRIGGER_WHERE_CLAUSE
static final String	TEST_TRIGGERS_TABLE
static final String	UNEXPECTED_INSERT3_CSV_ENDSWITH

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

engine

Constructor Summary

Constructors

Constructor	Description
AbstractTriggerRouterServiceTest()

Method Summary

Modifier and Type	Method	Description
protected static int[]	filterTypes(int[] types, ISymmetricDialect dbDialect)
protected static Object[]	filterValues(Object[] values, ISymmetricDialect dbDialect)
protected String	getNextDataRow()
static int	insert(Object[] values, ISqlTemplate jdbcTemplate, ISymmetricDialect dbDialect)
static int	insert(Object[] values, ISqlTransaction transaction, ISymmetricDialect dbDialect)
protected static boolean	isBooleanSupported(ISymmetricDialect dbDialect)
void	test01ReplaceCharactersForTriggerName()
void	test02SchemaSync()
void	test03SchemaSyncNoChanges()
void	test04GetRouterById()
void	test05ValidateTestTableTriggers()
void	test06InitialLoadSql()
void	test07CaptureOnlyChangedData()
void	test09ExcludedColumnsFunctionality()
void	test10DisableTriggers()
void	test11BinaryColumnTypesForOracle()
void	test12BinaryColumnTypesForPostgres()
void	test13BinaryColumnTypesForDerby()
void	test14OverlappingTriggerIds()

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_TRIGGERS_TABLE

public static final String TEST_TRIGGERS_TABLE

See Also:

• Constant Field Values

CREATE_ORACLE_BINARY_TYPE

public static final String CREATE_ORACLE_BINARY_TYPE

See Also:

• Constant Field Values

INSERT_ORACLE_BINARY_TYPE_1

public static final String INSERT_ORACLE_BINARY_TYPE_1

See Also:

• Constant Field Values

EXPECTED_INSERT_ORALCE_BINARY_TYPE_1

public static final String EXPECTED_INSERT_ORALCE_BINARY_TYPE_1

See Also:

• Constant Field Values

CREATE_POSTGRES_BINARY_TYPE

public static final String CREATE_POSTGRES_BINARY_TYPE

See Also:

• Constant Field Values

INSERT_POSTGRES_BINARY_TYPE_1

public static final String INSERT_POSTGRES_BINARY_TYPE_1

See Also:

• Constant Field Values

EXPECTED_INSERT_POSTGRES_BINARY_TYPE_1

public static final String EXPECTED_INSERT_POSTGRES_BINARY_TYPE_1

See Also:

• Constant Field Values

DROP_POSTGRES_BINARY_TYPE

public static final String DROP_POSTGRES_BINARY_TYPE

See Also:

• Constant Field Values

INSERT

public static final String INSERT

See Also:

• Constant Field Values

INSERT_TYPES

public static final int[] INSERT_TYPES

INSERT1_VALUES

public static final Object[] INSERT1_VALUES

INSERT2_VALUES

public static final Object[] INSERT2_VALUES

INSERT3_VALUES

public static final Object[] INSERT3_VALUES

EXPECTED_INSERT1_CSV_ENDSWITH

public static final String EXPECTED_INSERT1_CSV_ENDSWITH

See Also:

• Constant Field Values

EXPECTED_INSERT2_CSV_ENDSWITH

public static final String EXPECTED_INSERT2_CSV_ENDSWITH

See Also:

• Constant Field Values

UNEXPECTED_INSERT3_CSV_ENDSWITH

public static final String UNEXPECTED_INSERT3_CSV_ENDSWITH

See Also:

• Constant Field Values

TEST_TRIGGER_WHERE_CLAUSE

public static final String TEST_TRIGGER_WHERE_CLAUSE

See Also:

• Constant Field Values

insertSyncIncomingBatchSql

public static final String insertSyncIncomingBatchSql

See Also:

• Constant Field Values

Constructor Details

AbstractTriggerRouterServiceTest

public AbstractTriggerRouterServiceTest()

Method Details

test01ReplaceCharactersForTriggerName

@Test
public void test01ReplaceCharactersForTriggerName()

test02SchemaSync

@Test
public void test02SchemaSync()
                      throws Exception

Throws:

Exception

test03SchemaSyncNoChanges

@Test
public void test03SchemaSyncNoChanges()
                               throws Exception

Throws:

Exception

test04GetRouterById

@Test
public void test04GetRouterById()
                         throws Exception

Throws:

Exception

test05ValidateTestTableTriggers

@Test
public void test05ValidateTestTableTriggers()
                                     throws Exception

Throws:

Exception

test06InitialLoadSql

@Test
public void test06InitialLoadSql()
                          throws Exception

Throws:

Exception

test07CaptureOnlyChangedData

@Test
public void test07CaptureOnlyChangedData()
                                  throws Exception

Throws:

Exception

test09ExcludedColumnsFunctionality

@Test
public void test09ExcludedColumnsFunctionality()
                                        throws Exception

Throws:

Exception

test10DisableTriggers

@Test
public void test10DisableTriggers()
                           throws Exception

Throws:

Exception

test11BinaryColumnTypesForOracle

@Test
public void test11BinaryColumnTypesForOracle()

test12BinaryColumnTypesForPostgres

@Test
public void test12BinaryColumnTypesForPostgres()

test13BinaryColumnTypesForDerby

@Test
public void test13BinaryColumnTypesForDerby()

test14OverlappingTriggerIds

@Test
public void test14OverlappingTriggerIds()

filterTypes

protected static int[] filterTypes(int[] types,
 ISymmetricDialect dbDialect)

insert

public static int insert(Object[] values,
 ISqlTransaction transaction,
 ISymmetricDialect dbDialect)

insert

public static int insert(Object[] values,
 ISqlTemplate jdbcTemplate,
 ISymmetricDialect dbDialect)

isBooleanSupported

protected static boolean isBooleanSupported(ISymmetricDialect dbDialect)

filterValues

protected static Object[] filterValues(Object[] values,
 ISymmetricDialect dbDialect)

getNextDataRow

protected String getNextDataRow()