org.eclipse.persistence.platform.database.oracle.dcn
Class OracleChangeNotificationListener

java.lang.Object
  org.eclipse.persistence.platform.database.oracle.dcn.OracleChangeNotificationListener

All Implemented Interfaces:

DatabaseEventListener

public class OracleChangeNotificationListener
extends java.lang.Object
implements DatabaseEventListener

PUBLIC: Listener for Oracle Database Change event Notification (DCN). This allows the EclipseLink cache to be invalidated by database events.

See Also:

org.eclipse.persistence.descriptors.invalidation.DatabaseEventNotificationPolicy

Author:

James Sutherland

Since:

EclipseLink 2.4

Field Summary

protected java.util.Map<org.eclipse.persistence.internal.helper.DatabaseTable,ClassDescriptor>	descriptorsByTable Map each table to the descriptor that needs to be invalidated.
static java.lang.String	ORA_TRANSACTION_ID
protected oracle.jdbc.dcn.DatabaseChangeRegistration	register The Oracle JDBC registration object.
static java.lang.String	ROWID
protected ValueReadQuery	transactionIdQuery Cache query for transaction id.

Constructor Summary

OracleChangeNotificationListener()

Method Summary

java.util.Map<org.eclipse.persistence.internal.helper.DatabaseTable,ClassDescriptor>	getDescriptorsByTable() INTERNAL: Return the mapping of tables to descriptors.
oracle.jdbc.dcn.DatabaseChangeRegistration	getRegister() INTERNAL: Return the database register.
void	initialize(ClassDescriptor descriptor, org.eclipse.persistence.internal.sessions.AbstractSession session) Initialize the descriptor to receive database change events.
void	register(Session session) INTERNAL: Register the event listener with the database.
void	remove(Session session) INTERNAL: Remove the event listener from the database.
protected void	setDescriptorsByTable(java.util.Map<org.eclipse.persistence.internal.helper.DatabaseTable,ClassDescriptor> descriptorsByTable) INTERNAL: Set the mapping of tables to descriptors.
protected void	setRegister(oracle.jdbc.dcn.DatabaseChangeRegistration register) INTERNAL: Set the database register.

Methods inherited from class java.lang.Object

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

Field Detail

ORA_TRANSACTION_ID

public static java.lang.String ORA_TRANSACTION_ID

ROWID

public static java.lang.String ROWID

register

protected oracle.jdbc.dcn.DatabaseChangeRegistration register

The Oracle JDBC registration object.

descriptorsByTable

protected java.util.Map<org.eclipse.persistence.internal.helper.DatabaseTable,ClassDescriptor> descriptorsByTable

Map each table to the descriptor that needs to be invalidated.

transactionIdQuery

protected ValueReadQuery transactionIdQuery

Cache query for transaction id.

Constructor Detail

OracleChangeNotificationListener

public OracleChangeNotificationListener()

Method Detail

register

public void register(Session session)

INTERNAL: Register the event listener with the database.

Specified by:

register in interface DatabaseEventListener

initialize

public void initialize(ClassDescriptor descriptor,
                       org.eclipse.persistence.internal.sessions.AbstractSession session)

Initialize the descriptor to receive database change events. This is called when the descriptor is initialized.

Specified by:

initialize in interface DatabaseEventListener

remove

public void remove(Session session)

INTERNAL: Remove the event listener from the database.

Specified by:

remove in interface DatabaseEventListener

getRegister

public oracle.jdbc.dcn.DatabaseChangeRegistration getRegister()

INTERNAL: Return the database register.

setRegister

protected void setRegister(oracle.jdbc.dcn.DatabaseChangeRegistration register)

INTERNAL: Set the database register.

getDescriptorsByTable

public java.util.Map<org.eclipse.persistence.internal.helper.DatabaseTable,ClassDescriptor> getDescriptorsByTable()

INTERNAL: Return the mapping of tables to descriptors.

setDescriptorsByTable

protected void setDescriptorsByTable(java.util.Map<org.eclipse.persistence.internal.helper.DatabaseTable,ClassDescriptor> descriptorsByTable)

INTERNAL: Set the mapping of tables to descriptors.