org.springframework.r2dbc.core

public Interface ExecuteFunction

Annotations

Imports

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();

Method Summary

Modifier and Type	Method and Description
public Publisher<? extends Result>	Returns: the delayed result stream execute(Statement the request to execute statement) Execute the given `Statement` for a stream of `Result` objects.

execute back to summary

execute	back to summary
public Publisher<? extends Result> execute(Statement statement) Execute the given `Statement` for a stream of `Result` objects. Parameters statement:Statement the request to execute Returns:Publisher<? extends Result> the delayed result stream

public Publisher<? extends Result> execute(Statement statement)

Execute the given Statement for a stream of Result objects.

Parameters

Returns:Publisher<? extends Result>

the delayed result stream