org.jumpmind.symmetric.route

Class ConvertToReloadRouter

java.lang.Object

org.jumpmind.symmetric.route.AbstractDataRouter

org.jumpmind.symmetric.route.ConvertToReloadRouter

All Implemented Interfaces:

org.jumpmind.extension.IBuiltInExtensionPoint, org.jumpmind.extension.IExtensionPoint, IDataRouter

public class ConvertToReloadRouter
extends AbstractDataRouter
implements IDataRouter, org.jumpmind.extension.IBuiltInExtensionPoint

Converts multiple change data rows into reload batches for each table ordered by foreign key dependencies.

Field Summary

Fields

Modifier and Type	Field and Description
protected ISymmetricEngine	engine
protected boolean	firstTime
protected long	insertBatchMs
protected long	insertTempMs
protected long	queryNodesMs
protected long	routeMs
static java.lang.String	ROUTER_ID
protected long	sortMs

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

log

Constructor Summary

Constructors

Constructor and Description
ConvertToReloadRouter(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
void	completeBatch(SimpleRouterContext context, OutgoingBatch batch) Override if needed.
void	contextCommitted(SimpleRouterContext context)
protected java.util.List<org.jumpmind.db.model.Table>	getAllSortedTables(SimpleRouterContext context)
protected java.lang.Object[]	getPkObjects(org.jumpmind.symmetric.io.data.DataEventType eventType, DataMetaData dataMetaData)
protected java.lang.String	getTempTableSql(org.jumpmind.symmetric.route.ConvertToReloadRouter.RouterInfo routerInfo, org.jumpmind.symmetric.route.ConvertToReloadRouter.TableInfo tableInfo, long loadId)
protected long	insertData(org.jumpmind.db.sql.ISqlTransaction transaction, org.jumpmind.symmetric.route.ConvertToReloadRouter.TableInfo tableInfo, java.lang.String eventType, java.lang.String sql)
protected void	insertDataEvent(org.jumpmind.db.sql.ISqlTransaction transaction, long batchId, long dataId)
protected OutgoingBatch	newBatch(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String nodeId, long loadId, org.jumpmind.symmetric.route.ConvertToReloadRouter.TableInfo tableInfo, java.lang.String summary)
protected void	queueEvents(ChannelRouterContext context, org.jumpmind.db.sql.ISqlTransaction transaction, OutgoingBatch origBatch, java.util.List<org.jumpmind.symmetric.route.ConvertToReloadRouter.TableInfo> tableInfos)
java.util.Set<java.lang.String>	routeToNodes(SimpleRouterContext context, DataMetaData dataMetaData, java.util.Set<Node> nodes, boolean initialLoad, boolean initialLoadSelectUsed, TriggerRouter triggerRouter)
void	setSymmetricEngine(ISymmetricEngine engine)
protected java.util.List<org.jumpmind.symmetric.route.ConvertToReloadRouter.TableInfo>	sortTableInfos(SimpleRouterContext context, java.util.Collection<org.jumpmind.symmetric.route.ConvertToReloadRouter.TableInfo> tableInfos)

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

addNodeId, getDataAsObject, getDataAsString, getDataMap, getDataObjectMap, getNewDataAsObject, getNewDataAsString, getNullData, getOldDataAsObject, getOldDataAsString, getPkDataAsObject, getPkDataAsString, isConfigurable, 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

isConfigurable

Field Detail

ROUTER_ID

public static final java.lang.String ROUTER_ID

See Also:

Constant Field Values

engine

protected ISymmetricEngine engine

firstTime

protected boolean firstTime

routeMs

protected long routeMs

sortMs

protected long sortMs

insertTempMs

protected long insertTempMs

queryNodesMs

protected long queryNodesMs

insertBatchMs

protected long insertBatchMs

Constructor Detail

ConvertToReloadRouter

public ConvertToReloadRouter(ISymmetricEngine engine)

Method Detail

routeToNodes

public java.util.Set<java.lang.String> routeToNodes(SimpleRouterContext context,
                                                    DataMetaData dataMetaData,
                                                    java.util.Set<Node> nodes,
                                                    boolean initialLoad,
                                                    boolean initialLoadSelectUsed,
                                                    TriggerRouter triggerRouter)

Specified by:

routeToNodes in interface IDataRouter

getPkObjects

protected java.lang.Object[] getPkObjects(org.jumpmind.symmetric.io.data.DataEventType eventType,
                                          DataMetaData dataMetaData)

completeBatch

public void completeBatch(SimpleRouterContext context,
                          OutgoingBatch batch)

Description copied from class: AbstractDataRouter

Override if needed.

Specified by:

completeBatch in interface IDataRouter

Overrides:

completeBatch in class AbstractDataRouter

contextCommitted

public void contextCommitted(SimpleRouterContext context)

Specified by:

contextCommitted in interface IDataRouter

Overrides:

contextCommitted in class AbstractDataRouter

sortTableInfos

protected java.util.List<org.jumpmind.symmetric.route.ConvertToReloadRouter.TableInfo> sortTableInfos(SimpleRouterContext context,
                                                                                                      java.util.Collection<org.jumpmind.symmetric.route.ConvertToReloadRouter.TableInfo> tableInfos)

getAllSortedTables

protected java.util.List<org.jumpmind.db.model.Table> getAllSortedTables(SimpleRouterContext context)

queueEvents

protected void queueEvents(ChannelRouterContext context,
                           org.jumpmind.db.sql.ISqlTransaction transaction,
                           OutgoingBatch origBatch,
                           java.util.List<org.jumpmind.symmetric.route.ConvertToReloadRouter.TableInfo> tableInfos)

getTempTableSql

protected java.lang.String getTempTableSql(org.jumpmind.symmetric.route.ConvertToReloadRouter.RouterInfo routerInfo,
                                           org.jumpmind.symmetric.route.ConvertToReloadRouter.TableInfo tableInfo,
                                           long loadId)

newBatch

protected OutgoingBatch newBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
                                 java.lang.String nodeId,
                                 long loadId,
                                 org.jumpmind.symmetric.route.ConvertToReloadRouter.TableInfo tableInfo,
                                 java.lang.String summary)

insertData

protected long insertData(org.jumpmind.db.sql.ISqlTransaction transaction,
                          org.jumpmind.symmetric.route.ConvertToReloadRouter.TableInfo tableInfo,
                          java.lang.String eventType,
                          java.lang.String sql)

insertDataEvent

protected void insertDataEvent(org.jumpmind.db.sql.ISqlTransaction transaction,
                               long batchId,
                               long dataId)

setSymmetricEngine

public void setSymmetricEngine(ISymmetricEngine engine)