java.lang.Object

com.northconcepts.datapipeline.core.DataObject

com.northconcepts.datapipeline.jdbc.insert.PreparedStatementInsert

All Implemented Interfaces:: IInsert, Cloneable

Direct Known Subclasses:: MySqlPreparedStatementInsert

public class PreparedStatementInsert 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

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

PreparedStatementInsert

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

PreparedStatementInsert

setDebug(boolean debug)

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

protected PreparedStatementInsert

setInsertStatement(PreparedStatement insertStatement)

Replaces the statement that values are bound to and executed on; for subclasses that prepare their own SQL.

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
- PreparedStatementInsert
  
  public PreparedStatementInsert()
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 PreparedStatementInsert setDebug(boolean debug)
  
  Description copied from interface: IInsert
  
  Set to true to log generated SQL (default false).
  
  Specified by:
  
  setDebug in interface IInsert
- setInsertStatement
  
  protected PreparedStatementInsert setInsertStatement(PreparedStatement insertStatement)
  
  Replaces the statement that values are bound to and executed on; for subclasses that prepare their own SQL.
- 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 PreparedStatementInsert 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 PreparedStatementInsert

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

PreparedStatementInsert

Method Details

isDebug

setDebug

setInsertStatement

prepare

setValues

executeUpdate

isBatchSupported

addBatch

executeBatch

close

clone

addExceptionProperties