com.northconcepts.datapipeline.jdbc.insert

Class MultiRowStatementInsert

java.lang.Object

com.northconcepts.datapipeline.core.DataObject

com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert

All Implemented Interfaces:

IInsert, Cloneable

Direct Known Subclasses:

OracleMultiRowStatementInsert

public class MultiRowStatementInsert
extends DataObject
implements IInsert

Sample Generated SQL:
INSERT INTO tableName (col1, col2, col3) VALUES
(val1, val2, val3),
(val1, val2, val3),
(val1, val2, val3),..

Field Summary

Fields

Modifier and Type	Field and Description
protected SimpleDateFormat	DATE_FORMAT
protected SimpleDateFormat	DATE_TIME_FORMAT
protected SimpleDateFormat	TIME_FORMAT

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

id, log, name, TIMESTAMP_FORMAT

Constructor Summary

Constructors

Constructor and Description
MultiRowStatementInsert()

Method Summary

Modifier and Type	Method and Description
void	addBatch()
DataException	addExceptionProperties(DataException exception) Adds this object's current state to a DataException.
MultiRowStatementInsert	clone()
void	close()
void	executeBatch()
void	executeUpdate()
protected String	getBigDecimalLiteral(BigDecimal value)
protected String	getBigIntegerLiteral(BigInteger value)
protected String	getBooleanLiteral(boolean value)
protected String	getByteLiteral(byte value)
protected String	getBytesLiteral(byte[] value)
protected String	getDateLiteral(Date value)
protected String	getDateTimeLiteral(Date value)
protected String	getDoubleLiteral(double value)
protected String	getFloatLiteral(float value)
protected StringBuilder	getInsertSql()
protected String	getInsertSqlPrefix()
protected Statement	getInsertStatement()
protected String	getIntLiteral(int value)
protected String	getLongLiteral(long value)
protected int	getRecordsPendingInsert()
protected String	getShortLiteral(short value)
protected String	getSqlValueLiteral(Field field)
protected String	getStringLiteral(String value)
protected String	getTimeLiteral(Time value)
boolean	isBatchSupported()
boolean	isDebug() Indicates if the generated SQL should be logged (default false).
void	prepare(JdbcWriter writer, Record record)
MultiRowStatementInsert	setDebug(boolean debug) Set to true to log generated SQL (default false).
protected MultiRowStatementInsert	setInsertSqlPrefix(String insertSqlPrefix)
protected MultiRowStatementInsert	setInsertStatement(Statement insertStatement)
protected MultiRowStatementInsert	setRecordsPendingInsert(int recordsPendingInsert)
void	setValues(JdbcWriter writer, Record record)

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

Field Detail

DATE_TIME_FORMAT

protected final SimpleDateFormat DATE_TIME_FORMAT

DATE_FORMAT

protected final SimpleDateFormat DATE_FORMAT

TIME_FORMAT

protected final SimpleDateFormat TIME_FORMAT

Constructor Detail

MultiRowStatementInsert

public MultiRowStatementInsert()

Method Detail

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 MultiRowStatementInsert setDebug(boolean debug)

Description copied from interface: IInsert

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

Specified by:

setDebug in interface IInsert

prepare

public void prepare(JdbcWriter writer,
                    Record record)
             throws Throwable

Specified by:

prepare in interface IInsert

Throws:

Throwable

setValues

public void setValues(JdbcWriter writer,
                      Record record)
               throws Throwable

Specified by:

setValues in interface IInsert

Throws:

Throwable

getSqlValueLiteral

protected String getSqlValueLiteral(Field field)

getStringLiteral

protected String getStringLiteral(String value)

getIntLiteral

protected String getIntLiteral(int value)

getLongLiteral

protected String getLongLiteral(long value)

getDoubleLiteral

protected String getDoubleLiteral(double value)

getBigIntegerLiteral

protected String getBigIntegerLiteral(BigInteger value)

getBigDecimalLiteral

protected String getBigDecimalLiteral(BigDecimal value)

getDateTimeLiteral

protected String getDateTimeLiteral(Date value)

getBooleanLiteral

protected String getBooleanLiteral(boolean value)

getByteLiteral

protected String getByteLiteral(byte value)

getFloatLiteral

protected String getFloatLiteral(float value)

getShortLiteral

protected String getShortLiteral(short value)

getDateLiteral

protected String getDateLiteral(Date value)

getTimeLiteral

protected String getTimeLiteral(Time value)

getBytesLiteral

protected String getBytesLiteral(byte[] value)

executeUpdate

public void executeUpdate()
                   throws Throwable

Specified by:

executeUpdate in interface IInsert

Throws:

Throwable

getInsertSqlPrefix

protected String getInsertSqlPrefix()

setInsertSqlPrefix

protected MultiRowStatementInsert setInsertSqlPrefix(String insertSqlPrefix)

getInsertSql

protected StringBuilder getInsertSql()

getInsertStatement

protected Statement getInsertStatement()

setInsertStatement

protected MultiRowStatementInsert setInsertStatement(Statement insertStatement)

getRecordsPendingInsert

protected int getRecordsPendingInsert()

setRecordsPendingInsert

protected MultiRowStatementInsert setRecordsPendingInsert(int recordsPendingInsert)

isBatchSupported

public boolean isBatchSupported()

Specified by:

isBatchSupported in interface IInsert

addBatch

public void addBatch()
              throws Throwable

Specified by:

addBatch in interface IInsert

Throws:

Throwable

executeBatch

public void executeBatch()
                  throws Throwable

Specified by:

executeBatch in interface IInsert

Throws:

Throwable

close

public void close()
           throws Throwable

Specified by:

close in interface IInsert

Throws:

Throwable

clone

public MultiRowStatementInsert clone()

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