Package org.jumpmind.symmetric.route

Class LookupTableDataRouter

java.lang.Object

org.jumpmind.symmetric.route.AbstractDataRouter

org.jumpmind.symmetric.route.LookupTableDataRouter

All Implemented Interfaces:

IBuiltInExtensionPoint, IExtensionPoint, IDataRouter

public class LookupTableDataRouter
extends AbstractDataRouter
implements IDataRouter, IBuiltInExtensionPoint

A data router that uses a lookup table to map data to nodes

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	LookupTableDataRouter.RowMapper

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PARAM_ALL_NODES_VALUE
static final String	PARAM_EXTERNAL_ID_COLUMN
static final String	PARAM_KEY_COLUMN
static final String	PARAM_LOOKUP_TABLE
static final String	PARAM_MAPPED_KEY_COLUMN

Constructor Summary

Constructors

Constructor	Description
LookupTableDataRouter()
LookupTableDataRouter(ISymmetricDialect symmetricDialect)

Method Summary

Modifier and Type	Method	Description
protected Map<String,Set<String>>	getLookupTable(Map<String,String> params, Router router, SimpleRouterContext routingContext)
protected Map<String,String>	getParams(Router router, SimpleRouterContext routingContext)	Cache parsed expressions in the context to minimize the amount of parsing we have to do when we have lots of throughput.
Map<String,String>	parse(String routerExpression)
Set<String>	routeToNodes(SimpleRouterContext routingContext, DataMetaData dataMetaData, Set<Node> nodes, boolean initialLoad, boolean initialLoadSelectUsed, TriggerRouter triggerRouter)

Methods inherited from class org.jumpmind.symmetric.route.AbstractDataRouter

addNodeId, completeBatch, contextCommitted, getDataAsObject, getDataAsString, getDataMap, getDataObjectMap, getNewDataAsObject, getNewDataAsString, getNullData, getOldDataAsObject, getOldDataAsString, getPkDataAsObject, getPkDataAsString, isConfigurable, isDmlOnly, testColumnNamesMatchValues, toExternalIds, toNodeIds

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

completeBatch, contextCommitted, isConfigurable, isDmlOnly

Field Details

PARAM_LOOKUP_TABLE

public static final String PARAM_LOOKUP_TABLE

See Also:

• Constant Field Values

PARAM_KEY_COLUMN

public static final String PARAM_KEY_COLUMN

See Also:

• Constant Field Values

PARAM_MAPPED_KEY_COLUMN

public static final String PARAM_MAPPED_KEY_COLUMN

See Also:

• Constant Field Values

PARAM_EXTERNAL_ID_COLUMN

public static final String PARAM_EXTERNAL_ID_COLUMN

See Also:

• Constant Field Values

PARAM_ALL_NODES_VALUE

public static final String PARAM_ALL_NODES_VALUE

See Also:

• Constant Field Values

Constructor Details

LookupTableDataRouter

public LookupTableDataRouter(ISymmetricDialect symmetricDialect)

LookupTableDataRouter

public LookupTableDataRouter()

Method Details

routeToNodes

public Set<String> routeToNodes(SimpleRouterContext routingContext,
 DataMetaData dataMetaData,
 Set<Node> nodes,
 boolean initialLoad,
 boolean initialLoadSelectUsed,
 TriggerRouter triggerRouter)

Specified by:

routeToNodes in interface IDataRouter

getParams

protected Map<String,String> getParams(Router router,
 SimpleRouterContext routingContext)

Cache parsed expressions in the context to minimize the amount of parsing we have to do when we have lots of throughput.

parse

public Map<String,String> parse(String routerExpression)
                         throws SyntaxParsingException

Throws:

SyntaxParsingException

getLookupTable

protected Map<String,Set<String>> getLookupTable(Map<String,String> params,
 Router router,
 SimpleRouterContext routingContext)