de.hybris.platform.jdbcwrapper

Class JUnitConnectionImpl

java.lang.Object

de.hybris.platform.jdbcwrapper.WrapperRelease<Statement>

de.hybris.platform.jdbcwrapper.ConnectionImpl

de.hybris.platform.jdbcwrapper.JUnitConnectionImpl

All Implemented Interfaces:

ParsedStatement, AutoCloseable, Connection, Wrapper

public class JUnitConnectionImpl
extends ConnectionImpl

For testing error flag in connection itself.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JUnitConnectionImpl.CommitMode

Field Summary

Fields

Modifier and Type	Field and Description
static String	PREPARE_ERROR_QUERY

Fields inherited from interface java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Constructor Summary

Constructors

Constructor and Description
JUnitConnectionImpl(HybrisDataSource ds, Connection conn)

Method Summary

Modifier and Type	Method and Description
protected void	autoRollbackOnUnsetTxBOund()
void	commit()
protected boolean	gotError()
boolean	hasBeenDestroyed()
String	parseQuery(String queryIn)
void	resetTestMode()
void	setCommitMode(JUnitConnectionImpl.CommitMode mode)
void	setError(boolean hasError)

Methods inherited from class de.hybris.platform.jdbcwrapper.ConnectionImpl

abort, assureWritable, clearWarnings, close, closeUnderlayingConnection, commitInternal, createArrayOf, createBlob, createClob, createNClob, createSQLXML, createStatement, createStatement, createStatement, createStruct, getAutoCommit, getCatalog, getClientInfo, getClientInfo, getConnectionID, getConnectionInfo, getDataSource, getHoldability, getMetaData, getNetworkTimeout, getSchema, getTransactionIsolation, getTypeMap, getUnderlayingConnection, getWarnings, hasBeenRollbacked, invalidate, isClosed, isFlexibleSyntax, isReadOnly, isTxBound, isTxBoundUserTA, isValid, isWrapperFor, logError, nativeSQL, notifyError, notifyStatementClosed, prepareCall, prepareCall, prepareCall, prepareForUse, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, protectReadOnly, releaseResourceImpl, releaseSavepoint, resetError, restoreAfterUse, restoreAutoCommit, restoreTxIsolationLevel, rollback, rollback, rollbackInternal, setAutoCommit, setCatalog, setClientInfo, setClientInfo, setHoldability, setNetworkTimeout, setReadOnly, setSavepoint, setSavepoint, setSchema, setTransactionIsolation, setTxBoundNoUserTA, setTxBoundUserTA, setTypeMap, toString, unsetTxBound, unwrap, wrapPreparedStatement

Methods inherited from class de.hybris.platform.jdbcwrapper.WrapperRelease

addResource, releaseResources, removeResource

Methods inherited from class java.lang.Object

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

Field Detail

PREPARE_ERROR_QUERY

public static final String PREPARE_ERROR_QUERY

See Also:

Constant Field Values

Constructor Detail

JUnitConnectionImpl

public JUnitConnectionImpl(HybrisDataSource ds,
                           Connection conn)

Method Detail

setError

public void setError(boolean hasError)

setCommitMode

public void setCommitMode(JUnitConnectionImpl.CommitMode mode)

commit

public void commit()
            throws SQLException

Specified by:

commit in interface Connection

Overrides:

commit in class ConnectionImpl

Throws:

SQLException

hasBeenDestroyed

public boolean hasBeenDestroyed()

parseQuery

public String parseQuery(String queryIn)
                  throws SQLException

Specified by:

parseQuery in interface ParsedStatement

Overrides:

parseQuery in class ConnectionImpl

Parameters:

queryIn - query to be parsed in flex-mode implementation

Returns:

parsed query into plain sql for underlying DB to perform on

Throws:

SQLException - is thrown if during parsing something goes wrong

autoRollbackOnUnsetTxBOund

protected void autoRollbackOnUnsetTxBOund()

Overrides:

autoRollbackOnUnsetTxBOund in class ConnectionImpl

gotError

protected boolean gotError()

Overrides:

gotError in class ConnectionImpl

resetTestMode

public void resetTestMode()