com.northconcepts.datapipeline.jdbc.upsert.VariableFieldsUpsert

All Implemented Interfaces:: IUpsert, Cloneable

public class VariableFieldsUpsert extends Object implements IUpsert

A upsert strategy that wraps another strategy to support a variable set of fields. This allows you to upsert some records with just ID + FIRST_NAME, others with ID + LAST_NAME + ADDRESS, or any other sets of fields

Nested Class Summary

Nested Classes

Modifier and Type

Class

Description

static interface

VariableFieldsUpsert.IUpsertFactory

Creates the strategy used for each distinct sequence of field names.

static class

VariableFieldsUpsert.UpsertStub

Pairs a strategy with the number of records it has upserted.
Constructor Summary

Constructors

Constructor

Description

VariableFieldsUpsert(VariableFieldsUpsert.IUpsertFactory factory)

Creates an upsert that asks the factory for a new strategy for each distinct sequence of field names.

VariableFieldsUpsert(Class<? extends IUpsert> upsertType)

Creates an upsert that instantiates upsertType (via its no-arg constructor) for each distinct sequence of field names.
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.

VariableFieldsUpsert

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.

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).

VariableFieldsUpsert

setDebug(boolean debug)

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

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
- VariableFieldsUpsert
  
  public VariableFieldsUpsert(VariableFieldsUpsert.IUpsertFactory factory)
  
  Creates an upsert that asks the factory for a new strategy for each distinct sequence of field names.
- VariableFieldsUpsert
  
  public VariableFieldsUpsert(Class<? extends IUpsert> upsertType)
  
  Creates an upsert that instantiates upsertType (via its no-arg constructor) for each distinct sequence of field names.
Method Details
- 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 VariableFieldsUpsert 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
  
  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 VariableFieldsUpsert 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 VariableFieldsUpsert

Nested Class Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Details

VariableFieldsUpsert

VariableFieldsUpsert

Method Details

isDebug

setDebug

prepare

setValues

executeUpdate

isBatchSupported

addBatch

executeBatch

clone

close

addExceptionProperties