Application: gvSIG desktop

import com.iver.cit.gvsig.exceptions.visitors.StartWriterVisitorException;

import com.iver.cit.gvsig.fmap.edition.EditionEvent;

import com.iver.cit.gvsig.project.documents.table.gui.JoinWizardController;

			JoinWizardController wizardController = new JoinWizardController(this);

			wizardController.runWizard(pts);

	public void execJoin(ProjectTable sourceProjectTable, String field1, String prefix1,

			ProjectTable targetProjectTable, String field2, String prefix2) {

		// get source table and source field

		SelectableDataSource sds=null;

		try {

			sds = sourceProjectTable.getModelo().getRecordset();

		} catch (ReadDriverException e) {

			e.printStackTrace();

		}

		String tableName1 = sds.getName();

		// get target table and target field

		try {

			sds = targetProjectTable.getModelo().getRecordset();

		} catch (ReadDriverException e) {

			e.printStackTrace();

		}

		String tableName2 = sds.getName();

		// compute the join

		String sql =

			"custom com_iver_cit_gvsig_arcjoin tables '" +

			tableName1 + "', '" + tableName2 + "' values(" +

			field1 + ", " + field2 + ");";

		PluginServices.getLogger().debug(sql);

		try {

			SelectableDataSource result = new SelectableDataSource(LayerFactory.getDataSourceFactory()

					.executeSQL(sql,

							DataSourceFactory.AUTOMATIC_OPENING));

			EditableAdapter auxea=new EditableAdapter();

			auxea.setOriginalDataSource(result);

			renameFields(auxea, sourceProjectTable, sanitizeFieldName(prefix1),

					targetProjectTable, sanitizeFieldName(prefix2));

			sourceProjectTable.replaceDataSource(auxea);

		} catch (ParseException e) {

			throw new RuntimeException(e);

		} catch (DriverLoadException e) {

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

					e);

		} catch (ReadDriverException e) {

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

					e);

		} catch (SemanticException e) {

			throw new RuntimeException(e);

		} catch (EvaluationException e) {

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

					e);

		}

	}

	/**

	 * Renames fields in a JOIN, so that fields from TABLE1

	 * become sourcePrefix.field1, sourcePrefix.field2, etc, and fields

	 * from TABLE2 become targetPrefix.field1, targetPrefix.field2, etc.

	 * @param eds

	 * @param pt1

	 * @param pt1

	 */	

	private void renameFields(EditableAdapter eds,

			ProjectTable pt1, String sourcePrefix, ProjectTable pt2, String targetPrefix) {

		try {

			SelectableDataSource sourceDS1 = pt1.getModelo().getRecordset();

			SelectableDataSource sourceDS2 = pt2.getModelo().getRecordset();

			SelectableDataSource joinDS = eds.getRecordset();

			eds.startEdition(EditionEvent.ALPHANUMERIC);

			// rename fields from sourceDS1

			for (int i=0; i<sourceDS1.getFieldCount(); i++) {

				String fieldName = sourceDS1.getFieldName(i);

				if (joinDS.getFieldIndexByName(fieldName)!=-1) {

					eds.renameField(fieldName, sourcePrefix+"_"+fieldName);

				}

			}

			// rename fields from sourceDS2

			for (int i=0; i<sourceDS2.getFieldCount(); i++) {

				String fieldName = "link_"+sourceDS2.getFieldName(i);

				if (joinDS.getFieldIndexByName(fieldName)!=-1) {

					eds.renameField(fieldName, targetPrefix+"_"+sourceDS2.getFieldName(i));

				}

			}

		} catch (ReadDriverException e) {

			//just log the error, it's not bad if fields couldn't be removed

			PluginServices.getLogger().error("Error renaming fields in a JOIN", e);

		} catch (StartWriterVisitorException e) {

			PluginServices.getLogger().error("Error renaming fields in a JOIN", e);

		}

	}

	/**

	 * Ensure that field name only has 'safe' characters

	 * (no spaces, special characters, etc).

	 */

	public String sanitizeFieldName(String fieldName) {

		return fieldName.replaceAll("\\W", "_"); // replace any non-word character by an underscore

	}

/**

 * 

 */

package com.iver.cit.gvsig.project.documents.table.gui;

import java.awt.Dimension;

import java.awt.event.ItemEvent;

import java.awt.event.ItemListener;

import javax.swing.ImageIcon;

import jwizardcomponent.FinishAction;

import com.hardcode.gdbms.driver.exceptions.ReadDriverException;

import com.iver.andami.PluginServices;

import com.iver.andami.messages.NotificationManager;

import com.iver.cit.gvsig.TableOperations;

import com.iver.cit.gvsig.fmap.layers.SelectableDataSource;

import com.iver.cit.gvsig.gui.simpleWizard.SimpleWizard;

import com.iver.cit.gvsig.project.documents.table.FieldSelectionModel;

import com.iver.cit.gvsig.project.documents.table.ProjectTable;

public class JoinWizardController {

	private final TableOperations tableOperations;

	/**

	 * @param tableOperations

	 */

	public JoinWizardController(TableOperations tableOperations) {

		this.tableOperations = tableOperations;

	}

	public void runWizard(ProjectTable[] 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) {

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

							try {

								srcTableWzrd.setFieldModel(new FieldSelectionModel(

										pt.getModelo().getRecordset(),

										PluginServices.getText(this, "seleccione_campo_enlace"),

										-1));

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

							} catch (ReadDriverException e1) {

								NotificationManager.addError(

										PluginServices.getText(this, "Error_getting_table_fields"),

										e1);

							}

						}

					}

				}

		);

		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) {

							try {

								//tabla

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

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

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

								//?ndice del campo

								SelectableDataSource sds = sourcePt.getModelo().getRecordset();

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

								int fieldIndex = sds.getFieldIndexByName(fieldName);

								if (fieldIndex!=-1) {

									int type = sds.getFieldType(fieldIndex);

									targTableWzrd.setFieldModel(new FieldSelectionModel(

											targetPt.getModelo().getRecordset(),

											PluginServices.getText(this, "seleccione_campo_enlace"),

											type));

								}

								else {

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

											, new Exception());	

								}

							} catch (ReadDriverException e2) {

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

										e2);

							}

						}

					}

				}

		);

		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() {

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

				}

				ProjectTable targetProjectTable = (ProjectTable) 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 class InvalidParameterException extends Exception {

	}

}

/**

 * 

 */

package com.iver.cit.gvsig.project.documents.table.gui;

import java.awt.Font;

import java.awt.GridBagConstraints;

import java.awt.GridBagLayout;

import java.awt.Insets;

import javax.swing.JLabel;

import javax.swing.JTextField;

import jwizardcomponent.JWizardComponents;

import jwizardcomponent.JWizardPanel;

import com.iver.andami.PluginServices;

import com.iver.andami.messages.NotificationManager;

import com.iver.utiles.swing.JComboBox;

import com.iver.utiles.swing.objectSelection.ObjectSelectionModel;

public class TableWizardStep extends JWizardPanel {

	private JLabel lbl_header = null;

	private static final long serialVersionUID = 1L;

	private JLabel tableNameLbl = null;

	private JComboBox tableNameCmb = null;

	private JLabel fieldNameLbl = null;

	private JComboBox fieldNameCmb = null;

	private JLabel fieldPrefixLbl = null;

	private JTextField fieldPrefixTxt = null;

	public TableWizardStep(JWizardComponents wizardComponents, String title) {

		super(wizardComponents, title);

		initialize();

	}

	public void setTableModel(ObjectSelectionModel model) {

		getTableNameCmb().removeAllItems();

		Object[] tableNames;

		try {

			tableNames = model.getObjects();

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

				getTableNameCmb().addItem(tableNames[i]);

			}

		} catch (Exception e) {

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

		}	

	}

	public void setFieldModel(ObjectSelectionModel model) {

		getFieldNameCmb().removeAllItems();

		Object[] fieldNames;

		try {

			fieldNames = model.getObjects();

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

				getFieldNameCmb().addItem(fieldNames[i]);

			}

		} catch (Exception e) {

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

		}	

	}

	private void initialize() {

		this.setLayout(new GridBagLayout());

		GridBagConstraints constraints = new GridBagConstraints();

		constraints.gridx = 0;

		constraints.gridy = 0;

		constraints.gridwidth = 2;

		constraints.anchor = GridBagConstraints.NORTH;

		constraints.fill = GridBagConstraints.HORIZONTAL;

		constraints.weightx = 1.0;

		constraints.weighty = 0.0;

		constraints.insets = new Insets(4,10,8,4);

		this.add(getHeaderLbl(), constraints);

		constraints.gridx = 0;

		constraints.gridy = 1;

		constraints.gridwidth = 1;

		constraints.anchor = GridBagConstraints.NORTHWEST;

		constraints.fill = GridBagConstraints.NONE;

		constraints.weightx = 0.0;

		constraints.weighty = 0.0;

		constraints.insets = new Insets(4,10,4,6);

		this.add(getTableNameLbl(), constraints);

		constraints.gridx = 1;

		constraints.gridy = 1;

		constraints.gridwidth = 1;

		constraints.anchor = GridBagConstraints.NORTHWEST;

		constraints.fill = GridBagConstraints.HORIZONTAL;

		constraints.weightx = 0.5;

		constraints.weighty = 0.0;

		this.add(getTableNameCmb(), constraints);

		constraints.gridx = 0;

		constraints.gridy = 2;

		constraints.gridwidth = 1;

		constraints.anchor = GridBagConstraints.NORTHWEST;

		constraints.fill = GridBagConstraints.NONE;

		constraints.weightx = 0.0;

		constraints.weighty = 0.0;

		constraints.insets = new Insets(4,10,4,6);

		this.add(getFieldNameLbl(), constraints);

		constraints.gridx = 1;

		constraints.gridy = 2;

		constraints.gridwidth = 1;

		constraints.anchor = GridBagConstraints.NORTHWEST;

		constraints.fill = GridBagConstraints.HORIZONTAL;

		constraints.weightx = 0.5;

		constraints.weighty = 0.0;

		this.add(getFieldNameCmb(), constraints);

		constraints.gridx = 0;

		constraints.gridy = 3;

		constraints.gridwidth = 1;

		constraints.anchor = GridBagConstraints.NORTHWEST;

		constraints.fill = GridBagConstraints.NONE;

		constraints.weightx = 0.0;

		constraints.weighty = 0.0;

		constraints.insets = new Insets(4,10,4,6);

		this.add(getFieldPrefixLbl(), constraints);

		constraints.gridx = 1;

		constraints.gridy = 3;

		constraints.gridwidth = 1;

		constraints.anchor = GridBagConstraints.NORTHWEST;

		constraints.fill = GridBagConstraints.HORIZONTAL;

		constraints.weightx = 0.5;

		constraints.weighty = 0.0;

		this.add(getFieldPrefixTxt(), constraints);

	}

	public JLabel getHeaderLbl() {

		if (lbl_header==null) {

			lbl_header = new JLabel();

			Font font = lbl_header.getFont();

			lbl_header.setFont(font.deriveFont(Font.BOLD));

		}

		return lbl_header;

	}

	public JLabel getTableNameLbl() {

		if (tableNameLbl == null) {

			tableNameLbl = new JLabel();

		}

		return tableNameLbl;

	}

	public JComboBox getTableNameCmb() {

		if (tableNameCmb == null) {

			tableNameCmb = new JComboBox();

		}

		return tableNameCmb;

	}

	public JLabel getFieldNameLbl() {

		if (fieldNameLbl==null) {

			fieldNameLbl = new JLabel();

		}

		return fieldNameLbl;

	}

	public JComboBox getFieldNameCmb() {

		if (fieldNameCmb==null) {

			fieldNameCmb = new JComboBox();

		}

		return fieldNameCmb;

	}

	public JLabel getFieldPrefixLbl() {

		if (fieldPrefixLbl==null) {

			fieldPrefixLbl = new JLabel();

		}

		return fieldPrefixLbl;

	}

	public JTextField getFieldPrefixTxt() {

		if (fieldPrefixTxt==null) {

			fieldPrefixTxt = new JTextField();

		}

		return fieldPrefixTxt;

	}

}

Table_Join=Uni?n de tablas

Source_table_options=Opciones de la tabla de origen

Target_table_options=Opciones de la tabla de destino

Source_table_=Tabla de origen:

Field_to_use_for_JOIN_=Campo a usar para la uni?n:

Field_prefix_=Prefijo de campo:

Error_getting_table_fields=Error obteniendo los campos de la tabla

Target_table_=Tabla destino:

Join_parameters_are_incomplete=Los par?metros del JOIN est?n incompletos

Error_loading_driver=Error en la carga del driver

Error_reading_from_the_driver=Error leyendo del driver

Error_evaluationg_expression=Error de evaluaci?n en la expresi?n

unidades_area=Area units

Table_Join=Table Join

Source_table_options=Source Table Options

Target_table_options=Target Table Options

Source_table_=Source table:

Field_to_use_for_JOIN_=Field to use for JOIN:

Field_prefix_=Field prefix:

Error_getting_table_fields=Error getting table fields

Target_table_=Target table:

Join_parameters_are_incomplete=JOIN parameters are incomplete

Error_loading_driver=Error loading the driver

Error_reading_from_the_driver=Error reading from the driver

Error_evaluationg_expression=Error evaluating expression