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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Connection
getConnection()
Consumer<Connection>
getConnectionCloser()
PreparedStatement
getStatement()
boolean
isAutoCommit()
-
-
-
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()
-
-