org.jumpmind.symmetric.route

Class AbstractDataRouter

java.lang.Object

org.jumpmind.symmetric.route.AbstractDataRouter

All Implemented Interfaces:

org.jumpmind.extension.IExtensionPoint, IDataRouter

Direct Known Subclasses:

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

public abstract class AbstractDataRouter
extends java.lang.Object
implements IDataRouter

A common superclass for data routers

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
AbstractDataRouter()

Method Summary

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

log

protected org.slf4j.Logger log

Constructor Detail

AbstractDataRouter

public AbstractDataRouter()

Method Detail

contextCommitted

public void contextCommitted(SimpleRouterContext context)

Specified by:

contextCommitted in interface IDataRouter

getDataMap

protected java.util.Map<java.lang.String,java.lang.String> getDataMap(DataMetaData dataMetaData,
                                                                      ISymmetricDialect symmetricDialect)

getNewDataAsString

protected java.util.Map<java.lang.String,java.lang.String> getNewDataAsString(java.lang.String prefix,
                                                                              DataMetaData dataMetaData,
                                                                              ISymmetricDialect symmetricDialect)

getOldDataAsString

protected java.util.Map<java.lang.String,java.lang.String> getOldDataAsString(java.lang.String prefix,
                                                                              DataMetaData dataMetaData,
                                                                              ISymmetricDialect symmetricDialect)

getDataAsString

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

getPkDataAsString

protected java.util.Map<java.lang.String,java.lang.String> getPkDataAsString(DataMetaData dataMetaData,
                                                                             ISymmetricDialect symmetricDialect)

getDataObjectMap

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

getNewDataAsObject

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

getOldDataAsObject

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

getNullData

protected <T> java.util.Map<java.lang.String,T> getNullData(java.lang.String prefix,
                                                            DataMetaData dataMetaData)

getDataAsObject

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

testColumnNamesMatchValues

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

getPkDataAsObject

protected java.util.Map<java.lang.String,java.lang.Object> getPkDataAsObject(DataMetaData dataMetaData,
                                                                             ISymmetricDialect symmetricDialect)

addNodeId

protected java.util.Set<java.lang.String> addNodeId(java.lang.String nodeId,
                                                    java.util.Set<java.lang.String> nodeIds,
                                                    java.util.Set<Node> nodes)

toNodeIds

protected java.util.Set<java.lang.String> toNodeIds(java.util.Set<Node> nodes,
                                                    java.util.Set<java.lang.String> nodeIds)

toExternalIds

protected java.util.Set<java.lang.String> toExternalIds(java.util.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