diff options
Diffstat (limited to 'jpa/plugins/org.eclipse.jpt.db/src/org/eclipse/jpt/db/internal/DTPConnectionWrapper.java')
| -rw-r--r-- | jpa/plugins/org.eclipse.jpt.db/src/org/eclipse/jpt/db/internal/DTPConnectionWrapper.java | 225 |
1 files changed, 0 insertions, 225 deletions
diff --git a/jpa/plugins/org.eclipse.jpt.db/src/org/eclipse/jpt/db/internal/DTPConnectionWrapper.java b/jpa/plugins/org.eclipse.jpt.db/src/org/eclipse/jpt/db/internal/DTPConnectionWrapper.java deleted file mode 100644 index 180ff5c998..0000000000 --- a/jpa/plugins/org.eclipse.jpt.db/src/org/eclipse/jpt/db/internal/DTPConnectionWrapper.java +++ /dev/null @@ -1,225 +0,0 @@ -/******************************************************************************* - * Copyright (c) 2006, 2007 Oracle. All rights reserved. - * This program and the accompanying materials are made available under the - * terms of the Eclipse Public License v1.0, which accompanies this distribution - * and is available at http://www.eclipse.org/legal/epl-v10.html. - * - * Contributors: - * Oracle - initial API and implementation - ******************************************************************************/ -package org.eclipse.jpt.db.internal; - -import java.util.ArrayList; -import java.util.Collection; - -import org.eclipse.datatools.connectivity.ConnectEvent; -import org.eclipse.datatools.connectivity.IManagedConnection; -import org.eclipse.datatools.connectivity.IManagedConnectionOfflineListener; - -/** - * Wraps to two DTP connections (1 for live connection & 1 for offline). - * The connections are not cached any more, but obtained each time from the ConnectionProfile. - */ -final class DTPConnectionWrapper extends Connection { - - final private DTPConnectionProfileWrapper profile; - private LocalConnectionListener connectionListener; - - // ********** constructors ********** - - DTPConnectionWrapper( DTPConnectionProfileWrapper profile) { - super(); - this.profile = profile; - this.initialize(); - } - - // ********** behavior ********** - - protected void initialize() { - this.connectionListener = new LocalConnectionListener(); - this.getDTPConnection().addConnectionListener( this.connectionListener); - this.getDTPOfflineConnection().addConnectionListener( this.connectionListener); - } - - @Override - protected void dispose() { - this.getDTPConnection().removeConnectionListener( this.connectionListener); - this.getDTPOfflineConnection().removeConnectionListener( this.connectionListener); - } - - @Override - void databaseChanged( Database database, int eventType) { - - this.connectionListener.databaseChanged( database, eventType); - } - - @Override - void schemaChanged( Schema schema, Database database, int eventType) { - - this.connectionListener.schemaChanged( schema, database, eventType); - } - - @Override - void tableChanged( Table table, Schema schema, Database database, int eventType) { - - this.connectionListener.tableChanged( table, schema, database, eventType); - } - - // ********** queries ********** - - private IManagedConnection getDTPConnection() { - - return this.profile.getDTPConnection(); - } - - private IManagedConnection getDTPOfflineConnection() { - - return this.profile.getDTPOfflineConnection(); - } - - @Override - public String getName() { - - return this.getDTPConnection().getConnection().getConnectionProfile().getName(); - } - - @Override - String getFactoryId() { - - return this.getDTPConnection().getFactoryID(); - } - - @Override - protected boolean connectionIsOnline() { - return this.profile.connectionIsOnline(); - } - - // ********** listeners ********** - - @Override - void addConnectionListener( ConnectionListener listener) { - // hook up the specified listener to our intermediate listeners - this.connectionListener.addConnectionListener( listener); - } - - @Override - void removeConnectionListener( ConnectionListener listener) { - - this.connectionListener.removeConnectionListener( listener); - } - - // ********** member classes ********** - - /** - * This listener translates and forwards IManagedConnectionListener events to ConnectionListeners. - */ - private class LocalConnectionListener implements IManagedConnectionOfflineListener { - private Collection<ConnectionListener> listeners = new ArrayList<ConnectionListener>(); - - LocalConnectionListener() { - super(); - } - - void addConnectionListener( ConnectionListener listener) { - this.listeners.add( listener); - } - - void removeConnectionListener( ConnectionListener listener) { - this.listeners.remove( listener); - } - - // ********** behavior ********** - - public void aboutToClose( ConnectEvent event) { - if( event.getConnection() == DTPConnectionWrapper.this.getDTPConnection()) { - for (ConnectionListener listener : this.listeners) { - listener.aboutToClose( DTPConnectionWrapper.this.profile); - } - } - } - - public void aboutToDetach( ConnectEvent event) { - if( event.getConnection() == DTPConnectionWrapper.this.getDTPOfflineConnection()) { - for (ConnectionListener listener : this.listeners) { - listener.aboutToClose( DTPConnectionWrapper.this.profile); - } - } - } - - public void closed( ConnectEvent event) { - // There is no DETACHED event, therefore closed is sent twice (i.e. by both connections) - for (ConnectionListener listener : this.listeners) { - listener.closed( DTPConnectionWrapper.this.profile); - } - } - - public boolean okToClose( ConnectEvent event) { - if( event.getConnection() == DTPConnectionWrapper.this.getDTPConnection()) { - for (ConnectionListener listener : this.listeners) { - if( !listener.okToClose( DTPConnectionWrapper.this.profile)) { - return false; - } - } - } - return true; - } - - public boolean okToDetach( ConnectEvent event) { - if( event.getConnection() == DTPConnectionWrapper.this.getDTPOfflineConnection()) { - for (ConnectionListener listener : this.listeners) { - if( !listener.okToClose( DTPConnectionWrapper.this.profile)) { - return false; - } - } - } - return true; - } - - public void opened( ConnectEvent event) { - if( event.getConnection() == DTPConnectionWrapper.this.getDTPConnection()) { - for (ConnectionListener listener : this.listeners) { - listener.opened( DTPConnectionWrapper.this.profile); - } - } - } - - public void workingOffline( ConnectEvent event) { - for (ConnectionListener listener : this.listeners) { - listener.opened( DTPConnectionWrapper.this.profile); - } - } - - public void aboutToAttach( ConnectEvent event) { - // not interested to this event. - return; - } - - public void modified( ConnectEvent event) { - for (ConnectionListener listener : this.listeners) { - listener.modified( DTPConnectionWrapper.this.profile); - } - } - - @SuppressWarnings("unused") - void databaseChanged( Database database, int eventType) { - for (ConnectionListener listener : this.listeners) { - listener.databaseChanged( DTPConnectionWrapper.this.profile, database); - } - } - - @SuppressWarnings("unused") - void schemaChanged( Schema schema, Database database, int eventType) { - for (ConnectionListener listener : this.listeners) { - listener.schemaChanged( DTPConnectionWrapper.this.profile, schema); - } - } - - @SuppressWarnings("unused") - void tableChanged( Table table, Schema schema, Database database, int eventType) { - for (ConnectionListener listener : this.listeners) { - listener.tableChanged( DTPConnectionWrapper.this.profile, table); - } - } - } - -} |