Package org.springframework.r2dbc.core

Interface ExecuteFunction

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface ExecuteFunction

Represents a function that executes a Statement for a (delayed) Result stream.

Note that discarded Result objects must be consumed according to the R2DBC spec via either Result.getRowsUpdated() or Result.map(BiFunction).

Typically, implementations invoke the Statement.execute() method to initiate execution of the statement object. For example:

 DatabaseClient.builder()
                .executeFunction(statement -> statement.execute())
                .build();
 

Since:

5.3

Author:

Mark Paluch

See Also:

• Statement.execute()

Method Summary

Modifier and Type	Method	Description
Publisher<? extends Result>	execute(Statement statement)	Execute the given Statement for a stream of Result objects.

Method Details

execute

Publisher<? extends Result> execute(Statement statement)

Execute the given Statement for a stream of Result objects.

Parameters:

statement - the request to execute

Returns:

the delayed result stream