Application: gvSIG desktop

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0

                      http://maven.apache.org/maven-v4_0_0.xsd">

	<modelVersion>4.0.0</modelVersion>

	<groupId>org.gvsig</groupId>

	<artifactId>org.gvsig.app.join</artifactId>

	<packaging>jar</packaging>

	<version>2.0-SNAPSHOT</version>

	<name>extDalTransformJoin</name>

	<description>Allow join 2 tables by a common field and removing join.</description>

	<url>http://maven.apache.org</url>

	<parent>

		<groupId>org.gvsig</groupId>

		<artifactId>gvsig-base-extension-pom</artifactId>

		<version>2.0-SNAPSHOT</version>

	</parent>	

	<distributionManagement>

		<site>

			<id>gvsig-repository</id>

			<url>${site-repository}/</url>

		</site>

	</distributionManagement>

	<dependencies>

		<dependency>

			<groupId>org.gvsig</groupId>

			<artifactId>org.gvsig.app.daltransform</artifactId>

			<version>2.0-SNAPSHOT</version>

		</dependency>	

		<dependency>

			<groupId>org.gvsig</groupId>

			<artifactId>org.gvsig.andami</artifactId>

			<version>2.0-SNAPSHOT</version>

		</dependency>

		<dependency>

			<groupId>org.gvsig</groupId>

			<artifactId>org.gvsig.app</artifactId>

			<version>2.0-SNAPSHOT</version>

		</dependency>		

		<dependency>

			<groupId>org.gvsig</groupId>

			<artifactId>org.gvsig.projection</artifactId>

			<version>2.0-SNAPSHOT</version>

		</dependency>

		<!--TEST-->

		<dependency>

			<groupId>org.gvsig</groupId>

			<artifactId>org.gvsig.app.daltransform</artifactId>

			<version>2.0-SNAPSHOT</version>

			<classifier>tests</classifier>

			<scope>test</scope>

		</dependency>

		<dependency>

			<groupId>org.gvsig</groupId>

			<artifactId>org.gvsig.fmap.dal</artifactId>

			<version>2.0-SNAPSHOT</version>

			<classifier>tests</classifier>

			<scope>test</scope>

		</dependency>

		<dependency>

			<groupId>org.gvsig</groupId>

			<artifactId>org.gvsig.tools.lib</artifactId>

			<classifier>tests</classifier>

			<scope>test</scope>

		</dependency>		

	</dependencies>

	<build>

		<sourceDirectory>src</sourceDirectory>

		<testSourceDirectory>src-test</testSourceDirectory>

		<resources>

			<resource>

				<directory>${basedir}/resources</directory>

			</resource>

		</resources>

		<plugins>			

			<plugin>

				<groupId>org.apache.maven.plugins</groupId>

				<artifactId>maven-jar-plugin</artifactId>

				<executions>

					<!--

						Generates a jar file only with the test classes

					-->

					<execution>

						<goals>

							<goal>test-jar</goal>

						</goals>

						<configuration>

							<includes>

								<include>**/**</include>												

							</includes>

							<excludes>

								<exclude>NONE</exclude>

							</excludes>

						</configuration>

					</execution>

				</executions>

			</plugin>

			<!-- TODO: MAKE TESTS WORK AND REMOVE THIS OPTION -->

			<plugin>

				<groupId>org.apache.maven.plugins</groupId>

				<artifactId>maven-surefire-plugin</artifactId>

				<configuration>

					<skipTests>true</skipTests>

				</configuration>

			</plugin>

		</plugins>

	</build>	

	<properties>

		<build-dir>${basedir}/../build</build-dir>

	</properties>

</project>

org.gvsig.app.join.JoinTransformLibrary

<assembly>

  <id>distribution</id>

  <formats>

    <format>dir</format>

  </formats>

  <fileSets>

    <fileSet>

      <directory>config</directory>

	  <outputDirectory>${extension.install.dir.name}</outputDirectory>

    </fileSet>    

	<fileSet>

      <directory>images</directory>

	  <outputDirectory>/${extension.install.dir.name}/images</outputDirectory>

    </fileSet>

  </fileSets>

    <files>

        <file>

            <source>package.info</source>

            <outputDirectory>${extension.install.dir.name}

            </outputDirectory>

        </file>

    </files>

  	<dependencySets>

  		<dependencySet>			

  			<outputDirectory>${extension.install.dir.name}/${library-dir}

        	</outputDirectory>

          	 <includes>

           		<include>org.gvsig:org.gvsig.app.join</include>        	 

        	</includes>

  		</dependencySet>  		

	</dependencySets>

</assembly>

#maven.buildNumber.plugin properties file

#Mon Nov 08 10:00:26 CET 2010

buildNumber=2021

/* gvSIG. Geographic Information System of the Valencian Government

*

* Copyright (C) 2007-2008 Infrastructures and Transports Department

* of the Valencian Government (CIT)

* 

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* of the License, or (at your option) any later version.

* 

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU General Public License for more details.

* 

* You should have received a copy of the GNU General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, 

* MA  02110-1301, USA.

* 

*/

/*

* AUTHORS (In addition to CIT):

* 2009 {Iver T.I.}   {Task}

*/

package org.gvsig.app.join.dal.feature;

import java.io.File;

import java.net.URL;

import java.util.ArrayList;

import java.util.Iterator;

import org.gvsig.app.daltransform.BaseFeatureStoreTransform;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.exception.InitializeException;

import org.gvsig.fmap.dal.exception.ProviderNotRegisteredException;

import org.gvsig.fmap.dal.exception.ValidateDataParametersException;

import org.gvsig.fmap.dal.feature.FeatureAttributeDescriptor;

import org.gvsig.fmap.dal.feature.FeatureStore;

import org.gvsig.fmap.dal.feature.FeatureStoreTransform;

import org.gvsig.fmap.dal.store.dbf.DBFStoreParameters;

import org.gvsig.fmap.dal.store.dbf.DBFStoreProvider;

/**

 * @author <a href="mailto:jpiera@gvsig.org">Jorge Piera</a>

 */

public class JoinTransformTest extends BaseFeatureStoreTransform {

	private final File dbf = new File("src-test/org/gvsig/app/join/dal/feature/data/join.dbf");

	@Override

	public DataStoreParameters getDefaultDataStoreParameters()

			throws DataException {		

		DBFStoreParameters dbfParameters = null;

		dbfParameters = (DBFStoreParameters) dataManager

				.createStoreParameters(DBFStoreProvider.NAME);

		dbfParameters.setFile(dbf);

		return dbfParameters;

	}

	@Override

	public FeatureStoreTransform getFeatureStoreTransform()

			throws DataException, ValidateDataParametersException {

		URL url = JoinTransformTest.class.getResource("data/events.dbf");

		FeatureStore store = (FeatureStore) dataManager.createStore(this

				.getDefaultDataStoreParameters());

		FeatureStore store2 = (FeatureStore) dataManager.createStore(this

				.getDefaultDataStoreParameters2());		

		JoinTransform transform = new JoinTransform();

		ArrayList names = new ArrayList();

		Iterator iter = store2.getDefaultFeatureType().iterator();// <FeatureAttributeDescriptor>

		while (iter.hasNext()) {

			names.add(((FeatureAttributeDescriptor) iter.next()).getName());

		}

		transform.initialize(store, store2, 

				"NOMBRE", "NOMBRE", 

				null, null, 

				(String[]) names.toArray(new String[0]));

		return transform;

	}

	private DataStoreParameters getDefaultDataStoreParameters2() throws InitializeException, ProviderNotRegisteredException{

		DBFStoreParameters dbfParameters = null;

		dbfParameters = (DBFStoreParameters) dataManager

				.createStoreParameters(DBFStoreProvider.NAME);

		dbfParameters.setFile(dbf);

		return dbfParameters;

	}

}

<?xml version="1.0" encoding="ISO-8859-1"?>

<plugin-config>

	<libraries library-dir="lib"/>

	<depends plugin-name="org.gvsig.app"/>

	<depends plugin-name="org.gvsig.app.daltransform"/>

	<resourceBundle name="text"/>

	<extensions>

		<extension class-name="org.gvsig.app.join.RemoveTableUnion"

			description="Extensi?n encargada de quitar uniones de las tablas."

			active="true">

			<menu text="Tabla/quitar_uniones"/>

		</extension>

		<extension class-name="org.gvsig.app.join.JoinToolExtension"

			description="Extensi?n encargada de gestionar las operaciones sobre las tablas."

			active="true">

			<menu text="Tabla/join" icon="table-join" action-command="JOIN"/>

			<tool-bar name="Herramientas" position="12">

				<action-tool icon="table-join" action-command="JOIN" tooltip="join" position="1"/>

			</tool-bar>

		</extension>			

	</extensions>

	<icon src="gvsig-logo-icon" text="gvSIG"/>

</plugin-config>

#

#Mon Nov 08 10:00:30 CET 2010

state=devel

name=extDalTransformJoin

official=true

code=org.gvsig.app.join

operating-system=all

architecture=all

java-version=j1_5

gvSIG-version=2.0.0

version=2.0-SNAPSHOT

type=plugin

build=2021

description=Allow join 2 tables by a common field and removing join.

model-version=1.0.0

/**

 *

 */

package org.gvsig.project.document.table.gui;

import java.awt.Dimension;

import java.awt.event.ItemEvent;

import java.awt.event.ItemListener;

import javax.swing.ImageIcon;

import jwizardcomponent.FinishAction;

import org.gvsig.andami.PluginServices;

import org.gvsig.andami.messages.NotificationManager;

import org.gvsig.app.gui.simpleWizard.SimpleWizard;

import org.gvsig.app.join.JoinToolExtension;

import org.gvsig.app.project.documents.table.TableDocument;

import org.gvsig.app.project.documents.table.FieldSelectionModel;

import org.gvsig.app.project.documents.table.gui.TableWizardStep;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.exception.ReadException;

import org.gvsig.fmap.dal.feature.FeatureAttributeDescriptor;

import org.gvsig.fmap.dal.feature.FeatureStore;

public class JoinWizardController {

	private final JoinToolExtension tableOperations;

	/**

	 * @param tableOperations

	 */

	public JoinWizardController(JoinToolExtension tableOperations) {

		this.tableOperations = tableOperations;

	}

	public void runWizard(TableDocument[] pts) {

		// create wizard

		ImageIcon logo = PluginServices.getIconTheme().get("table-join");

		final SimpleWizard wizard = new SimpleWizard(logo);

		wizard.getWindowInfo().setTitle(PluginServices.getText(this, "Table_Join"));

		// create first step (source table)

		final TableWizardStep srcTableWzrd = new TableWizardStep(wizard.getWizardComponents(), "Title" );

		srcTableWzrd.getHeaderLbl().setText(PluginServices.getText(this,"Source_table_options"));

		srcTableWzrd.getTableNameLbl().setText(PluginServices.getText(this,"Source_table_"));

		srcTableWzrd.getFieldNameLbl().setText(PluginServices.getText(this,"Field_to_use_for_JOIN_"));

		srcTableWzrd.getFieldPrefixLbl().setText(PluginServices.getText(this,"Field_prefix_"));

		srcTableWzrd.getTableNameCmb().addItemListener(

				new ItemListener() {

					public void itemStateChanged(ItemEvent e) {

						if (e.getStateChange()==e.SELECTED) {

							TableDocument pt = (TableDocument) srcTableWzrd.getTableNameCmb().getSelectedItem();

							srcTableWzrd.setFieldModel(new FieldSelectionModel(

									pt.getStore(),

									PluginServices.getText(this, "seleccione_campo_enlace"),

									-1));

							srcTableWzrd.getFieldPrefixTxt().setText(tableOperations.sanitizeFieldName(pt.getName()));

						}

					}

				}

		);

		for (int i=0; i<pts.length; i++) {

			srcTableWzrd.getTableNameCmb().addItem(pts[i]);

		}

		// create second step (target table)

		final TableWizardStep targTableWzrd = new TableWizardStep(wizard.getWizardComponents(), "Title" );

		targTableWzrd.getHeaderLbl().setText(PluginServices.getText(this,"Target_table_options"));

		targTableWzrd.getTableNameLbl().setText(PluginServices.getText(this,"Target_table_"));

		targTableWzrd.getFieldNameLbl().setText(PluginServices.getText(this,"Field_to_use_for_JOIN_"));

		targTableWzrd.getFieldPrefixLbl().setText(PluginServices.getText(this,"Field_prefix_"));

		targTableWzrd.getTableNameCmb().addItemListener(

			new ItemListener() {

				public void itemStateChanged(ItemEvent e) {

					if (e.getStateChange()==e.SELECTED) 

						setTrgtWzrdFieldType(srcTableWzrd, targTableWzrd);

				}

			}

		);

		srcTableWzrd.getFieldNameCmb().addItemListener(new ItemListener() {

			public void itemStateChanged(ItemEvent e) {

				if (e.getStateChange()==e.SELECTED)

					setTrgtWzrdFieldType(srcTableWzrd,targTableWzrd);

			}

		});

		for (int i=0; i<pts.length; i++) {

			targTableWzrd.getTableNameCmb().addItem(pts[i]);

		}

		// add steps and configure wizard

		wizard.getWizardComponents().addWizardPanel(srcTableWzrd);

		wizard.getWizardComponents().addWizardPanel(targTableWzrd);

		wizard.getWizardComponents().updateComponents();

		wizard.setSize(new Dimension(450, 230));

		wizard.getWizardComponents().setFinishAction(new FinishAction(wizard.getWizardComponents()) {

			public void performAction() {

				TableDocument sourceProjectTable = (TableDocument) srcTableWzrd.getTableNameCmb().getSelectedItem();

				String field1 = (String) srcTableWzrd.getFieldNameCmb().getSelectedItem();

				String prefix1 = srcTableWzrd.getFieldPrefixTxt().getText();

				if (sourceProjectTable==null || field1==null || prefix1 == null) {

					NotificationManager.showMessageError(

							PluginServices.getText(this, "Join_parameters_are_incomplete"), new InvalidParameterException());

					return;

				}

				TableDocument targetProjectTable = (TableDocument) targTableWzrd.getTableNameCmb().getSelectedItem();

				String field2 = (String) targTableWzrd.getFieldNameCmb().getSelectedItem();

				String prefix2 = targTableWzrd.getFieldPrefixTxt().getText();

				if (targetProjectTable==null || field2==null || prefix2 == null) {

					NotificationManager.showMessageError(

							PluginServices.getText(this, "Join_parameters_are_incomplete"), new InvalidParameterException());

					return;

				}

				tableOperations.execJoin(sourceProjectTable, field1, prefix1, targetProjectTable, field2, prefix2);

				PluginServices.getMDIManager().closeWindow(wizard);

			}

		}

		);

		// show the wizard

		PluginServices.getMDIManager().addWindow(wizard);

	}

	private void setTrgtWzrdFieldType(TableWizardStep srcTableWzrd,TableWizardStep targTableWzrd) {

		try {

			//tabla

			TableDocument sourcePt = (TableDocument) srcTableWzrd.getTableNameCmb().getSelectedItem();

			TableDocument targetPt = (TableDocument) targTableWzrd.getTableNameCmb().getSelectedItem();

			targTableWzrd.getFieldPrefixTxt().setText(tableOperations.sanitizeFieldName(targetPt.getName()));

			//?ndice del campo

			FeatureStore sds = sourcePt.getStore();

			String fieldName = (String) srcTableWzrd.getFieldNameCmb().getSelectedItem();

			FeatureAttributeDescriptor fad=sds.getDefaultFeatureType().getAttributeDescriptor(fieldName);

//			int fieldIndex = sds.getFieldIndexByName(fieldName);

//			if (fieldIndex!=-1) {

//				int type = sds.getFieldType(fieldIndex);

				targTableWzrd.setFieldModel(new FieldSelectionModel(

						targetPt.getStore(),

						PluginServices.getText(this, "seleccione_campo_enlace"),

						fad.getType()));

//			}

//			else {

//				NotificationManager.addError(PluginServices.getText(this, "Error_getting_table_fields")

//						, new Exception());

//			}

		} catch (ReadException e2) {

			NotificationManager.addError(PluginServices.getText(this, "Error_getting_table_fields"),

					e2);

		} catch (DataException e2) {

			NotificationManager.addError(PluginServices.getText(this, "Error_getting_table_fields"),

					e2);

		}

	}

	private class InvalidParameterException extends Exception {

	}

}

package org.gvsig.app.join;

import org.gvsig.andami.PluginServices;

import org.gvsig.andami.plugins.Extension;

import org.gvsig.andami.ui.mdiManager.IWindow;

import org.gvsig.app.join.dal.feature.JoinTransform;

import org.gvsig.app.project.documents.table.TableDocument;

import org.gvsig.app.project.documents.table.gui.FeatureTableDocumentPanel;

import org.gvsig.fmap.dal.feature.FeatureStore;

import org.gvsig.fmap.dal.feature.FeatureStoreTransform;

import org.gvsig.fmap.dal.feature.FeatureStoreTransforms;

/**

 * @author Fernando Gonz?lez Cort?s

 */

public class RemoveTableUnion extends Extension{

	/**

	 * @see org.gvsig.andami.plugins.IExtension#initialize()

	 */

	public void initialize() {

		// TODO Auto-generated method stub

	}

	/**

	 * @see org.gvsig.andami.plugins.IExtension#execute(java.lang.String)

	 */

	public void execute(String actionCommand) {

		FeatureTableDocumentPanel t = (FeatureTableDocumentPanel) PluginServices.getMDIManager().getActiveWindow();

		TableDocument pt = t.getModel();

		FeatureStore fs = pt.getStore();

		this.removeJoinTransfor(fs);

		//		TODO

		//		if (fs instanceof JoinFeatureStore) {

		//			DataManager dm = DALLocator.getDataManager();

		//			DataStoreParameters originalParams = ((JoinFeatureStoreParameters) fs

		//					.getParameters()).getStorePrimary();

		//			FeatureStore original = null;

		//			try {

		//				original = (FeatureStore) dm.createStore(originalParams);

		//			} catch (InitializeException e) {

		//				NotificationManager.addError(e.getMessage(), e);

		//				return;

		//			}

		//

		//			pt.setStore(original);

		//			try {

		//				fs.dispose();

		//			} catch (CloseException e) {

		//				NotificationManager.addError(e);

		//			}

		//			t.setModel(pt);

		//

		//		}

		//		t.clearSelectedFields();

		t.getModel().setModified(true);

	}

	public void removeJoinTransfor(FeatureStore store) {

		FeatureStoreTransforms transforms = store.getTransforms();

		int size = transforms.size();

		if (size < 1) {

			return;

		}

		FeatureStoreTransform join = transforms.getTransform(size - 1);

		if (join instanceof JoinTransform) {

			transforms.remove(join);

		} else {

			return;

		}

	}

	public boolean hasJoinTransform(FeatureStore store) {

		FeatureStoreTransforms transforms = store.getTransforms();

		int size = transforms.size();

		if (size < 1) {

			return false;

		}

		return (transforms.getTransform(size - 1) instanceof JoinTransform);

	}

	/**

	 * @see org.gvsig.andami.plugins.IExtension#isEnabled()

	 */

	public boolean isEnabled() {

		IWindow v = PluginServices.getMDIManager().getActiveWindow();

		if (v == null) {

			return false;

		}

		if (v.getClass() == FeatureTableDocumentPanel.class) {

			FeatureTableDocumentPanel t = (FeatureTableDocumentPanel) v;

			// FIXME !!!! Asi se hacia antes

			//			if (t.getModel().getOriginal() != null){

			//				return true;

			//			}

			TableDocument pt = t.getModel();

			FeatureStore fs = pt.getStore();

			return this.hasJoinTransform(fs);

//			TODO

//			if (fs instanceof JoinFeatureStore) {

//				return true;

//			}

		}

		return false;

	}

	/**

	 * @see org.gvsig.andami.plugins.IExtension#isVisible()

	 */

	public boolean isVisible() {

		IWindow v = PluginServices.getMDIManager().getActiveWindow();

		if (v == null) {

			return false;

		}

		if (v instanceof FeatureTableDocumentPanel) {

			return true;

		} else {

			return false;

		}

	}

}

/* gvSIG. Geographic Information System of the Valencian Government

*

* Copyright (C) 2007-2008 Infrastructures and Transports Department

* of the Valencian Government (CIT)

* 

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* of the License, or (at your option) any later version.

* 

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU General Public License for more details.

* 

* You should have received a copy of the GNU General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, 

* MA  02110-1301, USA.

* 

*/

/*

* AUTHORS (In addition to CIT):

* 2009 {Iver T.I.}   {Task}

*/

package org.gvsig.app.join;

import org.gvsig.app.daltransform.DataTransformLocator;

import org.gvsig.app.daltransform.DataTransformManager;

import org.gvsig.app.join.dal.feature.JoinTransform;

import org.gvsig.app.join.daltransform.JoinTransformGui;

import org.gvsig.fmap.dal.impl.DALDefaultImplLibrary;

import org.gvsig.tools.library.AbstractLibrary;

import org.gvsig.tools.library.LibraryException;

import org.gvsig.tools.locator.ReferenceNotRegisteredException;

/**

 * @author <a href="mailto:jpiera@gvsig.org">Jorge Piera</a>

 */

public class JoinTransformLibrary extends AbstractLibrary {

	@Override

	protected void doInitialize() throws LibraryException {

		// TODO Auto-generated method stub

	}

	@Override

	protected void doPostInitialize() throws LibraryException {

		new DALDefaultImplLibrary().postInitialize();

		// Validate there is any implementation registered.

		DataTransformManager dataTransformManager = DataTransformLocator.getDataTransformManager();

		if (dataTransformManager == null) {

			throw new ReferenceNotRegisteredException(

					DataTransformLocator.DATA_TRANSFORM_MANAGER_NAME, DataTransformLocator.getInstance());

		}	

		dataTransformManager.registerDataTransform("join", JoinTransformGui.class);		

		JoinTransform.registerPersistent();

	}

}

package org.gvsig.app.join.dal.feature;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.HashMap;

import java.util.Iterator;

import java.util.List;

import java.util.Map;

import java.util.Map.Entry;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.feature.AbstractFeatureStoreTransform;

import org.gvsig.fmap.dal.feature.EditableFeature;

import org.gvsig.fmap.dal.feature.EditableFeatureType;

import org.gvsig.fmap.dal.feature.Feature;

import org.gvsig.fmap.dal.feature.FeatureAttributeDescriptor;

import org.gvsig.fmap.dal.feature.FeatureQuery;

import org.gvsig.fmap.dal.feature.FeatureSet;

import org.gvsig.fmap.dal.feature.FeatureStore;

import org.gvsig.fmap.dal.feature.FeatureType;

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.dispose.DisposableIterator;

import org.gvsig.tools.dynobject.DynStruct;

import org.gvsig.tools.evaluator.Evaluator;

import org.gvsig.tools.evaluator.EvaluatorData;

import org.gvsig.tools.evaluator.EvaluatorException;

import org.gvsig.tools.evaluator.EvaluatorFieldsInfo;

import org.gvsig.tools.persistence.PersistenceManager;

import org.gvsig.tools.persistence.PersistentState;

import org.gvsig.tools.persistence.exception.PersistenceException;

public class JoinTransform extends AbstractFeatureStoreTransform {

	/**

	 * Store from which the join transform will get the additional attributes

	 */

	private FeatureStore store2;

	/**

	 * name of the key attr in store1 that will be used to match features in

	 * store2

	 */

	private String keyAttr1;

	/**

	 * name of the key attr in store2 that will be used to match features in

	 * store1

	 */

	private String keyAttr2;

	/**

	 * names of the attributes to join from store2 to store1

	 */

	private String[] attrs;

	/**

	 * Attribute names may change after transformation if they are repeated in

	 * both stores. This map keeps correspondence between store2 original names

	 * and their transformed counterparts.

	 */

	private Map<String,String> targetNamesMap;

	private JoinTransformEvaluator evaluator = null;

	private FeatureType originalFeatureType;

	private String[] attrsForQuery;

	private String prefix1;

	private String prefix2;

	/**

	 * A default constructor

	 */

	public JoinTransform() {

		targetNamesMap = new HashMap<String,String>();

	}

	/**

	 * Initializes all the necessary data for this transform

	 *

	 * @param store1

	 *            store whose default feature type is the target of this

	 *            transform

	 *

	 * @param store2

	 *            store whose default feature type will provide the new

	 *            attributes to join

	 *

	 * @param keyAttr1

	 *            key attribute in store1 that matches keyAttr2 in store2

	 *            (foreign key), used for joining both stores.

	 *

	 * @param keyAttr2

	 *            key attribute in store2 that matches keyAttr1 in store2

	 *            (foreign key), used for joining both stores.

	 *

	 * @param attrs

	 *            names of the attributes in store2 that will be joined to

	 *            store1.

	 */

	public void initialize(FeatureStore store1, FeatureStore store2,

			String keyAttr1, String keyAttr2, String prefix1, String prefix2,

			String[] attrs)

	throws DataException {

		if (store1 == store2) {

			throw new IllegalArgumentException("store1 == store2");

		}

		// Initialize needed data

		this.setFeatureStore(store1);

		this.store2 = store2;

		this.keyAttr1 = keyAttr1;

		this.keyAttr2 = keyAttr2;

		this.prefix1 = prefix1; // TODO

		this.prefix2 = prefix2; // TODO

		this.attrs = attrs;

		// calculate this transform resulting feature type

		// by adding all specified attrs from store2 to store1's default

		// feature type

		// FIXME for more than one FTypes ??

		this.originalFeatureType = this.getFeatureStore()

		.getDefaultFeatureType();

		// TODO tener en cuenta prefix1

		EditableFeatureType type = this.getFeatureStore().getDefaultFeatureType().getEditable();

		FeatureType type2 = store2.getDefaultFeatureType();

		// TODO tener en cuenta prefix2

		for (int i = 0; i < attrs.length; i++) {

			String name = attrs[i];

			// If an attribute already exists with the same name in store1's

			// default feature type,

			// calculate an alternate name and add it to our type

			int j = 0;

			while (type.getIndex(name) >= 0) {

				name = attrs[i] + "_" + ++j;

			}

			type.add(name,

					type2.getAttributeDescriptor(attrs[i]).getType());

			// keep correspondence between original name and transformed name

			this.targetNamesMap.put(attrs[i], name);

		}

		if (this.targetNamesMap.containsKey(keyAttr2)) {

			this.attrsForQuery = this.attrs;

		} else {

			List<String> list = new ArrayList<String>(this.attrs.length + 1);

			list.addAll(Arrays.asList(this.attrs));

			list.add(keyAttr2);

			this.attrsForQuery = (String[]) list.toArray(new String[] {});

		}

		// assign calculated feature type as this transform's feature type

		FeatureType[] types = new FeatureType[] { type.getNotEditableCopy() };

		setFeatureTypes(Arrays.asList(types), types[0]);

	}

	/**

	 *

	 *

	 * @param source

	 *

	 * @param target

	 *

	 * @throws DataException

	 */

	public void applyTransform(Feature source, EditableFeature target)

	throws DataException {

		// copy the data from store1 into the resulting feature

		this.copySourceToTarget(source, target);

		// ask store2 for the specified attributes, filtering by the key

		// attribute value

		// from the source feature

		JoinTransformEvaluator eval = this.getEvaluator();

		eval.updateValue(source.get(this.keyAttr1));

		FeatureQuery query = store2.createFeatureQuery();

		query.setAttributeNames(attrsForQuery);

		query.setFilter(eval);

		FeatureSet set = null;

		DisposableIterator itFeat = null;

		try {

			set = store2.getFeatureSet(query);

			// In this join implementation, we will take only the first matching

			// feature found in store2

			Feature feat;

			itFeat = set.iterator();

			if (itFeat.hasNext()) {

				feat = (Feature) itFeat.next();

				// copy all attributes from joined feature to target

				this.copyJoinToTarget(feat, target);

			}

		} finally {

			if (itFeat != null) {

				itFeat.dispose();

			}

			if (set != null) {

				set.dispose();

			}

		}

	}

	/**

	 * @param feat

	 * @param target

	 */

	private void copyJoinToTarget(Feature join, EditableFeature target) {

		Iterator<Entry<String, String>> iter = targetNamesMap.entrySet()

		.iterator();

		Entry<String, String> entry;

		FeatureType trgType = target.getType();

		FeatureAttributeDescriptor attr;

		while (iter.hasNext()) {

			entry = iter.next();

			attr = trgType.getAttributeDescriptor((String) entry.getValue());

			if (attr != null) {

				target.set(attr.getIndex(), join.get((String) entry.getKey()));

			}

		}

	}

	/**

	 * @param source

	 * @param target

	 */

	private void copySourceToTarget(Feature source, EditableFeature target) {

		FeatureAttributeDescriptor attr, attrTrg;

		FeatureType ftSrc = source.getType();

		FeatureType ftTrg = target.getType();

		for (int i = 0; i < source.getType().size(); i++) {

			attr = ftSrc.getAttributeDescriptor(i);

			attrTrg = ftTrg.getAttributeDescriptor(attr.getName());

			if (attrTrg != null) {

				try {

					target.set(attrTrg.getIndex(), source.get(i));

				} catch (IllegalArgumentException e) {

					attrTrg = ftTrg.getAttributeDescriptor(attr.getName());

					target.set(attrTrg.getIndex(), attrTrg.getDefaultValue());

				}

			}

		}

	}

	private JoinTransformEvaluator getEvaluator() {

		if (this.evaluator == null){

			this.evaluator = new JoinTransformEvaluator(keyAttr2);

		}

		return evaluator;

	}

	private class JoinTransformEvaluator implements Evaluator {

		private String attribute;

		private Object value;

		private String sql;

		private EvaluatorFieldsInfo info = null;

		//		private int attributeIndex;

		public JoinTransformEvaluator(String attribute) {

			this.attribute = attribute;

			this.value = null;

			this.info = new EvaluatorFieldsInfo();

			//			this.attributeIndex = attrIndex;

		}

		public void updateValue(Object value) {

			this.value = value;

			this.sql = this.attribute + "= '" + this.value + "'";

			this.info = new EvaluatorFieldsInfo();

			this.info.addMatchFieldValue(this.attribute, value);

		}

		public Object evaluate(EvaluatorData arg0) throws EvaluatorException {

			Object curValue = arg0.getDataValue(attribute);

			if (curValue == null) {

				return value == null;

			}

			return curValue.equals(value);

		}

		public String getSQL() {

			return this.sql;

		}

		public String getDescription() {

			return "Evaluates join transform match";

		}

		public String getName() {

			return "JoinTransformEvaluator";

		}

		public EvaluatorFieldsInfo getFieldsInfo() {

			return this.info;

		}

	}	

	@SuppressWarnings("unchecked")

	public FeatureType getSourceFeatureTypeFrom(FeatureType arg0) {

		EditableFeatureType orgType = originalFeatureType.getEditable();

		Iterator<FeatureAttributeDescriptor> iter = arg0.iterator();

		FeatureAttributeDescriptor attr;

		List<String> toRetain = new ArrayList<String>();

		while (iter.hasNext()) {

			attr = (FeatureAttributeDescriptor) iter.next();

			if (this.targetNamesMap.containsValue(attr.getName())) {

				continue;

			}

			toRetain.add(attr.getName());

		}

		if (!toRetain.contains(keyAttr1)) {

			toRetain.add(keyAttr1);

		}

		iter = originalFeatureType.iterator();

		while (iter.hasNext()) {

			attr = (FeatureAttributeDescriptor) iter.next();

			if (!toRetain.contains(attr.getName())) {

				orgType.remove(attr.getName());

			}

		}

		return orgType.getNotEditableCopy();

	}

	public boolean isTransformsOriginalValues() {

		return false;

	}

	public static void registerPersistent() {

		PersistenceManager manager = ToolsLocator.getPersistenceManager();

		if( manager.getDefinition(AbstractFeatureStoreTransform.class) == null ) {

			AbstractFeatureStoreTransform.registerPersistent();

		}

		DynStruct definition = manager.addDefinition(

				JoinTransform.class,

				"JoinTransform",

				"JoinTransform Persistence definition",

				null, 

				null

		);

		definition.extend(PersistenceManager.PERSISTENCE_NAMESPACE,

				ABSTRACT_FEATURESTORE_DYNCLASS_NAME);

		definition.addDynFieldObject("store2").setClassOfValue(FeatureStore.class).setMandatory(true);

		definition.addDynFieldString("keyAttr1").setMandatory(true);

		definition.addDynFieldString("keyAttr2").setMandatory(true);

		definition.addDynFieldString("prefix1").setMandatory(true);

		definition.addDynFieldString("prefix2").setMandatory(true);

		definition.addDynFieldList("attrs").setClassOfItems(String.class).setMandatory(true);

	}

	public void saveToState(PersistentState state) throws PersistenceException {

		super.saveToState(state);

		state.set("store2", this.store2);

		state.set("keyAttr1", this.keyAttr1);

		state.set("keyAttr2", this.keyAttr2);

		state.set("prefix1", this.prefix1);

		state.set("prefix2", this.prefix2);		

		state.set("attrs", this.attrs);

	}

	public void loadFromState(PersistentState state) throws PersistenceException {

		super.loadFromState(state);

		FeatureStore store2 = (FeatureStore) state.get("store2");

		String keyAttr1 = state.getString("keyAttr1");

		String keyAttr2 = state.getString("keyAttr2");

		String prefix2 =  state.getString("prefix2");

		String[] attrs = (String[]) state.getArray("attrs", String.class);

		try {

			initialize(getFeatureStore(), store2, keyAttr1, keyAttr2, prefix1, prefix2, attrs);

		} catch (DataException e) {

			throw new PersistenceException("Impossible to create the transform", e);

		}

	}

}

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2008 Infrastructures and Transports Department

 * of the Valencian Government (CIT)

 * 

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * of the License, or (at your option) any later version.

 * 

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 * 

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, 

 * MA  02110-1301, USA.

 * 

 */

/*

 * AUTHORS (In addition to CIT):

 * 2009 {Iver T.I.}   {Task}

 */

package org.gvsig.app.join;

import java.util.ArrayList;

import java.util.Iterator;

import java.util.List;

import org.gvsig.andami.messages.NotificationManager;

import org.gvsig.app.extension.TableOperations;

import org.gvsig.app.join.dal.feature.JoinTransform;

import org.gvsig.app.project.Project;

import org.gvsig.app.project.ProjectManager;

import org.gvsig.app.project.documents.table.TableDocument;

import org.gvsig.app.project.documents.table.TableManager;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.exception.ReadException;

import org.gvsig.fmap.dal.feature.FeatureAttributeDescriptor;

import org.gvsig.fmap.dal.feature.FeatureStore;

import org.gvsig.project.document.table.gui.JoinWizardController;

/**

 * @author <a href="mailto:jpiera@gvsig.org">Jorge Piera</a>

 */

public class JoinToolExtension extends TableOperations {

//	private FeatureStore featureStore = null;

	/**

	 * @see com.iver.mdiApp.plugins.IExtension#updateUI(java.lang.String)

	 */

	public void execute(String actionCommand) {

//		ProjectExtension pe = (ProjectExtension) PluginServices.getExtension(ProjectExtension.class);

//		org.gvsig.app.project.Project project=pe.getProject();

		Project project = ProjectManager.getInstance().getCurrentProject();

		TableDocument[] pts = project.getDocuments(TableManager.TYPENAME)

		.toArray(new TableDocument[0]);

		JoinWizardController wizardController = new JoinWizardController(this);

		wizardController.runWizard(pts);

	}	

	@SuppressWarnings("unchecked")

	public void execJoin(TableDocument sourceProjectTable,

			String field1, String prefix1,

			TableDocument targetProjectTable, String field2,

			String prefix2) {

		FeatureStore fs1 = sourceProjectTable.getStore();

		FeatureStore fs2 = targetProjectTable.getStore();

		if (fs1 == fs2) {

			NotificationManager

					.addInfo("no_es_posible_aplicar_join_sobre_la_misma_fuente");

		}

		try {

//			DataManager dm = DALLocator.getDataManager();

			JoinTransform jt = new JoinTransform();

			List<String> fields = new ArrayList<String>();

			Iterator<FeatureAttributeDescriptor> iterator2 = fs2.getDefaultFeatureType().iterator();

			while (iterator2.hasNext()) {

				FeatureAttributeDescriptor descriptor = (FeatureAttributeDescriptor) iterator2

						.next();

				String name = descriptor.getName();

				if (!name.equals(field2)) {

					fields.add(name);

				}

			}

			jt.initialize(fs1, fs2, field1, field2, prefix1, prefix2, fields

					.toArray(new String[0]));

			fs1.getTransforms().add(jt);

			// featureStore=fs1;

		} catch (ReadException e) {

			NotificationManager.addError("Error leyendo del driver", e);

		} catch (DataException e) {

			NotificationManager.addError(e);

		}

	}

}

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2008 Infrastructures and Transports Department

 * of the Valencian Government (CIT)

 * 

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * of the License, or (at your option) any later version.

 * 

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 * 

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, 

 * MA  02110-1301, USA.

 * 

 */

/*

 * AUTHORS (In addition to CIT):

 * 2009 {Iver T.I.}   {Task}

 */

package org.gvsig.app.join.daltransform;

import java.awt.Dimension;

import java.util.ArrayList;

import java.util.List;

import org.gvsig.andami.PluginServices;

import org.gvsig.app.daltransform.gui.DataTransformGui;

import org.gvsig.app.daltransform.gui.DataTransformWizardPanel;

import org.gvsig.app.join.dal.feature.JoinTransform;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.feature.FeatureStore;

import org.gvsig.fmap.dal.feature.FeatureStoreTransform;

/**

 * @author <a href="mailto:jpiera@gvsig.org">Jorge Piera</a>

 */

public class JoinTransformGui implements DataTransformGui {

	private SelectSecondDataStoreWizardPanel secondDataStoreWizard = null;

	private SelectParametersWizardPanel parametersWizard = null;

	private List<DataTransformWizardPanel> panels = null;	

	public JoinTransformGui() {

		super();			

	}

	/* (non-Javadoc)

	 * @see org.gvsig.app.daltransform.gui.FeatureTransformGui#createFeatureStoreTransform(org.gvsig.fmap.dal.feature.FeatureStore)

	 */

	public FeatureStoreTransform createFeatureStoreTransform(

			FeatureStore featureStore) throws DataException {

		JoinTransform transform = new JoinTransform();

		transform.initialize(featureStore,

				secondDataStoreWizard.getSelectedFeatureStore(),

				parametersWizard.getKeyAttr1(),

				parametersWizard.getkeyAtrr2(),

				parametersWizard.getPrefix1(),

				parametersWizard.getPrefix2(),

				parametersWizard.getAttributes()

		);

		return transform;

	}

	/* (non-Javadoc)

	 * @see org.gvsig.app.daltransform.gui.FeatureTransformGui#getDescription()

	 */

	public String getDescription() {

		return PluginServices.getText(this, "join_description");

	}

	/* (non-Javadoc)

	 * @see org.gvsig.app.daltransform.gui.FeatureTransformGui#createPanels(org.gvsig.app.daltransform.gui.FeatureTransformWizardModel)

	 */

	public List<DataTransformWizardPanel> createPanels() {

		if (panels == null){

			parametersWizard = new SelectParametersWizardPanel();

			secondDataStoreWizard = new SelectSecondDataStoreWizardPanel(parametersWizard);

			panels = new ArrayList<DataTransformWizardPanel>();

			panels.add(secondDataStoreWizard);

			panels.add(parametersWizard);				

		}	

		return panels;		

	}

	/* (non-Javadoc)

	 * @see org.gvsig.app.daltransform.gui.FeatureTransformGui#getName()

	 */

	public String getName() {

		return PluginServices.getText(this, "join_name");

	}

	/* (non-Javadoc)

	 * @see org.gvsig.app.daltransform.gui.DataTransformGui#getMinDimension()

	 */

	public Dimension getMinDimension() {

		// TODO Auto-generated method stub

		return null;

	}

}

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2008 Infrastructures and Transports Department

 * of the Valencian Government (CIT)

 * 

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * of the License, or (at your option) any later version.

 * 

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 * 

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, 

 * MA  02110-1301, USA.

 * 

 */

/*

 * AUTHORS (In addition to CIT):

 * 2009 {Iver T.I.}   {Task}

 */

package org.gvsig.app.join.daltransform;

import org.gvsig.andami.PluginServices;

import org.gvsig.app.daltransform.gui.impl.SelectDataStoreWizardPanel;

import org.gvsig.fmap.dal.exception.DataException;

/**

 * @author <a href="mailto:jpiera@gvsig.org">Jorge Piera</a>

 */

public class SelectSecondDataStoreWizardPanel extends SelectDataStoreWizardPanel{

	private SelectParametersWizardPanel selectParametersWizardPanel = null;

	/**

	 * @param featureTransformWizardModel

	 */

	public SelectSecondDataStoreWizardPanel(SelectParametersWizardPanel selectParametersWizardPanel) {

		super();	

		this.selectParametersWizardPanel = selectParametersWizardPanel;

	}

	/* (non-Javadoc)

	 * @see org.gvsig.app.daltransform.gui.SelectDataStoreWizard#getPanelTitle()

	 */	

	public String getPanelTitle() {

		return PluginServices.getText(this, "transform_second_datastore_selection");

	}

	/* (non-Javadoc)

	 * @see jwizardcomponent.JWizardPanel#next()

	 */	

	public void nextPanel() {

		try {

			selectParametersWizardPanel.updateFeatureStores(getSelectedFeatureStore());

		} catch (DataException e) {

			logger.error("Error updating the params panel", e);

		}

	}

	/* (non-Javadoc)

	 * @see org.gvsig.app.daltransform.gui.SelectDataStoreWizard#update()

	 */

	public void updatePanel() {

		removeFeatureStore(getDataTransformWizard().getFeatureStore());

		super.updatePanel();

	}