com.northconcepts.datapipeline.jdbc.upsert

Class OracleUpsert

java.lang.Object

com.northconcepts.datapipeline.jdbc.upsert.OracleUpsert

All Implemented Interfaces:

IUpsert, Cloneable

public class OracleUpsert
extends Object
implements IUpsert

A batch-able upsert strategy that relies on the SQL Merge statement.

Does not support key-only upsert due to a restriction Oracle has placed on columns referenced in the ON clause.

See: Restrictions on the merge_update_clause.

Sample Generated SQL:
MERGE INTO tableName target USING dual ON ( ID=? )
WHEN NOT MATCHED THEN INSERT (col1, col2, col3) VALUES (?, ?, ?)
WHEN MATCHED THEN UPDATE SET col1=?, col2=?, col3=?

Constructor Summary

Constructors

Constructor and Description
OracleUpsert()

Method Summary

Modifier and Type	Method and Description
void	addBatch()
void	addExceptionProperties(DataException exception)
OracleUpsert	clone()
void	close()
void	executeBatch()
void	executeUpdate()
String	getMergeCondition()
String	getMergeSql()
PreparedStatement	getMergeStatement()
boolean	isBatchSupported()
boolean	isDebug() Indicates if the generated SQL should be logged (default false).
boolean	isTerminateWithSemicolon()
void	prepare(JdbcUpsertWriter writer, Record record)
OracleUpsert	setDebug(boolean debug) Set to true to log generated SQL (default false).
OracleUpsert	setMergeCondition(String mergeCondition)
OracleUpsert	setTerminateWithSemicolon(boolean terminateWithSemicolon)
void	setValues(JdbcUpsertWriter writer, Record record)

Methods inherited from class java.lang.Object

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

Constructor Detail

OracleUpsert

public OracleUpsert()

Method Detail

getMergeSql

public String getMergeSql()

getMergeStatement

public PreparedStatement getMergeStatement()

getMergeCondition

public String getMergeCondition()

setMergeCondition

public OracleUpsert setMergeCondition(String mergeCondition)

isTerminateWithSemicolon

public boolean isTerminateWithSemicolon()

setTerminateWithSemicolon

public OracleUpsert setTerminateWithSemicolon(boolean terminateWithSemicolon)

isDebug

public boolean isDebug()

Description copied from interface: IUpsert

Indicates if the generated SQL should be logged (default false).

Specified by:

isDebug in interface IUpsert

setDebug

public OracleUpsert setDebug(boolean debug)

Description copied from interface: IUpsert

Set to true to log generated SQL (default false).

Specified by:

setDebug in interface IUpsert

prepare

public void prepare(JdbcUpsertWriter writer,
                    Record record)
             throws Throwable

Specified by:

prepare in interface IUpsert

Throws:

Throwable

setValues

public void setValues(JdbcUpsertWriter writer,
                      Record record)
               throws Throwable

Specified by:

setValues in interface IUpsert

Throws:

Throwable

executeUpdate

public void executeUpdate()
                   throws Throwable

Specified by:

executeUpdate in interface IUpsert

Throws:

Throwable

isBatchSupported

public boolean isBatchSupported()

Specified by:

isBatchSupported in interface IUpsert

addBatch

public void addBatch()
              throws Throwable

Specified by:

addBatch in interface IUpsert

Throws:

Throwable

executeBatch

public void executeBatch()
                  throws Throwable

Specified by:

executeBatch in interface IUpsert

Throws:

Throwable

clone

public OracleUpsert clone()

Specified by:

clone in interface IUpsert

Overrides:

clone in class Object

close

public void close()
           throws Throwable

Specified by:

close in interface IUpsert

Throws:

Throwable

addExceptionProperties

public void addExceptionProperties(DataException exception)

Specified by:

addExceptionProperties in interface IUpsert