Application: gvSIG desktop » gvSIG data providers based on gdal

<?xml version="1.0"?>

<!--

Definitions of metadata fields of a shp file.  

 -->

<definitions>

  <version>1.0.0</version>

  <classes>

    <class name="OGRDataStoreProvider" namespace="Metadata">

      <extends>

      	<class namespace="Metadata" name="SpatialProvider"/>

      </extends>

      <description>Metadata of a OGR provider</description>

      <fields>

      </fields>

    </class>

  </classes>

</definitions>  

<?xml version="1.0"?>

<definitions>

	<version>1.0.0</version>

	<classes>

		<class name="OGRDataExplorerParameters">

			<description>Store the parameters needed to create OGR data explorers

			</description>

			<fields>

				<field name="file" type="file" mandatory="false" group="Basic">

					<description>Resource file</description>

				</field>

				<field name="connectionString" type="string" mandatory="false"

					group="Basic">

					<description>Connection string to open data source</description>

				</field>

			</fields>

		</class>

	</classes>

</definitions>

<definitions>

	<version>1.0.0</version>

	<classes>

		<class name="OGRNewDataStoreParameters">

			<description>Store the parameters needed to create OGR data stores

			</description>

			<extends>

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

				<class>OGRDataStoreParameters</class>

			</extends>

			<fields>

				<field name="driverName" type="string" mandatory="false" group="Basic">

					<description>Name of driver</description>

				</field>

				<field name="datasetCreationOptions" type="List" mandatory="false" group="Basic">

					<description>Name of driver</description>

				</field>

			</fields>

		</class>

	</classes>

</definitions>

<?xml version="1.0"?>

<definitions>

	<version>1.0.0</version>

	<classes>

		<class name="OGRDataStoreParameters">

			<extends>

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

			</extends>

			<description>Store the parameters needed to open OGR stores

			</description>

			<fields>

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

					<description>Coordinate reference system used</description>

				</field>

				<field name="file" type="file" mandatory="false" group="Basic">

					<description>Resource file</description>

				</field>

				<field name="connectionString" type="string" mandatory="false"

					group="Basic">

					<description>Connection string to open data source</description>

				</field>

				<field name="layerName" type="string" mandatory="false" group="Basic">

					<description>Layer name of data source</description>

				</field>

				<field name="defaultGeometryField" type="string" mandatory="false"

					group="Basic">

					<description>Name of default geometry field</description>

				</field>

        <field name="ignoreSpatialFilter" type="boolean" mandatory="false"

          group="Advanced" defaultValue="true">

          <description>Ignore spatial filter</description>

        </field>

			</fields>

		</class>

	</classes>

</definitions>

org.gvsig.gdal.prov.ogr.OGRLibrary

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright ? 2007-2016 gvSIG Association

 *

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

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

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

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

 *

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

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

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

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

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

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

 * MA  02110-1301, USA.

 *

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

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

 */

package org.gvsig.gdal.prov.ogr;

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

import org.gvsig.tools.dynobject.DynObject;

/**

 * OGR Provider factory to create parameters to create specific server data

 * explorers and specific data store providers.

 * 

 * @author <a href="mailto:lmarques@disid.com">Lluis Marques</a>

 *

 */

public interface OGRDataStoreProviderFactory extends FeatureStoreProviderFactory {

    /**

     * 

     * @return Name of driver used to open sources

     */

    public String getDriver();

    /**

     * Creates specific parameters if factory can open connection object. If it

     * can not open, it will be return null.

     * 

     * @param connectionObject

     *            File or connection string to be opened

     * @return Data explorer parameters If this factory can open connection

     *         object it will be return specific parameters, otherwise return

     *         null.

     */

    public DynObject createParameters(Object connectionObject);

    /**

     * Creates specific data explorer parameters if factory can open connection

     * object. If it

     * can not open, it will be return null.

     * 

     * @param connectionObject

     *            File or connection string to be opened

     * @return Data explorer parameters If this factory can open connection

     *         object it will be return specific data explrer parameters,

     *         otherwise return

     *         null.

     */

    public DynObject createDataExplorerParameters(Object connectionObject);

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright ? 2007-2016 gvSIG Association

 *

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

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

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

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

 *

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

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

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

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

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

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

 * MA  02110-1301, USA.

 *

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

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

 */

package org.gvsig.gdal.prov.ogr;

import java.io.File;

import java.util.ArrayList;

import java.util.List;

import org.apache.commons.lang3.StringUtils;

import org.cresques.cts.ICRSFactory;

import org.cresques.cts.IProjection;

import org.gdal.ogr.DataSource;

import org.gdal.ogr.FieldDefn;

import org.gdal.ogr.GeomFieldDefn;

import org.gdal.ogr.Layer;

import org.gdal.ogr.ogr;

import org.gdal.ogr.ogrConstants;

import org.gdal.osr.SpatialReference;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import org.gvsig.fmap.dal.DataServerExplorerParameters;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.NewDataStoreParameters;

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

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

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

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

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

import org.gvsig.fmap.dal.resource.file.FileResource;

import org.gvsig.fmap.dal.resource.spi.ResourceConsumer;

import org.gvsig.fmap.dal.resource.spi.ResourceManagerProviderServices;

import org.gvsig.fmap.dal.resource.spi.ResourceProvider;

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

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

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

import org.gvsig.tools.dynobject.DynField;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 * 

 * @author <a href="mailto:lmarques@disid.com">Lluis Marques</a>

 *

 */

public class OGRDataExplorer extends AbstractDataServerExplorer implements DataServerExplorerProvider, ResourceConsumer {

    private static final Logger LOG = LoggerFactory.getLogger(OGRDataExplorer.class);

    /**

     * 

     */

    public static final String NAME = "OGRDataExplorer";

    private DataServerExplorerProviderServices providerServives;

    protected OGRDataExplorerParameters parameters;

    private ResourceProvider resourceProvider;

    protected DataSource dataSource;

    protected Boolean updateSupport;

    private List<Layer> layerList;

    /**

     * @param parameters

     *            Parameters to open data explorer.

     * @param providerServices

     *            Available services

     * @throws InitializeException

     *             If there is some error initializing this store provider

     */

    public OGRDataExplorer(OGRDataExplorerParameters parameters,

        DataServerExplorerProviderServices providerServices) throws InitializeException {

        super(parameters, providerServices);

        this.providerServives = providerServices;

        this.parameters = parameters;

        getResourceProvider().addConsumer(this);

    }

    private ResourceProvider getResourceProvider() {

        if (this.resourceProvider == null) {

            ResourceManagerProviderServices manager =

                (ResourceManagerProviderServices) DALLocator.getResourceManager();

            if (StringUtils.isBlank(parameters.getConnectionString())) {

                try {

                    this.resourceProvider =

                        (FileResource) manager.createAddResource(FileResource.NAME,

                            new Object[] { this.parameters.getFile().getAbsolutePath() });

                } catch (InitializeException e) {

                    throw new ReadRuntimeException(getProviderName(), e);

                }

            } else {

                try {

                    this.resourceProvider =

                        (OGRResource) manager.createAddResource(OGRResource.NAME,

                            new Object[] { this.parameters.getConnectionString() });

                } catch (InitializeException e) {

                    throw new ReadRuntimeException(getProviderName(), e);

                }

            }

        }

        return this.resourceProvider;

    }

    protected synchronized DataSource getDataSource() throws OGRUnsupportedFormatException {

        if (this.dataSource == null) {

            // Prioritize connection string over file

            if (StringUtils.isNotBlank(this.parameters.getConnectionString())) {

                // Trying to open in update mode

                this.dataSource = ogr.Open(this.parameters.getConnectionString(), 1);

                if (this.dataSource == null) {

                    this.dataSource = ogr.Open(this.parameters.getConnectionString());

                    updateSupport = false;

                } else {

                    updateSupport = true;

                }

            } else if (this.parameters.getFile() != null && this.parameters.getFile().exists()) {

                // Trying to open in update mode

                this.dataSource = ogr.Open(this.parameters.getFile().getAbsolutePath(), 1);

                if (this.dataSource == null) {

                    this.dataSource = ogr.Open(this.parameters.getFile().getAbsolutePath());

                    updateSupport = false;

                } else {

                    updateSupport = true;

                }

            } else {

                throw new IllegalStateException(

                    "Invalid parameters. Connection string must not be blank or file must exists");

            }

        }

        if (this.dataSource == null) {

            if (StringUtils.isNotBlank(this.parameters.getConnectionString())) {

                throw new OGRUnsupportedFormatException(this.parameters.getConnectionString());

            }

        }

        return this.dataSource;

    }

    @SuppressWarnings("unchecked")

    protected List<Layer> getLayerList() {

        if (this.layerList == null) {

            this.layerList = (List<Layer>) getResourceProvider().execute(new ResourceAction() {

                @Override

                public Object run() throws Exception {

                    List<Layer> layers = new ArrayList<Layer>();

                    for (int i = 0; i < getDataSource().GetLayerCount(); i++) {

                        layers.add(getDataSource().GetLayer(i));

                    }

                    return layers;

                }

            });

        }

        return this.layerList;

    }

    private Boolean hasUpdateSupport() throws OGRUnsupportedFormatException {

        if (this.updateSupport == null) {

            // Open data source to check update support of driver

            getDataSource();

        }

        return this.updateSupport;

    }

    @Override

    public String getProviderName() {

        return NAME;

    }

    @Override

    public boolean canAdd() {

        return (boolean) getResourceProvider().execute(new ResourceAction() {

            @Override

            public Object run() throws Exception {

                return getDataSource().TestCapability(ogrConstants.ODsCCreateLayer)

                    && getDataSource().TestCapability(ogrConstants.ODsCDeleteLayer)

                    && hasUpdateSupport();

            }

        });

    }

    @Override

    public boolean canAdd(String storeName) throws DataException {

        return getDataStoreProviderNames().contains(storeName) && canAdd();

    }

    @SuppressWarnings("rawtypes")

    @Override

    public List list() throws DataException {

        return list(MODE_ALL);

    }

    @SuppressWarnings("rawtypes")

    @Override

    public List list(int mode) throws DataException {

        List<Layer> layerList = getLayerList();

        DataManager dataManager = DALLocator.getDataManager();

        List<OGRDataStoreParameters> parametersList = new ArrayList<OGRDataStoreParameters>();

        for (Layer layer : layerList) {

            OGRDataStoreParameters storeParameters =

                (OGRDataStoreParameters) dataManager.createStoreParameters(OGRDataStoreProvider.NAME);

            String connectionString = this.parameters.getConnectionString();

            File file = this.parameters.getFile();

            storeParameters.setConnectionString(connectionString);

            storeParameters.setFile(file);

            storeParameters.setLayerName(layer.GetName());

            parametersList.add(storeParameters);

        }

        return parametersList;

    }

    @Override

    public boolean add(String provider, final NewDataStoreParameters parameters,

        final boolean overwrite) throws DataException {

        if (canAdd()) {

            return (boolean) getResourceProvider().execute(new ResourceAction() {

                @Override

                public Object run() throws Exception {

                    if (parameters instanceof OGRNewDataStoreParameters) {

                        OGRNewDataStoreParameters ogrParameters =

                            (OGRNewDataStoreParameters) parameters;

                        String layerName = ogrParameters.getLayerName();

                        if (overwrite) {

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

                                if (getLayerList().get(i).GetName().equals(layerName)) {

                                    getDataSource().DeleteLayer(i);

                                }

                            }

                        } else {

                            for (Layer layer : getLayerList()) {

                                if (layer.GetName().equals(layerName)) {

                                    return false;

                                }

                            }

                        }

                        EditableFeatureType editableFeatureType =

                            ogrParameters.getDefaultFeatureType();

                        OGRConverter converter = new OGRConverter();

                        // If SRS is defined convert it to spatial reference

                        IProjection projection = editableFeatureType.getDefaultSRS();

                        SpatialReference srs = null;

                        if (projection != null) {

                            srs = new SpatialReference(projection.export(ICRSFactory.FORMAT_PROJ4));

                        }

                        // Convert to geometry type to OGR Geometry type

                        Integer ogrGeometryType = null;

                        if (editableFeatureType.getDefaultGeometryAttribute() != null) {

                            int geomType =

                                editableFeatureType.getDefaultGeometryAttribute().getGeomType()

                                    .getType();

                            ogrGeometryType = converter.convertToOGRGeomType(geomType);

                        }

                        // Create layer

                        Layer newlayer = null;

                        if (srs == null) {

                            newlayer = getDataSource().CreateLayer(layerName);

                        } else if (ogrGeometryType == null && srs != null) {

                            newlayer = getDataSource().CreateLayer(layerName, srs);

                        } else if (ogrGeometryType != null && srs != null) {

                            newlayer = getDataSource().CreateLayer(layerName, srs, ogrGeometryType);

                        }

                        List<FieldDefn> fields =

                            converter.convertFields(editableFeatureType.getNotEditableCopy());

                        for (FieldDefn fieldDefn : fields) {

                            newlayer.CreateField(fieldDefn);

                        }

                        List<GeomFieldDefn> geometryFields =

                            converter.convertGeometryFields(

                                editableFeatureType.getNotEditableCopy(), false);

                        for (GeomFieldDefn geomFieldDefn : geometryFields) {

                            newlayer.CreateGeomField(geomFieldDefn);

                        }

                        return true;

                    }

                    return false;

                }

            });

        }

        return false;

    }

    @Override

    public void remove(final DataStoreParameters parameters) throws DataException {

        if (canAdd()) {

            getResourceProvider().execute(new ResourceAction() {

                @Override

                public Object run() throws Exception {

                    if (parameters instanceof OGRNewDataStoreParameters) {

                        OGRNewDataStoreParameters ogrParameters =

                            (OGRNewDataStoreParameters) parameters;

                        String layerName = ogrParameters.getLayerName();

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

                            if (getLayerList().get(i).GetName().equals(layerName)) {

                                getDataSource().DeleteLayer(i);

                                return true;

                            }

                        }

                    }

                    return false;

                }

            });

        }

    }

    @Override

    public NewDataStoreParameters getAddParameters(String storeName) throws DataException {

        if (getDataStoreProviderNames().contains(storeName)) {

            OGRNewDataStoreParameters newParameters = new OGRNewDataStoreParameters();

            newParameters.setFile(this.parameters.getFile());

            newParameters.setConnectionString(this.parameters.getConnectionString());

            return newParameters;

        }

        return null;

    }

    @Override

    public DataServerExplorerParameters getParameters() {

        return parameters;

    }

    @SuppressWarnings("rawtypes")

    @Override

    public List getDataStoreProviderNames() {

        List<String> providerNames = new ArrayList<String>();

        providerNames.add(OGRDataStoreProvider.NAME);

        return providerNames;

    }

    @Override

    public void doDispose() {

        try {

            getDataSource().SyncToDisk();

            getDataSource().delete();

        } catch (OGRUnsupportedFormatException e) {

            LOG.warn("Can not dispose OGRDataExplorer", e);

        }

        this.dataSource = null;

        this.layerList = null;

        getResourceProvider().removeConsumer(this);

        this.resourceProvider = null;

    }

    @Override

    public DataServerExplorerProviderServices getServerExplorerProviderServices() {

        return providerServives;

    }

    @Override

    public boolean closeResourceRequested(ResourceProvider resource) {

        try {

            getDataSource().SyncToDisk();

            getDataSource().delete();

        } catch (OGRUnsupportedFormatException e) {

            LOG.warn(String.format("Can not close requested resource %1s", resource), e);

        }

        this.dataSource = null;

        this.layerList = null;

        return true;

    }

    @Override

    public void resourceChanged(ResourceProvider resource) {

        try {

            getDataSource().SyncToDisk();

            getDataSource().delete();

        } catch (OGRUnsupportedFormatException e) {

            LOG.warn("Can not sync to disk or release native resources to reopen data source", e);

        }

        this.dataSource = null;

        this.layerList = null;

    }

    @Override

    public DataStoreParameters get(String name) throws DataException {

        // "name" es un nombre de fichero sin path.

        // No tengo nada clara esta implementacion

        OGRDataStoreParameters params = new OGRDataStoreParameters();

        //

        // Copiamos los paramametros que se llamen igual entre el explorer y

        // el DataStoreParametes

        for( DynField field : params.getDynClass().getDynFields() ) {

            String fieldName = field.getName();

            if( parameters.hasDynValue(fieldName) ) {

                params.setDynValue(fieldName, parameters.getDynValue(fieldName));

            }

        }

        // Si el file es una carpeta asignamos como file el fichero name que haya

        // en ella

        // Si el file es un fichero cogemos el fichero name que se encuentre en

        // su misma carpeta.

        if( parameters.getFile().isDirectory() ) {

            params.setFile(new File(parameters.getFile(),name));

        } else {

            params.setFile(new File(parameters.getFile().getParentFile(),name));

        }

        // Usamos como layer el nombre del fichero pasado como parametro.

        params.setLayerName(name);

        return params;

    }

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright ? 2007-2016 gvSIG Association

 *

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

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

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

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

 *

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

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

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

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

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

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

 * MA  02110-1301, USA.

 *

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

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

 */

package org.gvsig.gdal.prov.ogr;

import java.io.File;

import org.apache.commons.lang3.StringUtils;

import org.cresques.cts.IProjection;

import org.gvsig.fmap.dal.DataStoreParameters;

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

import org.gvsig.fmap.dal.serverexplorer.filesystem.FilesystemStoreParameters;

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

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

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.dynobject.DelegatedDynObject;

/**

 *

 * @author <a href="mailto:lmarques@disid.com">Lluis Marques</a>

 *

 */

public class OGRDataStoreParameters extends AbstractDataParameters implements OpenFeatureStoreParameters,

    FilesystemStoreParameters {

    /**

     *

     */

    public static final String PARAMETERS_DEFINITION_NAME = "OGRDataStoreParameters";

    /**

     *

     */

    public static final String FILE_PARAMTER_NAME = "file";

    /**

     *

     */

    public static final String LAYER_NAME_PARAMTER_NAME = "layerName";

    /**

     *

     */

    public static final String CONNECTION_STRING_PARAMETER_NAME = "connectionString";

    /**

     *

     */

    public static final String DEFAULT_GEOMETRY_PARAMETER_NAME = "defaultGeometryField";

    /**

     *

     */

    public static final String CRS_PARAMETER_NAME = "crs";

    /**

     *

     */

    public static final String IGNORE_SPATIAL_FILTER = "ignoreSpatialFilter";

    protected DelegatedDynObject parameters;

    /**

     *

     */

    public OGRDataStoreParameters() {

        this.parameters =

            (DelegatedDynObject) ToolsLocator.getDynObjectManager().createDynObject(

                ToolsLocator.getPersistenceManager().getDefinition(PARAMETERS_DEFINITION_NAME));

        this.setDynValue(DataStoreProviderServices.PROVIDER_PARAMTER_NAME,

            OGRDataStoreProvider.NAME);

    }

    @Override

    public String getDataStoreName() {

        return OGRDataStoreProvider.NAME;

    }

    @Override

    public String getDescription() {

        return OGRDataStoreProvider.DESCRIPTION;

    }

    /**

     * @return File

     */

    public File getFile() {

        return (File) this.getDynValue(FILE_PARAMTER_NAME);

    }

    /**

     * @return String

     */

    public String getLayerName() {

        return (String) this.getDynValue(LAYER_NAME_PARAMTER_NAME);

    }

    /**

     * @return String

     */

    public String getConnectionString() {

        return (String) this.getDynValue(CONNECTION_STRING_PARAMETER_NAME);

    }

    /**

     * @return String

     */

    public String getDefaultGeometryField() {

        return (String) this.getDynValue(DEFAULT_GEOMETRY_PARAMETER_NAME);

    }

    /**

     *

     * @return String

     */

    public IProjection getCRS() {

        return (IProjection) this.getDynValue(CRS_PARAMETER_NAME);

    }

    /**

     * @param file

     *            File

     */

    public void setFile(File file) {

        this.setDynValue(FILE_PARAMTER_NAME, file);

    }

    /**

     * @param layerName

     *            Name of layer

     */

    public void setLayerName(String layerName) {

        this.setDynValue(LAYER_NAME_PARAMTER_NAME, layerName);

    }

    /**

     * @param connectionString

     *            Connection string

     */

    public void setConnectionString(String connectionString) {

        this.setDynValue(CONNECTION_STRING_PARAMETER_NAME, connectionString);

    }

    /**

     * @param defaultGeoemtryField

     *            Name of defualt geometry field.

     */

    public void setDefaultGeometryField(String defaultGeoemtryField) {

        this.setDynValue(DEFAULT_GEOMETRY_PARAMETER_NAME, defaultGeoemtryField);

    }

    /**

     *

     * @param crs

     */

    public void setCRS(IProjection crs) {

        this.setDynValue(CRS_PARAMETER_NAME, crs);

    }

    @Override

    public boolean isValid() {

        if ((this.getFile() != null && this.getFile().exists())

            || StringUtils.isNotBlank(this.getConnectionString())) {

            return true;

        }

        return false;

    }

    @Override

    protected DelegatedDynObject getDelegatedDynObject() {

        return parameters;

    }

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright ? 2007-2016 gvSIG Association

 *

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

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

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

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

 *

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

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

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

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

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

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

 * MA  02110-1301, USA.

 *

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

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

 */

package org.gvsig.gdal.prov.ogr;

import java.util.ArrayList;

import java.util.List;

import org.gvsig.fmap.dal.DataParameters;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.DataStoreProvider;

import org.gvsig.fmap.dal.DataTypes;

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

import org.gvsig.fmap.dal.feature.spi.AbstractFeatureStoreProviderFactory;

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

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

import org.gvsig.tools.dynobject.DynObject;

/**

 * 

 * @author <a href="mailto:lmarques@disid.com">Lluis Marques</a>

 *

 */

public class BasicOGRDataStoreProviderFactory extends AbstractFeatureStoreProviderFactory implements

    OGRDataStoreProviderFactory {

    /**

     * @param name

     *            Name of factory

     * @param description

     *            Description of factory

     */

    public BasicOGRDataStoreProviderFactory(String name, String description) {

        super(name, description);

    }

    @Override

    public DataStoreProvider createProvider(DataParameters dataParameters,

        DataStoreProviderServices providerServices) throws InitializeException {

        return new OGRDataStoreProvider((DataStoreParameters) dataParameters, providerServices);

    }

    @Override

    public DynObject createParameters() {

        return new OGRDataStoreParameters();

    }

    public int allowMultipleGeometryTypes() {

        return UNKNOWN;

    }

    public int allowEditableFeatureType() {

        return UNKNOWN;

    }

    /**

     * See {@link OGRConverter#convertToDataType(int)} method. The list of data

     * type of OGR. If the list of OGR types changes update this method.

     */

    @SuppressWarnings("rawtypes")

    public List getSupportedDataTypes() {

        List<Integer> supportedDataTypes = new ArrayList<Integer>();

        supportedDataTypes.add(DataTypes.BOOLEAN);

        supportedDataTypes.add(DataTypes.DATE);

        supportedDataTypes.add(DataTypes.FLOAT);

        supportedDataTypes.add(DataTypes.DOUBLE);

        supportedDataTypes.add(DataTypes.STRING);

        supportedDataTypes.add(DataTypes.INT);

        supportedDataTypes.add(DataTypes.LONG);

        supportedDataTypes.add(DataTypes.TIME);

        return supportedDataTypes;

    }

    @SuppressWarnings("rawtypes")

    public List getSupportedGeometryTypesSubtypes() {

        List<Integer> supportedSubtypes = new ArrayList<Integer>();

        supportedSubtypes.add(SUBTYPES.GEOM2D);

        return supportedSubtypes;

    }

    public boolean allowsMandatoryAttributes() {

        return false;

    }

    public boolean allowsPrimaryKeyAttributes() {

        return false;

    }

    public int useLocalIndexesCanImprovePerformance() {

        return UNKNOWN;

    }

    @Override

    public DynObject createDataExplorerParameters(Object connectionString) {

        return new OGRDataExplorerParameters();

    }

    @Override

    public DynObject createParameters(Object connectionObject) {

        return createParameters();

    }

    @Override

    public String getDriver() {

        return null;

    }

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2016 gvSIG Association.

 *

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

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

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

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

 *

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

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

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

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

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

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

 * MA  02110-1301, USA.

 *

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

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

 */

package org.gvsig.gdal.prov.ogr;

import org.gvsig.fmap.dal.resource.spi.AbstractResourceParameters;

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.dataTypes.DataTypes;

import org.gvsig.tools.dynobject.DelegatedDynObject;

import org.gvsig.tools.dynobject.DynClass;

import org.gvsig.tools.persistence.PersistenceManager;

/**

 * 

 * @author <a href="mailto:lmarques@disid.com">Lluis Marques</a>

 *

 */

public class OGRResourceParameters extends AbstractResourceParameters {

    /**

     * 

     */

    public static final String DYNCLASS_NAME = "OGRResourceParameters";

    /**

     * 

     */

    private static final String DYNFIELDNAME_NAME = "name";

    /**

     * 

     */

    private static final String DYNFIELDNAME_CONNECTION_STRING = "connectionString";

    private DelegatedDynObject delegatedDynObject;

    /**

     * 

     */

    public OGRResourceParameters() {

        super();

        PersistenceManager manager = ToolsLocator.getPersistenceManager();

        DynClass definition = (DynClass) manager.getDefinition(DYNCLASS_NAME);

        this.delegatedDynObject =

            (DelegatedDynObject) ToolsLocator.getDynObjectManager().createDynObject(definition);

    }

    /**

     * 

     * @param connectionString

     *            Connection string

     */

    public OGRResourceParameters(String connectionString) {

        this();

        setDynValue(DYNFIELDNAME_NAME,

            String.valueOf(connectionString.hashCode()).concat("@OGResource"));

        setDynValue(DYNFIELDNAME_CONNECTION_STRING, connectionString);

    }

    /**

     * 

     * @param params

     *            Array with parameter values

     */

    public OGRResourceParameters(Object[] params) {

        this((String) params[0]);

    }

    @Override

    public String getTypeName() {

        return OGRResource.NAME;

    }

    @Override

    protected DelegatedDynObject getDelegatedDynObject() {

        return delegatedDynObject;

    }

    /**

     * @return String

     */

    public String getName() {

        return (String) this.getDynValue(DYNFIELDNAME_NAME);

    }

    /**

     * @return String

     */

    public String getConnectionString() {

        return (String) this.getDynValue(DYNFIELDNAME_CONNECTION_STRING);

    }

    protected static void registerPersistenceDefinition() {

        PersistenceManager manager = ToolsLocator.getPersistenceManager();

        DynClass definition = (DynClass) manager.getDefinition(DYNCLASS_NAME);

        if (definition == null) {

            definition = (DynClass) manager.addDefinition(OGRResourceParameters.class,

                DYNCLASS_NAME, DYNCLASS_NAME + " persistence definition", null, null);

            definition.addDynField(DYNFIELDNAME_NAME).setType(DataTypes.STRING)

                .setDescription("Name of resource");

            definition.addDynField(DYNFIELDNAME_CONNECTION_STRING).setType(DataTypes.STRING)

                .setDescription("Connection string");

        }

    }

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright ? 2007-2016 gvSIG Association

 *

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

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

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

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

 *

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

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

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

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

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

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

 * MA  02110-1301, USA.

 *

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

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

 */

package org.gvsig.gdal.prov.ogr;

import java.io.File;

import org.gvsig.fmap.dal.DataServerExplorerParameters;

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

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.dynobject.DelegatedDynObject;

/**

 * 

 * @author <a href="mailto:lmarques@disid.com">Lluis Marques</a>

 *

 */

public class OGRDataExplorerParameters extends AbstractDataParameters

    implements DataServerExplorerParameters {

    /**

     * 

     */

    public static final String PARAMETERS_DEFINITION_NAME = "OGRDataExplorerParameters";

    /**

     * 

     */

    public static final String FILE_PARAMETER_NAME = "file";

    /**

     * 

     */

    public static final String CONNECTION_STRING_PARAMETER_NAME = "connectionString";

    private DelegatedDynObject parameters;

    /**

     * 

     */

    public OGRDataExplorerParameters() {

        this.parameters = (DelegatedDynObject) ToolsLocator.getDynObjectManager().createDynObject(

            ToolsLocator.getPersistenceManager().getDefinition(PARAMETERS_DEFINITION_NAME));

    }

    @Override

    public String getExplorerName() {

        return OGRDataExplorer.NAME;

    }

    @Override

    protected DelegatedDynObject getDelegatedDynObject() {

        return this.parameters;

    }

    /**

     * 

     * @return File

     */

    public File getFile() {

        return (File) this.getDynValue(FILE_PARAMETER_NAME);

    }

    /**

     * 

     * @return String

     */

    public String getConnectionString() {

        return (String) this.getDynValue(CONNECTION_STRING_PARAMETER_NAME);

    }

    /**

     * 

     * @param file

     *            File

     */

    public void setFile(File file) {

        this.setDynValue(FILE_PARAMETER_NAME, file);

    }

    /**

     * 

     * @param connection

     *            Connection string

     */

    public void setConnectionString(String connection) {

        this.setDynValue(CONNECTION_STRING_PARAMETER_NAME, connection);

    }

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright ? 2007-2016 gvSIG Association

 *

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

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

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

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

 *

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

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

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

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

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

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

 * MA  02110-1301, USA.

 *

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

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

 */

package org.gvsig.gdal.prov.ogr;

import java.util.Map;

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

/**

 * 

 * @author <a href="mailto:lmarques@disid.com">Lluis Marques</a>

 *

 */

@SuppressWarnings("unchecked")

public class OGRUnsupportedFormatException extends DataException {

    private static final long serialVersionUID = -2670314598211236837L;

    private final static String MESSAGE =

        "Unsupported vectorial format. There are not any OGR driver registered to open %(connectionString)";

    private final static String KEY = "_UnsupportedVectorialFormatException";

    /**

     * @param messageFormat

     *            Message format

     * @param cause

     *            Cause

     * @param messageKey

     *            Message key

     * @param code

     *            code

     * @param values

     *            Values

     */

    public OGRUnsupportedFormatException(String messageFormat, Throwable cause, String messageKey,

        long code, Map<Object, Object> values) {

        super(messageFormat, cause, messageKey, code);

        this.values.putAll(values);

    }

    /**

     * @param messageFormat

     *            Message format

     * @param cause

     *            Cause

     * @param values

     *            Values

     */

    public OGRUnsupportedFormatException(String messageFormat, Throwable cause,

        Map<Object, Object> values) {

        super(messageFormat, cause, KEY, serialVersionUID);

        this.values.putAll(values);

    }

    /**

     * @param connectionString

     *            Conenction string

     */

    public OGRUnsupportedFormatException(String connectionString) {

        super(MESSAGE, KEY, serialVersionUID);

        this.values.put("connectionString", connectionString);

    }

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright ? 2007-2016 gvSIG Association

 *

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

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

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

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

 *

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

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

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

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

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

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

 * MA  02110-1301, USA.

 *

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

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

 */

package org.gvsig.gdal.prov.ogr;

import java.util.ArrayList;

import java.util.Iterator;

import java.util.List;

import org.apache.commons.lang3.StringUtils;

import org.gdal.ogr.DataSource;

import org.gdal.ogr.Feature;

import org.gdal.ogr.FeatureDefn;

import org.gdal.ogr.FieldDefn;

import org.gdal.ogr.GeomFieldDefn;

import org.gdal.ogr.Geometry;

import org.gdal.ogr.Layer;

import org.gdal.ogr.ogr;

import org.gdal.ogr.ogrConstants;

import org.gvsig.fmap.dal.DataStore;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.DataTypes;

import org.gvsig.fmap.dal.FileHelper;

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

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

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

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

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

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

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

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

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

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

import org.gvsig.fmap.dal.feature.spi.AbstractFeatureStoreProvider;

import org.gvsig.fmap.dal.feature.spi.DefaultFeatureProvider;

import org.gvsig.fmap.dal.feature.spi.FeatureProvider;

import org.gvsig.fmap.dal.feature.spi.FeatureReferenceProviderServices;

import org.gvsig.fmap.dal.feature.spi.FeatureSetProvider;

import org.gvsig.fmap.dal.feature.spi.FeatureStoreProvider;

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

import org.gvsig.fmap.dal.resource.file.FileResource;

import org.gvsig.fmap.dal.resource.spi.ResourceConsumer;

import org.gvsig.fmap.dal.resource.spi.ResourceProvider;

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

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

import org.gvsig.fmap.geom.GeometryLocator;

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

import org.gvsig.fmap.geom.type.GeometryTypeNotSupportedException;

import org.gvsig.fmap.geom.type.GeometryTypeNotValidException;

import org.gvsig.tools.dynobject.DynObject;

import org.gvsig.tools.evaluator.Evaluator;

import org.gvsig.tools.exception.BaseException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 *

 * @author <a href="mailto:lmarques@disid.com">Lluis Marques</a>

 *

 */

public class OGRDataStoreProvider extends AbstractFeatureStoreProvider implements

    FeatureStoreProvider, ResourceConsumer {

    private static final Logger LOG = LoggerFactory.getLogger(OGRDataStoreProvider.class);

    /**

     *

     */

    public static final String METADATA_DEFINITION_NAME = "OGRDataStoreProvider";

    /**

     *

     */

    public static final String NAME = "OGRDataStoreProvider";

    /**

     *

     */

    public static final String DESCRIPTION = "OGR provider to open vectorial resources";

    protected DataSource dataSource;

    private Envelope envelope;

    private Layer newLayer;

    protected ResourceProvider resourceProvider;

    private Boolean updateSupport;

    private boolean opened = false;

    protected OGRDataStoreProvider(DataStoreParameters dataParameters,

        DataStoreProviderServices storeServices, DynObject metadata) throws InitializeException {

        super(dataParameters, storeServices, metadata);

        // Set CRS parameter to metadata

        this.setDynValue(DataStore.METADATA_CRS, dataParameters.getDynValue(DataStore.METADATA_CRS));

        getResource().addConsumer(this);

        try {

            this.open();

        } catch (OpenException e) {

            throw new InitializeException(NAME, e);

        }

    }

    protected OGRDataStoreProvider(DataStoreParameters dataParameters,

        DataStoreProviderServices storeServices) throws InitializeException {

        this(dataParameters, storeServices, FileHelper

            .newMetadataContainer(METADATA_DEFINITION_NAME));

    }

    /*

     * Lazy initialization of data source

     */

    protected synchronized DataSource getDataSource() throws OGRUnsupportedFormatException {

        if (this.dataSource == null) {

            // Prioritize connection string over file

            if (StringUtils.isNotBlank(getOGRParameters().getConnectionString())) {

                // Trying to open in update mode

                this.dataSource = ogr.Open(getOGRParameters().getConnectionString(), 1);

                if (this.dataSource == null) {

                    this.dataSource = ogr.Open(getOGRParameters().getConnectionString());

                    updateSupport = false;

                } else {

                    updateSupport = true;

                }

            } else if (getOGRParameters().getFile() != null