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

Description

static enum

PostgreSqlUpsert.ConflictAction

The action taken when an insert conflicts on the key fields: update the existing row or do nothing.
Constructor Summary

Constructors

Constructor

Description

PostgreSqlUpsert()
Method Summary

Modifier and Type

Method

Description

void

addBatch()

Adds the applied values to the batch; called instead of IUpsert.executeUpdate() when the writer is batching.

void

addExceptionProperties(DataException exception)

Adds this strategy's details, such as the generated SQL, to the exception.

PostgreSqlUpsert

clone()

Returns a new, unprepared copy with the same settings; JdbcMultiUpsertWriter uses one for each connection.

void

close()

Releases the statement(s); called when the writer is closed.

void

executeBatch()

Executes the batch; called each time the writer's batch size is reached and on close if records remain.

void

executeUpdate()

Executes the upsert with the values applied; called after each record when the writer is not batching.

PostgreSqlUpsert.ConflictAction

getConflictAction()

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

String

getInsertSql()

Returns the INSERT part of the generated SQL or null before prepare(JdbcUpsertWriter, Record) is called.

String

getUpsertSql()

Returns the generated INSERT ... ON CONFLICT SQL or null before prepare(JdbcUpsertWriter, Record) is called.

PreparedStatement

getUpsertStatement()

Returns the prepared upsert statement or null before prepare(JdbcUpsertWriter, Record) is called.

boolean

isBatchSupported()

Returns true if IUpsert.addBatch() and IUpsert.executeBatch() are supported; otherwise JdbcUpsertWriter.setBatchSize(int) rejects batch sizes above 1.

boolean

isDebug()

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

void

prepare(JdbcUpsertWriter writer, Record record)

Called once, with the first record written, to generate the SQL and create the statement(s).

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)

Applies the record's values to the pending statement(s); called for every record written.

Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- PostgreSqlUpsert
  
  public PostgreSqlUpsert()
Method Details
- getInsertSql
  
  public String getInsertSql()
  
  Returns the INSERT part of the generated SQL or null before prepare(JdbcUpsertWriter, Record) is called.
- getUpsertSql
  
  public String getUpsertSql()
  
  Returns the generated INSERT ... ON CONFLICT SQL or null before prepare(JdbcUpsertWriter, Record) is called.
- setUpsertSql
  
  public void setUpsertSql(String upsertSql)
- getUpsertStatement
  
  public PreparedStatement getUpsertStatement()
  
  Returns the prepared upsert statement or null before prepare(JdbcUpsertWriter, Record) is called.
- 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
  
  Description copied from interface: IUpsert
  
  Called once, with the first record written, to generate the SQL and create the statement(s).
  
  Specified by:
  
  prepare in interface IUpsert
  
  Throws:
  
  Throwable
- setValues
  
  public void setValues(JdbcUpsertWriter writer, Record record) throws Throwable
  
  Description copied from interface: IUpsert
  
  Applies the record's values to the pending statement(s); called for every record written.
  
  Specified by:
  
  setValues in interface IUpsert
  
  Throws:
  
  Throwable
- executeUpdate
  
  public void executeUpdate() throws Throwable
  
  Description copied from interface: IUpsert
  
  Executes the upsert with the values applied; called after each record when the writer is not batching.
  
  Specified by:
  
  executeUpdate in interface IUpsert
  
  Throws:
  
  Throwable
- isBatchSupported
  
  public boolean isBatchSupported()
  
  Description copied from interface: IUpsert
  
  Returns true if IUpsert.addBatch() and IUpsert.executeBatch() are supported; otherwise JdbcUpsertWriter.setBatchSize(int) rejects batch sizes above 1.
  
  Specified by:
  
  isBatchSupported in interface IUpsert
- addBatch
  
  public void addBatch() throws Throwable
  
  Description copied from interface: IUpsert
  
  Adds the applied values to the batch; called instead of IUpsert.executeUpdate() when the writer is batching.
  
  Specified by:
  
  addBatch in interface IUpsert
  
  Throws:
  
  Throwable
- executeBatch
  
  public void executeBatch() throws Throwable
  
  Description copied from interface: IUpsert
  
  Executes the batch; called each time the writer's batch size is reached and on close if records remain.
  
  Specified by:
  
  executeBatch in interface IUpsert
  
  Throws:
  
  Throwable
- clone
  
  public PostgreSqlUpsert clone()
  
  Description copied from interface: IUpsert
  
  Returns a new, unprepared copy with the same settings; JdbcMultiUpsertWriter uses one for each connection.
  
  Specified by:
  
  clone in interface IUpsert
  
  Overrides:
  
  clone in class Object
- close
  
  public void close() throws Throwable
  
  Description copied from interface: IUpsert
  
  Releases the statement(s); called when the writer is closed.
  
  Specified by:
  
  close in interface IUpsert
  
  Throws:
  
  Throwable
- addExceptionProperties
  
  public void addExceptionProperties(DataException exception)
  
  Description copied from interface: IUpsert
  
  Adds this strategy's details, such as the generated SQL, to the exception.
  
  Specified by:
  
  addExceptionProperties in interface IUpsert

Class PostgreSqlUpsert

Nested Class Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Details

PostgreSqlUpsert

Method Details

getInsertSql

getUpsertSql

setUpsertSql

getUpsertStatement

setUpsertStatement

getConflictAction

setConflictAction

isDebug

setDebug

prepare

setValues

executeUpdate

isBatchSupported

addBatch

executeBatch

clone

close

addExceptionProperties