io.r2dbc.proxy.callback

Interface ProxyFactory

public interface ProxyFactory

Defines factory methods to create proxy of SPI classes.

Author:

Tadaya Tsuyukubo

Method Summary

Modifier and Type	Method and Description
io.r2dbc.spi.Batch	wrapBatch(io.r2dbc.spi.Batch batch, ConnectionInfo connectionInfo) Create a proxy Batch.
io.r2dbc.spi.Connection	wrapConnection(io.r2dbc.spi.Connection connection, ConnectionInfo connectionInfo) Create a proxy Connection.
io.r2dbc.spi.ConnectionFactory	wrapConnectionFactory(io.r2dbc.spi.ConnectionFactory connectionFactory) Create a proxy ConnectionFactory.
io.r2dbc.spi.Result	wrapResult(io.r2dbc.spi.Result result, QueryExecutionInfo executionInfo, QueriesExecutionContext queriesExecutionContext) Create a proxy Result.
io.r2dbc.spi.Row	wrapRow(io.r2dbc.spi.Row row, QueryExecutionInfo executionInfo) Create a proxy Row.
io.r2dbc.spi.Result.RowSegment	wrapRowSegment(io.r2dbc.spi.Result.RowSegment rowSegment, QueryExecutionInfo executionInfo) Create a proxy Result.RowSegment.
io.r2dbc.spi.Statement	wrapStatement(io.r2dbc.spi.Statement statement, StatementInfo statementInfo, ConnectionInfo connectionInfo) Create a proxy Statement.

Method Detail

wrapConnectionFactory

io.r2dbc.spi.ConnectionFactory wrapConnectionFactory(io.r2dbc.spi.ConnectionFactory connectionFactory)

Create a proxy ConnectionFactory.

Parameters:

connectionFactory - original connectionFactory

Returns:

proxy connectionFactory

Throws:

IllegalArgumentException - if connectionFactory is null

wrapConnection

io.r2dbc.spi.Connection wrapConnection(io.r2dbc.spi.Connection connection,
                                       ConnectionInfo connectionInfo)

Create a proxy Connection.

Parameters:

connection - original connection

connectionInfo - connectionInfo

Returns:

proxy connection

Throws:

IllegalArgumentException - if connection is null

IllegalArgumentException - if connectionInfo is null

wrapBatch

io.r2dbc.spi.Batch wrapBatch(io.r2dbc.spi.Batch batch,
                             ConnectionInfo connectionInfo)

Create a proxy Batch.

Parameters:

batch - original batch

connectionInfo - connectionInfo

Returns:

proxy batch

Throws:

IllegalArgumentException - if batch is null

IllegalArgumentException - if connectionInfo is null

wrapStatement

io.r2dbc.spi.Statement wrapStatement(io.r2dbc.spi.Statement statement,
                                     StatementInfo statementInfo,
                                     ConnectionInfo connectionInfo)

Create a proxy Statement.

Parameters:

statement - original statement

statementInfo - contextual information of creating the Statement

connectionInfo - connectionInfo

Returns:

proxy statement

Throws:

IllegalArgumentException - if statement is null

IllegalArgumentException - if originalQuery is null

IllegalArgumentException - if updatedQuery is null

IllegalArgumentException - if connectionInfo is null

wrapResult

io.r2dbc.spi.Result wrapResult(io.r2dbc.spi.Result result,
                               QueryExecutionInfo executionInfo,
                               QueriesExecutionContext queriesExecutionContext)

Create a proxy Result.

Parameters:

result - original result

executionInfo - executionInfo

queriesExecutionContext - queries execution context

Returns:

proxy result

Throws:

IllegalArgumentException - if result is null

IllegalArgumentException - if executionInfo is null

IllegalArgumentException - if queriesExecutionContext is null

wrapRow

io.r2dbc.spi.Row wrapRow(io.r2dbc.spi.Row row,
                         QueryExecutionInfo executionInfo)

Create a proxy Row.

Parameters:

row - original row

executionInfo - executionInfo

Returns:

proxy row

Throws:

IllegalArgumentException - if row is null

IllegalArgumentException - if executionInfo is null

wrapRowSegment

io.r2dbc.spi.Result.RowSegment wrapRowSegment(io.r2dbc.spi.Result.RowSegment rowSegment,
                                              QueryExecutionInfo executionInfo)

Create a proxy Result.RowSegment.

Parameters:

rowSegment - original rowSegment

executionInfo - executionInfo

Returns:

proxy rowSegment

Throws:

IllegalArgumentException - if rowSegment is null

IllegalArgumentException - if executionInfo is null

Since:

1.1.3