Application: gvSIG desktop

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

<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">

<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/">

    <appender name="CONSOLE" class="org.apache.log4j.ConsoleAppender">

        <layout class="org.apache.log4j.PatternLayout">

            <param name="ConversionPattern" value="%d{HH:mm:ss,SSS} %-5p [%c{2}.%M()]\n  %m%n"/>

        </layout>

    </appender>

  <category name="org.gvsig.fmap.dal">

    <priority value="WARN"/>

  </category>

    <root>

        <priority value="INFO" />

        <appender-ref ref="CONSOLE" />

    </root>

</log4j:configuration>

/* 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 IVER T.I. S.A.   {{Task}}

*/

package org.gvsig.fmap.dal;

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

import org.gvsig.tools.dynobject.DynObject;

import org.gvsig.tools.persistence.Persistent;

/**

 * This interface is a generic persistent parameter container. It is used in a

 * variety of contexts in which a set of arbitrary parameters is needed.

 */

public interface DataParameters extends Persistent, DynObject {

	/**

	 * clears the parameter container.

	 */

	public void clear();

	/**

	 * Creates and returns a new copy of this DataParameters.

	 *

	 * @return a new copy of this

	 */

	public DataParameters getCopy();

	/**

	 * Checks its valid

	 *

	 * @throws ValidateDataParametersException

	 *             if any problem was detected

	 */

	public void validate() throws ValidateDataParametersException;

}

package org.gvsig.fmap.dal;

/**

 * This interface represents a notification produced by a DataStore.

 * 

 * Notifications can be of several types. This interface also defines a set 

 * of constants that represent the types of notifications that a DataStore 

 * can produce.

 */

public interface DataStoreNotification {

	/** Complex notification for special situations */

	public static final String COMPLEX_NOTIFICATION = "complex_notification";

	/** Fired before opening the store */

	public static final String BEFORE_OPEN = "before_Open_DataStore";

	/** Fired after opening the store */

	public static final String AFTER_OPEN = "after_Open_DataStore";

	/** Fired before closing the store */

	public static final String BEFORE_CLOSE = "before_Close_DataStore";

	/** Fired after closing the store */

	public static final String AFTER_CLOSE = "after_Close_DataStore";

	/** Fired before disposing the store */

	public static final String BEFORE_DISPOSE = "before_Dispose_DataStore";

	/** Fired after disposing the store */

	public static final String AFTER_DISPOSE = "after_Dispose_DataStore";

	/** Fired after the store selection has changed */

	public static final String SELECTION_CHANGE = "after_SelectionChange_DataStore";

	/** Fired when a resource of the store has changed */

	public static final String RESOURCE_CHANGED = "resourceChange_DataStore";

	/**

	 * Returns the DataStore that produced this notification

	 * @return DataStore source of this

	 */

	public DataStore getSource();

	/**

	 * Returns the type of this notification, represented by one of the constants defined in this interface.

	 * @return a String containing this notification's type

	 */

	public String getType();

}

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

 *

 */

package org.gvsig.fmap.dal;

/**

 * This interface defines a set of constants for all data types supported by the

 * DAL.

 * 

 * @author gvSIG Team

 * @version $Id$

 * 

 */

public interface DataTypes extends org.cresques.DataTypes,

    org.gvsig.fmap.geom.DataTypes, org.gvsig.timesupport.DataTypes {

}

/* 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}  {Create Parameter object to define queries}

 */

package org.gvsig.fmap.dal;

import org.gvsig.tools.persistence.Persistent;

/**

 * Defines the properties of a collection of data, as a result of a query

 * through a DataStore.

 * <p>

 * The scale parameter can be used by the DataStore as a hint about the quality

 * or resolution of the data needed to view or operate with the data returned.

 * As an example, it may use the scale to return only a representative subset of

 * the data, or maybe to return Data with less detail, like a point or a line

 * instead of a polygon.

 * </p>

 * 

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

 */

public interface DataQuery extends Persistent {

    /**

     * Sets the scale.

     *

     * @param scale

     *            the scale to set

     */

	void setScale(double scale);

	/**

	 * Returns the scale of the data to load.

	 * 

	 * @return the scale of the data to load

	 */

	double getScale();

	/**

	 * Returns the value of an query parameter.

	 *

	 * @param name

	 *            of the parameter

	 * @return the parameter value

	 */

	Object getQueryParameter(String name);

	/**

	 * Sets the value of an query parameter.

	 *

	 * @param name

	 *            of the query parameter

	 * @param value

	 *            for the query parameter

	 */

	void setQueryParameter(String name, Object 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):

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

 */

package org.gvsig.fmap.dal;

import java.util.List;

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

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

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

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

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

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

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

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

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

import org.gvsig.fmap.dal.feature.paging.FeaturePagingHelper;

import org.gvsig.fmap.dal.feature.spi.index.FeatureIndexProvider;

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

import org.gvsig.fmap.dal.store.memory.MemoryStoreProvider;

import org.gvsig.tools.dynobject.DynObject;

import org.gvsig.tools.evaluator.Evaluator;

import org.gvsig.tools.exception.BaseException;

/**

 * There are two top level management roles within DAL: data access and resource management.

 *

 * This class is responsible of the data access management role. It provides ways

 * for registering and instantiating {@link DataServerExplorer}(s), {@link DataStore}(s),

 * {@link Evaluator}(s) and {@link FeatureIndex}(es).

 *

 * @see ResourceManager

 *

 */

public interface DataManager {

	/**

	 * Returns the default DAL's temporary directory

	 *

	 * @return Temporary directory name

	 */

	public String getTemporaryDirectory();

	/*

	 * ====================================================================

	 *

	 * Store related services

	 */

	/**

	 * Creates, initializes and returns an instance of DataStoreParameters given

	 * the name with which their provider is registered.

	 * 

	 * @param name

	 *            provider name

	 * 

	 * @throws ProviderNotRegisteredException

	 *             if the memory provider is not registered

	 * @throws InitializeException

	 *             if there is an error initializing the parameters for the

	 *             memory provider

	 **/

	public DataStoreParameters createStoreParameters(String name)

			throws InitializeException, ProviderNotRegisteredException;

	/**

	 * 

	 * Creates, initializes and returns an instance of NewDataStoreParameters

	 * given the name with which their provider is registered.

	 * 

	 * @param name

	 * 

	 * @throws InitializeException

	 * @throws ProviderNotRegisteredException

	 */

	public NewDataStoreParameters createNewStoreParameters(String explorer, String provider)

			throws InitializeException, ProviderNotRegisteredException;

	/**

	 * 

	 * Creates, initializes and returns an instance of DataStore given the

	 * DataStoreParameters.

	 * 

	 * @param parameters

	 *            parameters used to instantiate and initialize the DataStore

	 * 

	 * @throws ProviderNotRegisteredException

	 *             if the memory provider is not registered

	 * @throws InitializeException

	 *             if there is an error initializing the parameters for the

	 *             memory provider

	 * @throws ValidateDataParametersException

	 *             if the parameters to open the memory based store are not

	 *             valid

	 */

	public DataStore openStore(String provider, DataStoreParameters parameters)

			throws InitializeException, ProviderNotRegisteredException,

			ValidateDataParametersException;

	/**

	 * @deprecated see openStore

	 */

	public DataStore createStore(DataStoreParameters parameters)

			throws InitializeException, ProviderNotRegisteredException,

			ValidateDataParametersException;

	/**

	 * Create a new physical store 

	 *  

	 * @param parameters

	 *

	 * @throws InitializeException

	 * @throws ProviderNotRegisteredException

	 * @throws ValidateDataParametersException

	 */

	public void newStore(String explorer, String provider, NewDataStoreParameters parameters, boolean overwrite)

			throws InitializeException, ProviderNotRegisteredException,

			ValidateDataParametersException;

	/**

	 * Returns a list of Strings containing the names of all available DataStore

	 * providers.

	 *

	 * @return list of String containing available DataStore provider names

	 */

	public List getStoreProviders();

	/**

	 * Returns a list of Strings containing the names of all available DataStore

	 * providers for an explorer.

	 * 

	 * @param explorer

	 *            name

	 */

	public List getStoreProviders(String name);

	/*

	 * ====================================================================

	 *

	 * Explorer related services

	 */

	/**

	 * Returns an instance of {@link DataServerExplorerParameters} corresponding to

	 * the given name.

	 *

	 * @param name

	 *            name of a registered server explorer provider

	 *

	 * @throws InitializeException

	 * 			if parameter initialization causes an error.

	 *

	 * @throws ProviderNotRegisteredException

	 * 			if could not find a provider by the given name.

	 *

	 **/

	public DataServerExplorerParameters createServerExplorerParameters(

			String name)

			throws InitializeException, ProviderNotRegisteredException;

	/**

	 * Returns an instance of {@link DataServerExplorer} given its parameters.

	 *

	 * @param parameters

	 *            parameters used to instantiate and initialize the

	 *            {@link DataServerExplorer}.

	 *

	 * @return an instance of {@link DataServerExplorer}.

	 *

	 * @throws InitializeException

	 *

	 * @throws ProviderNotRegisteredException

	 * @throws ValidateDataParametersException

	 */

	public DataServerExplorer openServerExplorer(

			String name,

			DataServerExplorerParameters parameters)

			throws InitializeException, ProviderNotRegisteredException,

			ValidateDataParametersException;

	/**

	 * @deprecated see openServerExplorer

	 */

	public DataServerExplorer createServerExplorer(

			DataServerExplorerParameters parameters)

			throws InitializeException, ProviderNotRegisteredException,

			ValidateDataParametersException;

	/**

	 * Returns a list of String containing the names of the available

	 * DataServerExplorer providers.

	 *

	 * @return list of String containing the names of the available

	 *         DataServerExplorer providers.

	 */

	public List getExplorerProviders();

	/*

	 * ====================================================================

	 *

	 * Expression evaluation related services

	 */

	/**

	 * Registers the default expression evaluator. It is used by DAL to evaluate

	 * and resolve query filters and expressions.

	 *

	 * @param evaluator

	 *            Class that will be called to evaluate the expression. It must

	 *            implement {@link Evaluator}.

	 */

	public void registerDefaultEvaluator(Class evaluator);

	/**

	 * Creates an instance of Evaluator that represents the given expression.

	 *

	 * @param expression

	 *            String containing a CQL expression.

	 * @return instance of Evaluator representing the given expression.

	 * @throws InitializeException

	 */

	public Evaluator createExpresion(String expression)

			throws InitializeException;

	/*

	 * ====================================================================

	 *

	 * Index related services

	 */

	/**

	 * Returns a list of String containing the names of the available index providers.

	 *

	 * @return

	 * 		list of strings with the names of the available index providers

	 */

	public List getFeatureIndexProviders();

	/**

	 * Sets the default DataIndexProvider for the given data type.

	 *

	 * @param dataType

	 * 				one of the data types defined in {@link DataTypes}.

	 * @param name

	 * 			Provider's name

	 */

    public void setDefaultFeatureIndexProviderName(int dataType, String name);

	/**

	 * Returns the default DataIndexProvider name, given a data type. Data types

	 * are defined in {@link DataTypes}.

	 *

	 * @param dataType

	 *            one of the constants in {@link DataTypes}.

	 *

	 * @return

	 * 		the name of the default {@link FeatureIndexProvider} if there is

	 * 		anyone available for the given data type.

	 */

    public String getDefaultFeatureIndexProviderName(int dataType);

    /**

	 * Returns a list of String containing the names of the available cache providers.

	 *

	 * @return

	 * 		list of strings with the names of the available cache providers

	 */    

    public List getFeatureCacheProviders();

	/**

	 * Returns an instance of {@link DataServerExplorerParameters} corresponding

	 * to the given name used by the cache to create a store to save the

	 * retrieved data.

	 * 

	 * @param name

	 *            name of a registered feature cache provider

	 * 

	 * @throws InitializeException

	 *             if parameter initialization causes an error.

	 * 

	 * @throws ProviderNotRegisteredException

	 *             if could not find a cache provider by the given name.

	 * 

	 */

	public DynObject createCacheParameters(String name)

			throws InitializeException, ProviderNotRegisteredException;

	/**

	 * Utility method to create the {@link DataStoreParameters} to create a

	 * {@link FeatureStore} based on the {@link MemoryStoreProvider}.

	 * 

	 * @param autoOrderAttributeName

	 *            the name of the {@link Feature} attribute to be used to order

	 *            the store {@link Feature}s by default. Set to null if you

	 *            don't want any order by default

	 * @return the parameters for the memory based store

	 * @throws InitializeException

	 *             if there is an error initializing the parameters for the

	 *             memory provider

	 */

	public DataStoreParameters createMemoryStoreParameters(

			String autoOrderAttributeName) throws InitializeException;

	/**

	 * Utility method to create the a {@link FeatureStore} based on the

	 * {@link MemoryStoreProvider}.

	 * 

	 * @param autoOrderAttributeName

	 *            the name of the {@link Feature} attribute to be used to order

	 *            the store {@link Feature}s by default. Set to null if you

	 *            don't want any order by default

	 * @return the the memory based store

	 * @throws InitializeException

	 *             if there is an error initializing the parameters for the

	 *             memory provider

	 */

	public FeatureStore createMemoryStore(String autoOrderAttributeName)

			throws InitializeException;

    /**

     * Creates a {@link FeaturePagingHelper} to paginate data from a

     * {@link FeatureStore}.

     * 

     * @param featureStore

     *            to get the {@link Feature}s from

     * @param pageSize

     *            the page size

     * @return a {@link FeaturePagingHelper}

     * @throws BaseException

     *             if there is an error creating the helper

     */

	public FeaturePagingHelper createFeaturePagingHelper(

        FeatureStore featureStore, int pageSize) throws BaseException;

	/**

     * Creates a {@link FeaturePagingHelper} to paginate data from a

     * {@link FeatureStore}.

     * 

     * @param featureStore

     *            to get the {@link Feature}s from

     * @param featureQuery

     *            to filter and/or order the data

     * @param pageSize

     *            the page size

     * @return a {@link FeaturePagingHelper}

     * @throws BaseException

     *             if there is an error creating the helper

     */

	public FeaturePagingHelper createFeaturePagingHelper(

			FeatureStore featureStore, FeatureQuery featureQuery, int pageSize)

        throws BaseException;

	/**

	 * Registers a class that can be used to create a {@link FeatureAttributeGetter}

	 * and associate it to a {@link FeatureAttributeDescriptor}.

	 * 

   	 * @param name

   	 *             the name used to register the class.

	 * @param clazz

	 *             it has to be an instance of {@link FeatureAttributeDescriptor}         

	 */

	public void registerFeatureAttributeGetter(String name, Class clazz);

	/**

	 * Creates a {@link FeatureAttributeGetter} by name. If there is not any class

	 * registered with this name or if there is any error an exception is thrown.

	 * 

	 * @param name

	 *             the name that was used to register the class              

	 * @return

	 *             a {@link FeatureAttributeGetter}

	 * @throws InitializeException

	 *             if there is any error creating the object

	 */

	public FeatureAttributeGetter createFeatureAttributeGetter(String name) throws InitializeException;

	public void setOpenErrorHandler(OpenErrorHandler handler);

}

/* 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 IVER T.I. S.A.   {{Task}}

*/

package org.gvsig.fmap.dal;

/**

 * DataServerExplorer parameter container. Provides a way to obtain the name 

 * of the specific data explorer type described by this parameters.

 * 

 */

public interface DataServerExplorerParameters extends DataParameters {

	/**

	 * Returns the name of the data explorer type of the DataServerExplorer

	 * represented by this DataServerExplorerParameters

	 * 

	 * @return a String containing the name of the data explorer type

	 */

	public String getExplorerName();

}

package org.gvsig.fmap.dal.resource;

import org.gvsig.fmap.dal.DataParameters;

/**

 * Interface that contains any resource parameters.

 * Each specific subtype of resource will extend this

 * interface with its own relevant parameters.

 *

 */

public interface ResourceParameters extends DataParameters {

	/**

	 * Returns the type name of the related resource.

	 * 

	 * @return

	 * 		type name of the resource.

	 */

	public String getTypeName();

}

/* gvSIG. Geographic Information System of the Valencian Government

 *

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

 * of the Valencian Government (CIT)

 *

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

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

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

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

 *

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

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

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

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

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

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

 * MA  02110-1301, USA.

 *

 */

/*

 * AUTHORS (In addition to CIT):

 * 2009 IVER T.I   {{Task}}

 */

/**

 *

 */

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

import java.lang.ref.WeakReference;

import java.util.ArrayList;

import java.util.Iterator;

import java.util.List;

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

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

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

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

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

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

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

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

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

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

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

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

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

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

import org.gvsig.fmap.dal.resource.impl.DefaultResourceNotification;

import org.gvsig.tools.observer.Observer;

import org.gvsig.tools.observer.WeakReferencingObservable;

import org.gvsig.tools.observer.impl.BaseWeakReferencingObservable;

import org.gvsig.tools.observer.impl.DelegateWeakReferencingObservable;

/**

 * <p>

 * Base implementation for Resource

 * </p>

 * 

 * <p>

 * This implementation not define the {@link Resource#begin()} and

 * {@link Resource#end()}

 * </p>

 * 

 * @author jmvivo

 * 

 */

public abstract class AbstractResource implements ResourceProvider,

		WeakReferencingObservable {

	private DelegateWeakReferencingObservable delegateObservable;

	private List consumers;

	private long lastTimeOpen;

	private long lastTimeUsed;

	private ResourceParameters parameters;

	private ResourceParameters preparedParameters;

	private Object data;

	private int openCount;

	/**

	 * Number of times an execute is being simultaneously performed with this

	 * resource.

	 */

	private int executeCount = 0;

	protected final Object lock;

	protected AbstractResource(ResourceParameters parameters)

			throws InitializeException {

		consumers = new ArrayList();

		lastTimeOpen = System.currentTimeMillis();

		lastTimeUsed = lastTimeOpen;

		openCount = 0;

		preparedParameters = null;

		delegateObservable = new DelegateWeakReferencingObservable(this);

		lock = new Object();

		try {

			this.parameters = (ResourceParameters) parameters.getCopy();

		} catch (CopyParametersException e) {

			throw new InitializeException(e);

		}

	}

	protected final void updateLastTimeUsed() {

		lastTimeUsed = System.currentTimeMillis();

	}

	protected final void updateLastTimeOpen() {

		lastTimeOpen = System.currentTimeMillis();

		lastTimeUsed = lastTimeOpen;

	}

	public final long getLastTimeOpen() {

		return lastTimeOpen;

	}

	public final long getLastTimeUsed() {

		return lastTimeUsed;

	}

	public final ResourceParameters getParameters() {

		if (preparedParameters != null) {

			return preparedParameters;

		}

		return this.parameters;

	}

	public void prepare(ResourceParameters params)

			throws PrepareResourceException {

		ResourceNotification notification =

				new DefaultResourceNotification(this,

						ResourceNotification.PREPARE, params);

		this.delegateObservable.notifyObservers(notification);

	}

	public void prepare() throws PrepareResourceException {

		if (preparedParameters == null) {

			try {

				ResourceParameters params =

						(ResourceParameters) parameters.getCopy();

				prepare(params);

				preparedParameters = params;

			} catch (CopyParametersException e) {

				throw new PrepareResourceException(this, e);

			}

		}

	}

	public void notifyOpen() throws ResourceNotifyOpenException {

		this.notifyObserver(ResourceNotification.OPEN);

		updateLastTimeOpen();

		openCount++;

	}

	public void notifyClose() throws ResourceNotifyCloseException {

		if (openCount <= 0) {

			throw new IllegalStateException();

		}

		this.notifyObserver(ResourceNotification.CLOSE);

		openCount--;

	}

	public void notifyChanges() throws ResourceNotifyChangesException {

		this.notifyObserver(ResourceNotification.CHANGED);

		Iterator it = consumers.iterator();

		while (it.hasNext()) {

			ResourceConsumer consumer =

					(ResourceConsumer) ((WeakReference) it.next()).get();

			if (consumer != null) {

				consumer.resourceChanged(this);

			} else {

				it.remove();

			}

		}

	}

	public boolean isOpen() {

		return this.openCount > 0;

	}

	public int openCount() {

		return this.openCount;

	}

	public void addObserver(Observer o) {

		this.delegateObservable.addObserver(o);

	}

	public void deleteObserver(Observer o) {

		this.delegateObservable.deleteObserver(o);

	}

	public void deleteObservers() {

		this.delegateObservable.deleteObservers();

	}

	public final void addObservers(BaseWeakReferencingObservable observers) {

		this.delegateObservable.addObservers(observers);

	}

	public final void addConsumer(ResourceConsumer consumer) {

		this.updateConsumersList();

		consumers.add(new WeakReference(consumer));

	}

	public final void removeConsumer(ResourceConsumer consumer) {

		ResourceConsumer cur;

		Iterator it = consumers.iterator();

		while (it.hasNext()) {

			cur = (ResourceConsumer) ((WeakReference) it.next()).get();

			if (cur == null || (cur == consumer)) {

				it.remove();

			}

		}

	}

	public int getConsumersCount() {

		this.updateConsumersList();

		return consumers.size();

	}

	private synchronized void updateConsumersList() {

		Iterator it = consumers.iterator();

		WeakReference ref;

		while (it.hasNext()) {

			ref = (WeakReference) it.next();

			if (ref.get() == null) {

				it.remove();

			}

		}

	}

	public void closeRequest() throws ResourceException {

		if (inUse()) {

			return;

		}

		if (consumers != null) {

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

			}

		}

		if (consumers != null) {

			Iterator it = consumers.iterator();

			while (it.hasNext()) {

				ResourceConsumer consumer =

						(ResourceConsumer) ((WeakReference) it.next()).get();

				if (consumer != null) {

					consumer.closeResourceRequested(this);

				} else {

					it.remove();

				}

			}

		}

	}

	public void setData(Object data) {

		this.data = data;

	}

	public Object getData() {

		return this.data;

	}

	protected void notifyObserver(String type) {

		if (delegateObservable != null) {

			this.delegateObservable.notifyObservers(new DefaultResourceNotification(

					this, type));

		}

	}

	public void notifyDispose() throws ResourceNotifyDisposeException {

		this.notifyObserver(ResourceNotification.DISPOSE);

		if (consumers != null) {

			consumers.clear();

		}

		lastTimeOpen = 0l;

		lastTimeUsed = 0l;

		data = null;

		if (delegateObservable != null) {

			delegateObservable.deleteObservers();

		}

	}

	public final boolean inUse() {

		return executeCount > 0;

	}

	public Object execute(ResourceAction action)

			throws ResourceExecuteException {

		Object value = null;

		synchronized (lock) {

			executeBegins();

			try {

				value = performExecution(action);

			} catch (Exception e) {

				throw new ResourceExecuteException(this, e);

			} finally {

				executeEnds();

			}

		}

		return value;

	}

	protected Object performExecution(ResourceAction action) throws Exception {

		return action.run();

	}

	protected final void executeBegins() {

		executeCount++;

	}

	protected final void executeEnds() {

		updateLastTimeUsed();

		executeCount--;

	}

	/**

	 * Returns the name of the {@link Resource}.

	 * 

	 * @throws AccessResourceException

	 *             if there is an error while accessing the resource

	 */

	public abstract String getName() throws AccessResourceException;

	/**

	 * Returns the real resource represented by this object.

	 * 

	 * @throws AccessResourceException

	 *             if there is an error while accessing the resource

	 */

	public abstract Object get() throws AccessResourceException;

}

/* gvSIG. Geographic Information System of the Valencian Government

 *

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

 * of the Valencian Government (CIT)

 *

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

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

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

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

 *

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

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

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

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

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

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

 * MA  02110-1301, USA.

 *

 */

/*

 * AUTHORS (In addition to CIT):

 * 2009 IVER T.I   {{Task}}

 */

/**

 *

 */

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

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

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

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

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

/**

 * <p>

 * Abstract Implementation for Resource that allows the concurrent access.

 * </p>

 * 

 * @author jmvivo

 * 

 */

public abstract class AbstractNonBlockingResource extends AbstractResource {

	/**

	 * @param parameters

	 * @throws InitializeException

	 */

	public AbstractNonBlockingResource(ResourceParameters parameters)

			throws InitializeException {

		super(parameters);

	}

	public Object execute(ResourceAction action)

			throws ResourceExecuteException {

		Object value = null;

		synchronized (lock) {

			executeBegins();

		}

		try {

			value = performExecution(action);

		} catch (Exception e) {

			throw new ResourceExecuteException(this, e);

		} finally {

			synchronized (lock) {

				executeEnds();

			}

		}

		return value;

	}

}

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

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

import org.gvsig.fmap.dal.spi.AbstractDataParameters;

public abstract class AbstractResourceParameters extends AbstractDataParameters

		implements ResourceParameters {

}

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

import java.util.List;

import org.gvsig.fmap.dal.DataParameters;

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

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

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

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

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

public interface ResourceManagerProviderServices extends ResourceManager {

	public boolean register(String type, String description, Class handler,

			Class params);

	public DataParameters createParameters(String type)

			throws InitializeException;

	public ResourceProvider createAddResource(ResourceParameters params)

			throws InitializeException;

	public ResourceProvider createResource(ResourceParameters params)

			throws InitializeException;

	public ResourceProvider createAddResource(String type, Object[] params)

			throws InitializeException;

	public ResourceProvider createResource(String type, Object[] params)

			throws InitializeException;

	public void remove(Resource resource) throws DataException;

	public void remove(String name) throws DataException;

	public List getResourceProviders();

}

/* 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 java.util.ArrayList;

import java.util.List;

import org.gvsig.fmap.dal.DALLocator;

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

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

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

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

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

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 * Resource implementation which is able to show an unique interface to a group

 * of Resources.

 * 

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

 */

public class MultiResource extends AbstractResource {

	public static final String TYPE_NAME = "multi";

	public static final String DESCRIPTION = "Group of multiple resources";

	private static final Logger LOG =

			LoggerFactory.getLogger(MultiResource.class);

	private List resources = new ArrayList();

	// Initially, the first one

	private int defaultResourcePos = 0;

	/**

	 * Creates a new {@link MultiResource} from the given parameters.

	 * 

	 * @param parameters

	 *            to create the resource from

	 * @throws InitializeException

	 *             if there is an error creating the resource

	 */

	public MultiResource(MultiResourceParameters parameters)

			throws InitializeException {

		super(parameters);

	}

	private List getResources() {

		return resources;

	}

	/**

	 * Adds a new {@link ResourceProvider} to the list of Resources managed by

	 * this group.

	 * 

	 * @param parameters

	 *            to create the resource from

	 * @param defaultResource

	 *            if the added resource is to be used as the multi resource

	 *            default one

	 * @throws InitializeException

	 *             if there is an error adding the resource

	 */

	public void addResource(ResourceParameters parameters,

			boolean defaultResource) throws InitializeException {

		ResourceProvider resourceProvider =

				((ResourceManagerProviderServices) DALLocator.getResourceManager()).createResource(parameters);

		resources.add(resourceProvider);

		if (defaultResource) {

			defaultResourcePos = resources.size() - 1;

		}

	}

	/**

	 * Adds a new {@link ResourceProvider} to the list of Resources managed by

	 * this group.

	 * 

	 * @param name

	 *            of the resource to add

	 * @param params

	 *            parameters to create the resource with

	 * @param defaultResource

	 *            if the added resource is to be used as the multi resource

	 *            default one

	 * @throws InitializeException

	 *             if there is an error adding the resource

	 */

	public void addResource(String name, Object[] params,

			boolean defaultResource) throws InitializeException {

		ResourceProvider resourceProvider =

				((ResourceManagerProviderServices) DALLocator.getResourceManager()).createResource(

						name, params);

		resources.add(resourceProvider);

		if (defaultResource) {

			defaultResourcePos = resources.size() - 1;

		}

	}

	public boolean isThis(ResourceParameters parameters)

			throws ResourceException {

		if (parameters instanceof MultiResourceParameters) {

			MultiResourceParameters multiParams =

					(MultiResourceParameters) parameters;

			return multiParams.getName() != null

					&& multiParams.getName().equals(

							getMultiResourceParameters().getName());

		}

		return false;

	}

	public void notifyChanges() throws ResourceNotifyChangesException {

		List resources = getResources();

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

			((ResourceProvider) getResources().get(i)).notifyChanges();

		}

	}

	public void notifyClose() throws ResourceNotifyCloseException {

		List resources = getResources();

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

			((ResourceProvider) getResources().get(i)).notifyClose();

		}

	}

	public void notifyDispose() throws ResourceNotifyDisposeException {

		List resources = getResources();

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

			((ResourceProvider) getResources().get(i)).notifyDispose();

		}

	}

	public void notifyOpen() throws ResourceNotifyOpenException {

		List resources = getResources();

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

			((ResourceProvider) getResources().get(i)).notifyOpen();

		}

	}

	public void prepare() throws PrepareResourceException {

		List resources = getResources();

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

			((ResourceProvider) getResources().get(i)).prepare();

		}

	}

	public void closeRequest() throws ResourceException {

		List resources = getResources();

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

			((ResourceProvider) getResources().get(i)).closeRequest();

		}

	}

	public Object get() throws AccessResourceException {

		ResourceProvider defaultResource = getDefaultResource();

		if (defaultResource == null) {

			return null;

		} else {