org.jumpmind.symmetric.route

Class AbstractFileParsingRouter

java.lang.Object

org.jumpmind.symmetric.route.AbstractDataRouter

org.jumpmind.symmetric.route.AbstractFileParsingRouter

All Implemented Interfaces:

org.jumpmind.extension.IExtensionPoint, IDataRouter

Direct Known Subclasses:

CSVRouter, DBFRouter, TPSRouter

public abstract class AbstractFileParsingRouter
extends AbstractDataRouter

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	EXTERNAL_DATA_FILE_DATA_ID
static java.lang.String	EXTERNAL_DATA_ROUTER_KEY
static java.lang.String	EXTERNAL_DATA_TRIGGER_KEY
static java.lang.String	ROUTER_EXPRESSION_CHANNEL_KEY
static java.lang.String	ROUTER_EXPRESSION_INCLUDE_TRANSACTION_ID
static java.lang.String	TRIGGER_ID_FILE_PARSER

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

log

Constructor Summary

Constructors

Constructor and Description
AbstractFileParsingRouter()

Method Summary

Modifier and Type	Method and Description
java.lang.String	buildNodeList(java.util.Set<Node> nodes)
java.io.File	createSourceFile(java.lang.String baseDir, java.lang.String relativeDir, java.lang.String fileName)
void	deleteFileIfNecessary(DataMetaData dataMetaData)
abstract java.lang.String	getColumnNames()
abstract ISymmetricEngine	getEngine()
static java.lang.String	getRouterIdFromExternalData(java.lang.String externalData)
java.util.Map<java.lang.Integer,java.lang.String>	getTableNames(java.lang.String tableName, java.io.File file)
java.lang.String	getTargetTableName(java.lang.String targetTableName, java.lang.String fileName)
protected TriggerHistory	getTriggerHistory(java.lang.String tableName, java.lang.String columnNames)
abstract java.util.List<java.lang.String>	parse(java.io.File file, int lineNumber, int tableId)
static java.util.Map<java.lang.String,java.lang.String>	parseExternalData(java.lang.String externalData)
java.util.Map<java.lang.String,java.lang.Integer>	readStagingFile(org.jumpmind.symmetric.io.stage.IStagedResource resource)
java.util.Set<java.lang.String>	routeToNodes(SimpleRouterContext context, DataMetaData dataMetaData, java.util.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, testColumnNamesMatchValues, toExternalIds, toNodeIds

Methods inherited from class java.lang.Object

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

Field Detail

TRIGGER_ID_FILE_PARSER

public static final java.lang.String TRIGGER_ID_FILE_PARSER

See Also:

Constant Field Values

EXTERNAL_DATA_ROUTER_KEY

public static final java.lang.String EXTERNAL_DATA_ROUTER_KEY

See Also:

Constant Field Values

EXTERNAL_DATA_TRIGGER_KEY

public static final java.lang.String EXTERNAL_DATA_TRIGGER_KEY

See Also:

Constant Field Values

EXTERNAL_DATA_FILE_DATA_ID

public static final java.lang.String EXTERNAL_DATA_FILE_DATA_ID

See Also:

Constant Field Values

ROUTER_EXPRESSION_CHANNEL_KEY

public static final java.lang.String ROUTER_EXPRESSION_CHANNEL_KEY

See Also:

Constant Field Values

ROUTER_EXPRESSION_INCLUDE_TRANSACTION_ID

public static final java.lang.String ROUTER_EXPRESSION_INCLUDE_TRANSACTION_ID

See Also:

Constant Field Values

Constructor Detail

AbstractFileParsingRouter

public AbstractFileParsingRouter()

Method Detail

parse

public abstract java.util.List<java.lang.String> parse(java.io.File file,
                                                       int lineNumber,
                                                       int tableId)

getColumnNames

public abstract java.lang.String getColumnNames()

getEngine

public abstract ISymmetricEngine getEngine()

routeToNodes

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

getTableNames

public java.util.Map<java.lang.Integer,java.lang.String> getTableNames(java.lang.String tableName,
                                                                       java.io.File file)
                                                                throws java.io.IOException

Throws:

java.io.IOException

getTargetTableName

public java.lang.String getTargetTableName(java.lang.String targetTableName,
                                           java.lang.String fileName)

buildNodeList

public java.lang.String buildNodeList(java.util.Set<Node> nodes)

readStagingFile

public java.util.Map<java.lang.String,java.lang.Integer> readStagingFile(org.jumpmind.symmetric.io.stage.IStagedResource resource)

createSourceFile

public java.io.File createSourceFile(java.lang.String baseDir,
                                     java.lang.String relativeDir,
                                     java.lang.String fileName)

getTriggerHistory

protected TriggerHistory getTriggerHistory(java.lang.String tableName,
                                           java.lang.String columnNames)

getRouterIdFromExternalData

public static java.lang.String getRouterIdFromExternalData(java.lang.String externalData)

parseExternalData

public static java.util.Map<java.lang.String,java.lang.String> parseExternalData(java.lang.String externalData)

deleteFileIfNecessary

public void deleteFileIfNecessary(DataMetaData dataMetaData)