pack-priv final Class ResultFunction

Class Inheritance

extends Object
implements ConnectionFunction<Flux<Result>>

java.lang.Object
org.springframework.r2dbc.core.ResultFunction

All Implemented Interfaces

org.springframework.r2dbc.core.ConnectionFunction, org.springframework.r2dbc.core.SqlProvider, java.util.function.Function

Imports

java.util.function.BiFunction, .Supplier, io.r2dbc.spi.Connection, .Result, .Statement, reactor.core.publisher.Flux, org.springframework.lang.Nullable, org.springframework.util.Assert, .StringUtils

A ConnectionFunction that produces a Flux of Result and that defers generation of the SQL until the function has been applied. Beforehand, the getSql() method simply returns null. The sql String is also memoized during application, so that subsequent calls to getSql() return the same String without further calls to the Supplier.

Authors: Mark Paluch, Simon Baslé
Since: 5.3.26

Field Summary

Modifier and Type	Field and Description
pack-priv final ExecuteFunction	executeFunction
pack-priv final StatementFilterFunction	filterFunction
pack-priv String	resolvedSql
pack-priv final Supplier<String>	sqlSupplier
pack-priv final BiFunction<Connection, String, Statement>	statementFunction

Constructor Summary

Access	Constructor and Description
pack-priv	ResultFunction(Supplier<String> sqlSupplier, BiFunction<Connection, String, Statement> statementFunction, StatementFilterFunction filterFunction, ExecuteFunction executeFunction)

Method Summary

Modifier and Type	Method and Description
public Flux<Result>	apply(Connection the function argument connection) Implements java.util.function.Function.apply. Applies this function to the given argument.
public String	getSql() Implements org.springframework.r2dbc.core.SqlProvider.getSql. Return the SQL string for this object, i.e. typically the SQL used for creating statements.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

executeFunction	back to summary
pack-priv final ExecuteFunction executeFunction

filterFunction	back to summary
pack-priv final StatementFilterFunction filterFunction

resolvedSql	back to summary
pack-priv String resolvedSql Annotations @Nullable

sqlSupplier	back to summary
pack-priv final Supplier<String> sqlSupplier

statementFunction	back to summary
pack-priv final BiFunction<Connection, String, Statement> statementFunction

Constructor Detail

ResultFunction	back to summary
pack-priv ResultFunction(Supplier<String> sqlSupplier, BiFunction<Connection, String, Statement> statementFunction, StatementFilterFunction filterFunction, ExecuteFunction executeFunction)

Method Detail

apply	back to summary
public Flux<Result> apply(Connection connection) Implements java.util.function.Function.apply. Doc from java.util.function.Function.apply. Applies this function to the given argument. Parameters connection:Connection the function argument Returns:Flux<Result> the function result Annotations @Override

apply

back to summary

public Flux<Result> apply(Connection connection)

Implements java.util.function.Function.apply.

Doc from java.util.function.Function.apply.

Applies this function to the given argument.

Parameters

connection:Connection: the function argument

Returns:Flux<Result>

the function result

Annotations

@Override

getSql back to summary

getSql	back to summary
public String getSql() Implements org.springframework.r2dbc.core.SqlProvider.getSql. Doc from org.springframework.r2dbc.core.SqlProvider.getSql. Return the SQL string for this object, i.e. typically the SQL used for creating statements. Returns:String the SQL string, or `null` if not available Annotations @Nullable @Override

public String getSql()

Implements org.springframework.r2dbc.core.SqlProvider.getSql.

Doc from org.springframework.r2dbc.core.SqlProvider.getSql.

Return the SQL string for this object, i.e. typically the SQL used for creating statements.

Returns:String

the SQL string, or null if not available

Annotations

@Nullable
@Override