org.jumpmind.symmetric.load.csv
Class CsvLoader

java.lang.Object
  org.jumpmind.symmetric.load.csv.CsvLoader

All Implemented Interfaces:

java.lang.Cloneable, IDataLoader

public class CsvLoader
extends java.lang.Object
implements IDataLoader

Field Summary

protected java.util.Map<java.lang.String,IColumnFilter>	columnFilters
protected IConfigurationService	configurationService
protected DataLoaderContext	context
protected CsvReader	csvReader
protected IDbDialect	dbDialect
protected java.util.List<IDataLoaderFilter>	filters
protected org.springframework.jdbc.core.JdbcTemplate	jdbcTemplate
protected INodeService	nodeService
protected IParameterService	parameterService
protected DataLoaderStatistics	stats

Constructor Summary

CsvLoader()

Method Summary

protected void	cleanupAfterDataLoad()
IDataLoader	clone()
void	close()
protected int	delete(java.lang.String[] tokens)
IDataLoaderContext	getContext()
IDataLoaderStatistics	getStatistics()
boolean	hasNext()
protected int	insert(java.lang.String[] tokens, BinaryEncoding encoding)
protected boolean	isMetaTokenParsed(java.lang.String[] tokens)
void	load()
void	open(java.io.BufferedReader reader)
void	open(java.io.BufferedReader reader, java.util.List<IDataLoaderFilter> filters, java.util.Map<java.lang.String,IColumnFilter> columnFilters)
protected java.lang.String[]	parseColumns(java.lang.String[] tokens, int startIndex)
protected java.lang.String[]	parseKeys(java.lang.String[] tokens, int startIndex)
protected java.lang.String[]	parseValues(java.lang.String name, java.lang.String[] tokens, int startIndex, int endIndex)
protected void	prepareTableForDataLoad()
protected void	runDdl(java.lang.String xml)
protected void	runSql(java.lang.String sql)
void	setConfigurationService(IConfigurationService configurationService)
void	setDbDialect(IDbDialect dbDialect)
void	setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate)
void	setNodeService(INodeService nodeService)
void	setParameterService(IParameterService parameterService)
protected void	setTable(java.lang.String tableName)
void	skip()
protected int	update(java.lang.String[] tokens, BinaryEncoding encoding)

Methods inherited from class java.lang.Object

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

Field Detail

jdbcTemplate

protected org.springframework.jdbc.core.JdbcTemplate jdbcTemplate

dbDialect

protected IDbDialect dbDialect

parameterService

protected IParameterService parameterService

configurationService

protected IConfigurationService configurationService

nodeService

protected INodeService nodeService

csvReader

protected CsvReader csvReader

context

protected DataLoaderContext context

stats

protected DataLoaderStatistics stats

filters

protected java.util.List<IDataLoaderFilter> filters

columnFilters

protected java.util.Map<java.lang.String,IColumnFilter> columnFilters

Constructor Detail

CsvLoader

public CsvLoader()

Method Detail

open

public void open(java.io.BufferedReader reader)
          throws java.io.IOException

Specified by:

open in interface IDataLoader

Throws:

java.io.IOException

open

public void open(java.io.BufferedReader reader,
                 java.util.List<IDataLoaderFilter> filters,
                 java.util.Map<java.lang.String,IColumnFilter> columnFilters)
          throws java.io.IOException

Specified by:

open in interface IDataLoader

Throws:

java.io.IOException

hasNext

public boolean hasNext()
                throws java.io.IOException

Specified by:

hasNext in interface IDataLoader

Throws:

java.io.IOException

skip

public void skip()
          throws java.io.IOException

Specified by:

skip in interface IDataLoader

Throws:

java.io.IOException

load

public void load()
          throws java.io.IOException

Specified by:

load in interface IDataLoader

Throws:

java.io.IOException

isMetaTokenParsed

protected boolean isMetaTokenParsed(java.lang.String[] tokens)

setTable

protected void setTable(java.lang.String tableName)

prepareTableForDataLoad

protected void prepareTableForDataLoad()

cleanupAfterDataLoad

protected void cleanupAfterDataLoad()

insert

protected int insert(java.lang.String[] tokens,
                     BinaryEncoding encoding)

update

protected int update(java.lang.String[] tokens,
                     BinaryEncoding encoding)

delete

protected int delete(java.lang.String[] tokens)

runSql

protected void runSql(java.lang.String sql)

runDdl

protected void runDdl(java.lang.String xml)

parseKeys

protected java.lang.String[] parseKeys(java.lang.String[] tokens,
                                       int startIndex)

parseColumns

protected java.lang.String[] parseColumns(java.lang.String[] tokens,
                                          int startIndex)

parseValues

protected java.lang.String[] parseValues(java.lang.String name,
                                         java.lang.String[] tokens,
                                         int startIndex,
                                         int endIndex)

clone

public IDataLoader clone()

Specified by:

clone in interface IDataLoader

Overrides:

clone in class java.lang.Object

close

public void close()

Specified by:

close in interface IDataLoader

getContext

public IDataLoaderContext getContext()

Specified by:

getContext in interface IDataLoader

getStatistics

public IDataLoaderStatistics getStatistics()

Specified by:

getStatistics in interface IDataLoader

setJdbcTemplate

public void setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate)

setDbDialect

public void setDbDialect(IDbDialect dbDialect)

setParameterService

public void setParameterService(IParameterService parameterService)

setConfigurationService

public void setConfigurationService(IConfigurationService configurationService)

setNodeService

public void setNodeService(INodeService nodeService)