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

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

All Implemented Interfaces:

CsvLoader

public class VerticaCsvLoader
extends SqlCsvLoader

Implements a CSV loader that uses streaming interface available from the Vertica JDBC driver.

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

VerticaCsvLoader()

Method Summary

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

Methods inherited from class com.continuent.tungsten.replicator.applier.batch.SqlCsvLoader

getStageLoadScript, setStageLoadScript

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

VerticaCsvLoader

public VerticaCsvLoader()

Method Detail

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

Overrides:

load in class SqlCsvLoader

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)