Application: gvSIG desktop

package org.gvsig.fmap.dal.commands;

import junit.framework.TestCase;

public class CommandTest extends TestCase {

	public static void main(String[] args) {

		junit.textui.TestRunner.run(CommandTest.class);

	}

	protected void setUp() throws Exception {

		super.setUp();

	}

	public void testInitialize() {

	}

}

package org.gvsig.fmap.dal;

import junit.framework.TestCase;

public class DataStoreTest extends TestCase {

    public void testVoid() {

    }

}

/* 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 {}  {{Task}}

*/

package org.gvsig.fmap.dal.resource.spi;

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

import org.gvsig.fmap.dal.resource.ResourceParameters;

import org.gvsig.fmap.dal.resource.exception.AccessResourceException;

import org.gvsig.fmap.dal.resource.exception.ResourceException;

/**

 * Test non blocking resource implementation.

 * 

 * @author 2009- <a href="cordinyana@gvsig.org">C?sar Ordi?ana</a> - gvSIG team

 */

public class TestResource extends AbstractResource {

	protected TestResource(ResourceParameters parameters)

			throws InitializeException {

		super(parameters);

	}

	public Object get() throws AccessResourceException {

		return getName();

	}

	public String getName() throws AccessResourceException {

		return getClass().getName();

	}

	public boolean isThis(ResourceParameters parameters)

			throws ResourceException {

		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 {}  {{Task}}

*/

package org.gvsig.fmap.dal.resource.spi;

import junit.framework.TestCase;

import org.easymock.MockControl;

import org.gvsig.fmap.dal.resource.ResourceAction;

import org.gvsig.fmap.dal.resource.ResourceParameters;

import org.gvsig.fmap.dal.resource.exception.ResourceNotifyOpenException;

/**

 * Unit tests for the class {@link AbstractResource}

 * 

 * @author 2009- <a href="cordinyana@gvsig.org">C?sar Ordi?ana</a> - gvSIG team

 */

public class AbstractResourceTest extends TestCase {

	private AbstractResource resource;

	private MockControl paramsControl;

	private ResourceParameters params;

	protected void setUp() throws Exception {

		super.setUp();

		paramsControl = MockControl.createNiceControl(ResourceParameters.class);

		params = (ResourceParameters) paramsControl.getMock();

		resource = new TestResource(params);

	}

	/**

	 * Test method for {@link org.gvsig.fmap.dal.resource.spi.AbstractResource#getLastTimeOpen()}.

	 */

	public void testGetLastTimeOpen() throws ResourceNotifyOpenException {

		long time = resource.getLastTimeOpen();

		resource.notifyOpen();

		assertTrue("The resource last time open hasn't been updated",

				resource.getLastTimeOpen() > time);

	}

	/**

	 * Test method for {@link org.gvsig.fmap.dal.resource.spi.AbstractResource#getLastTimeUsed()}.

	 */

	public void testGetLastTimeUsed() throws Exception {

		long time = resource.getLastTimeUsed();

		resource.execute(new ResourceAction() {

			public Object run() throws Exception {

				try {

					// Wait for 100 milliseconds

					Thread.sleep(100);

				} catch (InterruptedException e) {

					// No problem

				}

				return null;

			}

		});

		assertTrue("The resource last time used hasn't been updated",

				resource.getLastTimeUsed() > time);

	}

	/**

	 * Test method for {@link org.gvsig.fmap.dal.resource.spi.AbstractResource#openCount()}.

	 */

	public void testOpenCount() throws Exception {

		assertEquals(0, resource.openCount());

		resource.notifyOpen();

		assertEquals(1, resource.openCount());

		resource.notifyOpen();

		resource.notifyOpen();

		assertEquals(3, resource.openCount());

		resource.notifyClose();

		assertEquals(2, resource.openCount());

	}

	/**

	 * Test method for

	 * {@link org.gvsig.fmap.dal.resource.spi.AbstractResource#execute(java.lang.Runnable)}

	 * .

	 */

	public void testExecute() throws Exception {

		final MutableBoolean testValue = new MutableBoolean();

		resource.execute(new ResourceAction() {

			public Object run() throws Exception {

				testValue.setValue(true);

				return null;

			}

		});

		assertTrue("Runnable execution not performed", testValue.isValue());

	}

	public class MutableBoolean {

		private boolean value = false;

		public void setValue(boolean value) {

			this.value = value;

		}

		public boolean isValue() {

			return value;

		}

	}

}

/* 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 {}  {{Task}}

*/

package org.gvsig.fmap.dal.resource.spi;

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

import org.gvsig.fmap.dal.resource.ResourceParameters;

import org.gvsig.fmap.dal.resource.exception.AccessResourceException;

import org.gvsig.fmap.dal.resource.exception.ResourceException;

/**

 * Test resource implementation.

 * 

 * @author 2009- <a href="cordinyana@gvsig.org">C?sar Ordi?ana</a> - gvSIG team

 */

public class TestNonBlockingResource extends AbstractNonBlockingResource {

	protected TestNonBlockingResource(ResourceParameters parameters)

			throws InitializeException {

		super(parameters);

	}

	public Object get() throws AccessResourceException {

		return getName();

	}

	public String getName() throws AccessResourceException {

		return getClass().getName();

	}

	public boolean isThis(ResourceParameters parameters)

			throws ResourceException {

		return false;

	}

}

package org.gvsig.fmap.dal.resource.spi;

import junit.framework.TestCase;

import org.easymock.MockControl;

import org.gvsig.fmap.dal.resource.Resource;

import org.gvsig.fmap.dal.resource.ResourceAction;

import org.gvsig.fmap.dal.resource.ResourceParameters;

public class TestAbstractResourcePerformance extends TestCase {

	private MockControl paramsControl;

	private ResourceParameters params;

	private AbstractResource resource;

	private MockControl paramsControl2;

	private ResourceParameters params2;

	private AbstractNonBlockingResource nonBlockingResource;

	protected void setUp() throws Exception {

		super.setUp();

		paramsControl = MockControl.createNiceControl(ResourceParameters.class);

		params = (ResourceParameters) paramsControl.getMock();

		resource = new TestResource(params);

		paramsControl2 =

				MockControl.createNiceControl(ResourceParameters.class);

		params2 = (ResourceParameters) paramsControl2.getMock();

		nonBlockingResource = new TestNonBlockingResource(params2);

	}

	/**

	 * Test method for

	 * {@link org.gvsig.fmap.dal.resource.spi.AbstractResource#execute(java.lang.Runnable)}

	 * .

	 */

	public void testExecuteBlockingPerformance() throws Exception {

		executePerformance(new ResourceAction() {

			public Object run() throws Exception {

				return null;

			}

		}, resource);

	}

	/**

	 * Test method for

	 * {@link org.gvsig.fmap.dal.resource.spi.AbstractResource#execute(java.lang.Runnable)}

	 * .

	 */

	public void testExecuteNonBlockingPerformance() throws Exception {

		executePerformance(new ResourceAction() {

			public Object run() throws Exception {

				return null;

			}

		}, nonBlockingResource);

	}

	/**

	 * Test method for

	 * {@link org.gvsig.fmap.dal.resource.spi.AbstractResource#execute(java.lang.Runnable)}

	 * .

	 */

	public void executePerformance(ResourceAction action, Resource resource)

			throws Exception {

		final int executions = 100000;

		long time1 = System.currentTimeMillis();

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

			resource.execute(action);

		}

		long time2 = System.currentTimeMillis();

		System.out.print(resource.getName());

		System.out.print(": total time: " + (time2 - time1) + " ms.");

		System.out.println(" - time per execution: "

				+ ((float) (time2 - time1) / (float) executions) + " ms.");

	}

}

package org.gvsig.fmap.dal;

import junit.framework.Test;

import junit.framework.TestCase;

import junit.framework.TestSuite;

import org.gvsig.fmap.dal.commands.CommandTest;

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

public class AllTests extends TestCase{

	public static Test suite() {

		TestSuite suite = new TestSuite("Test for libDataSource");

		//$JUnit-BEGIN$

		suite.addTestSuite(CommandTest.class);

		suite.addTestSuite(DataStoreTest.class);

		suite.addTestSuite(FeatureTest.class);

		//$JUnit-END$

		return suite;

	}

}

/* 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):

 * 2008 {DiSiD Technologies}   {{Test indexed iterator retrieval}}

 */

package org.gvsig.fmap.dal.feature;

import junit.framework.TestCase;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import org.gvsig.fmap.dal.DataStoreParameters;

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

import org.gvsig.tools.dispose.DisposableIterator;

/**

 * Unit tests for the {@link AbstractFeatureCollection} class.

 *

 * @author <a href="mailto:cordin@disid.com">C?sar Ordi?ana</a>

 */

public abstract class FeatureSetTestParent extends TestCase {

    protected void setUp() throws Exception {

        super.setUp();

        register();

    }

    protected void tearDown() throws Exception {

        super.tearDown();

    }

    /**

     * Test method for

     * {@link org.gvsig.fmap.dal.feature.AbstractFeatureCollection#iterator(int)}

     * .

     *

     * @throws Exception

     */

    public void testIteratorInt() throws Exception {

        FeatureSet featureSet = createFeatureCollection();

        testIteratorInt(featureSet);

        featureSet.dispose();

    }

    public void testIteratorInt(FeatureSet featureSet) throws DataException {

        if (featureSet.getSize() < 3) {

            fail("The Collection to create for the test must contain "

                    + "at least 3 values");

        }

        try {

            featureSet.iterator(-5);

            fail("Iterator index accepted with a value < 0");

        } catch (Exception ex) {

            // Good

        }

        try {

            featureSet.iterator(featureSet.getSize() + 2);

            fail("Iterator index accepted with a value > collection size");

        } catch (Exception ex) {

            // Good

        }

        long index = featureSet.getSize() - 3l;

        DisposableIterator iter = featureSet.iterator(index);

        int iterations = 0;

        while (iter.hasNext()) {

            iter.next();

            iterations++;

        }

        assertEquals("The number of iterations remaining is not correct", 3,

                iterations);

        iter.dispose();

        iter = featureSet.iterator(0);

        iterations = 0;

        while (iter.hasNext()) {

            iter.next();

            iterations++;

        }

        assertEquals("The number of iterations is not the "

                + "total size of the collection", featureSet.getSize(),

                iterations);

        iter.dispose();

    }

    protected FeatureSet createFeatureCollection() throws Exception {

        FeatureStore store = createFeatureStore();

        FeatureType ft = store.getDefaultFeatureType();

        return createFeatureCollection(store, ft);

    }

    protected FeatureStore createFeatureStore() throws Exception {

        DataManager manager = DALLocator.getDataManager();

        return (FeatureStore) manager

                .createStore(createStoreParameters(manager));

    }

    protected abstract void register();

    protected abstract DataStoreParameters createStoreParameters(

            DataManager manager)

            throws Exception;

    /**

     * If this method is rewritten, the returned FeatureCollection must have at

     * least 3 values.

     */

    protected abstract FeatureSet createFeatureCollection(

            FeatureStore store,

            FeatureType ft) throws DataException;

}

package org.gvsig.fmap.dal.feature.impl;

import java.util.Arrays;

import org.gvsig.fmap.dal.DataTypes;

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.FeatureStore;

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

import org.gvsig.fmap.dal.feature.exception.CreateGeometryException;

import org.gvsig.fmap.geom.GeometryLocator;

import org.gvsig.fmap.geom.GeometryManager;

import org.gvsig.fmap.geom.Geometry.SUBTYPES;

import org.gvsig.fmap.geom.Geometry.TYPES;

import org.gvsig.fmap.geom.primitive.Point;

import org.gvsig.tools.persistence.PersistentState;

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

/**

 *

 * This transform adds a new attribute of type Geometry to the original store's

 * default FeatureType. When applying the transform to a single feature this new

 * attribute is assigned the value of a point whose coordinates proceed from two

 * numeric attributes from the store, called xname, yname.

 *

 */

class MyTransform extends AbstractFeatureStoreTransform {

	private FeatureType originalType;

	private String geomName;

	private String xname;

	private String yname;

	/**

	 * Empty default constructor

	 */

	public MyTransform() {

	}

	/**

	 * Initializes the transform by assigning the source store and the names of

	 * the necessary attributes.

	 *

	 * @param store

	 *            source store.

	 *

	 * @param geomName

	 *            name of the geometry attribute in the default feature type

	 *            from the source store.

	 *

	 * @param xname

	 *            name of the attribute containing the X coordinates

	 *

	 * @param yname

	 *            name of the attribute containing the Y coordinates

	 *

	 * @throws DataException

	 */

	public void initialize(FeatureStore store, String geomName, String xname, String yname) throws DataException {

		// Initialize some data

		this.setFeatureStore(store);

		this.geomName = geomName;

		this.xname = xname;

		this.yname = yname;

		this.originalType = store.getDefaultFeatureType();

		// obtain the feature type, add the new attribute and keep a reference to the resulting feature type

		EditableFeatureType type = store.getDefaultFeatureType().getEditable();

		type.add(geomName, DataTypes.GEOMETRY);

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

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

	}

	/**

	 * Applies this transform to a target editable feature, using data from the

	 * source feature.

	 */

	public void applyTransform(Feature source, EditableFeature target)

			throws DataException {

		// copy source feature data over target feature

		target.copyFrom(source);

		// calculate and assign new attribute's value

		GeometryManager geomManager = GeometryLocator.getGeometryManager();

		Point point;

		try {

			point = (Point)geomManager.create(TYPES.POINT, SUBTYPES.GEOM2D);

			point.setX(source.getDouble(xname));

			point.setY(source.getDouble(yname));

			target.setGeometry(this.geomName, point);

		} catch (org.gvsig.fmap.geom.exception.CreateGeometryException e) {

        	throw new CreateGeometryException(TYPES.POINT, SUBTYPES.GEOM2D, e);

		}

	}

	public void saveToState(PersistentState state) throws PersistenceException {

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

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

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

	}

	public void loadFromState(PersistentState state) throws PersistenceException {

	}

	/*

	 * (non-Javadoc)

	 *

	 * @see

	 * org.gvsig.fmap.dal.feature.FeatureStoreTransform#getSourceFeatureTypeFrom

	 * (org.gvsig.fmap.dal.feature.FeatureType)

	 */

	public FeatureType getSourceFeatureTypeFrom(FeatureType targetFeatureType) {

		return originalType;

	}

	public boolean isTransformsOriginalValues() {

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

 * 2008 {DiSiD Technologies}  {{Task}}

 */

package org.gvsig.fmap.dal.feature.impl;

import java.util.Iterator;

import junit.framework.TestCase;

import org.easymock.MockControl;

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

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

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

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

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

import org.gvsig.tools.exception.BaseException;

import org.gvsig.tools.junit.AbstractLibraryAutoInitTestCase;

import org.gvsig.tools.visitor.Visitor;

/**

 * @author <a href="mailto:cordin@disid.com">C?sar Ordi?ana</a>

 */

public class DefaultFeatureReferenceSelectionTest extends AbstractLibraryAutoInitTestCase {

    private FeatureReferenceSelection selection;

    private MockControl refControl1;

    private FeatureReference ref1;

    private MockControl refControl2;

    private FeatureReference ref2;

    private MockControl storeControl;

    private FeatureStore store;

    private MockControl fsetControl;

    private FeatureSet featureSet;

    private MockControl helperControl;

    private FeatureSelectionHelper helper;

    private int total = 10;

    protected void doSetUp() throws Exception {     

        refControl1 = MockControl.createNiceControl(FeatureReference.class);

        ref1 = (FeatureReference) refControl1.getMock();

        refControl2 = MockControl.createNiceControl(FeatureReference.class);

        ref2 = (FeatureReference) refControl2.getMock();

        storeControl = MockControl.createNiceControl(FeatureStore.class);

        store = (FeatureStore) storeControl.getMock();

        storeControl.expectAndReturn(store.getFeatureCount(), total);

        helperControl = MockControl

                .createNiceControl(FeatureSelectionHelper.class);

        helper = (FeatureSelectionHelper) helperControl.getMock();

        helperControl.expectAndDefaultReturn(helper.getFeatureStoreDeltaSize(),

                0);

        fsetControl = MockControl.createNiceControl(FeatureSet.class);

        featureSet = (FeatureSet) fsetControl.getMock();

        storeControl.expectAndReturn(store.getFeatureSet(), featureSet);

        fsetControl.expectAndReturn(featureSet.getSize(), total);

        storeControl.replay();

        fsetControl.replay();

        helperControl.replay();

        selection = new DefaultFeatureReferenceSelection(store, helper);

    }

    protected void tearDown() throws Exception {

        super.tearDown();

    }

    public void testSelect() throws Exception {

        // Add a feature

        selection.select(ref1);

        assertTrue(selection.isSelected(ref1));

        assertFalse(selection.isSelected(ref2));

        selection.select(ref2);

        assertTrue(selection.isSelected(ref2));

    }

    public void testSelectAll() throws Exception {

        selection.selectAll();

        assertTrue(selection.isSelected(ref1));

        assertTrue(selection.isSelected(ref2));

    }

    public void testDeselect() throws Exception {

        // Remove a feature

        selection.select(ref1);

        selection.select(ref2);

        assertTrue(selection.isSelected(ref2));

        selection.deselect(ref2);

        assertFalse(selection.isSelected(ref2));

        selection.deselect(ref1);

        assertFalse(selection.isSelected(ref1));

    }

    public void testDeselectAll() throws Exception {

        selection.select(ref1);

        selection.select(ref2);

        selection.deselectAll();

        assertFalse(selection.isSelected(ref1));

        assertFalse(selection.isSelected(ref2));

    }

    public void testReverse() throws Exception {

        // Reverse selection

        selection.select(ref1);

        selection.reverse();

        assertFalse(selection.isSelected(ref1));

        assertTrue(selection.isSelected(ref2));

    }

    public void testGetSelectedCount() throws Exception {

        // None selected

        assertEquals(0, selection.getSelectedCount());

        selection.select(ref1);

        selection.select(ref2);

        // Two selected

        assertEquals(2, selection.getSelectedCount());

        // Deselect one, so one left selected

        selection.deselect(ref2);

        assertEquals(1, selection.getSelectedCount());

        // Reverse the selection, so all buy one selected

        selection.reverse();

        assertEquals(total - 1, selection.getSelectedCount());

        // Deselect another one, so all but two selected

        selection.deselect(ref2);

        assertEquals(total - 2, selection.getSelectedCount());

        // Deselect an already deselected one, nothing changes

        selection.deselect(ref2);

        assertEquals(total - 2, selection.getSelectedCount());

    }

    public void testGetSelectedValues() throws DataException {

        selection.deselectAll();

        selection.select(ref1);

        selection.select(ref2);

        boolean ref1Pending = true;

        boolean ref2Pending = true;

        for (Iterator references = selection.referenceIterator(); references

                .hasNext();) {

            FeatureReference reference = (FeatureReference) references.next();

            if (reference.equals(ref1)) {

                if (ref1Pending) {

                    ref1Pending = false;

                } else {

                    fail("FeatureReference 1 was already obtained");

                }

            } else if (reference.equals(ref2)) {

                if (ref2Pending) {

                    ref2Pending = false;

                } else {

                    fail("FeatureReference 2 was already obtained");

                }

            } else {

                fail("A reference not selected was obtained: " + reference);

            }

        }

    }

    public void testDispose() {

        selection.select(ref1);

        selection.select(ref2);

        selection.dispose();

        assertFalse(selection.isSelected(ref1));

        assertFalse(selection.isSelected(ref2));

    }

    public void testAccept() throws BaseException {

        // Create a Mopck Visitor and add expected usage

        MockControl visitorControl = MockControl

                .createNiceControl(Visitor.class);

        Visitor visitor = (Visitor) visitorControl.getMock();

        visitor.visit(ref1);

        visitor.visit(ref2);

        visitorControl.replay();

        // Add selected references

        selection.select(ref1);

        selection.select(ref2);

        // Use visitor

        selection.accept(visitor);

        // check correct visitor usage

        visitorControl.verify();

    }

}

/* 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):

 * 2008 {DiSiD Technologies}  {{Task}}

 */

package org.gvsig.fmap.dal.feature.impl;

import org.easymock.MockControl;

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

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

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

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.junit.AbstractLibraryAutoInitTestCase;

/**

 * @author <a href="mailto:cordin@disid.com">C?sar Ordi?ana</a>

 */

public class DefaultFeatureSelectionTest extends AbstractLibraryAutoInitTestCase {

    private FeatureSelection selection;

    private MockControl refControl1;

    private FeatureReference ref1;

    private MockControl refControl2;

    private FeatureReference ref2;

    private MockControl fControl1;

    private Feature feature1;

    private MockControl fControl2;

    private Feature feature2;

    private MockControl storeControl;

    private FeatureType featureType;

    private MockControl fTypeControl;

    private FeatureStore store;

    private MockControl fsetControl;

    private FeatureSet featureSet;

    private MockControl helperControl;

    private FeatureSelectionHelper helper;

    private int total = 10;

    protected void doSetUp() throws Exception { 

        refControl1 = MockControl.createNiceControl(FeatureReference.class);

        ref1 = (FeatureReference) refControl1.getMock();

        refControl2 = MockControl.createNiceControl(FeatureReference.class);

        ref2 = (FeatureReference) refControl2.getMock();

        fControl1 = MockControl.createControl(Feature.class);

        feature1 = (Feature) fControl1.getMock();

        fControl2 = MockControl.createControl(Feature.class);

        feature2 = (Feature) fControl2.getMock();

        fTypeControl = MockControl.createNiceControl(FeatureType.class);

        featureType = (FeatureType) fTypeControl.getMock();

        fControl1.expectAndDefaultReturn(feature1.getType(), featureType);

        fControl2.expectAndDefaultReturn(feature2.getType(), featureType);

        storeControl = MockControl.createNiceControl(FeatureStore.class);

        store = (FeatureStore) storeControl.getMock();

        storeControl.expectAndReturn(store.getFeatureCount(), total);

        helperControl = MockControl

                .createNiceControl(FeatureSelectionHelper.class);

        helper = (FeatureSelectionHelper) helperControl.getMock();

        helperControl.expectAndDefaultReturn(helper.getFeatureStoreDeltaSize(),

                0);

        fsetControl = MockControl.createNiceControl(FeatureSet.class);

        featureSet = (FeatureSet) fsetControl.getMock();

        storeControl.expectAndReturn(store.getFeatureSet(), featureSet);

        fsetControl.expectAndReturn(featureSet.getSize(), total);

        storeControl.replay();

        fsetControl.replay();

        helperControl.replay();

        selection = new DefaultFeatureSelection(store, helper);

    }

    protected void tearDown() throws Exception {

        super.tearDown();

    }

    /**

     * Test method for

     * {@link org.gvsig.fmap.dal.feature.impl.DefaultFeatureSelection#select(org.gvsig.fmap.dal.feature.Feature)}

     * .

     */

    public void testSelectFeature() {

        fControl1.expectAndReturn(feature1.getReference(), ref1, 2);

        fControl2.expectAndReturn(feature2.getReference(), ref2, 3);

        fControl1.replay();

        fControl2.replay();

        // Add a feature

        selection.select(feature1);

        assertTrue("Selected feature1 is not recognized as selected", selection

                .isSelected(feature1));

        assertFalse("Selected feature2 is recognized as selected", selection

                .isSelected(feature2));

        selection.select(feature2);

        assertTrue(selection.isSelected(feature2));

    }

    /**

     * Test method for

     * {@link org.gvsig.fmap.dal.feature.impl.DefaultFeatureSelection#deselect(org.gvsig.fmap.dal.feature.Feature)}

     * .

     */

    public void testDeselectFeature() {

        fControl1.expectAndReturn(feature1.getReference(), ref1, 3);

        fControl2.expectAndReturn(feature2.getReference(), ref2, 4);

        fControl1.replay();

        fControl2.replay();

        // Remove a feature

        selection.select(feature1);

        selection.select(feature2);

        assertTrue(selection.isSelected(feature2));

        selection.deselect(feature2);

        assertFalse(selection.isSelected(feature2));

        selection.deselect(feature1);

        assertFalse(selection.isSelected(feature1));

    }

    /**

     * Test method for

     * {@link org.gvsig.fmap.dal.feature.impl.DefaultFeatureSelection#getSize()}

     * .

     */

    public void testGetSize() throws Exception {

        fControl1.expectAndReturn(feature1.getReference(), ref1, 1);

        fControl2.expectAndReturn(feature2.getReference(), ref2, 4);

        fControl1.replay();

        fControl2.replay();

        // None selected

        assertEquals(0, selection.getSize());

        selection.select(feature1);

        selection.select(feature2);

        // Two selected

        assertEquals(2, selection.getSize());

        // Deselect one, so one left selected

        selection.deselect(feature2);

        assertEquals(1, selection.getSize());

        // Reverse the selection, so all buy one selected

        selection.reverse();

        assertEquals(total - 1, selection.getSize());

        // Deselect another one, so all but two selected

        selection.deselect(feature2);

        assertEquals(total - 2, selection.getSize());

        // Deselect an already deselected one, nothing changes

        selection.deselect(feature2);

        assertEquals(total - 2, selection.getSize());

    }

    /**

     * Test method for

     * {@link org.gvsig.fmap.dal.feature.impl.DefaultFeatureSelection#isEmpty()}

     * .

     */

    public void testIsEmpty() throws Exception {

        fControl1.expectAndReturn(feature1.getReference(), ref1, 1);

        fControl2.expectAndReturn(feature2.getReference(), ref2, 4);

        fControl1.replay();

        fControl2.replay();

        // None selected

        assertTrue(selection.isEmpty());

        // One selected

        selection.select(feature1);

        assertFalse(selection.isEmpty());

        // Deselect all

        selection.deselectAll();

        assertTrue(selection.isEmpty());

        // Reverse

        selection.reverse();

        assertFalse(selection.isEmpty());

    }

}

package org.gvsig.fmap.dal.feature.impl;

import java.util.Arrays;

import java.util.HashMap;

import java.util.Iterator;

import java.util.Map;

import org.gvsig.fmap.dal.DALLocator;

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.dispose.DisposableIterator;

import org.gvsig.tools.dispose.DisposeUtils;

import org.gvsig.tools.evaluator.Evaluator;

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 targetNamesMap;

	private FeatureType originalFeatureType;

	/**

	 * A default constructor

	 */

	public JoinTransform() {

		targetNamesMap = new HashMap();

	}

	/**

	 * 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[] attrs)

			throws DataException {

		// Initialize needed data

		this.setFeatureStore(store1);

		this.store2 = store2;

		this.keyAttr1 = keyAttr1;

		this.keyAttr2 = keyAttr2;

		this.attrs = attrs;

		this.originalFeatureType = this.getFeatureStore()

				.getDefaultFeatureType();

		// calculate this transform resulting feature type

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

		// feature type

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

		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, store2.getDefaultFeatureType()

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

			// keep correspondence between original name and transformed name

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

		}

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

		target.copyFrom(source);

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

		// attribute value

		// from the source feature

		Evaluator eval = DALLocator.getDataManager().createExpresion(

				keyAttr2 + "=" + source.get(keyAttr1));

		FeatureQuery query = this.getFeatureStore().createFeatureQuery();

		query.setAttributeNames(attrs);

		query.setFilter(eval);

		FeatureSet set = null;

		DisposableIterator it = null;

		try {

			set = store2.getFeatureSet(query);

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

			// feature found in store2

			it = set.iterator();

			if (it.hasNext()) {

				Feature feat = (Feature) it.next();

				// copy all attributes from joined feature to target

				Iterator it2 = feat.getType().iterator();

				while (it2.hasNext()) {

					FeatureAttributeDescriptor attr =

							(FeatureAttributeDescriptor) it2.next();

					// find original attribute name

					String targetName =

							(String) this.targetNamesMap.get(attr.getName());

					// copy its value to target feature attribute

					target.set(targetName, feat.get(attr.getName()));

				}

			}

		} finally {

			DisposeUtils.dispose(set);

			DisposeUtils.dispose(it);

		}

	}

	public void saveToState(PersistentState state) throws PersistenceException {

		// TODO Auto-generated method stub

	}

	public void loadFromState(PersistentState state) throws PersistenceException {

		// TODO Auto-generated method stub

	}

	/*

	 * (non-Javadoc)

	 *

	 * @see

	 * org.gvsig.fmap.dal.feature.FeatureStoreTransform#getSourceFeatureTypeFrom

	 * (org.gvsig.fmap.dal.feature.FeatureType)

	 */

	public FeatureType getSourceFeatureTypeFrom(FeatureType targetFeatureType) {

		return this.originalFeatureType;

	}

	public boolean isTransformsOriginalValues() {

		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. S.A.   {{Task}}

*/

/**

 *

 */

package org.gvsig.fmap.dal.feature;

import java.util.ArrayList;

import java.util.Collections;

import java.util.Iterator;

import java.util.List;

import java.util.Random;

import java.util.TreeSet;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import org.gvsig.fmap.dal.DataServerExplorer;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.DataTypes;

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

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

import org.gvsig.fmap.dal.feature.FeatureQueryOrder.FeatureQueryOrderMember;

import org.gvsig.fmap.dal.feature.testmulithread.StoreTask;

import org.gvsig.fmap.dal.resource.ResourceManager;

import org.gvsig.fmap.geom.Geometry;

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.dispose.DisposableIterator;

import org.gvsig.tools.dynobject.DynClass;

import org.gvsig.tools.dynobject.DynField;

import org.gvsig.tools.dynobject.DynObject;

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.junit.AbstractLibraryAutoInitTestCase;

import org.gvsig.tools.persistence.PersistentState;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 * @author jmvivo

 *

 */

public abstract class BaseTestFeatureStore extends

		AbstractLibraryAutoInitTestCase {

	private static Logger logger = null;

	protected DataManager dataManager = null;

	private static Random rnd;

	public Logger getLogger() {

		if (logger == null) {

			logger = LoggerFactory.getLogger(this.getClass());

		}

		return logger;

	}

	public abstract boolean usesResources();

	public abstract boolean hasExplorer();

	public FeatureQuery getDefaultQuery(FeatureStore store)

			throws DataException {

		FeatureQuery query = store.createFeatureQuery();

		FeatureAttributeDescriptor[] key = store.getDefaultFeatureType()

				.getPrimaryKey();

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

			query.getOrder().add(key[i].getName(), true);

		}

		return query;

	}

	public abstract DataStoreParameters getDefaultDataStoreParameters()

			throws DataException;

	protected void doSetUp() throws Exception {

		dataManager = DALLocator.getDataManager();

	}

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

	public void printFeature(Feature feature, int maxColSize) {

		printFeature(feature, true, maxColSize);

	}

	public void printFeature(Feature feature, boolean showColName,int maxColSize) {

		FeatureType fType = feature.getType();

		if (showColName){

			this.printFeatureTypeColNames(feature.getType(), maxColSize);

		}

		StringBuffer row = new StringBuffer();

		Iterator iter = fType.iterator();

		FeatureAttributeDescriptor attr;

		while (iter.hasNext()) {

			attr = (FeatureAttributeDescriptor) iter.next();

			row.append(truncateOrFillString(feature.get(attr.getName()),

					maxColSize + 1, ' '));

		}

		System.out.println(row.toString());

	}

	public String truncateOrFillString(Object str, int max, char fillWith) {

		if (str == null) {

			return truncateOrFillString("{null}", max, fillWith);

		}

		return truncateOrFillString(str.toString(), max, fillWith);

	}

	public String truncateOrFillString(String str, int max, char fillWith) {

		if (str.length() > max) {

			return str.substring(0, max - 1) + " ";

		} else {

			StringBuffer strB = new StringBuffer(str);

			while (strB.length() < max) {

				strB.append(fillWith);

			}

			return strB.toString();

		}