Connection (Apache Derby V10.10 Internals)

java.lang.Object
- org.apache.derby.client.am.Connection

All Implemented Interfaces:

java.lang.AutoCloseable, java.sql.Connection, java.sql.Wrapper, ConnectionCallbackInterface

Direct Known Subclasses:

NetConnection
```
public abstract class Connection
extends java.lang.Object
implements java.sql.Connection, ConnectionCallbackInterface
```

Field Summary

Fields
Modifier and Type	Field and Description
`private boolean`	`aborting_`
`private boolean`	`accumulated440ForMessageProcFailure_`
`private boolean`	`accumulated444ForMessageProcFailure_`
`Agent`	`agent_`
`boolean`	`autoCommit_`
`private boolean`	`availableForReuse_`
`(package private) java.util.Hashtable<java.lang.String,java.lang.String>`	`clientCursorNameCache_`
`int`	`clientSSLMode_`
`int`	`commBufferSize_`
`(package private) java.util.WeakHashMap<UnitOfWorkListener,java.lang.Void>`	`CommitAndRollbackListeners_`
`private java.lang.String`	`currentSchemaName_` Cached copy of the schema name.
`DatabaseMetaData`	`databaseMetaData_`
`java.lang.String`	`databaseName_`
`ClientBaseDataSourceRoot`	`dataSource_`
`private int`	`defaultIsolation` The default isolation level, enforced on connection resets.
`private static java.lang.String`	`DERBY_TRANSACTION_READ_COMMITTED`
`private static java.lang.String`	`DERBY_TRANSACTION_READ_UNCOMMITTED`
`private static java.lang.String`	`DERBY_TRANSACTION_REPEATABLE_READ`
`private static java.lang.String`	`DERBY_TRANSACTION_SERIALIZABLE`
`int`	`dncGeneratedSavepointId_`
`static java.lang.String`	`dncGeneratedSavepointNamePrefix__`
`protected EncryptionManager`	`encryptionManager_`
`private PreparedStatement`	`getTransactionIsolationPrepStmt`
`private int`	`holdability` Holdabilty for created statements.
`protected boolean`	`inUnitOfWork_`
`private static int`	`INVALID_LOCATOR`
`private int`	`isolation_` Cached copy of the isolation level.
`private java.util.HashMap<java.lang.String,PreparedStatement>`	`isolationLevelPreparedStmts`
`protected boolean`	`isXAConnection_`
`protected boolean`	`jdbcReadOnly_`
`private CallableLocatorProcedures`	`lobProcs` Reference to object with prepared statements for calling the locator procedures.
`int`	`loginTimeout_`
`protected boolean`	`open_`
`(package private) java.util.WeakHashMap<Statement,java.lang.Void>`	`openStatements_`
`int`	`portNumber_`
`java.lang.String`	`productID_`
`boolean`	`resetConnectionAtFirstSql_`
`boolean`	`retrieveMessageText_`
`java.lang.String`	`serverNameIP_`
`private static int`	`TRANSACTION_UNKNOWN` Constant indicating that isolation_ has not been updated through piggy-backing, (or that the previously stored value was invalidated, e.g. by an XA state change).
`private int`	`transactionID_`
`protected java.lang.String`	`user_`
`private SqlWarning`	`warnings_`
`static int`	`XA_T0_NOT_ASSOCIATED` `XA_T0_NOT_ASSOCIATED` This connection is not currently associated with an XA transaction In this state commits will flow in autocommit mode.
`static int`	`XA_T1_ASSOCIATED` `XA_T1_ASSOCIATED` In this state commits will not flow in autocommit mode.
`int`	`xaHostVersion_`
`private int`	`xaState_`

Fields inherited from interface java.sql.Connection
TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Constructor Summary

Constructors
Modifier	Constructor and Description
`protected`	`Connection(LogWriter logWriter, boolean isXAConn, ClientBaseDataSourceRoot dataSource)`
`protected`	`Connection(LogWriter logWriter, int driverManagerLoginTimeout, java.lang.String serverName, int portNumber, java.lang.String databaseName, java.util.Properties properties)`
`protected`	`Connection(LogWriter logWriter, java.lang.String user, java.lang.String password, boolean isXAConn, ClientBaseDataSourceRoot dataSource)`
`protected`	`Connection(LogWriter logWriter, java.lang.String user, java.lang.String password, ClientBaseDataSourceRoot dataSource)`

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`accumulate440WarningForMessageProcFailure(SqlWarning e)`
`void`	`accumulate444WarningForMessageProcFailure(SqlWarning e)`
`void`	`accumulateWarning(SqlWarning e)`
`abstract void`	`addSpecialRegisters(java.lang.String s)`
`protected abstract boolean`	`allowCloseInUOW_()`
`protected abstract boolean`	`allowLocalCommitRollback_()`
`protected void`	`beginAborting()` Begin aborting the connection
`protected void`	`checkForClosedConnection()`
`private void`	`checkForInvalidXAStateOnCommitOrRollback()`
`(package private) void`	`checkForTransactionInProgress()` Check if the transaction is in progress and the connection cannot be closed.
`void`	`clearWarnings()`
`void`	`clearWarningsX()`
`void`	`close()`
`void`	`closeForReuse(boolean statementPooling)`
`void`	`closeResources()`
`private void`	`closeResourcesX()`
`void`	`closeX()`
`void`	`commit()`
`void`	`completeAbnormalUnitOfWork()`
`void`	`completeAbnormalUnitOfWork(UnitOfWorkListener uwl)` Rollback the UnitOfWorkListener specifically.
`void`	`completeChainBreakingDisconnect()`
`void`	`completeConnect()`
`void`	`completeInitialPiggyBackIsolation(int pbIsolation)` Sets the default isolation level of the connection upon connection initialization.
`void`	`completeInitialPiggyBackSchema(java.lang.String pbSchema)` Sets the current schema upon connection initialization.
`void`	`completeLocalCommit()`
`void`	`completeLocalRollback()`
`void`	`completePiggyBackIsolation(int pbIsolation)` Completes piggy-backing of the new current isolation level by updating the cached copy in am.Connection.
`void`	`completePiggyBackSchema(java.lang.String pbSchema)` Completes piggy-backing of the new current schema by updating the cached copy in am.Connection.
`protected void`	`completeReset(boolean isDeferredReset, boolean closeStatementsOnClose, NetXAResource xares)` NOTE: The following comments are valid for the changes done as part of implementing statement caching only (see DERBY-3313 and linked issues).
`void`	`completeSpecificRollback(UnitOfWorkListener uwl)` Rollback the specific UnitOfWorkListener.
`void`	`completeSqlca(Sqlca sqlca)`
`(package private) void`	`completeTransactionStart()`
`java.sql.Blob`	`createBlob()` Constructs an object that implements the `Blob` interface.
`java.sql.Clob`	`createClob()` Constructs an object that implements the `Clob` interface.
`java.sql.Statement`	`createStatement()`
`java.sql.Statement`	`createStatement(int resultSetType, int resultSetConcurrency)`
`java.sql.Statement`	`createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)`
`private Statement`	`createStatementX(int resultSetType, int resultSetConcurrency, int resultSetHoldability)`
`protected abstract boolean`	`doCloseStatementsOnClose_()`
`private int`	`downgradeResultSetType(int resultSetType)`
`protected void`	`finalize()`
`boolean`	`flowAutoCommit()`
`private void`	`flowClose()`
`void`	`flowCommit()`
`protected void`	`flowRollback()`
`boolean`	`getAutoCommit()`
`java.lang.String`	`getCatalog()`
`java.lang.String`	`getCurrentSchemaName()` Returns the current schema (the schema that would be used for compilation.
`int`	`getHoldability()`
`java.sql.DatabaseMetaData`	`getMetaData()`
`java.lang.String`	`getSchema()` Get the name of the current schema.
`int`	`getServerVersion()`
`int`	`getTransactionID()` Returns the ID of the active transaction for this connection.
`int`	`getTransactionIsolation()`
`int`	`getTransactionIsolationX()`
`java.util.Map<java.lang.String,java.lang.Class<?>>`	`getTypeMap()`
`java.sql.SQLWarning`	`getWarnings()`
`int`	`getXAState()`
`(package private) int`	`holdability()` Return the holdabilty for the Connection.
`protected void`	`initConnection(LogWriter logWriter, ClientBaseDataSourceRoot dataSource)`
`boolean`	`isAborting()` Return true if the connection is aborting
`boolean`	`isClosed()`
`boolean`	`isClosedX()`
`protected abstract boolean`	`isGlobalPending_()`
`boolean`	`isPhysicalConnClosed()` Return true if the physical connection is still open.
`boolean`	`isReadOnly()`
`boolean`	`isXAConnection()`
`void`	`lightReset()`
`(package private) CallableLocatorProcedures`	`locatorProcedureCall()` Get handle to the object that contains prepared statements for calling locator procedures for this connection.
`protected abstract void`	`markClosed_()`
`void`	`markClosed(boolean statementPooling)`
`private void`	`markClosedForReuse(boolean statementPooling)`
`private void`	`markStatementsClosed()`
`java.lang.String`	`nativeSQL(java.lang.String sql)`
`java.lang.String`	`nativeSQLX(java.lang.String sql)`
`protected abstract Agent`	`newAgent_(LogWriter logWriter, int loginTimeout, java.lang.String serverName, int portNumber, int clientSSLMode)`
`protected abstract CallableStatement`	`newCallableStatement_(java.lang.String sql, int type, int concurrency, int holdability)`
`protected abstract DatabaseMetaData`	`newDatabaseMetaData_()`
`protected abstract PreparedStatement`	`newPositionedUpdatePreparedStatement_(java.lang.String sql, Section section)`
`protected abstract PreparedStatement`	`newPreparedStatement_(java.lang.String sql, int type, int concurrency, int holdability, int autoGeneratedKeys, java.lang.String[] columnNames, int[] columnIndexes)`
`abstract SectionManager`	`newSectionManager(java.lang.String collection, Agent agent, java.lang.String databaseName)`
`protected abstract Statement`	`newStatement_(int type, int concurrency, int holdability)`
`java.sql.CallableStatement`	`prepareCall(java.lang.String sql)`
`java.sql.CallableStatement`	`prepareCall(java.lang.String sql, int resultSetType, int resultSetConcurrency)`
`java.sql.CallableStatement`	`prepareCall(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)`
`(package private) CallableStatement`	`prepareCallX(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)`
`(package private) PreparedStatement`	`prepareDynamicCatalogQuery(java.lang.String sql)`
`CallableStatement`	`prepareMessageProc(java.lang.String sql)`
`PreparedStatement`	`preparePositionedUpdateStatement(java.lang.String sql, Section querySection)`
`java.sql.PreparedStatement`	`prepareStatement(java.lang.String sql)`
`java.sql.PreparedStatement`	`prepareStatement(java.lang.String sql, int autoGeneratedKeys)`
`java.sql.PreparedStatement`	`prepareStatement(java.lang.String sql, int[] columnIndexes)`
`java.sql.PreparedStatement`	`prepareStatement(java.lang.String sql, int resultSetType, int resultSetConcurrency)`
`java.sql.PreparedStatement`	`prepareStatement(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)`
`java.sql.PreparedStatement`	`prepareStatement(java.lang.String sql, java.lang.String[] columnNames)`
`(package private) PreparedStatement`	`prepareStatementX(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability, int autoGeneratedKeys, java.lang.String[] columnNames, int[] columnIndexes)`
`(package private) void`	`readAutoCommit()`
`private void`	`readCloseStatements()`
`void`	`readCommit()`
`abstract void`	`readCommitSubstitute_()`
`abstract void`	`readLocalCommit_()`
`abstract void`	`readLocalRollback_()`
`abstract void`	`readLocalXACommit_()`
`abstract void`	`readLocalXARollback_()`
`abstract void`	`readLocalXAStart_()`
`void`	`readRollback()`
`void`	`readTransactionStart()`
`protected abstract void`	`readXACommit_()`
`protected abstract void`	`readXARollback_()`
`void`	`releaseSavepoint(java.sql.Savepoint savepoint)`
`protected abstract void`	`reset_(LogWriter logWriter)`
`void`	`reset(LogWriter logWriter)`
`protected abstract void`	`resetCallableStatement_(CallableStatement cs, java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)`
`protected void`	`resetConnection(LogWriter logWriter)`
`protected void`	`resetPrepareCall(CallableStatement cs)`
`protected abstract void`	`resetPreparedStatement_(PreparedStatement ps, java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability, int autoGeneratedKeys, java.lang.String[] columnNames, int[] columnIndexes)`
`protected void`	`resetPrepareStatement(PreparedStatement ps)`
`protected abstract void`	`resetStatement_(Statement statement, int type, int concurrency, int holdability)`
`protected void`	`resetStatement(Statement s)`
`void`	`rollback()`
`void`	`rollback(java.sql.Savepoint savepoint)`
`protected abstract boolean`	`serverSupportsLocators()` Checks whether the server supports locators for large objects.
`protected abstract boolean`	`serverSupportsTimestampNanoseconds()` Return true if the server supports nanoseconds in timestamps
`void`	`setAutoCommit(boolean autoCommit)`
`void`	`setCatalog(java.lang.String catalog)`
`void`	`setHoldability(int holdability)`
`void`	`setReadOnly(boolean readOnly)`
`java.sql.Savepoint`	`setSavepoint()`
`java.sql.Savepoint`	`setSavepoint(java.lang.String name)`
`private Savepoint`	`setSavepointX(Savepoint savepoint)`
`void`	`setSchema(java.lang.String schemaName)` Set the default schema for the Connection.
`void`	`setTransactionIsolation(int level)`
`private void`	`setTransactionIsolationX(int level)` Set the transaction isolation level as specified.
`void`	`setTypeMap(java.util.Map map)`
`void`	`setXAState(int state)`
`protected abstract boolean`	`supportsSessionDataCaching()` Finds out if the underlaying database connection supports session data caching.
`boolean`	`transactionInProgress()` Check if there are uncommitted operations in the current transaction that prevent us from closing the connection.
`private int`	`translateIsolation(java.lang.String isolationStr)` Translates the isolation level from a SQL string to the JDBC int value
`boolean`	`willAutoCommitGenerateFlow()`
`(package private) void`	`writeAutoCommit()`
`private void`	`writeCloseStatements()`
`void`	`writeCommit()`
`abstract void`	`writeCommitSubstitute_()`
`abstract void`	`writeLocalCommit_()`
`abstract void`	`writeLocalRollback_()`
`abstract void`	`writeLocalXACommit_()`
`abstract void`	`writeLocalXARollback_()`
`abstract void`	`writeLocalXAStart_()`
`void`	`writeRollback()`
`void`	`writeTransactionStart(Statement statement)`
`protected abstract void`	`writeXACommit_()`
`protected abstract void`	`writeXARollback_()`
`protected abstract void`	`writeXATransactionStart(Statement statement)`

Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.sql.Connection
abort, createArrayOf, createNClob, createSQLXML, createStruct, getClientInfo, getClientInfo, getNetworkTimeout, isValid, setClientInfo, setClientInfo, setNetworkTimeout

Methods inherited from interface java.sql.Wrapper
isWrapperFor, unwrap

Field Detail
- agent_
```
public Agent agent_
```
- databaseMetaData_
```
public DatabaseMetaData databaseMetaData_
```
- openStatements_
```
final java.util.WeakHashMap<Statement,java.lang.Void> openStatements_
```
- CommitAndRollbackListeners_
```
final java.util.WeakHashMap<UnitOfWorkListener,java.lang.Void> CommitAndRollbackListeners_
```
- warnings_
```
private SqlWarning warnings_
```
- INVALID_LOCATOR
```
private static final int INVALID_LOCATOR
```
  See Also:
  
  Constant Field Values
- user_
```
protected final java.lang.String user_
```
- retrieveMessageText_
```
public boolean retrieveMessageText_
```
- jdbcReadOnly_
```
protected boolean jdbcReadOnly_
```
- holdability
```
private int holdability
```
  Holdabilty for created statements. Only access through the holdability method to ensure the correct value is returned for an XA connection.
- databaseName_
```
public java.lang.String databaseName_
```
- productID_
```
public java.lang.String productID_
```
- encryptionManager_
```
protected EncryptionManager encryptionManager_
```
- isolationLevelPreparedStmts
```
private final java.util.HashMap<java.lang.String,PreparedStatement> isolationLevelPreparedStmts
```
- getTransactionIsolationPrepStmt
```
private PreparedStatement getTransactionIsolationPrepStmt
```
- open_
```
protected boolean open_
```
- aborting_
```
private boolean aborting_
```
- availableForReuse_
```
private boolean availableForReuse_
```
- TRANSACTION_UNKNOWN
```
private static final int TRANSACTION_UNKNOWN
```
  Constant indicating that isolation_ has not been updated through piggy-backing, (or that the previously stored value was invalidated, e.g. by an XA state change).
  
  See Also:
  
  Constant Field Values
- isolation_
```
private int isolation_
```
  Cached copy of the isolation level. Kept in sync with server through piggy-backing.
- defaultIsolation
```
private int defaultIsolation
```
  The default isolation level, enforced on connection resets.
  Note that this value may be changed upon connection initialization in the future, as the server can piggy-back the isolation level.
- currentSchemaName_
```
private java.lang.String currentSchemaName_
```
  Cached copy of the schema name. Updated through piggy-backing and used to implement statement caching.
- autoCommit_
```
public boolean autoCommit_
```
- inUnitOfWork_
```
protected boolean inUnitOfWork_
```
- accumulated440ForMessageProcFailure_
```
private boolean accumulated440ForMessageProcFailure_
```
- accumulated444ForMessageProcFailure_
```
private boolean accumulated444ForMessageProcFailure_
```
- transactionID_
```
private int transactionID_
```
- isXAConnection_
```
protected boolean isXAConnection_
```
- XA_T0_NOT_ASSOCIATED
```
public static final int XA_T0_NOT_ASSOCIATED
```
  XA_T0_NOT_ASSOCIATED This connection is not currently associated with an XA transaction In this state commits will flow in autocommit mode.
  
  See Also:
  
  Constant Field Values
- XA_T1_ASSOCIATED
```
public static final int XA_T1_ASSOCIATED
```
  XA_T1_ASSOCIATED In this state commits will not flow in autocommit mode.
  
  See Also:
  
  Constant Field Values
- xaState_
```
private int xaState_
```
- xaHostVersion_
```
public int xaHostVersion_
```
- loginTimeout_
```
public int loginTimeout_
```
- dataSource_
```
public ClientBaseDataSourceRoot dataSource_
```
- serverNameIP_
```
public java.lang.String serverNameIP_
```
- portNumber_
```
public int portNumber_
```
- clientSSLMode_
```
public int clientSSLMode_
```
- clientCursorNameCache_
```
java.util.Hashtable<java.lang.String,java.lang.String> clientCursorNameCache_
```
- commBufferSize_
```
public int commBufferSize_
```
- resetConnectionAtFirstSql_
```
public boolean resetConnectionAtFirstSql_
```
- DERBY_TRANSACTION_REPEATABLE_READ
```
private static java.lang.String DERBY_TRANSACTION_REPEATABLE_READ
```
- DERBY_TRANSACTION_SERIALIZABLE
```
private static java.lang.String DERBY_TRANSACTION_SERIALIZABLE
```
- DERBY_TRANSACTION_READ_COMMITTED
```
private static java.lang.String DERBY_TRANSACTION_READ_COMMITTED
```
- DERBY_TRANSACTION_READ_UNCOMMITTED
```
private static java.lang.String DERBY_TRANSACTION_READ_UNCOMMITTED
```
- dncGeneratedSavepointId_
```
public int dncGeneratedSavepointId_
```
- dncGeneratedSavepointNamePrefix__
```
public static final java.lang.String dncGeneratedSavepointNamePrefix__
```
  See Also:
  
  Constant Field Values
- lobProcs
```
private CallableLocatorProcedures lobProcs
```
  Reference to object with prepared statements for calling the locator procedures. Makes it possible to reuse prepared statements within the connection.

Constructor Detail

Connection

protected Connection(LogWriter logWriter,
                     java.lang.String user,
                     java.lang.String password,
                     ClientBaseDataSourceRoot dataSource)
              throws SqlException

Throws:: SqlException

Connection

protected Connection(LogWriter logWriter,
                     java.lang.String user,
                     java.lang.String password,
                     boolean isXAConn,
                     ClientBaseDataSourceRoot dataSource)
              throws SqlException

Throws:: SqlException

Connection

protected Connection(LogWriter logWriter,
                     boolean isXAConn,
                     ClientBaseDataSourceRoot dataSource)
              throws SqlException

Throws:: SqlException

Connection

protected Connection(LogWriter logWriter,
                     int driverManagerLoginTimeout,
                     java.lang.String serverName,
                     int portNumber,
                     java.lang.String databaseName,
                     java.util.Properties properties)
              throws SqlException

Throws:: SqlException

Method Detail

initConnection

protected void initConnection(LogWriter logWriter,
                              ClientBaseDataSourceRoot dataSource)
                       throws SqlException

Throws:: SqlException

resetConnection

protected void resetConnection(LogWriter logWriter)
                        throws SqlException

Throws:: SqlException

finalize
```
protected void finalize()
                 throws java.lang.Throwable
```
Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

createStatement

public java.sql.Statement createStatement()
                                   throws java.sql.SQLException

Specified by:: createStatement in interface java.sql.Connection
Throws:: java.sql.SQLException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql)
                                            throws java.sql.SQLException

Specified by:: prepareStatement in interface java.sql.Connection
Throws:: java.sql.SQLException

preparePositionedUpdateStatement

public PreparedStatement preparePositionedUpdateStatement(java.lang.String sql,
                                                          Section querySection)
                                                   throws SqlException

Throws:: SqlException

prepareCall

public java.sql.CallableStatement prepareCall(java.lang.String sql)
                                       throws java.sql.SQLException

Specified by:: prepareCall in interface java.sql.Connection
Throws:: java.sql.SQLException

prepareDynamicCatalogQuery

PreparedStatement prepareDynamicCatalogQuery(java.lang.String sql)
                                      throws SqlException

Throws:: SqlException

nativeSQL

public java.lang.String nativeSQL(java.lang.String sql)
                           throws java.sql.SQLException

Specified by:: nativeSQL in interface java.sql.Connection
Throws:: java.sql.SQLException

nativeSQLX

public java.lang.String nativeSQLX(java.lang.String sql)
                            throws SqlException

Throws:: SqlException

allowLocalCommitRollback_

protected abstract boolean allowLocalCommitRollback_()
                                              throws SqlException

Throws:: SqlException

setAutoCommit
```
public void setAutoCommit(boolean autoCommit)
                   throws java.sql.SQLException
```
Specified by:

setAutoCommit in interface java.sql.Connection

Throws:

java.sql.SQLException

getAutoCommit
```
public boolean getAutoCommit()
                      throws java.sql.SQLException
```
Specified by:

getAutoCommit in interface java.sql.Connection

Throws:

java.sql.SQLException

commit
```
public void commit()
            throws java.sql.SQLException
```
Specified by:

commit in interface java.sql.Connection

Throws:

java.sql.SQLException

checkForInvalidXAStateOnCommitOrRollback

private void checkForInvalidXAStateOnCommitOrRollback()
                                               throws SqlException

Throws:: SqlException

flowCommit

public void flowCommit()
                throws SqlException

Throws:: SqlException

flowAutoCommit

public boolean flowAutoCommit()
                       throws SqlException

Throws:: SqlException

willAutoCommitGenerateFlow

public boolean willAutoCommitGenerateFlow()
                                   throws SqlException

Throws:: SqlException

writeAutoCommit

void writeAutoCommit()
              throws SqlException

Throws:: SqlException

writeCommit

public void writeCommit()
                 throws SqlException

Throws:: SqlException

readAutoCommit

void readAutoCommit()
             throws SqlException

Throws:: SqlException

readCommit

public void readCommit()
                throws SqlException

Throws:: SqlException

rollback
```
public void rollback()
              throws java.sql.SQLException
```
Specified by:

rollback in interface java.sql.Connection

Throws:

java.sql.SQLException

flowRollback

protected void flowRollback()
                     throws SqlException

Throws:: SqlException

writeRollback

public void writeRollback()
                   throws SqlException

Throws:: SqlException

readRollback

public void readRollback()
                  throws SqlException

Throws:: SqlException

close
```
public void close()
           throws java.sql.SQLException
```
Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.sql.Connection

Throws:

java.sql.SQLException

checkForTransactionInProgress
```
void checkForTransactionInProgress()
                            throws SqlException
```
Check if the transaction is in progress and the connection cannot be closed.

Throws:

SqlException - if the connection cannot be closed because the transaction is active

transactionInProgress
```
public boolean transactionInProgress()
```
Check if there are uncommitted operations in the current transaction that prevent us from closing the connection.

Returns:

true if the connection cannot be closed due to uncommitted operations in the transaction

closeX

public void closeX()
            throws java.sql.SQLException

Throws:: java.sql.SQLException

closeResources

public void closeResources()
                    throws java.sql.SQLException

Throws:: java.sql.SQLException

closeResourcesX

private void closeResourcesX()
                      throws java.sql.SQLException

Throws:: java.sql.SQLException

isGlobalPending_

protected abstract boolean isGlobalPending_()

closeForReuse

public void closeForReuse(boolean statementPooling)
                   throws SqlException

Throws:: SqlException

flowClose

private void flowClose()
                throws SqlException

Throws:: SqlException

markClosed_
```
protected abstract void markClosed_()
```

markClosed

public void markClosed(boolean statementPooling)

markClosedForReuse

private void markClosedForReuse(boolean statementPooling)

markStatementsClosed
```
private void markStatementsClosed()
```

writeCloseStatements

private void writeCloseStatements()
                           throws SqlException

Throws:: SqlException

readCloseStatements

private void readCloseStatements()
                          throws SqlException

Throws:: SqlException

isPhysicalConnClosed
```
public boolean isPhysicalConnClosed()
```
Return true if the physical connection is still open. Might be logically closed but available for reuse.

Returns:

true if physical connection still open

isClosed
```
public boolean isClosed()
```
Specified by:

isClosed in interface java.sql.Connection

isClosedX
```
public boolean isClosedX()
```

setTransactionIsolation
```
public void setTransactionIsolation(int level)
                             throws java.sql.SQLException
```
Specified by:

setTransactionIsolation in interface java.sql.Connection

Throws:

java.sql.SQLException

setTransactionIsolationX
```
private void setTransactionIsolationX(int level)
                               throws SqlException
```
Set the transaction isolation level as specified.
If this method is called during a transaction, the result is implementation-defined.
Information about Derby specific isolation level handling:
- REPEATABLE_READ = JDBC: TRANSACTION_SERIALIZABLE, DERBY: RR, PROTOCOL: repeatable read
- READ_STABILITY = JDBC: TRANSACTION_REPEATABLE_READ, DERBY: RS, PROTOCOL: All
- CURSOR_STABILITY = JDBC: TRANSACTION_READ_COMMITTED, DERBY: CS, PROTOCOL: Cursor stability
- UNCOMMITTED_READ = JDBC: TRANSACTION_READ_UNCOMMITTED, DERBY: UR, PROTOCOL: Change
- NO_COMMIT = JDBC: TRANSACTION_NONE, DERBY: NC, PROTOCOL: No commit
Throws:

SqlException

supportsSessionDataCaching
```
protected abstract boolean supportsSessionDataCaching()
```
Finds out if the underlaying database connection supports session data caching.

Returns:

true if sessionData is supported

serverSupportsLocators
```
protected abstract boolean serverSupportsLocators()
```
Checks whether the server supports locators for large objects. Note that even though the server supports LOB locators, the database that is accessed through the server may not have the necessary stored procedures to support LOB locators (e.g., because the database is soft upgraded from an earlier version).

Returns:

true if LOB locators are supported.

serverSupportsTimestampNanoseconds
```
protected abstract boolean serverSupportsTimestampNanoseconds()
```
Return true if the server supports nanoseconds in timestamps

getTransactionIsolation
```
public int getTransactionIsolation()
                            throws java.sql.SQLException
```
Specified by:

getTransactionIsolation in interface java.sql.Connection

Throws:

java.sql.SQLException

getTransactionIsolationX

public int getTransactionIsolationX()
                             throws java.sql.SQLException

Throws:: java.sql.SQLException

getTransactionID
```
public int getTransactionID()
```
Returns the ID of the active transaction for this connection.

Returns:

the ID of the active transaction

getCurrentSchemaName
```
public java.lang.String getCurrentSchemaName()
                                      throws java.sql.SQLException
```
Returns the current schema (the schema that would be used for compilation. This is not part of the java.sql.Connection interface, and is only intended for use with statement caching.

Returns:

the name of the current schema

Throws:

java.sql.SQLException

translateIsolation
```
private int translateIsolation(java.lang.String isolationStr)
```
Translates the isolation level from a SQL string to the JDBC int value

Parameters:

isolationStr - SQL isolation string

Returns:

isolation level as a JDBC integer value

getWarnings

public java.sql.SQLWarning getWarnings()
                                throws java.sql.SQLException

Specified by:: getWarnings in interface java.sql.Connection
Throws:: java.sql.SQLException

clearWarnings
```
public void clearWarnings()
                   throws java.sql.SQLException
```
Specified by:

clearWarnings in interface java.sql.Connection

Throws:

java.sql.SQLException

clearWarningsX

public void clearWarningsX()
                    throws SqlException

Throws:: SqlException

getMetaData

public java.sql.DatabaseMetaData getMetaData()
                                      throws java.sql.SQLException

Specified by:: getMetaData in interface java.sql.Connection
Throws:: java.sql.SQLException

setReadOnly
```
public void setReadOnly(boolean readOnly)
                 throws java.sql.SQLException
```
Specified by:

setReadOnly in interface java.sql.Connection

Throws:

java.sql.SQLException

isReadOnly
```
public boolean isReadOnly()
                   throws java.sql.SQLException
```
Specified by:

isReadOnly in interface java.sql.Connection

Throws:

java.sql.SQLException

setCatalog

public void setCatalog(java.lang.String catalog)
                throws java.sql.SQLException

Specified by:: setCatalog in interface java.sql.Connection
Throws:: java.sql.SQLException

getCatalog

public java.lang.String getCatalog()
                            throws java.sql.SQLException

Specified by:: getCatalog in interface java.sql.Connection
Throws:: java.sql.SQLException

createStatement

public java.sql.Statement createStatement(int resultSetType,
                                          int resultSetConcurrency)
                                   throws java.sql.SQLException

Specified by:: createStatement in interface java.sql.Connection
Throws:: java.sql.SQLException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                   int resultSetType,
                                                   int resultSetConcurrency)
                                            throws java.sql.SQLException

Specified by:: prepareStatement in interface java.sql.Connection
Throws:: java.sql.SQLException

prepareCall

public java.sql.CallableStatement prepareCall(java.lang.String sql,
                                              int resultSetType,
                                              int resultSetConcurrency)
                                       throws java.sql.SQLException

Specified by:: prepareCall in interface java.sql.Connection
Throws:: java.sql.SQLException

prepareMessageProc

public CallableStatement prepareMessageProc(java.lang.String sql)
                                     throws SqlException

Throws:: SqlException

downgradeResultSetType

private int downgradeResultSetType(int resultSetType)

getTypeMap

public java.util.Map<java.lang.String,java.lang.Class<?>> getTypeMap()
                                                              throws java.sql.SQLException

Specified by:: getTypeMap in interface java.sql.Connection
Throws:: java.sql.SQLException

setTypeMap
```
public void setTypeMap(java.util.Map map)
                throws java.sql.SQLException
```
Specified by:

setTypeMap in interface java.sql.Connection

Throws:

java.sql.SQLException

setHoldability
```
public void setHoldability(int holdability)
                    throws java.sql.SQLException
```
Specified by:

setHoldability in interface java.sql.Connection

Throws:

java.sql.SQLException

getHoldability
```
public int getHoldability()
                   throws java.sql.SQLException
```
Specified by:

getHoldability in interface java.sql.Connection

Throws:

java.sql.SQLException

setSavepoint

public java.sql.Savepoint setSavepoint()
                                throws java.sql.SQLException

Specified by:: setSavepoint in interface java.sql.Connection
Throws:: java.sql.SQLException

setSavepoint

public java.sql.Savepoint setSavepoint(java.lang.String name)
                                throws java.sql.SQLException

Specified by:: setSavepoint in interface java.sql.Connection
Throws:: java.sql.SQLException

setSavepointX

private Savepoint setSavepointX(Savepoint savepoint)
                         throws java.sql.SQLException

Throws:: java.sql.SQLException

rollback

public void rollback(java.sql.Savepoint savepoint)
              throws java.sql.SQLException

Specified by:: rollback in interface java.sql.Connection
Throws:: java.sql.SQLException

releaseSavepoint

public void releaseSavepoint(java.sql.Savepoint savepoint)
                      throws java.sql.SQLException

Specified by:: releaseSavepoint in interface java.sql.Connection
Throws:: java.sql.SQLException

createStatement

public java.sql.Statement createStatement(int resultSetType,
                                          int resultSetConcurrency,
                                          int resultSetHoldability)
                                   throws java.sql.SQLException

Specified by:: createStatement in interface java.sql.Connection
Throws:: java.sql.SQLException

createStatementX

private Statement createStatementX(int resultSetType,
                                   int resultSetConcurrency,
                                   int resultSetHoldability)
                            throws SqlException

Throws:: SqlException

resetStatement

protected void resetStatement(Statement s)
                       throws SqlException

Throws:: SqlException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                   int resultSetType,
                                                   int resultSetConcurrency,
                                                   int resultSetHoldability)
                                            throws java.sql.SQLException

Specified by:: prepareStatement in interface java.sql.Connection
Throws:: java.sql.SQLException

prepareStatementX

PreparedStatement prepareStatementX(java.lang.String sql,
                                    int resultSetType,
                                    int resultSetConcurrency,
                                    int resultSetHoldability,
                                    int autoGeneratedKeys,
                                    java.lang.String[] columnNames,
                                    int[] columnIndexes)
                             throws SqlException

Throws:: SqlException

resetPrepareStatement

protected void resetPrepareStatement(PreparedStatement ps)
                              throws SqlException

Throws:: SqlException

prepareCall

public java.sql.CallableStatement prepareCall(java.lang.String sql,
                                              int resultSetType,
                                              int resultSetConcurrency,
                                              int resultSetHoldability)
                                       throws java.sql.SQLException

Specified by:: prepareCall in interface java.sql.Connection
Throws:: java.sql.SQLException

prepareCallX

CallableStatement prepareCallX(java.lang.String sql,
                               int resultSetType,
                               int resultSetConcurrency,
                               int resultSetHoldability)
                        throws SqlException

Throws:: SqlException

resetPrepareCall

protected void resetPrepareCall(CallableStatement cs)
                         throws SqlException

Throws:: SqlException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                   int autoGeneratedKeys)
                                            throws java.sql.SQLException

Specified by:: prepareStatement in interface java.sql.Connection
Throws:: java.sql.SQLException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                   int[] columnIndexes)
                                            throws java.sql.SQLException

Specified by:: prepareStatement in interface java.sql.Connection
Throws:: java.sql.SQLException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                   java.lang.String[] columnNames)
                                            throws java.sql.SQLException

Specified by:: prepareStatement in interface java.sql.Connection
Throws:: java.sql.SQLException

allowCloseInUOW_

protected abstract boolean allowCloseInUOW_()

doCloseStatementsOnClose_

protected abstract boolean doCloseStatementsOnClose_()

newSectionManager

public abstract SectionManager newSectionManager(java.lang.String collection,
                                                 Agent agent,
                                                 java.lang.String databaseName)

newAgent_

protected abstract Agent newAgent_(LogWriter logWriter,
                                   int loginTimeout,
                                   java.lang.String serverName,
                                   int portNumber,
                                   int clientSSLMode)
                            throws SqlException

Throws:: SqlException

newDatabaseMetaData_

protected abstract DatabaseMetaData newDatabaseMetaData_()

newStatement_

protected abstract Statement newStatement_(int type,
                                           int concurrency,
                                           int holdability)
                                    throws SqlException

Throws:: SqlException

resetStatement_

protected abstract void resetStatement_(Statement statement,
                                        int type,
                                        int concurrency,
                                        int holdability)
                                 throws SqlException

Throws:: SqlException

newPositionedUpdatePreparedStatement_

protected abstract PreparedStatement newPositionedUpdatePreparedStatement_(java.lang.String sql,
                                                                           Section section)
                                                                    throws SqlException

Throws:: SqlException

newPreparedStatement_

protected abstract PreparedStatement newPreparedStatement_(java.lang.String sql,
                                                           int type,
                                                           int concurrency,
                                                           int holdability,
                                                           int autoGeneratedKeys,
                                                           java.lang.String[] columnNames,
                                                           int[] columnIndexes)
                                                    throws SqlException

Throws:: SqlException

resetPreparedStatement_

protected abstract void resetPreparedStatement_(PreparedStatement ps,
                                                java.lang.String sql,
                                                int resultSetType,
                                                int resultSetConcurrency,
                                                int resultSetHoldability,
                                                int autoGeneratedKeys,
                                                java.lang.String[] columnNames,
                                                int[] columnIndexes)
                                         throws SqlException

Throws:: SqlException

newCallableStatement_

protected abstract CallableStatement newCallableStatement_(java.lang.String sql,
                                                           int type,
                                                           int concurrency,
                                                           int holdability)
                                                    throws SqlException

Throws:: SqlException

resetCallableStatement_

protected abstract void resetCallableStatement_(CallableStatement cs,
                                                java.lang.String sql,
                                                int resultSetType,
                                                int resultSetConcurrency,
                                                int resultSetHoldability)
                                         throws SqlException

Throws:: SqlException

completeConnect

public void completeConnect()
                     throws SqlException

Throws:: SqlException

writeCommitSubstitute_

public abstract void writeCommitSubstitute_()
                                     throws SqlException

Throws:: SqlException

readCommitSubstitute_

public abstract void readCommitSubstitute_()
                                    throws SqlException

Throws:: SqlException

writeLocalXAStart_

public abstract void writeLocalXAStart_()
                                 throws SqlException

Throws:: SqlException

readLocalXAStart_

public abstract void readLocalXAStart_()
                                throws SqlException

Throws:: SqlException

writeLocalXACommit_

public abstract void writeLocalXACommit_()
                                  throws SqlException

Throws:: SqlException

writeXACommit_

protected abstract void writeXACommit_()
                                throws SqlException

Throws:: SqlException

readLocalXACommit_

public abstract void readLocalXACommit_()
                                 throws SqlException

Throws:: SqlException

readXACommit_

protected abstract void readXACommit_()
                               throws SqlException

Throws:: SqlException

writeLocalCommit_

public abstract void writeLocalCommit_()
                                throws SqlException

Throws:: SqlException

readLocalCommit_

public abstract void readLocalCommit_()
                               throws SqlException

Throws:: SqlException

writeXATransactionStart

protected abstract void writeXATransactionStart(Statement statement)
                                         throws SqlException

Throws:: SqlException

completeLocalCommit
```
public void completeLocalCommit()
```
Specified by:

completeLocalCommit in interface ConnectionCallbackInterface

writeLocalRollback_

public abstract void writeLocalRollback_()
                                  throws SqlException

Throws:: SqlException

readLocalRollback_

public abstract void readLocalRollback_()
                                 throws SqlException

Throws:: SqlException

completeLocalRollback
```
public void completeLocalRollback()
```
Specified by:

completeLocalRollback in interface ConnectionCallbackInterface

completeSpecificRollback
```
public void completeSpecificRollback(UnitOfWorkListener uwl)
```
Rollback the specific UnitOfWorkListener.

Parameters:

uwl - The UnitOfWorkLitener to be rolled back

writeLocalXARollback_

public abstract void writeLocalXARollback_()
                                    throws SqlException

Throws:: SqlException

writeXARollback_

protected abstract void writeXARollback_()
                                  throws SqlException

Throws:: SqlException

readLocalXARollback_

public abstract void readLocalXARollback_()
                                   throws SqlException

Throws:: SqlException

readXARollback_

protected abstract void readXARollback_()
                                 throws SqlException

Throws:: SqlException

writeTransactionStart

public void writeTransactionStart(Statement statement)
                           throws SqlException

Throws:: SqlException

readTransactionStart

public void readTransactionStart()
                          throws SqlException

Throws:: SqlException

completeTransactionStart
```
void completeTransactionStart()
```

completeAbnormalUnitOfWork
```
public void completeAbnormalUnitOfWork()
```
Specified by:

completeAbnormalUnitOfWork in interface ConnectionCallbackInterface

completeAbnormalUnitOfWork
```
public void completeAbnormalUnitOfWork(UnitOfWorkListener uwl)
```
Rollback the UnitOfWorkListener specifically.

Specified by:

completeAbnormalUnitOfWork in interface ConnectionCallbackInterface

Parameters:

uwl - The UnitOfWorkListener to be rolled back.

completeChainBreakingDisconnect
```
public void completeChainBreakingDisconnect()
```
Specified by:

completeChainBreakingDisconnect in interface ConnectionCallbackInterface

completeSqlca
```
public void completeSqlca(Sqlca sqlca)
```
Specified by:

completeSqlca in interface ConnectionCallbackInterface

completePiggyBackIsolation
```
public void completePiggyBackIsolation(int pbIsolation)
```
Description copied from interface: ConnectionCallbackInterface

Completes piggy-backing of the new current isolation level by updating the cached copy in am.Connection.

Specified by:

completePiggyBackIsolation in interface ConnectionCallbackInterface

Parameters:

pbIsolation - new isolation level from the server

completeInitialPiggyBackIsolation
```
public void completeInitialPiggyBackIsolation(int pbIsolation)
```
Sets the default isolation level of the connection upon connection initialization.
Note that depending on the server version, the default isolation value may not be piggy-backed on the initialization flow. In that case, the default is assumed / hardcoded to be READ_COMMITTED.

Parameters:

pbIsolation - isolation level as specified by java.sql.Connection

completePiggyBackSchema
```
public void completePiggyBackSchema(java.lang.String pbSchema)
```
Description copied from interface: ConnectionCallbackInterface

Completes piggy-backing of the new current schema by updating the cached copy in am.Connection.

Specified by:

completePiggyBackSchema in interface ConnectionCallbackInterface

Parameters:

pbSchema - new current schema from the server

completeInitialPiggyBackSchema
```
public void completeInitialPiggyBackSchema(java.lang.String pbSchema)
```
Sets the current schema upon connection initialization.

Parameters:

pbSchema - the schema name

addSpecialRegisters

public abstract void addSpecialRegisters(java.lang.String s)

reset

public void reset(LogWriter logWriter)
           throws SqlException

Throws:: SqlException

lightReset

public void lightReset()
                throws SqlException

Throws:: SqlException

reset_

protected abstract void reset_(LogWriter logWriter)
                        throws SqlException

Throws:: SqlException

completeReset
```
protected void completeReset(boolean isDeferredReset,
                             boolean closeStatementsOnClose,
                             NetXAResource xares)
                      throws SqlException
```
NOTE:
The following comments are valid for the changes done as part of implementing statement caching only (see DERBY-3313 and linked issues).
We don't reset the isolation level to unknown unconditionally, as this forces us to go to the server all the time. Since the value should now be valid (DERBY-3192), we check if it has been changed from the default.

Parameters:

closeStatementsOnClose - is used to differentiate between cases where statement pooling is enabled or not. If true, it means statement pooling is disabled and the statements are fully reset, which includes a re-prepare. If false, statement pooling is enabled, and a more lightweight reset procedure is used.

Throws:

SqlException

locatorProcedureCall
```
CallableLocatorProcedures locatorProcedureCall()
```
Get handle to the object that contains prepared statements for calling locator procedures for this connection. The object will be created on the first invocation. An example of how to call a stored procedure via this method:
```
 
    connection.locatorProcedureCall().blobReleaseLocator(locator);
  
```
Returns:

object with prepared statements for calling locator procedures

checkForClosedConnection

protected void checkForClosedConnection()
                                 throws SqlException

Throws:: SqlException

isXAConnection
```
public boolean isXAConnection()
```

getXAState
```
public int getXAState()
```

setXAState
```
public void setXAState(int state)
```

accumulateWarning

public void accumulateWarning(SqlWarning e)

accumulate440WarningForMessageProcFailure

public void accumulate440WarningForMessageProcFailure(SqlWarning e)

accumulate444WarningForMessageProcFailure

public void accumulate444WarningForMessageProcFailure(SqlWarning e)

getServerVersion
```
public int getServerVersion()
```

holdability
```
final int holdability()
```
Return the holdabilty for the Connection. Matches the embedded driver in the restriction that while in a global (XA) transaction the holdability is CLOSE_CURSORS_AT_COMMIT. Otherwise return the holdability set by the user.

createClob
```
public java.sql.Clob createClob()
                         throws java.sql.SQLException
```
Constructs an object that implements the Clob interface. The object returned initially contains no data.

Specified by:

createClob in interface java.sql.Connection

Returns:

An object that implements the Clob interface

Throws:

java.sql.SQLException - if an object that implements the Clob interface can not be constructed.

createBlob
```
public java.sql.Blob createBlob()
                         throws java.sql.SQLException
```
Constructs an object that implements the Blob interface. The object returned initially contains no data.

Specified by:

createBlob in interface java.sql.Connection

Returns:

An object that implements the Blob interface

Throws:

java.sql.SQLException - if an object that implements the Blob interface can not be constructed.

isAborting
```
public boolean isAborting()
```
Return true if the connection is aborting

beginAborting
```
protected void beginAborting()
```
Begin aborting the connection

getSchema
```
public java.lang.String getSchema()
                           throws java.sql.SQLException
```
Get the name of the current schema.

Specified by:

getSchema in interface java.sql.Connection

Throws:

java.sql.SQLException

setSchema
```
public void setSchema(java.lang.String schemaName)
               throws java.sql.SQLException
```
Set the default schema for the Connection.

Specified by:

setSchema in interface java.sql.Connection

Throws:

java.sql.SQLException

Class Connection

Field Summary

Fields inherited from interface java.sql.Connection

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface java.sql.Connection

Methods inherited from interface java.sql.Wrapper

Field Detail

agent_

databaseMetaData_

openStatements_

CommitAndRollbackListeners_

warnings_

INVALID_LOCATOR

user_

retrieveMessageText_

jdbcReadOnly_

holdability

databaseName_

productID_

encryptionManager_

isolationLevelPreparedStmts

getTransactionIsolationPrepStmt

open_

aborting_

availableForReuse_

TRANSACTION_UNKNOWN

isolation_

defaultIsolation

currentSchemaName_

autoCommit_

inUnitOfWork_

accumulated440ForMessageProcFailure_

accumulated444ForMessageProcFailure_

transactionID_

isXAConnection_

XA_T0_NOT_ASSOCIATED

XA_T1_ASSOCIATED

xaState_

xaHostVersion_

loginTimeout_

dataSource_

serverNameIP_

portNumber_

clientSSLMode_

clientCursorNameCache_

commBufferSize_

resetConnectionAtFirstSql_

DERBY_TRANSACTION_REPEATABLE_READ

DERBY_TRANSACTION_SERIALIZABLE

DERBY_TRANSACTION_READ_COMMITTED

DERBY_TRANSACTION_READ_UNCOMMITTED

dncGeneratedSavepointId_

dncGeneratedSavepointNamePrefix__

lobProcs

Constructor Detail

Connection

Connection

Connection

Connection

Method Detail

initConnection

resetConnection

finalize

createStatement

prepareStatement

preparePositionedUpdateStatement

prepareCall

prepareDynamicCatalogQuery

nativeSQL

nativeSQLX

allowLocalCommitRollback_

setAutoCommit

getAutoCommit

commit

checkForInvalidXAStateOnCommitOrRollback

flowCommit

flowAutoCommit

willAutoCommitGenerateFlow