com.northconcepts.datapipeline.jdbc.upsert

Class PostgreSqlUpsert

java.lang.Object

com.northconcepts.datapipeline.jdbc.upsert.PostgreSqlUpsert

All Implemented Interfaces:

IUpsert, Cloneable

public class PostgreSqlUpsert
extends Object
implements IUpsert

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

Sample Generated SQL:
INSERT INTO tableName (col1, col2, col3) VALUES (?, ?, ?)
ON CONFLICT (ID) DO UPDATE SET col1=?, col2=?, col3=?

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PostgreSqlUpsert.ConflictAction

Constructor Summary

Constructors

Constructor and Description
PostgreSqlUpsert()

Method Summary

Modifier and Type	Method and Description
void	addBatch()
void	addExceptionProperties(DataException exception)
PostgreSqlUpsert	clone()
void	close()
void	executeBatch()
void	executeUpdate()
PostgreSqlUpsert.ConflictAction	getConflictAction() Returns the action to perform on conflict (default ConflictAction.UPDATE).
String	getInsertSql()
String	getUpsertSql()
PreparedStatement	getUpsertStatement()
boolean	isBatchSupported()
boolean	isDebug() Indicates if the generated SQL should be logged (default false).
void	prepare(JdbcUpsertWriter writer, Record record)
PostgreSqlUpsert	setConflictAction(PostgreSqlUpsert.ConflictAction conflictAction) Indicates the action to perform on conflict (default ConflictAction.UPDATE).
PostgreSqlUpsert	setDebug(boolean debug) Set to true to log generated SQL (default false).
void	setUpsertSql(String upsertSql)
void	setUpsertStatement(PreparedStatement upsertStatement)
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

PostgreSqlUpsert

public PostgreSqlUpsert()

Method Detail

getInsertSql

public String getInsertSql()

getUpsertSql

public String getUpsertSql()

setUpsertSql

public void setUpsertSql(String upsertSql)

getUpsertStatement

public PreparedStatement getUpsertStatement()

setUpsertStatement

public void setUpsertStatement(PreparedStatement upsertStatement)

getConflictAction

public PostgreSqlUpsert.ConflictAction getConflictAction()

Returns the action to perform on conflict (default ConflictAction.UPDATE).

setConflictAction

public PostgreSqlUpsert setConflictAction(PostgreSqlUpsert.ConflictAction conflictAction)

Indicates the action to perform on conflict (default ConflictAction.UPDATE).

isDebug

public boolean isDebug()

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

Specified by:

isDebug in interface IUpsert

setDebug

public PostgreSqlUpsert 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 PostgreSqlUpsert 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