Package org.infinispan.persistence.jdbc.common.sql

Class BaseTableOperations.FlowableConnection

java.lang.Object

org.infinispan.persistence.jdbc.common.sql.BaseTableOperations.FlowableConnection

Enclosing class:

BaseTableOperations<K,V>

protected static class BaseTableOperations.FlowableConnection
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final boolean	autoCommit
protected final Connection	connection
protected final Consumer<Connection>	connectionCloser
protected final PreparedStatement	statement

Constructor Summary

Constructors

Constructor	Description
FlowableConnection(Connection connection, Consumer<Connection> connectionCloser, String sql)

Method Summary

Modifier and Type	Method	Description
void	close()
Connection	getConnection()
Consumer<Connection>	getConnectionCloser()
PreparedStatement	getStatement()
boolean	isAutoCommit()

Methods inherited from class java.lang.Object

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

Field Details

autoCommit

protected final boolean autoCommit

connection

protected final Connection connection

connectionCloser

protected final Consumer<Connection> connectionCloser

statement

protected final PreparedStatement statement

Constructor Details

FlowableConnection

public FlowableConnection(Connection connection,
 Consumer<Connection> connectionCloser,
 String sql)
                   throws SQLException

Throws:

SQLException

Method Details

isAutoCommit

public boolean isAutoCommit()

getConnection

public Connection getConnection()

getConnectionCloser

public Consumer<Connection> getConnectionCloser()

getStatement

public PreparedStatement getStatement()

close

public void close()