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 SqlBatchHandler.ChunkSizeFunction	batchChunkSize
private java.util.function.Function<PreparedBatch,ResultIterator<?>>	batchIntermediate
private ResultReturner	magic
private SqlBatch	sqlBatch

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

EQUALS_HANDLER, HASHCODE_HANDLER, NULL_HANDLER

Constructor Summary

Constructors

Constructor	Description
SqlBatchHandler(java.lang.Class<?> sqlObjectType, java.lang.reflect.Method method)

Method Summary

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

sqlBatch

private final SqlBatch sqlBatch

batchChunkSize

private final SqlBatchHandler.ChunkSizeFunction batchChunkSize

batchIntermediate

private final java.util.function.Function<PreparedBatch,ResultIterator<?>> batchIntermediate

magic

private final ResultReturner magic

Constructor Detail

SqlBatchHandler

public SqlBatchHandler(java.lang.Class<?> sqlObjectType,
                       java.lang.reflect.Method method)

Method Detail

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 java.util.function.Function<PreparedBatch,ResultIterator<?>> mapToBoolean(java.util.function.Function<PreparedBatch,ResultIterator<?>> modCounts)

determineBatchChunkSize

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

indexOfBatchChunkSizeParameter

private int indexOfBatchChunkSizeParameter(java.lang.reflect.Method method)

createStatement

PreparedBatch createStatement(Handle handle,
                              java.lang.String locatedSql)

Specified by:

createStatement in class CustomizingStatementHandler<PreparedBatch>

configureReturner

void configureReturner(PreparedBatch stmt,
                       SqlObjectStatementConfiguration cfg)

Specified by:

configureReturner in class CustomizingStatementHandler<PreparedBatch>

getParameterType

java.lang.reflect.Type getParameterType(java.lang.reflect.Parameter parameter)

Overrides:

getParameterType in class CustomizingStatementHandler<PreparedBatch>

invoke

public java.lang.Object invoke(HandleSupplier handleSupplier,
                               java.lang.Object target,
                               java.lang.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 java.util.Iterator<java.lang.Object[]> zipArgs(java.lang.reflect.Method method,
                                                       java.lang.Object[] args)

executeBatch

private ResultIterator<?> executeBatch(Handle handle,
                                       java.util.function.Supplier<PreparedBatch> preparedBatchSupplier)

returnTypeIsValid

private static boolean returnTypeIsValid(java.lang.Class<?> type)

invalidReturnTypeMessage

private static java.lang.String invalidReturnTypeMessage(java.lang.reflect.Method method)