io.r2dbc.spi

Interface Connection

public interface Connection

A single connection to a database.

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Publisher<Void>	beginTransaction() Begins a new transaction.
org.reactivestreams.Publisher<Void>	close() Release any resources held by the Connection.
org.reactivestreams.Publisher<Void>	commitTransaction() Commits the current transaction.
Batch	createBatch() Creates a new Batch instance for building a batched request.
org.reactivestreams.Publisher<Void>	createSavepoint(String name) Creates a savepoint in the current transaction.
Statement	createStatement(String sql) Creates a new statement for building a statement-based request.
org.reactivestreams.Publisher<Void>	releaseSavepoint(String name) Releases a savepoint in the current transaction.
org.reactivestreams.Publisher<Void>	rollbackTransaction() Rolls back the current transaction.
org.reactivestreams.Publisher<Void>	rollbackTransactionToSavepoint(String name) Rolls back to a savepoint in the current transaction.
org.reactivestreams.Publisher<Void>	setTransactionIsolationLevel(IsolationLevel isolationLevel) Configures the isolation level for the current transaction.

Method Detail

beginTransaction

org.reactivestreams.Publisher<Void> beginTransaction()

Begins a new transaction.

Returns:

a Publisher that indicates that the transaction is open

close

org.reactivestreams.Publisher<Void> close()

Release any resources held by the Connection.

Returns:

a Publisher that termination is complete

commitTransaction

org.reactivestreams.Publisher<Void> commitTransaction()

Commits the current transaction.

Returns:

a Publisher that indicates that a transaction has been committed

createBatch

Batch createBatch()

Creates a new Batch instance for building a batched request.

Returns:

a new Batch instance

createSavepoint

org.reactivestreams.Publisher<Void> createSavepoint(String name)

Creates a savepoint in the current transaction.

Parameters:

name - the name of the savepoint to create

Returns:

a Publisher that indicates that a savepoint has been created

Throws:

IllegalArgumentException - if name is null

createStatement

Statement createStatement(String sql)

Creates a new statement for building a statement-based request.

Parameters:

sql - the SQL of the statement

Returns:

a new Statement instance

Throws:

IllegalArgumentException - if sql is null

releaseSavepoint

org.reactivestreams.Publisher<Void> releaseSavepoint(String name)

Releases a savepoint in the current transaction.

Parameters:

name - the name of the savepoint to release

Returns:

a Publisher that indicates that a savepoint has been released

Throws:

IllegalArgumentException - if name is null

rollbackTransaction

org.reactivestreams.Publisher<Void> rollbackTransaction()

Rolls back the current transaction.

Returns:

a Publisher that indicates that a transaction has been rolled back

rollbackTransactionToSavepoint

org.reactivestreams.Publisher<Void> rollbackTransactionToSavepoint(String name)

Rolls back to a savepoint in the current transaction.

Parameters:

name - the name of the savepoint to rollback to

Returns:

a Publisher that indicates that a savepoint has been rolled back to

Throws:

IllegalArgumentException - if name is null

setTransactionIsolationLevel

org.reactivestreams.Publisher<Void> setTransactionIsolationLevel(IsolationLevel isolationLevel)

Configures the isolation level for the current transaction.

Parameters:

isolationLevel - the isolation level for this transaction

Returns:

a Publisher that indicates that a transaction level has been configured

Throws:

IllegalArgumentException - if isolationLevel is null