io.r2dbc.proxy.callback

Class ProxyUtils

java.lang.Object

io.r2dbc.proxy.callback.ProxyUtils

public class ProxyUtils
extends Object

Utility methods to obtain original Connection from proxy class.

Author:

Tadaya Tsuyukubo

Method Summary

Modifier and Type	Method and Description
static Optional<io.r2dbc.spi.Connection>	unwrapConnection(io.r2dbc.spi.Batch batch) Get original Connection from proxy Batch.
static Optional<io.r2dbc.spi.Connection>	unwrapConnection(io.r2dbc.spi.Connection connection) Get original Connection if given Connection has implemented Wrapped.
static Optional<io.r2dbc.spi.Connection>	unwrapConnection(io.r2dbc.spi.Result result) Get original Connection from proxy Result.
static Optional<io.r2dbc.spi.Connection>	unwrapConnection(io.r2dbc.spi.Statement statement) Get original Connection from proxy Statement.

Methods inherited from class java.lang.Object

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

Method Detail

unwrapConnection

public static Optional<io.r2dbc.spi.Connection> unwrapConnection(io.r2dbc.spi.Connection connection)

Get original Connection if given Connection has implemented Wrapped.

Parameters:

connection - a connection

Returns:

optional of original connection or give connection

Throws:

IllegalArgumentException - if connection is null

unwrapConnection

public static Optional<io.r2dbc.spi.Connection> unwrapConnection(io.r2dbc.spi.Batch batch)

Get original Connection from proxy Batch. When provided Batch is a proxy that implements ConnectionHolder, retrieves original Connection; otherwise, returns empty Optional.

Parameters:

batch - a batch

Returns:

optional of original connection or empty

Throws:

IllegalArgumentException - if batch is null

unwrapConnection

public static Optional<io.r2dbc.spi.Connection> unwrapConnection(io.r2dbc.spi.Statement statement)

Get original Connection from proxy Statement. When provided Statement is a proxy that implements ConnectionHolder, retrieves original Connection; otherwise, returns empty Optional.

Parameters:

statement - a statement

Returns:

optional of original connection or empty

Throws:

IllegalArgumentException - if statement is null

unwrapConnection

public static Optional<io.r2dbc.spi.Connection> unwrapConnection(io.r2dbc.spi.Result result)

Get original Connection from proxy Result. When provided Result is a proxy that implements ConnectionHolder, retrieves original Connection; otherwise, returns empty Optional.

Parameters:

result - a statement

Returns:

optional of original connection or empty

Throws:

IllegalArgumentException - if result is null