io.r2dbc.h2

Class H2Connection

java.lang.Object

io.r2dbc.h2.H2Connection

All Implemented Interfaces:

io.r2dbc.spi.Closeable, io.r2dbc.spi.Connection

public final class H2Connection
extends Object
implements io.r2dbc.spi.Connection

An implementation of Connection for connecting to an H2 database.

Method Summary

Modifier and Type	Method and Description
Mono<Void>	beginTransaction()
Mono<Void>	close()
Mono<Void>	commitTransaction()
H2Batch	createBatch()
Mono<Void>	createSavepoint(String name)
H2Statement	createStatement(String sql)
H2ConnectionMetadata	getMetadata()
io.r2dbc.spi.IsolationLevel	getTransactionIsolationLevel()
boolean	isAutoCommit()
Mono<Void>	releaseSavepoint(String name)
Mono<Void>	rollbackTransaction()
Mono<Void>	rollbackTransactionToSavepoint(String name)
Mono<Void>	setAutoCommit(boolean autoCommit)
Mono<Void>	setTransactionIsolationLevel(io.r2dbc.spi.IsolationLevel isolationLevel)
Mono<Boolean>	validate(io.r2dbc.spi.ValidationDepth depth) Validates the connection according to the given ValidationDepth.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

beginTransaction

public Mono<Void> beginTransaction()

Specified by:

beginTransaction in interface io.r2dbc.spi.Connection

close

public Mono<Void> close()

Specified by:

close in interface io.r2dbc.spi.Closeable

Specified by:

close in interface io.r2dbc.spi.Connection

commitTransaction

public Mono<Void> commitTransaction()

Specified by:

commitTransaction in interface io.r2dbc.spi.Connection

createBatch

public H2Batch createBatch()

Specified by:

createBatch in interface io.r2dbc.spi.Connection

createSavepoint

public Mono<Void> createSavepoint(String name)

Specified by:

createSavepoint in interface io.r2dbc.spi.Connection

createStatement

public H2Statement createStatement(String sql)

Specified by:

createStatement in interface io.r2dbc.spi.Connection

getTransactionIsolationLevel

public io.r2dbc.spi.IsolationLevel getTransactionIsolationLevel()

Specified by:

getTransactionIsolationLevel in interface io.r2dbc.spi.Connection

getMetadata

public H2ConnectionMetadata getMetadata()

Specified by:

getMetadata in interface io.r2dbc.spi.Connection

isAutoCommit

public boolean isAutoCommit()

Specified by:

isAutoCommit in interface io.r2dbc.spi.Connection

releaseSavepoint

public Mono<Void> releaseSavepoint(String name)

Specified by:

releaseSavepoint in interface io.r2dbc.spi.Connection

rollbackTransaction

public Mono<Void> rollbackTransaction()

Specified by:

rollbackTransaction in interface io.r2dbc.spi.Connection

rollbackTransactionToSavepoint

public Mono<Void> rollbackTransactionToSavepoint(String name)

Specified by:

rollbackTransactionToSavepoint in interface io.r2dbc.spi.Connection

setAutoCommit

public Mono<Void> setAutoCommit(boolean autoCommit)

Specified by:

setAutoCommit in interface io.r2dbc.spi.Connection

setTransactionIsolationLevel

public Mono<Void> setTransactionIsolationLevel(io.r2dbc.spi.IsolationLevel isolationLevel)

Specified by:

setTransactionIsolationLevel in interface io.r2dbc.spi.Connection

validate

public Mono<Boolean> validate(io.r2dbc.spi.ValidationDepth depth)

Validates the connection according to the given ValidationDepth.

Specified by:

validate in interface io.r2dbc.spi.Connection

Parameters:

depth - the validation depth

Returns:

a Publisher that indicates whether the validation was successful

Throws:

IllegalArgumentException - if depth is null