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>

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

	<packaging>jar</packaging>

	<version>2.0-SNAPSHOT</version>

	<name>Transformation: Join</name>

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

	<parent>

		<groupId>org.gvsig</groupId>

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

		<version>2.0-SNAPSHOT</version>

	</parent>	

	<dependencies>

		<dependency>

			<groupId>org.gvsig</groupId>

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

            <scope>compile</scope>

		</dependency>

		<dependency>

			<groupId>org.gvsig</groupId>

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

			<version>2.0-SNAPSHOT</version>

            <scope>compile</scope>

		</dependency>		

		<dependency>

            <groupId>org.gvsig</groupId>

            <artifactId>org.gvsig.app.document.table.app.mainplugin</artifactId>

            <version>2.0.0-SNAPSHOT</version>

            <scope>compile</scope>

        </dependency>  

        <dependency>

            <groupId>org.gvsig</groupId>

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

            <version>2.0-SNAPSHOT</version>

            <scope>compile</scope>

        </dependency>  

        <dependency>

            <groupId>org.gvsig</groupId>

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

            <scope>compile</scope>

        </dependency>

        <dependency>

            <groupId>org.gvsig</groupId>

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

            <scope>compile</scope>

        </dependency>  

		<dependency>

            <groupId>org.gvsig</groupId>

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

            <scope>compile</scope>

        </dependency>	

        <dependency>

            <groupId>org.gvsig</groupId>

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

            <scope>compile</scope>

        </dependency>       

        <dependency>

            <groupId>org.gvsig</groupId>

            <artifactId>org.gvsig.i18n</artifactId>

            <scope>compile</scope>

        </dependency> 

        <dependency>

            <groupId>org.gvsig</groupId>

            <artifactId>org.gvsig.metadata.lib.basic.api</artifactId>

            <scope>compile</scope>

        </dependency>

        <dependency>

            <groupId>org.gvsig</groupId>

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

            <scope>compile</scope>

        </dependency>      

        <dependency>

            <groupId>org.gvsig</groupId>

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

            <scope>compile</scope>

        </dependency>        

        <dependency>

            <groupId>org.gvsig</groupId>

            <artifactId>org.gvsig.utils</artifactId>

            <scope>compile</scope>

        </dependency>

        <dependency>

            <groupId>jwizardcomponent</groupId>

            <artifactId>jwizardcomponent</artifactId>

            <scope>compile</scope>

        </dependency>

        <dependency>

            <groupId>org.slf4j</groupId>

            <artifactId>slf4j-api</artifactId>

            <scope>compile</scope>

        </dependency>

        <dependency>

            <groupId>org.gvsig</groupId>

            <artifactId>org.gvsig.timesupport.lib.impl</artifactId>

            <scope>runtime</scope>

        </dependency>

		<!--TEST-->

		<dependency>

			<groupId>org.gvsig</groupId>

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

			<version>2.0-SNAPSHOT</version>

            <type>test-jar</type>

            <scope>test</scope>

		</dependency>

		<dependency>

			<groupId>org.gvsig</groupId>

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

			<classifier>tests</classifier>

			<scope>test</scope>

		</dependency>

		<dependency>

			<groupId>org.gvsig</groupId>

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

			<type>test-jar</type>

			<scope>test</scope>

		</dependency>		

	</dependencies>

	<build>

		<sourceDirectory>src</sourceDirectory>

		<testSourceDirectory>src-test</testSourceDirectory>

		<resources>

			<resource>

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

			</resource>

		</resources>

		<plugins>			

			<!-- 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>

        <eclipse.project.name>extDalTransformJoin</eclipse.project.name>

        <package.info.dependencies>required: org.gvsig.daltransform.app.mainplugin -ge 2</package.info.dependencies>

        <package.info.state>devel</package.info.state>

        <!-- alpha-devel -->

	</properties>

</project>

join_description=La uni?n entre tablas crea una nueva tabla a partir de dos tablas de origen. Para ello es necesario que ambas tengan un campo con el que poder hacer la uni?n.

join_name=Uni?n

join_first_key=Selecciona la clave de la primera tabla

join_second_key=Selecciona la clave de la segunda tabla

join_first_prefix=Escriba el prefijo de la primera tabla

join_second_prefix=Escriba el prefijo de la segunda tabla

join_select_attributes=Selecciona los atributos a unir

_Unable_to_refresh_table_contents=No se ha podido actualizar la tabla

_First_table_has_no_fields=La primera tabla no tiene campos

_Join=Uni?n de tablas

_Error_getting_attributes=Error al obtener campos

_No_compatible_field_in_second_table=No hay campos compatibles en la segunda tabla

_Remove_join=Deshacer uni?n

_Create_join=Crear uni?n

join_description=Join two tables creates a new table from a two origin tables. It is necessary a common attribute to apply the join. 

join_name=Join

join_first_key=Select the key of the first table

join_second_key=Select the key of the second table

join_first_prefix=Type a prefix for the first table

join_second_prefix=Type a prefix for the second table

join_select_attributes=Select the attributes to join

_Unable_to_refresh_table_contents=Unable to refresh table contents

_First_table_has_no_fields=First table has no fields

_Join=Join

_Error_getting_attributes=Error getting attributes

_No_compatible_field_in_second_table=No compatible fields in second table

_Remove_join=Remove join

_Create_join=Create join

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 05 17:10:36 CET 2012

buildNumber=2061

/* 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.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 {		

	    DataStoreParameters dbfParameters = null;

        dbfParameters = dataManager.createStoreParameters(DBFStoreProvider.NAME);

        dbfParameters.setDynValue("dbfFile", 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.daltransform.app.mainplugin"/>

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

	<resourceBundle name="text"/>

	<extensions>

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

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

			active="true">

            <action 

                name="table-remove-join"

                label="_Remove_join" 

                tooltip="_Remove_join" 

                position="501200000" 

                action-command="table-remove-join"

                icon="table-remove-join"

                accelerator=""

                />

			<menu

			     name="table-remove-join" 

			     text="Table/_Remove_join"

			/>

		</extension>

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

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

			active="true">

            <action 

                name="table-create-join"

                label="_Create_join" 

                tooltip="_Create_join" 

                position="501200000" 

                action-command="table-create-join"

                icon="table-create-join"

                accelerator=""

                />

            <menu

                name="table-create-join" 

                text="Table/_Create_join"

                />

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

				<action-tool name="table-create-join"/>

			</tool-bar>

		</extension>			

	</extensions>

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

</plugin-config>

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

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

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

import org.gvsig.daltransform.DataTransformLibrary;

import org.gvsig.daltransform.DataTransformLocator;

import org.gvsig.daltransform.DataTransformManager;

import org.gvsig.fmap.dal.DALLibrary;

import org.gvsig.i18n.Messages;

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

    public void doRegistration() {

        registerAsImplementationOf(JoinTransformLibrary.class);

        require(DALLibrary.class);

        require(DataTransformLibrary.class);

    }

	@Override

	protected void doInitialize() throws LibraryException {

		if (!Messages.hasLocales()) {

            Messages.addLocale(Locale.getDefault());

        }

        Messages.addResourceFamily("org.gvsig.app.join.i18n.text",

            JoinTransformLibrary.class.getClassLoader(),

            JoinTransformLibrary.class.getClass().getName());		

	}

	@Override

	protected void doPostInitialize() throws LibraryException {

		// 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.EditableFeatureAttributeDescriptor;

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 {

    public static final String PERSISTENCE_DEFINITION_NAME = "JoinTransform";

    /**

     * 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 a prefix is applied.

     * This map keeps correspondence between store1 original names

     * and their transformed counterparts.

     */

    private Map<String,String> store1NamesMap;

    /**

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

     * both stores or if a prefix is applied. This map keeps correspondence

     * between store2 original names and their transformed counterparts.

     */

    private Map<String,String> store2NamesMap;

    private JoinTransformEvaluator evaluator = null;

    private FeatureType originalFeatureType;

    private String[] attrsForQuery;

    private String prefix1;

    private String prefix2;

    /**

     * A default constructor

     */

    public JoinTransform() {

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

        store2NamesMap = 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();

        // keep index of geometry and att desc ==============

        int orig_geom_field_index =

            this.originalFeatureType.getDefaultGeometryAttributeIndex();

        FeatureAttributeDescriptor orig_geom_field_att = 

            this.originalFeatureType.getDefaultGeometryAttribute();

        // Create the feature type and copy the store 1 type        

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

        FeatureAttributeDescriptor[] featureAttributeDescriptors = editableFeatureType.getAttributeDescriptors();

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

            editableFeatureType.remove(featureAttributeDescriptors[i].getName());           

        }    

        addFeatureType(editableFeatureType, featureAttributeDescriptors, prefix1, store1NamesMap);

        // =========== set the new geom field name and restore geometry values

        if (orig_geom_field_index >= 0) {

            EditableFeatureAttributeDescriptor ed_att = null;

            ed_att = (EditableFeatureAttributeDescriptor)

                editableFeatureType.getAttributeDescriptor(orig_geom_field_index);

            ed_att.setSRS(orig_geom_field_att.getSRS());

            ed_att.setObjectClass(orig_geom_field_att.getObjectClass());

            ed_att.setGeometryType(orig_geom_field_att.getGeomType());

            ed_att.setDefaultValue(orig_geom_field_att.getDefaultValue());

            String new_geom_field_name = ed_att.getName();

            editableFeatureType.setDefaultGeometryAttributeName(new_geom_field_name);

        }

        // =====================================================================

        // Add the store 2 fields    

        FeatureType featureType2 = store2.getDefaultFeatureType();

        // Add the fields       

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

            addFeatureType(editableFeatureType, featureType2.getAttributeDescriptor(attrs[i]), prefix2, store2NamesMap);        

        }

        if (this.store2NamesMap.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[] { editableFeatureType.getNotEditableCopy() };

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

    }

    private void addFeatureType(EditableFeatureType targetFeatureType, FeatureAttributeDescriptor[] featureAttributeDescriptors,

        String prefix, Map<String, String> storeMap) throws DataException{

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

            addFeatureType(targetFeatureType, featureAttributeDescriptors[i], prefix, storeMap);

        }

    }

    private void addFeatureType(EditableFeatureType targetFeatureType, FeatureAttributeDescriptor featureAttributeDescriptor,

        String prefix, Map<String, String> storeMap) throws DataException{

        String attName = featureAttributeDescriptor.getName();

        if ((prefix != null) && (!prefix.equals(""))){

            attName = prefix + "_" + attName;

        }

        // If an attribute already exists, calculate an alternate name and add it to our type

        int j = 0;

        while (targetFeatureType.getIndex(attName) >= 0) {

            attName = targetFeatureType.getAttributeDescriptor(attName).getName() + "_" + ++j;

        }

        EditableFeatureAttributeDescriptor editableFeatureAttributeDescriptor = 

            targetFeatureType.add(attName, featureAttributeDescriptor.getType(),

                featureAttributeDescriptor.getSize());

        editableFeatureAttributeDescriptor.setPrecision(featureAttributeDescriptor.getPrecision());

        // keep correspondence between original name and transformed name

        storeMap.put(featureAttributeDescriptor.getName(), attName);

    } 

    /**

     *

     *

     * @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 = store2NamesMap.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(store1NamesMap.get(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) {

        return originalFeatureType;

    }

    public boolean isTransformsOriginalValues() {

        return false;

    }

    public static void registerPersistent() {

        PersistenceManager persistenceManager = ToolsLocator.getPersistenceManager();

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

            AbstractFeatureStoreTransform.registerPersistent();

        }

        DynStruct definition = persistenceManager.getDefinition(PERSISTENCE_DEFINITION_NAME);

        if (definition == null){  

            definition = persistenceManager.addDefinition(

                JoinTransform.class,

                PERSISTENCE_DEFINITION_NAME,

                "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(false);

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

            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. Desktop Geographic Information System.

 *

 * Copyright ? 2007-2012 gvSIG Association

 *

 * 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.

 *

 * For any additional information, do not hesitate to contact us

 * at info AT gvsig.com, or visit our website www.gvsig.com.

 */

package org.gvsig.app.join.utils;

import java.util.ArrayList;

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

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

import org.gvsig.tools.dataTypes.DataTypes;

/**

 * {@link DataTypes}-related utility methods

 * 

 * @author jldominguez

 *

 */

public class TransformUtils {

    public static boolean isNumericType(int t) {

        return (t == DataTypes.DOUBLE

            || t == DataTypes.FLOAT

            || t == DataTypes.INT

            || t == DataTypes.LONG

            || t == DataTypes.BYTE);

    }

    public static boolean comparableTypes(int a, int b) {

        if (a == b) {

            return true;

        } else {

            return isNumericType(a) && isNumericType(b);

        }

    }

    /**

     * @param ft

     * @param the_type

     * @return

     */

    public static ArrayList<Integer> getComparableDataTypes(

        FeatureType ft,

        int the_type) {

        ArrayList<Integer> resp = new ArrayList<Integer>();

        FeatureAttributeDescriptor[] atts = ft.getAttributeDescriptors();

        int len = atts.length;

        for (int i=0; i<len; i++) {

            if (comparableTypes(the_type, atts[i].getType())) {

                resp.add(atts[i].getType());

            }

        }

        return resp;

    }

}

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

import javax.swing.JOptionPane;

import org.gvsig.andami.IconThemeHelper;

import org.gvsig.andami.PluginServices;

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

import org.gvsig.app.extension.TableOperations;

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

import org.gvsig.daltransform.DataTransformLocator;

import org.gvsig.daltransform.swing.DataTransformWizard;

/**

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

 */

public class JoinToolExtension extends TableOperations {

	public void initialize() {

		IconThemeHelper.registerIcon("action", "table-create-join", this);

	}

	/**

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

	 */

	public void execute(String actionCommand) {

		if( "table-create-join".equalsIgnoreCase(actionCommand)) {

		    try {

		        DataTransformWizard dataTransformWizard = DataTransformLocator.getDataTransformManager().createWizard();

	            dataTransformWizard.setDataTransformGui(new JoinTransformGui());

		        PluginServices.getMDIManager().addWindow(dataTransformWizard.getWindow());

	        } catch (Exception e) {

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

	            JOptionPane.showInternalMessageDialog(

	                iw instanceof Component ? (Component) iw : null,

	                    PluginServices.getText(this, "transform_create_wizard_exception"),

	                    PluginServices.getText(this, "feature_transform"),

	                    JOptionPane.ERROR_MESSAGE);

	        }

		}

	}		

}

/* 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 javax.swing.JOptionPane;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.gvsig.andami.PluginServices;

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

import org.gvsig.app.ApplicationLocator;

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

import org.gvsig.daltransform.swing.DataTransformGui;

import org.gvsig.daltransform.swing.DataTransformWizardPanel;

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

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

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

import org.gvsig.fmap.mapcontrol.dal.feature.swing.FeatureTypesTablePanel;

import org.gvsig.fmap.mapcontrol.dal.feature.swing.table.ConfigurableFeatureTableModel;

import org.gvsig.i18n.Messages;

/**

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

 */

public class JoinTransformGui implements DataTransformGui {

    private static Logger logger = LoggerFactory.getLogger(JoinTransformGui.class);

	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;

	}

    public boolean accept(FeatureStore featureStore) {        

        return true;

    }

    public String toString() {

        return getName();

    }

}

/* 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.daltransform.swing.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();

	}

}

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

import java.awt.event.ActionListener;

import java.util.ArrayList;

import javax.swing.JOptionPane;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.gvsig.andami.PluginServices;

import org.gvsig.app.ApplicationLocator;

import org.gvsig.app.join.utils.TransformUtils;

import org.gvsig.daltransform.swing.DataTransformWizardPanel;

import org.gvsig.daltransform.swing.impl.AbstractDataTransformWizardPanel;

import org.gvsig.daltransform.swing.impl.components.FeatureTypeAttributesCombo;

import org.gvsig.daltransform.swing.impl.components.FeatureTypeAttributesList;

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

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

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

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

import org.gvsig.i18n.Messages;

/**

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

 */

public class SelectParametersWizardPanel extends AbstractDataTransformWizardPanel

implements DataTransformWizardPanel, ActionListener{

    private static Logger logger =

        LoggerFactory.getLogger(SelectParametersWizardPanel.class);

	private javax.swing.JLabel attributesLabel;

	private FeatureTypeAttributesList attributesList;

	private javax.swing.JScrollPane attributesScroll;

	private FeatureTypeAttributesCombo key1Combo;

	private javax.swing.JLabel key1Label;

	private FeatureTypeAttributesCombo key2_Combo;

	private javax.swing.JLabel key2Label;

	private javax.swing.JLabel prefix1Label;

	private javax.swing.JTextField prefix1Text;

	private javax.swing.JLabel prefix2Label;

	private javax.swing.JTextField prefix2Text; 

	private FeatureStore secondFeatStore = null;