Module org.itsallcode.jdbc

Package org.itsallcode.jdbc.batch

Class RowPreparedStatementBatchBuilder<T>

java.lang.Object

org.itsallcode.jdbc.batch.RowPreparedStatementBatchBuilder<T>

Type Parameters:

T - row type

public class RowPreparedStatementBatchBuilder<T>
extends Object

Builder for PreparedStatement batch jobs for a Stream or Iterable of row objects using e.g. INSERT or UPDATE statements.

Create a new instance using DbOperations.preparedStatementBatch(Class).

Constructor Summary

Constructors

Constructor	Description
RowPreparedStatementBatchBuilder(Function<String,SimplePreparedStatement> statementFactory)	Create a new instance.

Method Summary

Modifier and Type	Method	Description
RowPreparedStatementBatchBuilder<T>	into(String tableName, List<String> columnNames)	Define table and column names used for generating the INSERT statement.
RowPreparedStatementBatchBuilder<T>	into(Identifier tableName, List<Identifier> columnNames)	Define table and column names used for generating the INSERT statement.
RowPreparedStatementBatchBuilder<T>	mapping(ParamConverter<T> rowMapper)	Define mapping how rows are converted to Object[] for inserting.
RowPreparedStatementBatchBuilder<T>	mapping(RowPreparedStatementSetter<T> preparedStatementSetter)	Define RowPreparedStatementSetter that sets values of a PreparedStatement for each row.
RowPreparedStatementBatchBuilder<T>	maxBatchSize(int maxBatchSize)	Define maximum batch size, using PreparedStatementBatchBuilder.DEFAULT_MAX_BATCH_SIZE as default.
RowPreparedStatementBatchBuilder<T>	rows(Iterator<T> rows)	Define Iterator of rows to insert.
RowPreparedStatementBatchBuilder<T>	rows(Stream<T> rows)	Define Stream of rows to insert.
RowPreparedStatementBatchBuilder<T>	sql(String sql)	Define the SQL statement to be used for the batch job, e.g.
void	start()	Start the batch insert process using the given rows.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RowPreparedStatementBatchBuilder

public RowPreparedStatementBatchBuilder(Function<String,SimplePreparedStatement> statementFactory)

Create a new instance.

Parameters:

statementFactory - factory for creating SimplePreparedStatement

Method Details

sql

public RowPreparedStatementBatchBuilder<T> sql(String sql)

Define the SQL statement to be used for the batch job, e.g. INSERT or UPDATE.

Parameters:

sql - SQL statement

Returns:

this for fluent programming

into

public RowPreparedStatementBatchBuilder<T> into(Identifier tableName,
 List<Identifier> columnNames)

Define table and column names used for generating the INSERT statement.

Parameters:

tableName - table name

columnNames - column names

Returns:

this for fluent programming

into

public RowPreparedStatementBatchBuilder<T> into(String tableName,
 List<String> columnNames)

Define table and column names used for generating the INSERT statement.

Parameters:

tableName - table name

columnNames - column names

Returns:

this for fluent programming

rows

public RowPreparedStatementBatchBuilder<T> rows(Stream<T> rows)

Define Stream of rows to insert.

Parameters:

rows - rows to insert

Returns:

this for fluent programming

rows

public RowPreparedStatementBatchBuilder<T> rows(Iterator<T> rows)

Define Iterator of rows to insert.

Parameters:

rows - rows to insert

Returns:

this for fluent programming

mapping

public RowPreparedStatementBatchBuilder<T> mapping(ParamConverter<T> rowMapper)

Define mapping how rows are converted to Object[] for inserting.

Parameters:

rowMapper - row mapper

Returns:

this for fluent programming

mapping

public RowPreparedStatementBatchBuilder<T> mapping(RowPreparedStatementSetter<T> preparedStatementSetter)

Define RowPreparedStatementSetter that sets values of a PreparedStatement for each row.

Parameters:

preparedStatementSetter - prepared statement setter

Returns:

this for fluent programming

maxBatchSize

public RowPreparedStatementBatchBuilder<T> maxBatchSize(int maxBatchSize)

Define maximum batch size, using PreparedStatementBatchBuilder.DEFAULT_MAX_BATCH_SIZE as default.

Parameters:

maxBatchSize - maximum batch size

Returns:

this for fluent programming

start

public void start()

Start the batch insert process using the given rows.