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 boolean	autoCommit
protected Connection	connection
protected Consumer<Connection>	connectionCloser
protected 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 Detail

autoCommit

protected final boolean autoCommit

connection

protected final Connection connection

connectionCloser

protected final Consumer<Connection> connectionCloser

statement

protected final PreparedStatement statement

Constructor Detail

FlowableConnection

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

Throws:

SQLException

Method Detail

isAutoCommit

public boolean isAutoCommit()

getConnection

public Connection getConnection()

getConnectionCloser

public Consumer<Connection> getConnectionCloser()

getStatement

public PreparedStatement getStatement()

close

public void close()