Module jdk.incubator.adba

Package jdk.incubator.sql2

Interface ParameterizedRowPublisherOperation<T>

Type Parameters:

T - the type of the result of this Operation

All Superinterfaces:

Operation<T>, ParameterizedOperation<T>, PrimitiveOperation<T>, RowPublisherOperation<T>

public interface ParameterizedRowPublisherOperation<T>
extends RowPublisherOperation<T>, ParameterizedOperation<T>

An Operation that accepts parameters, subscribes to a sequence of rows, and returns a result.

Method Summary

Modifier and Type	Method	Description
ParameterizedRowPublisherOperation<T>	onError(java.util.function.Consumer<java.lang.Throwable> handler)	Provides an error handler for this Operation.
ParameterizedRowPublisherOperation<T>	set(java.lang.String id, java.lang.Object value)	Set a parameter value.
ParameterizedRowPublisherOperation<T>	set(java.lang.String id, java.lang.Object value, SqlType type)	Set a parameter value.
ParameterizedRowPublisherOperation<T>	set(java.lang.String id, java.util.concurrent.CompletionStage<?> source)	Set a parameter value to be the future value of a CompletionStage.
ParameterizedRowPublisherOperation<T>	set(java.lang.String id, java.util.concurrent.CompletionStage<?> source, SqlType type)	Set a parameter value to be the value of a CompletionStage.
ParameterizedRowPublisherOperation<T>	subscribe(java.util.concurrent.Flow.Subscriber<? super Result.RowColumn> subscriber, java.util.concurrent.CompletionStage<? extends T> result)	Subscribe to the stream of rows returned by this Operation.
ParameterizedRowPublisherOperation<T>	timeout(java.time.Duration minTime)	The minimum time before this Operation might be canceled automatically.

Methods inherited from interface jdk.incubator.sql2.PrimitiveOperation

submit

Method Detail

subscribe

ParameterizedRowPublisherOperation<T> subscribe(java.util.concurrent.Flow.Subscriber<? super Result.RowColumn> subscriber,
                                                java.util.concurrent.CompletionStage<? extends T> result)

Subscribe to the stream of rows returned by this Operation. The value of the result parameter is the result of this Operation.

Specified by:

subscribe in interface RowPublisherOperation<T>

Parameters:

subscriber - Not null.

result - Not null.

Returns:

this ParameterizedRowPublisherOperation

set

ParameterizedRowPublisherOperation<T> set(java.lang.String id,
                                          java.lang.Object value,
                                          SqlType type)

Set a parameter value. The value is captured and should not be modified before the Operation is completed.

Specified by:

set in interface ParameterizedOperation<T>

Parameters:

id - the identifier of the parameter marker to be set

value - the value the parameter is to be set to

type - the SQL type of the value to send to the database

Returns:

this ParameterizedRowPublisherOperation

set

ParameterizedRowPublisherOperation<T> set(java.lang.String id,
                                          java.util.concurrent.CompletionStage<?> source,
                                          SqlType type)

Set a parameter value to be the value of a CompletionStage. The Operation will not be executed until the CompletionStage is completed. This method allows submitting Operations that depend on the result of previous Operations rather than requiring that the dependent Operation be submitted only when the previous Operation completes.

Specified by:

set in interface ParameterizedOperation<T>

Parameters:

id - the identifier of the parameter marker to be set

source - the CompletionStage that provides the value the parameter is to be set to

type - the SQL type of the value to send to the database

Returns:

this ParameterizedRowPublisherOperation

set

ParameterizedRowPublisherOperation<T> set(java.lang.String id,
                                          java.util.concurrent.CompletionStage<?> source)

Set a parameter value to be the future value of a CompletionStage. The Operation will not be executed until the CompletionStage is completed. This method allows submitting Operations that depend on the result of previous Operations rather than requiring that the dependent Operation be submitted only when the previous Operation completes. Use a default SQL type determined by the type of the value of the CompletionStage argument.

Specified by:

set in interface ParameterizedOperation<T>

Parameters:

id - the identifier of the parameter marker to be set

source - the CompletionStage that provides the value the parameter is to be set to

Returns:

this ParameterizedRowPublisherOperation

set

ParameterizedRowPublisherOperation<T> set(java.lang.String id,
                                          java.lang.Object value)

Set a parameter value. Use a default SQL type determined by the type of the value argument. The value is captured and should not be modified before the Operation is completed.

Specified by:

set in interface ParameterizedOperation<T>

Parameters:

id - the identifier of the parameter marker to be set

value - the value the parameter is to be set to

Returns:

this ParameterizedRowPublisherOperation

onError

ParameterizedRowPublisherOperation<T> onError(java.util.function.Consumer<java.lang.Throwable> handler)

Provides an error handler for this Operation. If execution of this Operation results in an error, before the Operation is completed, the handler is called with the Throwable as the argument. The type of the Throwable is implementation dependent.

Specified by:

onError in interface Operation<T>

Specified by:

onError in interface RowPublisherOperation<T>

Returns:

this ParameterizedRowPublisherOperation

timeout

ParameterizedRowPublisherOperation<T> timeout(java.time.Duration minTime)

The minimum time before this Operation might be canceled automatically. The default value is forever. The time is counted from the beginning of Operation execution. The Operation will not be canceled before minTime after the beginning of execution. Some time at least minTime after the beginning of execution, an attempt will be made to cancel the Operation if it has not yet completed. Implementations are encouraged to attempt to cancel within a reasonable time, though what is reasonable is implementation dependent.

Specified by:

timeout in interface Operation<T>

Specified by:

timeout in interface RowPublisherOperation<T>

Parameters:

minTime - minimum time to wait before attempting to cancel

Returns:

this ParameterizedRowPublisherOperation