EclipseLink Core 4.0.2 · org.eclipse.persistence.internal.databaseaccess.DatasourceAccessor

Modifier and Type	Field and Description
protected int	callCount Keep track of the number of concurrent active calls.
protected transient AbstractSession	currentSession Used only in externalConnectionPooling case.
protected ConnectionCustomizer	customizer Allows session-specific connection customization.
protected Object	datasourceConnection Store the reference to the driver level connection.
protected boolean	isConnected Keep track of whether the accessor is "connected".
protected boolean	isInTransaction Keep track if the accessor is within a transaction context
protected boolean	isValid This attribute is used to determine if the connection should be returned to the pool or removed from the pool and closed.
protected Login	login Store the login information that connected this accessor.
protected DatasourcePlatform	platform This is also required to ensure all accessors for a session are using the same platform.
protected ConnectionPool	pool
protected boolean	possibleFailure This attribute is used to track failures on an accessor that may be communication based.
public static final String	READ_STATEMENTS_COUNT_PROPERTY
public int	readStatementsCount Keep track of the number of the read statement that being executed.
protected transient SequencingCallback	sequencingCallback During (not external) transaction, SequencingManager may set SequencingCallback on the accessor, The callback's only method is called when transaction commits, after transaction is completed the callback is discarded.
public static boolean	shouldCheckConnection Back-door to allow isConnect checks.
public static final String	STOREDPROCEDURE_STATEMENTS_COUNT_PROPERTY
public int	storedProcedureStatementsCount Keep track of the number of the storedprocedure statement that being executed.
protected boolean	usesExternalConnectionPooling PERF: Cache connection pooling flag.
public static final String	WRITE_STATEMENTS_COUNT_PROPERTY
public int	writeStatementsCount Keep track of the number of the write statement that being executed.

Access	Constructor and Description
protected	DatasourceAccessor() Default Constructor.

Method Summary

Modifier and Type	Method and Description
protected abstract void	basicBeginTransaction(AbstractSession session) Begin the driver level transaction.
protected abstract void	basicCommitTransaction(AbstractSession session) Commit the driver level transaction.
protected abstract Object	basicExecuteCall(Call call, AbstractRecord row, AbstractSession session) Execute the call to driver level datasource.
protected abstract void	basicRollbackTransaction(AbstractSession session) Rollback the driver level transaction.
public void	beginTransaction(AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.beginTransaction. Begin a transaction on the database.
protected abstract void	buildConnectLog(AbstractSession session) Build a log string of any driver metadata that can be obtained.
public Object	clone() Overrides java.lang.Object.clone. Implements org.eclipse.persistence.internal.databaseaccess.Accessor.clone. Clone the accessor.
public void	closeConnection() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.closeConnection. Close the accessor's connection.
protected abstract void	closeDatasourceConnection() Close the connection to the driver level datasource.
public void	closeJTSConnection() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.closeJTSConnection. Called from beforeCompletion external transaction synchronization listener callback to close the external connection corresponding to the completing external transaction.
public void	commitTransaction(AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.commitTransaction. Commit a transaction on the database.
public void	connect(Login login, AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.connect. Connect to the datasource.
protected void	connectInternal(Login login, AbstractSession session) Connect to the database.
public void	createCustomizer(AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.createCustomizer. Attempts to create ConnectionCustomizer.
public synchronized void	decrementCallCount() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.decrementCallCount. Used for load balancing and external pooling.
public void	disconnect(AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.disconnect. Disconnect from the datasource.
public Object	Returns: depending of the type either the row count, row or vector of rows. executeCall(Call call, AbstractRecord translationRow, AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.executeCall. Execute the call.
public void	flushSelectCalls(AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.flushSelectCalls. Added as a result of Bug 2804663 - satisfy the Accessor interface implementation.
public int	getCallCount() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getCallCount. Used for load balancing and external pooling.
public Vector<AbstractRecord>	getColumnInfo(String catalog, String schema, String tableName, String columnName, AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getColumnInfo. Return column information for the specified database objects.
public Vector<AbstractRecord>	getColumnInfo(String tableName, String columnName, AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getColumnInfo. Return the column metadata for the specified selection criteria limited to the context of the current `Accessor`.
public Connection	getConnection() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getConnection. Helper method to return the JDBC connection for DatabaseAccessor.
public Object	getDatasourceConnection() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getDatasourceConnection. Return the driver level connection.
public DatasourcePlatform	getDatasourcePlatform() Return the platform.
public Login	getLogin() Return the login
public ConnectionPool	getPool() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getPool. Return the associated connection pool this connection was obtained from.
public int	getReadStatementsCount() Return the number of read statements.
public SequencingCallback	getSequencingCallback(SequencingCallbackFactory sequencingCallbackFactory) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getSequencingCallback. Return sequencing callback.
public int	getStoredProcedureStatementsCount() Return the number of stored procedure call.
public Vector<AbstractRecord>	getTableInfo(String catalog, String schema, String tableName, String[] types, AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getTableInfo. Return table information for the specified database objects.
public Vector<AbstractRecord>	getTableInfo(String tableName, String[] types, AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getTableInfo. Return the table metadata for the specified selection criteria limited to the context of the current `Accessor`.
public int	getWriteStatementsCount() Return the number of write statements.
public synchronized void	incrementCallCount(AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.incrementCallCount. Used for load balancing and external pooling.
public boolean	isConnected() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.isConnected. Return true if the accessor is currently connected to a data source.
protected abstract boolean	isDatasourceConnected() Return if the driver level connection is connected.
public boolean	isInTransaction() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.isInTransaction. Return the transaction status of the receiver.
public boolean	isPossibleFailure()
public boolean	isValid() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.isValid. Returns true if this Accessor can continue to be used.
protected void	reconnect(AbstractSession session) Attempt to save some of the cost associated with getting a fresh connection.
public void	reestablishConnection(AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.reestablishConnection. PUBLIC: Reconnect to the database.
protected void	reestablishCustomizer() This method is called by reestablishConnection.
public void	releaseCustomizer() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.releaseCustomizer. Clear customizer if it's active and set it to null.
public void	releaseCustomizer(AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.releaseCustomizer. Clear and remove customizer if its session is the same as the passed one; in case prevCustomizer exists set it as a new customizer.
public void	reset() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.reset. Reset statement count.
public void	rollbackTransaction(AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.rollbackTransaction. Rollback the transaction on the datasource.
protected void	setCallCount(int callCount) Used for load balancing and external pooling.
protected void	setCustomizer(ConnectionCustomizer newCustomizer) Set customizer, customize the connection if it's available.
protected void	setDatasourceConnection(Object connection) If client requires to manually set connection they can use the connection manager.
public void	setDatasourcePlatform(DatasourcePlatform platform) Set the platform.
protected void	setIsConnected(boolean isConnected) Set whether the accessor has a connection to the "data store".
protected void	setIsInTransaction(boolean value) Set the transaction transaction status of the receiver.
public void	setIsValid(boolean isValid) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.setIsValid. This should be set to false if a communication failure occurred during a call execution.
protected void	setLogin(Login login) SECURE: set the login
public void	setPool(ConnectionPool pool) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.setPool. Set the associated connection pool this connection was obtained from.
public void	setPossibleFailure(boolean possibleFailure)
public boolean	usesExternalConnectionPooling() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.usesExternalConnectionPooling. Return true if some external connection pool is in use.
public boolean	usesExternalTransactionController() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.usesExternalTransactionController. Return true if some external transaction service is controlling transactions.
public void	writesCompleted(AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.writesCompleted. This method will be called after a series of writes have been issued to mark where a particular set of writes has completed.

Inherited from java.lang.Object:: equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

callCount	back to summary
protected int callCount Keep track of the number of concurrent active calls. This is used for connection pooling for loadbalancing and for external connection pooling.

currentSession	back to summary
protected transient AbstractSession currentSession Used only in externalConnectionPooling case. Indicates which session is currently using connection. Allows to rise appropriate session's event when connection is already/still alive. Events will be risen when ClientSession or DatabaseSession acquires connection in the beginning and releases connection in the end of transaction (in afterCompletion in jta case). In case the session requires exclusive connection (ExclusiveIsolatedClientSession) the events will be risen every time the session acquires or releases connection - which is a rare event - the connection is kept for the duration of jta transaction, after jta transaction is completed the new connection is acquired on a first query execution and kept until the next beginTransaction call. In non-jta case the connection is acquired for session's life and release only by session's release. Note that the attribute is nullified only in one place - by closeConnection method.

currentSession

back to summary

protected transient AbstractSession currentSession

Used only in externalConnectionPooling case. Indicates which session is currently using connection. Allows to rise appropriate session's event when connection is already/still alive. Events will be risen when ClientSession or DatabaseSession acquires connection in the beginning and releases connection in the end of transaction (in afterCompletion in jta case). In case the session requires exclusive connection (ExclusiveIsolatedClientSession) the events will be risen every time the session acquires or releases connection - which is a rare event - the connection is kept for the duration of jta transaction, after jta transaction is completed the new connection is acquired on a first query execution and kept until the next beginTransaction call. In non-jta case the connection is acquired for session's life and release only by session's release. Note that the attribute is nullified only in one place - by closeConnection method.

customizer	back to summary
protected ConnectionCustomizer customizer Allows session-specific connection customization.

datasourceConnection	back to summary
protected Object datasourceConnection Store the reference to the driver level connection.

isConnected	back to summary
protected boolean isConnected Keep track of whether the accessor is "connected".

isInTransaction	back to summary
protected boolean isInTransaction Keep track if the accessor is within a transaction context

isValid	back to summary
protected boolean isValid This attribute is used to determine if the connection should be returned to the pool or removed from the pool and closed. It will be set to false if an exception occurs during Call execution.

login	back to summary
protected Login login Store the login information that connected this accessor.

platform	back to summary
protected DatasourcePlatform platform This is also required to ensure all accessors for a session are using the same platform.

pool	back to summary
protected ConnectionPool pool

possibleFailure	back to summary
protected boolean possibleFailure This attribute is used to track failures on an accessor that may be communication based. If a failure is detected executing a call with a query timeout this flag is set. If an error happens twice in a row on the same accessor then that accessor will be checked for a comm error. If there is no query timeout then the flag is not set and the accessor will be checked immediately.

possibleFailure

back to summary

protected boolean possibleFailure

This attribute is used to track failures on an accessor that may be communication based. If a failure is detected executing a call with a query timeout this flag is set. If an error happens twice in a row on the same accessor then that accessor will be checked for a comm error. If there is no query timeout then the flag is not set and the accessor will be checked immediately.

READ_STATEMENTS_COUNT_PROPERTY	back to summary
public static final String READ_STATEMENTS_COUNT_PROPERTY

readStatementsCount	back to summary
public int readStatementsCount Keep track of the number of the read statement that being executed.

sequencingCallback	back to summary
protected transient SequencingCallback sequencingCallback During (not external) transaction, SequencingManager may set SequencingCallback on the accessor, The callback's only method is called when transaction commits, after transaction is completed the callback is discarded.

shouldCheckConnection	back to summary
public static boolean shouldCheckConnection Back-door to allow isConnect checks. Since we now support fail-over and retry, removing old isConnected usage which can cause major performance issues (on Sybase), and minor ones in general.

STOREDPROCEDURE_STATEMENTS_COUNT_PROPERTY	back to summary
public static final String STOREDPROCEDURE_STATEMENTS_COUNT_PROPERTY

storedProcedureStatementsCount	back to summary
public int storedProcedureStatementsCount Keep track of the number of the storedprocedure statement that being executed.

usesExternalConnectionPooling	back to summary
protected boolean usesExternalConnectionPooling PERF: Cache connection pooling flag.

WRITE_STATEMENTS_COUNT_PROPERTY	back to summary
public static final String WRITE_STATEMENTS_COUNT_PROPERTY

writeStatementsCount	back to summary
public int writeStatementsCount Keep track of the number of the write statement that being executed.

Constructor Detail

DatasourceAccessor	back to summary
protected DatasourceAccessor() Default Constructor.

Method Detail

basicBeginTransaction	back to summary
protected abstract void basicBeginTransaction(AbstractSession session) Begin the driver level transaction.

basicCommitTransaction	back to summary
protected abstract void basicCommitTransaction(AbstractSession session) Commit the driver level transaction.

basicExecuteCall	back to summary
protected abstract Object basicExecuteCall(Call call, AbstractRecord row, AbstractSession session) Execute the call to driver level datasource.

basicRollbackTransaction	back to summary
protected abstract void basicRollbackTransaction(AbstractSession session) Rollback the driver level transaction.

beginTransaction	back to summary
public void beginTransaction(AbstractSession session) throws DatabaseException Implements org.eclipse.persistence.internal.databaseaccess.Accessor.beginTransaction. Begin a transaction on the database. If not using managed transaction begin a local transaction. Annotations @Override

beginTransaction

back to summary

public void beginTransaction(AbstractSession session) throws DatabaseException

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.beginTransaction.

Begin a transaction on the database. If not using managed transaction begin a local transaction.

Annotations

@Override

buildConnectLog	back to summary
protected abstract void buildConnectLog(AbstractSession session) Build a log string of any driver metadata that can be obtained.

clone	back to summary
public Object clone() Overrides java.lang.Object.clone. Implements org.eclipse.persistence.internal.databaseaccess.Accessor.clone. Clone the accessor. Returns:Object Doc from java.lang.Object.clone. a clone of this instance. Annotations @Override

clone

back to summary

public Object clone()

Overrides java.lang.Object.clone.

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.clone.

Clone the accessor.

Returns:Object

Doc from java.lang.Object.clone.

a clone of this instance.

Annotations

@Override

closeConnection	back to summary
public void closeConnection() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.closeConnection. Close the accessor's connection. This is used only for external connection pooling when it is intended for the connection to be reconnected in the future. Annotations @Override

closeConnection

back to summary

public void closeConnection()

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.closeConnection.

Close the accessor's connection. This is used only for external connection pooling when it is intended for the connection to be reconnected in the future.

Annotations

@Override

closeDatasourceConnection	back to summary
protected abstract void closeDatasourceConnection() Close the connection to the driver level datasource.

closeJTSConnection	back to summary
public void closeJTSConnection() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.closeJTSConnection. Called from beforeCompletion external transaction synchronization listener callback to close the external connection corresponding to the completing external transaction. Final sql calls could be sent through the connection by this method before it closes the connection. Annotations @Override

closeJTSConnection

back to summary

public void closeJTSConnection()

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.closeJTSConnection.

Called from beforeCompletion external transaction synchronization listener callback to close the external connection corresponding to the completing external transaction. Final sql calls could be sent through the connection by this method before it closes the connection.

Annotations

@Override

commitTransaction	back to summary
public void commitTransaction(AbstractSession session) throws DatabaseException Implements org.eclipse.persistence.internal.databaseaccess.Accessor.commitTransaction. Commit a transaction on the database. If using non-managed transaction commit the local transaction. Annotations @Override

commitTransaction

back to summary

public void commitTransaction(AbstractSession session) throws DatabaseException

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.commitTransaction.

Commit a transaction on the database. If using non-managed transaction commit the local transaction.

Annotations

@Override

connect	back to summary
public void connect(Login login, AbstractSession session) throws DatabaseException Implements org.eclipse.persistence.internal.databaseaccess.Accessor.connect. Connect to the datasource. Through using a CCI ConnectionFactory. Catch exceptions and re-throw as EclipseLink exceptions. Annotations @Override

connect

back to summary

public void connect(Login login, AbstractSession session) throws DatabaseException

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.connect.

Connect to the datasource. Through using a CCI ConnectionFactory. Catch exceptions and re-throw as EclipseLink exceptions.

Annotations

@Override

connectInternal	back to summary
protected void connectInternal(Login login, AbstractSession session) throws DatabaseException Connect to the database. Exceptions are caught and re-thrown as EclipseLink exceptions.

createCustomizer	back to summary
public void createCustomizer(AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.createCustomizer. Attempts to create ConnectionCustomizer. If created the customizer is cached by the accessor. Called by the owner of accessor (DatabaseSession, ServerSession through ConnectionPool) just once, typically right after the accessor is created. Also called by ClientSession when it acquires write accessor. If accessor already has a customizer set by ConnectionPool then ClientSession's customizer compared with the existing one and if they are not equal (don't produce identical customization) then the new customizer set onto accessor, caching the old customizer so that it could be restored later. Annotations @Override

createCustomizer

back to summary

public void createCustomizer(AbstractSession session)

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.createCustomizer.

Attempts to create ConnectionCustomizer. If created the customizer is cached by the accessor. Called by the owner of accessor (DatabaseSession, ServerSession through ConnectionPool) just once, typically right after the accessor is created. Also called by ClientSession when it acquires write accessor. If accessor already has a customizer set by ConnectionPool then ClientSession's customizer compared with the existing one and if they are not equal (don't produce identical customization) then the new customizer set onto accessor, caching the old customizer so that it could be restored later.

Annotations

@Override

decrementCallCount	back to summary
public synchronized void decrementCallCount() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.decrementCallCount. Used for load balancing and external pooling. Annotations @Override

decrementCallCount

back to summary

public synchronized void decrementCallCount()

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.decrementCallCount.

Used for load balancing and external pooling.

Annotations

@Override

disconnect	back to summary
public void disconnect(AbstractSession session) throws DatabaseException Implements org.eclipse.persistence.internal.databaseaccess.Accessor.disconnect. Disconnect from the datasource. Annotations @Override

disconnect

back to summary

public void disconnect(AbstractSession session) throws DatabaseException

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.disconnect.

Disconnect from the datasource.

Annotations

@Override

executeCall	back to summary
public Object executeCall(Call call, AbstractRecord translationRow, AbstractSession session) throws DatabaseException Implements org.eclipse.persistence.internal.databaseaccess.Accessor.executeCall. Execute the call. Returns:Object depending of the type either the row count, row or vector of rows. Annotations @Override

executeCall

back to summary

public Object executeCall(Call call, AbstractRecord translationRow, AbstractSession session) throws DatabaseException

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.executeCall.

Execute the call.

Returns:Object

depending of the type either the row count, row or vector of rows.

Annotations

@Override

flushSelectCalls	back to summary
public void flushSelectCalls(AbstractSession session) Implements org.eclipse.persistence.internal.databaseaccess.Accessor.flushSelectCalls. Added as a result of Bug 2804663 - satisfy the Accessor interface implementation. Annotations @Override

flushSelectCalls

back to summary

public void flushSelectCalls(AbstractSession session)

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.flushSelectCalls.

Added as a result of Bug 2804663 - satisfy the Accessor interface implementation.

Annotations

@Override

getCallCount	back to summary
public int getCallCount() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getCallCount. Used for load balancing and external pooling. Annotations @Override

getCallCount

back to summary

public int getCallCount()

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getCallCount.

Used for load balancing and external pooling.

Annotations

@Override

getColumnInfo	back to summary
public Vector<AbstractRecord> getColumnInfo(String catalog, String schema, String tableName, String columnName, AbstractSession session) throws DatabaseException Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getColumnInfo. Return column information for the specified database objects. Annotations @Override

getColumnInfo

back to summary

public Vector<AbstractRecord> getColumnInfo(String catalog, String schema, String tableName, String columnName, AbstractSession session) throws DatabaseException

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getColumnInfo.

Return column information for the specified database objects.

Annotations

@Override

getColumnInfo back to summary

getColumnInfo	back to summary
public Vector<AbstractRecord> getColumnInfo(String tableName, String columnName, AbstractSession session) throws DatabaseException Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getColumnInfo. Doc from org.eclipse.persistence.internal.databaseaccess.Accessor.getColumnInfo. Return the column metadata for the specified selection criteria limited to the context of the current `Accessor`. Annotations @Override

public Vector<AbstractRecord> getColumnInfo(String tableName, String columnName, AbstractSession session) throws DatabaseException

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getColumnInfo.

Doc from org.eclipse.persistence.internal.databaseaccess.Accessor.getColumnInfo.

Return the column metadata for the specified selection criteria limited to the context of the current Accessor.

Annotations

@Override

getConnection	back to summary
public Connection getConnection() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getConnection. Helper method to return the JDBC connection for DatabaseAccessor. Was going to deprecate this, but since most clients are JDBC this is useful. Annotations @Override

getConnection

back to summary

public Connection getConnection()

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getConnection.

Helper method to return the JDBC connection for DatabaseAccessor. Was going to deprecate this, but since most clients are JDBC this is useful.

Annotations

@Override

getDatasourceConnection	back to summary
public Object getDatasourceConnection() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getDatasourceConnection. Return the driver level connection. Annotations @Override

getDatasourceConnection

back to summary

public Object getDatasourceConnection()

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getDatasourceConnection.

Return the driver level connection.

Annotations

@Override

getDatasourcePlatform	back to summary
public DatasourcePlatform getDatasourcePlatform() Return the platform.

getLogin	back to summary
public Login getLogin() Return the login

getPool	back to summary
public ConnectionPool getPool() Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getPool. Return the associated connection pool this connection was obtained from. Annotations @Override

getPool

back to summary

public ConnectionPool getPool()

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getPool.

Return the associated connection pool this connection was obtained from.

Annotations

@Override

getReadStatementsCount	back to summary
public int getReadStatementsCount() Return the number of read statements.

getSequencingCallback

back to summary

public SequencingCallback getSequencingCallback(SequencingCallbackFactory sequencingCallbackFactory)

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getSequencingCallback.

Return sequencing callback.

Annotations

@Override

getStoredProcedureStatementsCount	back to summary
public int getStoredProcedureStatementsCount() Return the number of stored procedure call.

getTableInfo

back to summary

public Vector<AbstractRecord> getTableInfo(String catalog, String schema, String tableName, String[] types, AbstractSession session) throws DatabaseException

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getTableInfo.

Return table information for the specified database objects.

Annotations

@Override

getTableInfo back to summary

public Vector<AbstractRecord> getTableInfo(String tableName, String[] types, AbstractSession session) throws DatabaseException

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.getTableInfo.

Doc from org.eclipse.persistence.internal.databaseaccess.Accessor.getTableInfo.

Return the table metadata for the specified selection criteria limited to the context of the current Accessor.

Annotations

@Override

getWriteStatementsCount	back to summary
public int getWriteStatementsCount() Return the number of write statements.

incrementCallCount

back to summary

public synchronized void incrementCallCount(AbstractSession session)

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.incrementCallCount.

Used for load balancing and external pooling.

Annotations

@Override

isConnected

back to summary

public boolean isConnected()

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.isConnected.

Return true if the accessor is currently connected to a data source. Return false otherwise.

Annotations

@Override

isDatasourceConnected	back to summary
protected abstract boolean isDatasourceConnected() Return if the driver level connection is connected.

isInTransaction

back to summary

public boolean isInTransaction()

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.isInTransaction.

Return the transaction status of the receiver.

Annotations

@Override

isPossibleFailure	back to summary
public boolean isPossibleFailure()

isValid

back to summary

public boolean isValid()

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.isValid.

Returns true if this Accessor can continue to be used. This will be false if a communication failure occurred during a call execution. In the case of an invalid accessor the Accessor will not be returned to the pool.

Annotations

@Override

reconnect	back to summary
protected void reconnect(AbstractSession session) throws DatabaseException Attempt to save some of the cost associated with getting a fresh connection. Assume the DatabaseDriver has been cached, if appropriate. Note Connections that are participating in transactions will not be refreshed.^M

reestablishConnection

back to summary

public void reestablishConnection(AbstractSession session) throws DatabaseException

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.reestablishConnection.

PUBLIC: Reconnect to the database. This can be used if the connection was disconnected or timedout. This ensures that the security is checked as it is public. Because the messages can take a long time to build, pre-check whether messages should be logged.

Annotations

@Override

reestablishCustomizer

back to summary

protected void reestablishCustomizer()

This method is called by reestablishConnection. Nothing needs to be done in case customize is not active (customization hasn't been applied yet). to repair existing customizer after connection became invalid. However if connection has been customized then if connection is still there and deemed to be valid - clear customization. Otherwise (or if clear fails) remove customizer and set its prevCustomizer as a new customizer, then re-create customizer using the same session as the original one.

releaseCustomizer

back to summary

public void releaseCustomizer()

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.releaseCustomizer.

Clear customizer if it's active and set it to null. Called by the same object that has created customizer (DatabaseSession, ConnectionPool) when the latter is no longer required, typically before releasing the accessor. Ignored if there's no customizer.

Annotations

@Override

releaseCustomizer

back to summary

public void releaseCustomizer(AbstractSession session)

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.releaseCustomizer.

Clear and remove customizer if its session is the same as the passed one; in case prevCustomizer exists set it as a new customizer. Called when ClientSession releases write accessor: if the customizer was created by the ClientSession it's removed, and the previous customizer (that ConnectionPool had set) is brought back; otherwise the customizer (created by ConnectionPool) is kept. Ignored if there's no customizer.

Annotations

@Override

reset

back to summary

public void reset()

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.reset.

Reset statement count.

Annotations

@Override

rollbackTransaction

back to summary

public void rollbackTransaction(AbstractSession session) throws DatabaseException

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.rollbackTransaction.

Rollback the transaction on the datasource. If not using managed transaction rollback the local transaction.

Annotations

@Override

setCallCount	back to summary
protected void setCallCount(int callCount) Used for load balancing and external pooling.

setCustomizer	back to summary
protected void setCustomizer(ConnectionCustomizer newCustomizer) Set customizer, customize the connection if it's available.

setDatasourceConnection	back to summary
protected void setDatasourceConnection(Object connection) If client requires to manually set connection they can use the connection manager.

setDatasourcePlatform	back to summary
public void setDatasourcePlatform(DatasourcePlatform platform) Set the platform. This should be set to the session's platform, not the connections which may not be configured correctly.

setIsConnected	back to summary
protected void setIsConnected(boolean isConnected) Set whether the accessor has a connection to the "data store".

setIsInTransaction	back to summary
protected void setIsInTransaction(boolean value) Set the transaction transaction status of the receiver.

setIsValid

back to summary

public void setIsValid(boolean isValid)

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.setIsValid.

This should be set to false if a communication failure occurred during a call execution. In the case of an invalid accessor the Accessor will not be returned to the pool.

Annotations

@Override

setPool

back to summary

public void setPool(ConnectionPool pool)

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.setPool.

Set the associated connection pool this connection was obtained from.

Annotations

@Override

setPossibleFailure	back to summary
public void setPossibleFailure(boolean possibleFailure)

usesExternalConnectionPooling

back to summary

public boolean usesExternalConnectionPooling()

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.usesExternalConnectionPooling.

Return true if some external connection pool is in use.

Annotations

@Override

usesExternalTransactionController

back to summary

public boolean usesExternalTransactionController()

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.usesExternalTransactionController.

Return true if some external transaction service is controlling transactions.

Annotations

@Override

writesCompleted

back to summary

public void writesCompleted(AbstractSession session)

Implements org.eclipse.persistence.internal.databaseaccess.Accessor.writesCompleted.

This method will be called after a series of writes have been issued to mark where a particular set of writes has completed. It will be called from commitTransaction and may be called from writeChanges. Its main purpose is to ensure that the batched statements have been executed

Annotations

@Override

public abstract Class DatasourceAccessor

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail