org.jumpmind.symmetric.extract.csv
Class CsvExtractor13

java.lang.Object
  org.jumpmind.symmetric.extract.csv.CsvExtractor13

All Implemented Interfaces:

IDataExtractor

public class CsvExtractor13
extends java.lang.Object
implements IDataExtractor

Constructor Summary

CsvExtractor13()

Method Summary

void	begin(OutgoingBatch batch, java.io.BufferedWriter writer)
void	commit(OutgoingBatch batch, java.io.BufferedWriter writer)
void	init(java.io.BufferedWriter writer, DataExtractorContext context)
void	preprocessTable(Data data, java.io.BufferedWriter out, DataExtractorContext context) Writes the table metadata out to a stream only if it hasn't already been written out before
void	setDbDialect(IDbDialect dbDialect)
void	setDictionary(java.util.Map<java.lang.String,org.jumpmind.symmetric.extract.csv.IStreamDataCommand> dictionary)
void	setParameterService(IParameterService parameterService)
void	setTablePrefix(java.lang.String tablePrefix)
void	write(java.io.BufferedWriter writer, Data data, DataExtractorContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

CsvExtractor13

public CsvExtractor13()

Method Detail

init

public void init(java.io.BufferedWriter writer,
                 DataExtractorContext context)
          throws java.io.IOException

Specified by:

init in interface IDataExtractor

Throws:

java.io.IOException

begin

public void begin(OutgoingBatch batch,
                  java.io.BufferedWriter writer)
           throws java.io.IOException

Specified by:

begin in interface IDataExtractor

Throws:

java.io.IOException

commit

public void commit(OutgoingBatch batch,
                   java.io.BufferedWriter writer)
            throws java.io.IOException

Specified by:

commit in interface IDataExtractor

Throws:

java.io.IOException

write

public void write(java.io.BufferedWriter writer,
                  Data data,
                  DataExtractorContext context)
           throws java.io.IOException

Specified by:

write in interface IDataExtractor

Throws:

java.io.IOException

preprocessTable

public void preprocessTable(Data data,
                            java.io.BufferedWriter out,
                            DataExtractorContext context)
                     throws java.io.IOException

Writes the table metadata out to a stream only if it hasn't already been written out before

Specified by:

preprocessTable in interface IDataExtractor

Parameters:

tableName -

out -

Throws:

java.io.IOException

setDictionary

public void setDictionary(java.util.Map<java.lang.String,org.jumpmind.symmetric.extract.csv.IStreamDataCommand> dictionary)

setDbDialect

public void setDbDialect(IDbDialect dbDialect)

setTablePrefix

public void setTablePrefix(java.lang.String tablePrefix)

setParameterService

public void setParameterService(IParameterService parameterService)