Package org.jumpmind.symmetric.route

Class CSVRouter

java.lang.Object

org.jumpmind.symmetric.route.AbstractDataRouter

org.jumpmind.symmetric.route.AbstractFileParsingRouter

org.jumpmind.symmetric.route.CSVRouter

All Implemented Interfaces:

IBuiltInExtensionPoint, IExtensionPoint, IDataRouter

public class CSVRouter
extends AbstractFileParsingRouter
implements IDataRouter, IBuiltInExtensionPoint

Field Summary

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

EXTERNAL_DATA_FILE_DATA_ID, EXTERNAL_DATA_ROUTER_KEY, EXTERNAL_DATA_TRIGGER_KEY, ROUTER_EXPRESSION_CHANNEL_KEY, ROUTER_EXPRESSION_INCLUDE_TRANSACTION_ID, TRIGGER_ID_FILE_PARSER

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

log

Constructor Summary

Constructors

Constructor	Description
CSVRouter(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
String	getColumnNames()
ISymmetricEngine	getEngine()
List<String>	parse(File file, int lineNumber, int tableIndex)

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

buildNodeList, createSourceFile, deleteFileIfNecessary, getRouterIdFromExternalData, getTableNames, getTargetTableName, getTriggerHistory, parseExternalData, readStagingFile, routeToNodes

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, routeToNodes

Constructor Details

CSVRouter

public CSVRouter(ISymmetricEngine engine)

Method Details

getEngine

public ISymmetricEngine getEngine()

Specified by:

getEngine in class AbstractFileParsingRouter

parse

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

Specified by:

parse in class AbstractFileParsingRouter

getColumnNames

public String getColumnNames()

Specified by:

getColumnNames in class AbstractFileParsingRouter