/*******************************************************************************
 * 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.IManagedConnectionListener;

/**
 *  Wrap a DTP Connection
 */
public final class DTPConnectionWrapper extends Connection {
	
	final private org.eclipse.datatools.connectivity.IManagedConnection dtpConnection;
	private LocalConnectionListener connectionListener;
	
	// ********** constructors **********

	DTPConnectionWrapper( org.eclipse.datatools.connectivity.IManagedConnection dtpConnection) {
		super();
		this.dtpConnection = dtpConnection;
		this.initialize();
	}

	// ********** behavior **********
	
	protected void initialize() {
		this.connectionListener = new LocalConnectionListener();
		this.dtpConnection.addConnectionListener( this.connectionListener);
	}
	
	@Override
	protected void dispose() {
		this.dtpConnection.removeConnectionListener( this.connectionListener);
	}

	@Override
	public String getName() {

		return this.dtpConnection.getConnection().getConnectionProfile().getName();
	}
	
	@Override
	public boolean isConnected() {

		return this.dtpConnection.isConnected();
	}

	@Override
	public String getFactoryId() {
		
		return this.dtpConnection.getFactoryID();
	}

	@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);
	}
		
	// ********** listeners **********

	@Override
	public void addConnectionListener( ConnectionListener listener) {
		// hook up the specified listener to our intermediate listeners
		this.connectionListener.addConnectionListener( listener);
	}

	@Override
	public void removeConnectionListener( ConnectionListener listener) {

		this.connectionListener.removeConnectionListener( listener);
	}
	
	// ********** member classes **********

	/**
	 * This listener translates and forwards IManagedConnectionListener events to ConnectionListeners.
	 */
	private class LocalConnectionListener implements IManagedConnectionListener {
		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) {
			for (ConnectionListener listener : this.listeners) {
				listener.aboutToClose( DTPConnectionWrapper.this);
			}
		}

		public void closed( ConnectEvent event) {
			for (ConnectionListener listener : this.listeners) {
				listener.closed( DTPConnectionWrapper.this);
			}
		}

		public void modified( ConnectEvent event) {
			for (ConnectionListener listener : this.listeners) {
				listener.modified( DTPConnectionWrapper.this);
			}
		}

		public boolean okToClose( ConnectEvent event) {
			for (ConnectionListener listener : this.listeners) {
				if( !listener.okToClose( DTPConnectionWrapper.this)) {
					return false;
				}
			}
			return true;
		}
		
		public void opened( ConnectEvent event) {
			for (ConnectionListener listener : this.listeners) {
				listener.opened( DTPConnectionWrapper.this);
			}
		}
		
		void databaseChanged( Database database, int eventType) {
			for (ConnectionListener listener : this.listeners) {
				listener.databaseChanged( DTPConnectionWrapper.this, database);
			}
		}
		
		void schemaChanged( Schema schema, Database database, int eventType) {
			for (ConnectionListener listener : this.listeners) {
				listener.schemaChanged( DTPConnectionWrapper.this, schema);
			}
		}
		
		void tableChanged( Table table, Schema schema, Database database, int eventType) {
			for (ConnectionListener listener : this.listeners) {
				listener.tableChanged( DTPConnectionWrapper.this, table);
			}
		}
	}

}