Package org.jdbi.v3.sqlobject.statement.internal

Class SqlBatchHandler

java.lang.Object

org.jdbi.v3.sqlobject.statement.internal.CustomizingStatementHandler<PreparedBatch>

org.jdbi.v3.sqlobject.statement.internal.SqlBatchHandler

All Implemented Interfaces:

ExtensionHandler

public class SqlBatchHandler
extends CustomizingStatementHandler<PreparedBatch>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static interface	SqlBatchHandler.ChunkSizeFunction
private static class	SqlBatchHandler.ConstantChunkSizeFunction
private static class	SqlBatchHandler.ParamBasedChunkSizeFunction

Field Summary

Fields

Modifier and Type	Field	Description
private final SqlBatchHandler.ChunkSizeFunction	batchChunkSize
private final Function<PreparedBatch,ResultIterator<?>>	batchIntermediate
private final ResultReturner	magic
private final SqlBatch	sqlBatch

Fields inherited from interface org.jdbi.v3.core.extension.ExtensionHandler

EQUALS_HANDLER, HASHCODE_HANDLER, NULL_HANDLER

Constructor Summary

Constructors

Constructor	Description
SqlBatchHandler(Class<?> sqlObjectType, Method method)

Method Summary

Modifier and Type	Method	Description
(package private) void	configureReturner(PreparedBatch stmt, SqlObjectStatementConfiguration cfg)
(package private) PreparedBatch	createStatement(Handle handle, String locatedSql)
private SqlBatchHandler.ChunkSizeFunction	determineBatchChunkSize(Class<?> sqlObjectType, Method method)
private ResultIterator<?>	executeBatch(Handle handle, Supplier<PreparedBatch> preparedBatchSupplier)
(package private) Type	getParameterType(Parameter parameter)
private int	indexOfBatchChunkSizeParameter(Method method)
private static String	invalidReturnTypeMessage(Method method)
Object	invoke(HandleSupplier handleSupplier, Object target, Object... args)	Gets invoked to return a value for the method that this handler was bound to.
private Function<PreparedBatch,ResultIterator<?>>	mapToBoolean(Function<PreparedBatch,ResultIterator<?>> modCounts)
private static boolean	returnTypeIsValid(Class<?> type)
void	warm(ConfigRegistry config)	Called after the method handler is constructed to pre-initialize any important configuration data structures.
private Iterator<Object[]>	zipArgs(Method method, Object[] args)

Methods inherited from class org.jdbi.v3.sqlobject.statement.internal.CustomizingStatementHandler

applyCustomizers, getMethod, locateSql, rowMapperFor, rowReducerFor

Methods inherited from class java.lang.Object

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

Field Details

sqlBatch

private final SqlBatch sqlBatch

batchChunkSize

private final SqlBatchHandler.ChunkSizeFunction batchChunkSize

batchIntermediate

private final Function<PreparedBatch,ResultIterator<?>> batchIntermediate

magic

private final ResultReturner magic

Constructor Details

SqlBatchHandler

public SqlBatchHandler(Class<?> sqlObjectType,
 Method method)

Method Details

warm

public void warm(ConfigRegistry config)

Description copied from interface: ExtensionHandler

Called after the method handler is constructed to pre-initialize any important configuration data structures.

Specified by:

warm in interface ExtensionHandler

Overrides:

warm in class CustomizingStatementHandler<PreparedBatch>

Parameters:

config - the method configuration to use for warming up

mapToBoolean

private Function<PreparedBatch,ResultIterator<?>> mapToBoolean(Function<PreparedBatch,ResultIterator<?>> modCounts)

determineBatchChunkSize

private SqlBatchHandler.ChunkSizeFunction determineBatchChunkSize(Class<?> sqlObjectType,
 Method method)

indexOfBatchChunkSizeParameter

private int indexOfBatchChunkSizeParameter(Method method)

createStatement

PreparedBatch createStatement(Handle handle,
 String locatedSql)

Specified by:

createStatement in class CustomizingStatementHandler<PreparedBatch>

configureReturner

void configureReturner(PreparedBatch stmt,
 SqlObjectStatementConfiguration cfg)

Specified by:

configureReturner in class CustomizingStatementHandler<PreparedBatch>

getParameterType

Type getParameterType(Parameter parameter)

Overrides:

getParameterType in class CustomizingStatementHandler<PreparedBatch>

invoke

public Object invoke(HandleSupplier handleSupplier,
 Object target,
 Object... args)

Description copied from interface: ExtensionHandler

Gets invoked to return a value for the method that this handler was bound to.

Specified by:

invoke in interface ExtensionHandler

Overrides:

invoke in class CustomizingStatementHandler<PreparedBatch>

Parameters:

handleSupplier - A HandleSupplier instance for accessing the handle and its related objects

target - The target object on which the handler should operate

args - Optional arguments for the handler

Returns:

The return value for the method that was bound to the extension handler. Can be null

zipArgs

private Iterator<Object[]> zipArgs(Method method,
 Object[] args)

executeBatch

private ResultIterator<?> executeBatch(Handle handle,
 Supplier<PreparedBatch> preparedBatchSupplier)

returnTypeIsValid

private static boolean returnTypeIsValid(Class<?> type)

invalidReturnTypeMessage

private static String invalidReturnTypeMessage(Method method)