Package org.jumpmind.symmetric.route

Class AbstractDataRouter

java.lang.Object

org.jumpmind.symmetric.route.AbstractDataRouter

All Implemented Interfaces:

IExtensionPoint, IDataRouter

Direct Known Subclasses:

AbstractFileParsingRouter, AuditTableDataRouter, BshDataRouter, ColumnMatchDataRouter, ConfigurationChangedDataRouter, ConvertToReloadRouter, DefaultDataRouter, FileSyncDataRouter, JavaDataRouter, LookupTableDataRouter, SubSelectDataRouter

public abstract class AbstractDataRouter
extends Object
implements IDataRouter

A common superclass for data routers

Field Summary

Fields

Modifier and Type	Field	Description
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
AbstractDataRouter()

Method Summary

Modifier and Type	Method	Description
protected Set<String>	addNodeId(String nodeId, Set<String> nodeIds, Set<Node> nodes)
void	completeBatch(SimpleRouterContext context, OutgoingBatch batch)	Override if needed.
void	contextCommitted(SimpleRouterContext context)
protected Map<String,Object>	getDataAsObject(String prefix, DataMetaData dataMetaData, ISymmetricDialect symmetricDialect, String[] rowData, boolean upperCase)
protected Map<String,String>	getDataAsString(String prefix, DataMetaData dataMetaData, ISymmetricDialect symmetricDialect, String[] rowData)
protected Map<String,String>	getDataMap(DataMetaData dataMetaData, ISymmetricDialect symmetricDialect)
protected Map<String,Object>	getDataObjectMap(DataMetaData dataMetaData, ISymmetricDialect symmetricDialect, boolean upperCase)
protected Map<String,Object>	getNewDataAsObject(String prefix, DataMetaData dataMetaData, ISymmetricDialect symmetricDialect, boolean upperCase)
protected Map<String,String>	getNewDataAsString(String prefix, DataMetaData dataMetaData, ISymmetricDialect symmetricDialect)
protected <T> Map<String,T>	getNullData(String prefix, DataMetaData dataMetaData)
protected Map<String,Object>	getOldDataAsObject(String prefix, DataMetaData dataMetaData, ISymmetricDialect symmetricDialect, boolean upperCase)
protected Map<String,String>	getOldDataAsString(String prefix, DataMetaData dataMetaData, ISymmetricDialect symmetricDialect)
protected Map<String,Object>	getPkDataAsObject(DataMetaData dataMetaData, ISymmetricDialect symmetricDialect)
protected Map<String,String>	getPkDataAsString(DataMetaData dataMetaData, ISymmetricDialect symmetricDialect)
boolean	isConfigurable()	Override if a router is not configurable.
boolean	isDmlOnly()	Override if a router is able to route non-DML DataEventTypes.
protected void	testColumnNamesMatchValues(DataMetaData dataMetaData, String[] columnNames, Object[] values)
protected Set<String>	toExternalIds(Set<Node> nodes)
protected Set<String>	toNodeIds(Set<Node> nodes, Set<String> nodeIds)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jumpmind.symmetric.route.IDataRouter

routeToNodes

Field Details

log

protected org.slf4j.Logger log

Constructor Details

AbstractDataRouter

public AbstractDataRouter()

Method Details

contextCommitted

public void contextCommitted(SimpleRouterContext context)

Specified by:

contextCommitted in interface IDataRouter

getDataMap

protected Map<String,String> getDataMap(DataMetaData dataMetaData,
 ISymmetricDialect symmetricDialect)

getNewDataAsString

protected Map<String,String> getNewDataAsString(String prefix,
 DataMetaData dataMetaData,
 ISymmetricDialect symmetricDialect)

getOldDataAsString

protected Map<String,String> getOldDataAsString(String prefix,
 DataMetaData dataMetaData,
 ISymmetricDialect symmetricDialect)

getDataAsString

protected Map<String,String> getDataAsString(String prefix,
 DataMetaData dataMetaData,
 ISymmetricDialect symmetricDialect,
 String[] rowData)

getPkDataAsString

protected Map<String,String> getPkDataAsString(DataMetaData dataMetaData,
 ISymmetricDialect symmetricDialect)

getDataObjectMap

protected Map<String,Object> getDataObjectMap(DataMetaData dataMetaData,
 ISymmetricDialect symmetricDialect,
 boolean upperCase)

getNewDataAsObject

protected Map<String,Object> getNewDataAsObject(String prefix,
 DataMetaData dataMetaData,
 ISymmetricDialect symmetricDialect,
 boolean upperCase)

getOldDataAsObject

protected Map<String,Object> getOldDataAsObject(String prefix,
 DataMetaData dataMetaData,
 ISymmetricDialect symmetricDialect,
 boolean upperCase)

getNullData

protected <T> Map<String,T> getNullData(String prefix,
 DataMetaData dataMetaData)

getDataAsObject

protected Map<String,Object> getDataAsObject(String prefix,
 DataMetaData dataMetaData,
 ISymmetricDialect symmetricDialect,
 String[] rowData,
 boolean upperCase)

testColumnNamesMatchValues

protected void testColumnNamesMatchValues(DataMetaData dataMetaData,
 String[] columnNames,
 Object[] values)

getPkDataAsObject

protected Map<String,Object> getPkDataAsObject(DataMetaData dataMetaData,
 ISymmetricDialect symmetricDialect)

addNodeId

protected Set<String> addNodeId(String nodeId,
 Set<String> nodeIds,
 Set<Node> nodes)

toNodeIds

protected Set<String> toNodeIds(Set<Node> nodes,
 Set<String> nodeIds)

toExternalIds

protected Set<String> toExternalIds(Set<Node> nodes)

completeBatch

public void completeBatch(SimpleRouterContext context,
 OutgoingBatch batch)

Override if needed.

Specified by:

completeBatch in interface IDataRouter

isConfigurable

public boolean isConfigurable()

Override if a router is not configurable.

Specified by:

isConfigurable in interface IDataRouter

isDmlOnly

public boolean isDmlOnly()

Override if a router is able to route non-DML DataEventTypes.

Specified by:

isDmlOnly in interface IDataRouter