Package org.jumpmind.symmetric.route

Class AbstractFileParsingRouter

java.lang.Object

org.jumpmind.symmetric.route.AbstractDataRouter

org.jumpmind.symmetric.route.AbstractFileParsingRouter

All Implemented Interfaces:

IExtensionPoint, IDataRouter

Direct Known Subclasses:

CSVRouter, DBFRouter, TPSRouter

public abstract class AbstractFileParsingRouter
extends AbstractDataRouter

Field Summary

Fields

Modifier and Type	Field	Description
static final String	EXTERNAL_DATA_FILE_DATA_ID
static final String	EXTERNAL_DATA_ROUTER_KEY
static final String	EXTERNAL_DATA_TRIGGER_KEY
static final String	ROUTER_EXPRESSION_CHANNEL_KEY
static final String	ROUTER_EXPRESSION_INCLUDE_TRANSACTION_ID
static final String	TRIGGER_ID_FILE_PARSER

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

log

Constructor Summary

Constructors

Constructor	Description
AbstractFileParsingRouter()

Method Summary

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

Field Details

TRIGGER_ID_FILE_PARSER

public static final String TRIGGER_ID_FILE_PARSER

See Also:

• Constant Field Values

EXTERNAL_DATA_ROUTER_KEY

public static final String EXTERNAL_DATA_ROUTER_KEY

See Also:

• Constant Field Values

EXTERNAL_DATA_TRIGGER_KEY

public static final String EXTERNAL_DATA_TRIGGER_KEY

See Also:

• Constant Field Values

EXTERNAL_DATA_FILE_DATA_ID

public static final String EXTERNAL_DATA_FILE_DATA_ID

See Also:

• Constant Field Values

ROUTER_EXPRESSION_CHANNEL_KEY

public static final String ROUTER_EXPRESSION_CHANNEL_KEY

See Also:

• Constant Field Values

ROUTER_EXPRESSION_INCLUDE_TRANSACTION_ID

public static final String ROUTER_EXPRESSION_INCLUDE_TRANSACTION_ID

See Also:

• Constant Field Values

Constructor Details

AbstractFileParsingRouter

public AbstractFileParsingRouter()

Method Details

parse

public abstract List<String> parse(File file,
 int lineNumber,
 int tableId)

getColumnNames

public abstract String getColumnNames()

getEngine

public abstract ISymmetricEngine getEngine()

routeToNodes

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

getTableNames

public Map<Integer,String> getTableNames(String tableName,
 File file)
                                  throws IOException

Throws:

IOException

getTargetTableName

public String getTargetTableName(String targetTableName,
 String fileName)

buildNodeList

public String buildNodeList(Set<Node> nodes)

readStagingFile

public Map<String,Integer> readStagingFile(IStagedResource resource)

createSourceFile

public File createSourceFile(String baseDir,
 String relativeDir,
 String fileName)

getTriggerHistory

protected TriggerHistory getTriggerHistory(String tableName,
 String columnNames)

getRouterIdFromExternalData

public static String getRouterIdFromExternalData(String externalData)

parseExternalData

public static Map<String,String> parseExternalData(String externalData)

deleteFileIfNecessary

public void deleteFileIfNecessary(DataMetaData dataMetaData)