java.lang.Object

com.northconcepts.datapipeline.core.DataObject

com.northconcepts.datapipeline.jdbc.insert.MultiRowPreparedStatementInsert

All Implemented Interfaces:: IInsert, Cloneable

public class MultiRowPreparedStatementInsert extends DataObject implements IInsert

Sample Generated SQL:
INSERT INTO tableName (col1, col2, col3) VALUES (?, ?, ?), (?, ?, ?), (?, ?, ?),...

Field Summary

Fields inherited from class com.northconcepts.datapipeline.core.DataObject
id, log, name, TIMESTAMP_FORMAT
Constructor Summary

Constructors

Constructor

Description

MultiRowPreparedStatementInsert()
Method Summary

Modifier and Type

Method

Description

void

addBatch()

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

DataException

addExceptionProperties(DataException exception)

Adds this object's current state to a DataException.

protected String

buildSql(JdbcWriter writer, Record record, int rowCount)

Returns the INSERT SQL with rowCount rows of ? placeholders, using the record's field names as columns.

MultiRowPreparedStatementInsert

clone()

Returns a new, unprepared copy with the same settings; JdbcMultiWriter 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 statement with the values applied; called after each record when the writer is not batching.

boolean

isBatchSupported()

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

boolean

isDebug()

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

void

prepare(JdbcWriter writer, Record record)

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

MultiRowPreparedStatementInsert

setDebug(boolean debug)

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

void

setValues(JdbcWriter writer, Record record)

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

Methods inherited from class com.northconcepts.datapipeline.core.DataObject
exception, exception, exception, getId, getName, resetID, toString

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

Constructor Details
- MultiRowPreparedStatementInsert
  
  public MultiRowPreparedStatementInsert()
Method Details
- isDebug
  
  public boolean isDebug()
  
  Description copied from interface: IInsert
  
  Indicates if the generated SQL should be logged (default false).
  
  Specified by:
  
  isDebug in interface IInsert
- setDebug
  
  public MultiRowPreparedStatementInsert setDebug(boolean debug)
  
  Description copied from interface: IInsert
  
  Set to true to log generated SQL (default false).
  
  Specified by:
  
  setDebug in interface IInsert
- buildSql
  
  protected String buildSql(JdbcWriter writer, Record record, int rowCount) throws Throwable
  
  Returns the INSERT SQL with rowCount rows of ? placeholders, using the record's field names as columns.
  
  Throws:
  
  Throwable
- prepare
  
  public void prepare(JdbcWriter writer, Record record) throws Throwable
  
  Description copied from interface: IInsert
  
  Called once, with the first record written, to generate the SQL and create the statement(s).
  
  Specified by:
  
  prepare in interface IInsert
  
  Throws:
  
  Throwable
- setValues
  
  public void setValues(JdbcWriter writer, Record record) throws Throwable
  
  Description copied from interface: IInsert
  
  Applies the record's values to the pending statement; called for every record written.
  
  Specified by:
  
  setValues in interface IInsert
  
  Throws:
  
  Throwable
- executeUpdate
  
  public void executeUpdate() throws Throwable
  
  Description copied from interface: IInsert
  
  Executes the statement with the values applied; called after each record when the writer is not batching.
  
  Specified by:
  
  executeUpdate in interface IInsert
  
  Throws:
  
  Throwable
- isBatchSupported
  
  public boolean isBatchSupported()
  
  Description copied from interface: IInsert
  
  Returns true if IInsert.addBatch() and IInsert.executeBatch() are supported; otherwise JdbcWriter.setBatchSize(int) rejects batch sizes above 1.
  
  Specified by:
  
  isBatchSupported in interface IInsert
- addBatch
  
  public void addBatch() throws Throwable
  
  Description copied from interface: IInsert
  
  Adds the applied values to the batch; called instead of IInsert.executeUpdate() when the writer is batching.
  
  Specified by:
  
  addBatch in interface IInsert
  
  Throws:
  
  Throwable
- executeBatch
  
  public void executeBatch() throws Throwable
  
  Description copied from interface: IInsert
  
  Executes the batch; called each time the writer's batch size is reached and on close if records remain.
  
  Specified by:
  
  executeBatch in interface IInsert
  
  Throws:
  
  Throwable
- close
  
  public void close() throws Throwable
  
  Description copied from interface: IInsert
  
  Releases the statement(s); called when the writer is closed.
  
  Specified by:
  
  close in interface IInsert
  
  Throws:
  
  Throwable
- clone
  
  public MultiRowPreparedStatementInsert clone()
  
  Description copied from interface: IInsert
  
  Returns a new, unprepared copy with the same settings; JdbcMultiWriter uses one for each connection.
  
  Specified by:
  
  clone in interface IInsert
  
  Overrides:
  
  clone in class Object
- addExceptionProperties
  
  public DataException addExceptionProperties(DataException exception)
  
  Description copied from class: DataObject
  
  Adds this object's current state to a DataException. Since this method is called whenever an exception is thrown, subclasses should override it to add their specific information.
  
  Specified by:
  
  addExceptionProperties in interface IInsert
  
  Overrides:
  
  addExceptionProperties in class DataObject

Class MultiRowPreparedStatementInsert

Field Summary

Fields inherited from class com.northconcepts.datapipeline.core.DataObject

Constructor Summary

Method Summary

Methods inherited from class com.northconcepts.datapipeline.core.DataObject

Methods inherited from class java.lang.Object

Constructor Details

MultiRowPreparedStatementInsert

Method Details

isDebug

setDebug

buildSql

prepare

setValues

executeUpdate

isBatchSupported

addBatch

executeBatch

close

clone

addExceptionProperties