com.northconcepts.datapipeline.jdbc.upsert

Class GenericUpsert

java.lang.Object

com.northconcepts.datapipeline.jdbc.upsert.GenericUpsert

All Implemented Interfaces:

IUpsert, Cloneable

public class GenericUpsert
extends Object
implements IUpsert

An upsert strategy that attempts to either:

1. "insert" and then "update" if SQLIntegrityConstraintViolationException is thrown or
2. update and then insert if no records were affected.

Sample Generated SQL:
Insert SQL: INSERT INTO tableName (col1, col2, col3) VALUES (?, ?, ?)
Update SQL: UPDATE tableName SET col1=?, col2=?, col3=? WHERE ID=?

Constructor Summary

Constructors

Constructor and Description
GenericUpsert()

Method Summary

Modifier and Type	Method and Description
void	addBatch()
void	addExceptionProperties(DataException exception)
GenericUpsert	clone()
void	close()
void	executeBatch()
void	executeUpdate()
String	getInsertSql()
PreparedStatement	getInsertStatement()
String	getUpdateSql()
PreparedStatement	getUpdateStatement()
boolean	isBatchSupported()
boolean	isDebug() Indicates if the generated SQL should be logged (default false).
boolean	isInsertFirst() Indicates if an insert should be attempted before and update (the default) or false if the update should be attempted first.
void	prepare(JdbcUpsertWriter writer, Record record)
GenericUpsert	setDebug(boolean debug) Set to true to log generated SQL (default false).
GenericUpsert	setInsertFirst(boolean insertFirst) Indicates if this upsert strategy should attempt an insert before and update (the default).
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

GenericUpsert

public GenericUpsert()

Method Detail

isInsertFirst

public boolean isInsertFirst()

Indicates if an insert should be attempted before and update (the default) or false if the update should be attempted first.

setInsertFirst

public GenericUpsert setInsertFirst(boolean insertFirst)

Indicates if this upsert strategy should attempt an insert before and update (the default). Passing in false will cause an update to be attempted first followed by an insert if 0 records were affected by the update.

getInsertSql

public String getInsertSql()

getInsertStatement

public PreparedStatement getInsertStatement()

getUpdateSql

public String getUpdateSql()

getUpdateStatement

public PreparedStatement getUpdateStatement()

isDebug

public boolean isDebug()

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

Specified by:

isDebug in interface IUpsert

setDebug

public GenericUpsert setDebug(boolean debug)

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 GenericUpsert 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