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/xsd/maven-4.0.0.xsd">

	<modelVersion>4.0.0</modelVersion>

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

	<name>libFMap_dal</name>

	<version>2.0-SNAPSHOT</version>

    <parent>

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

        <groupId>org.gvsig</groupId>

        <version>2.0-SNAPSHOT</version>

    </parent>   

	<dependencies>

		<dependency>

			<groupId>org.gvsig</groupId>

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

            <scope>compile</scope>

		</dependency>

        <dependency>

            <groupId>org.gvsig</groupId>

            <artifactId>org.gvsig.compat</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.i18n</artifactId>

            <scope>compile</scope>

        </dependency>

		<dependency>

			<groupId>org.gvsig</groupId>

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

			<scope>runtime</scope>

		</dependency>

		<dependency>

			<groupId>org.gvsig</groupId>

			<artifactId>org.gvsig.projection</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.timesupport.lib.api</artifactId>

            <scope>compile</scope>

        </dependency>

        <dependency>

            <groupId>org.slf4j</groupId>

            <artifactId>slf4j-api</artifactId>

            <scope>compile</scope>

        </dependency>

		<dependency>

			<groupId>easymock</groupId>

			<artifactId>easymock</artifactId>

			<version>1.2_Java1.3</version>

			<scope>test</scope>

		</dependency>

        <dependency>

            <groupId>easymock</groupId>

            <artifactId>easymockclassextension</artifactId>

            <version>1.2</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>xmlpull</groupId>

            <artifactId>xmlpull</artifactId>

            <scope>compile</scope>

        </dependency>

		<!-- Implementation dependencies for TESTS -->

		<dependency>

			<groupId>org.gvsig</groupId>

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

			<type>test-jar</type>

		</dependency>

        <dependency>

            <groupId>org.gvsig</groupId>

            <artifactId>org.gvsig.compat</artifactId>

            <classifier>se</classifier>

            <scope>test</scope>

        </dependency>

		<dependency>

			<groupId>org.gvsig</groupId>

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

			<classifier>impl</classifier>

			<scope>test</scope>

		</dependency>

	</dependencies>

	<properties>

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

        <eclipse.project.name>libFMap_dal</eclipse.project.name>

	</properties>

	<profiles>

		<profile>

			<id>se</id>

			<activation>

				<activeByDefault>true</activeByDefault>

			</activation>

			<dependencies>

				<!-- TESTS -->

				<dependency>

					<groupId>org.gvsig</groupId>

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

					<classifier>operation</classifier>

					<scope>test</scope>

				</dependency>

				<dependency>

					<groupId>org.gvsig</groupId>

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

					<classifier>cresques-impl</classifier>

					<scope>test</scope>

				</dependency>

				<dependency>

					<groupId>org.geotools</groupId>

					<artifactId>gt2-legacy</artifactId>

					<scope>test</scope>

				</dependency>

				<dependency>

					<groupId>org.geotools</groupId>

					<artifactId>gt2-main</artifactId>

					<scope>test</scope>

				</dependency>

				<dependency>

					<groupId>org.opengis</groupId>

				    <artifactId>geoapi</artifactId>

					<scope>test</scope>

				</dependency>

				<dependency>

					<groupId>javax.media</groupId>

					<artifactId>jai_core</artifactId>

					<scope>test</scope>

				</dependency>

				<dependency>

					<groupId>javax.media</groupId>

					<artifactId>jai_codec</artifactId>

					<scope>test</scope>

				</dependency>

			</dependencies>

		</profile>

		<profile>

			<id>cdc</id>

			<activation>

				<activeByDefault>false</activeByDefault>

			</activation>

			<dependencies>

				<!-- TESTS -->

				<dependency>

					<groupId>org.gvsig.mobile</groupId>

					<artifactId>org.gvsig.mobile.libProjection</artifactId>

					<version>0.0.1-SNAPSHOT</version>

				</dependency>

			</dependencies>			

		</profile>

		<profile>

			<id>eclipse-project</id>

			<build>

				<defaultGoal>antrun:run</defaultGoal>

				<plugins>

					<plugin>

						<artifactId>maven-antrun-plugin</artifactId>

						<configuration>

							<tasks>

								<ant antfile="${build-dir}/ant-tasks/eclipse-tasks.xml"

									target="eclipse.all"/>

							</tasks>

						</configuration>

					</plugin>

				</plugins>

			</build>				

		</profile>		

	</profiles>

	<build>

		<sourceDirectory>src</sourceDirectory>

		<testSourceDirectory>src-test</testSourceDirectory>

		<plugins>

			<plugin>

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

				<artifactId>maven-compiler-plugin</artifactId>

				<configuration>

					<source>1.4</source>

					<target>1.4</target>

				</configuration>

			</plugin>

			<plugin>

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

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

				<configuration>

					<excludes>

						<exclude>**/impl/**</exclude>

						<exclude>**/spi/**</exclude>

					</excludes>

				</configuration>

				<executions>

					<!--

						Generates a jar file only with the DAL default implementation

					-->

					<execution>

						<id>impl</id>

						<phase>package</phase>

						<goals>

							<goal>jar</goal>

						</goals>

						<configuration>

							<classifier>impl</classifier>

							<includes>

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

							</includes>

							<excludes>

								<exclude>**/spi/**</exclude>

							</excludes>

						</configuration>

					</execution>

					<!--

						Generates a jar file only with the DAL SPI

					-->

					<execution>

						<id>spi</id>

						<phase>package</phase>

						<goals>

							<goal>jar</goal>

						</goals>

						<configuration>

							<classifier>spi</classifier>

							<includes>

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

							</includes>

							<excludes>

								<exclude>**/impl/**</exclude>

							</excludes>

						</configuration>

					</execution>

					<!--

						Generates a jar file only with the test classes

					-->

					<execution>

						<goals>

							<goal>test-jar</goal>

						</goals>

						<configuration>

							<includes>

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

							</includes>

							<excludes>

								<exclude>NONE</exclude>

							</excludes>

						</configuration>

					</execution>

				</executions>

			</plugin>

			<plugin>

				<artifactId>maven-antrun-plugin</artifactId>

				<executions>

					<execution>

						<id>services</id>

						<phase>package</phase>

						<goals>

							<goal>run</goal>

						</goals>

						<configuration>

							<tasks>

								<jar destfile="${project.build.directory}/${project.build.finalName}.jar"

									update="true">

									<fileset dir="${basedir}/resources/api" />

								</jar>

								<jar destfile="${project.build.directory}/${project.build.finalName}-impl.jar"

									update="true">

									<fileset dir="${basedir}/resources/impl" />

								</jar>

							</tasks>

						</configuration>

					</execution>

				</executions>

			</plugin>

			<plugin>

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

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

				<configuration>

					<excludes>

						<exclude>**/BlockTest.java</exclude>

					</excludes>

					<additionalClasspathElements>

						<additionalClasspathElement>${basedir}/resources/api</additionalClasspathElement>

						<additionalClasspathElement>${basedir}/resources/impl</additionalClasspathElement>

					</additionalClasspathElements>

                    <skipTests>true</skipTests>

				</configuration>

			</plugin>

		</plugins>

	</build>

	<reporting>

		<plugins>

			<plugin>

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

				<artifactId>maven-javadoc-plugin</artifactId>

				<reportSets>

					<reportSet>

						<id>api</id>

						<configuration>

							<excludePackageNames>*.spi:*.impl</excludePackageNames>

							<name>Javadoc: API</name>

							<destDir>apidoc</destDir>

							<windowtitle>API Documentation</windowtitle>

						</configuration>

						<reports>

							<report>javadoc</report>

						</reports>

					</reportSet>

					<reportSet>

						<id>spi</id>

						<configuration>

							<doctitle>${project.name} ${project.version} SPI</doctitle>

							<subpackages>org.gvsig.fmap.dal.spi:org.gvsig.fmap.dal.feature.spi:org.gvsig.fmap.dal.raster.spi:org.gvsig.fmap.dal.resource.spi</subpackages>

							<name>Javadoc: SPI</name>

							<destDir>spidoc</destDir>

							<windowtitle>SPI Documentation</windowtitle>

							<links>

								<link>../apidoc/</link>

							</links>

						</configuration>

						<reports>

							<report>javadoc</report>

						</reports>

					</reportSet>

					<reportSet>

						<id>impl</id>

						<configuration>

							<doctitle>${project.name} ${project.version} Default implementation</doctitle>

							<subpackages>org.gvsig.fmap.dal.impl:org.gvsig.fmap.dal.feature.impl:org.gvsig.fmap.dal.raster.impl:org.gvsig.fmap.dal.resource.impl</subpackages>

							<name>Javadoc: Impl</name>

							<destDir>impldoc</destDir>

							<windowtitle>Default implementation Documentation</windowtitle>

							<links>

								<link>../apidoc/</link>

								<link>../spidoc/</link>

							</links>

						</configuration>

						<reports>

							<report>javadoc</report>

						</reports>

					</reportSet>

				</reportSets>

			</plugin>

		</plugins>

	</reporting>

</project>

org.gvsig.fmap.dal.impl.DALDefaultImplLibrary

filling_index=Filling index

updating_index=Updating index

filling_index=Llenando ?ndice

updating_index=Actualizando ?ndice

org.gvsig.fmap.dal.DALLibrary

org.gvsig.fmap.dal.store.memory.MemoryStoreLibrary

<?xml version="1.0"?>

<definitions>

  <version>1.0.0</version>

  <classes>

    <class name="DataProvider" namespace="metadata">

      <description>Metadata of a feature store</description>

      <fields>

        <field name="ProviderName" type="string" mandatory="true">

          <description>The name of the provider of data</description>

        </field>

        <field name="ContainerName" type="string" mandatory="false">

          <description>Name of the container of the data, by example, in a dbf, the file name of the dbf</description>

        </field>

      </fields>

    </class>

    <class name="FeatureProvider" namespace="metadata">

      <extends>

      	<class namespace="metadata" name="DataProvider"/>

      </extends>

      <description>Metadata of a feature store</description>

      <fields>

        <field name="FeatureType" type="dynobject" subType="org.gvsig.fmap.dal.feature.FeatureType" mandatory="false">

          <description>The definition of the structure of the store</description>

        </field>    

      </fields>

    </class>

    <class name="SpatialProvider" namespace="metadata">

      <extends>

      	<class namespace="metadata" name="FeatureProvider"/>

      </extends>

      <description>Metadata of a feature store with spatial support</description>

      <fields>

        <field name="CRS" type="crs" mandatory="false">

          <description></description>

        </field>    

        <field name="Envelope" type="envelope" mandatory="false">

          <description></description>

        </field>    

      </fields>

    </class>

  </classes>

</definitions>  

<?xml version="1.0"?>

<definitions>

  <version>1.0.0</version>

  <classes>

    <class namespace="dal" name="ProviderParameters">

      <description>Parameters used for open a store</description>

      <fields>

        <field name="ProviderName" type="string" mandatory="true" group="Advanced">

          <description>Name of the provider</description>

        </field>

      </fields>

    </class>

    <class namespace="dal" name="NewProviderParameters">

      <extends>

      	<class namespace="dal" name="ProviderParameters"/>

      </extends>

      <description>Parameters used for create a new store in the server</description>

      <fields>

        <field name="FeatureType" type="object" mandatory="true" hidden="true" classOfValue="org.gvsig.fmap.dal.feature.FeatureType">

          <description>Define the structure of the new store</description>

        </field>

      </fields>

    </class>

  </classes>

</definitions>  

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

* 2009 IVER T.I. S.A.   {{Task}}

*/

/**

 *

 */

package org.gvsig.fmap.dal.feature;

import java.util.Iterator;

import org.gvsig.fmap.dal.DataServerExplorer;

import org.gvsig.fmap.dal.DataStore;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.DataTypes;

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

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

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

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

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

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

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

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

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

import org.gvsig.tools.dispose.DisposableIterator;

import org.gvsig.tools.evaluator.AbstractEvaluator;

import org.gvsig.tools.evaluator.Evaluator;

import org.gvsig.tools.evaluator.EvaluatorData;

import org.gvsig.tools.evaluator.EvaluatorException;

import org.gvsig.tools.evaluator.EvaluatorFieldValue;

import org.gvsig.tools.observer.Observable;

import org.gvsig.tools.observer.Observer;

/**

 * @author jmvivo

 *

 */

public abstract class BaseTestEditableFeatureStore extends BaseTestFeatureStore {

	public abstract NewFeatureStoreParameters getDefaultNewDataStoreParameters()

			throws Exception;

	public abstract boolean resourcesNotifyChanges();

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

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

	public void fillPrimaryKeyInserFeature(EditableFeature feature) {

		return;

	}

	protected Evaluator getEvaluatorToLower(String attibuteName) {

		return new ToLower(attibuteName);

	}

	protected Evaluator getEvaluatorToUpper(String attibuteName) {

		return new ToUpper(attibuteName);

	}

	public class ToLower extends AbstractEvaluator {

		private String attributeName;

		public ToLower(String attrName) {

			this.attributeName = attrName;

			this.getFieldsInfo().addFieldValue(this.attributeName);

		}

		public Object evaluate(EvaluatorData data) throws EvaluatorException {

			String value = (String) data.getDataValue(this.attributeName);

			if (value == null) {

				return null;

			}

			return value.toLowerCase();

		}

		public String getSQL() {

			return null;

		}

		public String getDescription() {

			return null;

		}

		public String getName() {

			return null;

		}

	}

	public class ToUpper extends AbstractEvaluator {

		private String attributeName;

		public ToUpper(String attrName) {

			this.attributeName = attrName;

			this.getFieldsInfo().addFieldValue(this.attributeName);

		}

		public Object evaluate(EvaluatorData data) throws EvaluatorException {

			String value = (String) data.getDataValue(this.attributeName);

			if (value == null) {

				return null;

			}

			return value.toUpperCase();

		}

		public String getSQL() {

			return null;

		}

		public String getDescription() {

			return null;

		}

		public EvaluatorFieldValue[] getFieldValues(String name) {

			return null;

		}

		public String getName() {

			return null;

		}

	}

	protected FeatureStore getStoreCopy(FeatureStore source,

			NewFeatureStoreParameters targetParams) throws DataException,

			ValidateDataParametersException {

		DataServerExplorer explorer = source.getExplorer();

		source.export(explorer, source.getProviderName(), targetParams);

		FeatureStore result = (FeatureStore) dataManager.openStore(source.getProviderName(), targetParams);

		return result;

	}

	protected void clearCopy(FeatureStore source,

			NewFeatureStoreParameters targetParams) throws Exception {

		DataServerExplorer explorer = source.getExplorer();

		explorer.remove(targetParams);

	}

	protected boolean compareFeatures(Feature f1, Feature f2,

			String[] attrsNames, UpdateFeature updated, long index,

			long lastIndex) throws DataException, EvaluatorException {

		FeatureAttributeDescriptor attr1;

		FeatureAttributeDescriptor attr2;

		EditableFeature f2e = f2.getEditable();

		updated.applyUpdateList(f2e, index, lastIndex);

		Object v1, v2;

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

			attr1 = f1.getType().getAttributeDescriptor(attrsNames[i]);

			attr2 = f2e.getType().getAttributeDescriptor(attrsNames[i]);

			if (attr1 != attr2) {

				if (!compareAttributes(attr1, attr1)) {

					return false;

				}

			}

			v1 = f1.get(attr1.getName());

			v2 = f2.get(attr2.getName());

			if (!compareFeatureValue(v1, v2, attr1)) {

				return false;

			}

		}

		return true;

	}

	protected boolean compareFeatures(Feature f1, Feature f2,

			UpdateFeature updated, long index, long lastIndex)

			throws DataException, EvaluatorException {

		if (!compareTypes(f1.getType(), f2.getType())) {

			System.out.println("compareFeatures() type !=");

			return false;

		}

		Iterator iter = f1.getType().iterator();

		FeatureAttributeDescriptor attr;

		EditableFeature f1e = f1.getEditable();

		updated.applyUpdateList(f1e, index, lastIndex);

		Object v1, v2;

		while (iter.hasNext()) {

			attr = (FeatureAttributeDescriptor) iter.next();

			v1 = f1e.get(attr.getName());

			v2 = f2.get(attr.getName());

			if (!compareFeatureValue(v1, v2, attr)) {

				return false;

			}

		}

		return true;

	}

	//---------------

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

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

	public void testExport() throws Exception {

		DataStoreParameters parameters = null;

		parameters = getDefaultDataStoreParameters();

		FeatureStore store = (FeatureStore) dataManager.createStore(parameters);

		NewFeatureStoreParameters newParams = this

				.getDefaultNewDataStoreParameters();

		try {

			this.clearCopy(store, newParams);

		} catch (RemoveException e) {

			// Dp nothing

		}

		FeatureStore result = this.getStoreCopy(store, newParams);

		fullStoreIteratorTest(result);

		FeatureSet set;

		FeatureSet originalSet;

		if (result.getDefaultFeatureType().getPrimaryKey() != null

				&& result.getDefaultFeatureType().getPrimaryKey().length > 0) {

			FeatureQuery queryR = result.createFeatureQuery();

			FeatureQuery queryO = store.createFeatureQuery();

			FeatureAttributeDescriptor[] pk = result.getDefaultFeatureType()

					.getPrimaryKey();

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

				queryO.getOrder().add(pk[i].getName(), true);

				queryR.getOrder().add(pk[i].getName(), true);

			}

			set = result.getFeatureSet(queryR);

			originalSet = store.getFeatureSet(queryO);

		} else {

			set = result.getFeatureSet();

			originalSet = store.getFeatureSet();

		}

		assertEquals(set.getSize(), originalSet.getSize());

		DisposableIterator originalIter = originalSet.iterator();

		DisposableIterator iter = set.iterator();

		assertTrue(compareFeatureIterators(originalIter, iter));

		originalIter.dispose();

		iter.dispose();

		if (store.getEnvelope() != result.getEnvelope()) {

			if (store.getEnvelope() != null) {

				assertTrue(store.getEnvelope().equals(result.getEnvelope()));

			} else {

				fail("Envelope: src=" + store.getEnvelope() + " traget="

						+ store.getEnvelope());

			}

		}

		set.dispose();

		originalSet.dispose();

		result.dispose();

		this.clearCopy(store, newParams);

		store.dispose();

	}

	public void testRemove() throws Exception {

		DataStoreParameters parameters = null;

		parameters = getDefaultDataStoreParameters();

		FeatureStore store = (FeatureStore) dataManager.createStore(parameters);

		NewFeatureStoreParameters newParams = this

				.getDefaultNewDataStoreParameters();

		try {

			this.clearCopy(store, newParams);

		} catch (RemoveException e) {

			// Dp nothing

		}

		FeatureStore result = this.getStoreCopy(store, newParams);

		result.edit(FeatureStore.MODE_FULLEDIT);

		FeatureSet set = result.getFeatureSet(getDefaultQuery(result));

		FeatureSet originalSet = store.getFeatureSet(getDefaultQuery(store));

		assertEquals(set.getSize(), originalSet.getSize());

		DisposableIterator originalIter = originalSet.iterator();

		DisposableIterator iter = set.iterator();

		int i = 0;

		while (iter.hasNext()) {

			assertTrue("" + i, compareFeatures((Feature) originalIter.next(),

					(Feature) iter.next()));

			i++;

		}

		iter.remove();

		assertEquals(originalSet.getSize() - 1, set.getSize());

		iter.dispose();

		originalIter.dispose();

		originalIter = originalSet.iterator();

		iter = set.iterator();

		i = 0;

		while (iter.hasNext()) {

			assertTrue("" + i, compareFeatures((Feature) originalIter.next(),

					(Feature) iter.next()));

			i++;

		}

		iter.remove();

		assertEquals(originalSet.getSize() - 2, set.getSize());

		iter.dispose();

		originalIter.dispose();

		set.dispose();

		result.finishEditing();

		set = result.getFeatureSet();

		assertEquals(originalSet.getSize() - 2, set.getSize());

		originalIter = originalSet.iterator();

		iter = set.iterator();

		i = 0;

		while (iter.hasNext()) {

			assertTrue("" + i, compareFeatures((Feature) originalIter.next(),

					(Feature) iter.next()));

			i++;

		}

		iter.dispose();

		originalIter.dispose();

		set.dispose();

		originalSet.dispose();

		result.dispose();

		this.clearCopy(store, newParams);

		store.dispose();

	}

	public void testInsert() throws Exception {

		DataStoreParameters parameters = null;

		parameters = getDefaultDataStoreParameters();

		FeatureStore store = (FeatureStore) dataManager

		.createStore(parameters);

		NewFeatureStoreParameters newParams = this

		.getDefaultNewDataStoreParameters();

		try {

			this.clearCopy(store, newParams);

		} catch (RemoveException e) {

			//Do nothing

		}

		FeatureStore result = this.getStoreCopy(store, newParams);

		result.edit(FeatureStore.MODE_FULLEDIT);

		FeatureSet set = result.getFeatureSet(getDefaultQuery(result));

		FeatureSet originalSet = store.getFeatureSet(getDefaultQuery(store));

		assertEquals(set.getSize(), originalSet.getSize());

		EditableFeature newFeature = result.createNewFeature(true);

		fillPrimaryKeyInserFeature(newFeature);

		set.insert(newFeature);

		DisposableIterator originalIter = originalSet.iterator();

		DisposableIterator iter = set.iterator();

		int i = 0;

		while (originalIter.hasNext()) {

			assertTrue("" + i, compareFeatures((Feature) originalIter

					.next(), (Feature) iter.next()));

			i++;

		}

		assertTrue(iter.hasNext());

		assertNotNull(iter.next());

		assertFalse(iter.hasNext());

		assertEquals(originalSet.getSize() + 1, set.getSize());

		iter.dispose();

		originalIter.dispose();

		originalIter = originalSet.iterator();

		iter = set.iterator();

		i = 0;

		while (originalIter.hasNext()) {

			assertTrue("" + i, compareFeatures((Feature) originalIter

					.next(), (Feature) iter.next()));

			i++;

		}

		assertTrue(iter.hasNext());

		assertNotNull(iter.next());

		newFeature = result.createNewFeature(true);

		fillPrimaryKeyInserFeature(newFeature);

		set.insert(newFeature);

		assertEquals(originalSet.getSize() + 2, set.getSize());

		iter.dispose();

		originalIter.dispose();

		set.dispose();

		result.finishEditing();

		set = result.getFeatureSet();

		assertEquals(originalSet.getSize() + 2, set.getSize());

		originalIter = originalSet.iterator();

		iter = set.iterator();

		i = 0;

		while (originalIter.hasNext()) {

			assertTrue("" + i, compareFeatures((Feature) originalIter

					.next(), (Feature) iter.next()));

			i++;

		}

		assertNotNull(iter.next());

		assertNotNull(iter.next());

		assertFalse(iter.hasNext());

		iter.dispose();

		originalIter.dispose();

		set.dispose();

		originalSet.dispose();

		result.dispose();

		this.clearCopy(store, newParams);

		store.dispose();

	}

	public void testConcurrentRemove() throws Exception {

		DataStoreParameters parameters = null;

		parameters = getDefaultDataStoreParameters();

		FeatureStore store = (FeatureStore) dataManager.createStore(parameters);

		NewFeatureStoreParameters newParams = this

		.getDefaultNewDataStoreParameters();

		try {

			this.clearCopy(store, newParams);

		} catch (RemoveException e) {

			// Dp nothing

		}

		FeatureStore result = this.getStoreCopy(store, newParams);

		result.edit(FeatureStore.MODE_FULLEDIT);

		DeleteFirstAndLastFeature deleteFeature = new DeleteFirstAndLastFeature(

				"1", result, StoreTask.TIME_TO_WAIT_NO_WAIT);

		FeatureSet set = result.getFeatureSet();

		DisposableIterator iter = set.iterator();

		assertTrue(iter.hasNext());

		assertNotNull(iter.next());

		deleteFeature.start();

		while (deleteFeature.getCurrentStatus() <= StoreTask.STATUS_RUNING) {

			Thread.yield();

			Thread.sleep(100);

			if (deleteFeature.isOutOfDate()) {

				break;

			}

		}

		assertEquals(deleteFeature.getCurrentStatus(),

				StoreTask.STATUS_FINISHED_OK);

		Exception ex = null;

		try {

			iter.next();

		} catch (Exception e) {

			ex = e;

		}

		assertNotNull(ex);

		assertEquals(ConcurrentDataModificationException.class, ex.getClass());

		ex = null;

		try {

			set.getSize();

		} catch (Exception e) {

			ex = e;

		}

		assertNotNull(ex);

		assertEquals(ConcurrentDataModificationException.class, ex.getClass());

		iter.dispose();

		result.dispose();

		this.clearCopy(store, newParams);

		store.dispose();

	}

	public void testConcurrentInsert() throws Exception{

		DataStoreParameters parameters = null;

		parameters = getDefaultDataStoreParameters();

		FeatureStore store = (FeatureStore) dataManager.createStore(parameters);

		NewFeatureStoreParameters newParams = this

		.getDefaultNewDataStoreParameters();

		try {

			this.clearCopy(store, newParams);

		} catch (RemoveException e) {

			// Dp nothing

		}

		FeatureStore result = this.getStoreCopy(store, newParams);

		result.edit(FeatureStore.MODE_FULLEDIT);

		InsertFeature insertFeature = new InsertFeature("1", result,

				StoreTask.TIME_TO_WAIT_NO_WAIT, this);

		FeatureSet set = result.getFeatureSet();

		DisposableIterator iter = set.iterator();

		assertTrue(iter.hasNext());

		assertNotNull(iter.next());

		insertFeature.start();

		while (insertFeature.getCurrentStatus() <= StoreTask.STATUS_RUNING) {

			Thread.yield();

			Thread.sleep(100);

			if (insertFeature.isOutOfDate()) {

				break;

			}

		}

		assertEquals(StoreTask.STATUS_FINISHED_OK, insertFeature

				.getCurrentStatus());

		Exception ex = null;

		try {

			iter.next();

		} catch (Exception e) {

			ex = e;

		}

		assertNotNull(ex);

		assertEquals(ConcurrentDataModificationException.class, ex.getClass());

		ex = null;

		try {

			set.getSize();

		} catch (Exception e) {

			ex = e;

		}

		assertNotNull(ex);

		assertEquals(ConcurrentDataModificationException.class, ex.getClass());

		iter.dispose();

		result.dispose();

		this.clearCopy(store, newParams);

		store.dispose();

	}

	public void testConcurrentUpdate() throws Exception {

		DataStoreParameters parameters = null;

		parameters = getDefaultDataStoreParameters();

		FeatureStore store = (FeatureStore) dataManager.createStore(parameters);

		NewFeatureStoreParameters newParams = this