com.continuent.tungsten.replicator.applier.batch
Class SqlCsvLoader

java.lang.Object
  com.continuent.tungsten.replicator.applier.batch.SqlCsvLoader

All Implemented Interfaces:

CsvLoader

Direct Known Subclasses:

VerticaCsvLoader

public class SqlCsvLoader
extends java.lang.Object
implements CsvLoader

Implements a CSV loader that loads files using SQL. This class follows JavaBean convention including having a default constructor plus matching setters and getters for all properties.

Field Summary

protected SqlScriptGenerator	loadScriptGenerator
protected java.util.Map<java.lang.String,java.util.List<java.lang.String>>	loadScripts
protected java.lang.String	stageLoadScript

Constructor Summary

SqlCsvLoader()

Method Summary

java.lang.String	getStageLoadScript()
void	load(Database conn, CsvInfo info, LoadMismatch onLoadMismatch) Loads a CSV file to the DBMS using an appropriate mechanism for this DBMS type.
void	setStageLoadScript(java.lang.String stageLoadScript)

Methods inherited from class java.lang.Object

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

Field Detail

stageLoadScript

protected java.lang.String stageLoadScript

loadScriptGenerator

protected SqlScriptGenerator loadScriptGenerator

loadScripts

protected java.util.Map<java.lang.String,java.util.List<java.lang.String>> loadScripts

Constructor Detail

SqlCsvLoader

public SqlCsvLoader()

Method Detail

setStageLoadScript

public void setStageLoadScript(java.lang.String stageLoadScript)

getStageLoadScript

public java.lang.String getStageLoadScript()

load

public void load(Database conn,
                 CsvInfo info,
                 LoadMismatch onLoadMismatch)
          throws ReplicatorException

Loads a CSV file to the DBMS using an appropriate mechanism for this DBMS type.

Specified by:

load in interface CsvLoader

Parameters:

conn - JDBC connection to the DBMS

info - Information on CSV file and table to which it applies

onLoadMismatch - How to handle a mismatch between actual rows loaded to DBMS and rows in the CSV file

Throws:

ReplicatorException - Thrown if load fails

See Also:

CsvLoader.load(com.continuent.tungsten.replicator.database.Database, com.continuent.tungsten.replicator.applier.batch.CsvInfo, com.continuent.tungsten.replicator.applier.batch.LoadMismatch)