Application: gvSIG desktop

org.gvsig.fmap.dal.store.mdb.MdbLibrary

<?xml version="1.0"?>

<definitions>

  <version>1.0.0</version>

  <classes>

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

      <extends>

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

      </extends>

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

      <fields>

      </fields>

    </class>

  </classes>

</definitions>  

<?xml version="1.0"?>

<definitions>

  <version>1.0.0</version>

  <classes>

    <class name="H2SpatialResourceParameters">

      <extends>

        <class>JDBC2ResourceParameters</class>

      </extends>

      <fields>

        <field name="JDBCDriverClass" type="string" mandatory="true"

          defaultValue="org.h2.Driver" group="Advanced">

          <description>JDBC Driver class</description>

        </field>

		<field name="port" type="integer" mandatory="false"

          defaultValue="9123" group="Connection">

          <description></description>

        </field>

        <field name="database_file" label="Database file" type="file" mandatory="true" defaultValue="" group="Basic">        

          <description></description>

        </field>   

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

          defaultValue="false" group="Basic">

          <description>Use SSL connetion</description>

        </field>

        <field name="dbuser" type="string" mandatory="false" group="Basic" defaultValue="SA" >

          <description></description>

        </field>

      </fields>

    </class>

    <class name="H2SpatialStoreParameters">

      <extends>

        <class>JDBC2StoreParameters</class>

        <class>H2SpatialResourceParameters</class>

      </extends>

      <fields/>

    </class>

    <class name="H2SpatialNewStoreParameters">

      <extends>

        <class>JDBC2NewStoreParameters</class>

        <class>H2SpatialResourceParameters</class>

      </extends>

      <fields/>

    </class>

    <class name="H2SpatialServerExplorerParameters">

      <extends>

        <class>H2SpatialResourceParameters</class>

        <class>JDBC2ServerExplorerParameters</class>

      </extends>

      <fields/>

    </class>

  </classes>

</definitions>  

package org.gvsig.fmap.dal.store.mdb;

import org.gvsig.fmap.dal.DataServerExplorerParameters;

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

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

import org.gvsig.fmap.dal.store.jdbc.JDBCConnectionParameters;

import org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorerParameters;

import org.gvsig.fmap.dal.store.jdbc2.JDBCHelper;

import org.gvsig.fmap.dal.store.jdbc2.JDBCServerExplorer;

import org.gvsig.fmap.dal.store.jdbc2.impl.JDBCServerExplorerFactory;

public class MdbExplorerFactory extends JDBCServerExplorerFactory {

    public MdbExplorerFactory() {

        super(

                MdbLibrary.NAME,

                "Mdb"

        );

    }

    @Override

    public JDBCServerExplorer create(

            DataServerExplorerParameters parameters, 

            DataServerExplorerProviderServices providerServices

        ) throws InitializeException {

        JDBCHelper helper = new MdbHelper((JDBCConnectionParameters) parameters);

        JDBCServerExplorer server = helper.createServerExplorer(

                (JDBCServerExplorerParameters) parameters, 

                providerServices

        );

        return server;

    }

    @Override

    public JDBCServerExplorerParameters createParameters() {

        JDBCServerExplorerParameters params = new MdbExplorerParameters();

        return params;    

    }

}

/* 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.store.mdb;

import java.io.File;

import java.util.Properties;

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

import org.gvsig.fmap.dal.store.jdbc.JDBCNewStoreParameters;

public class MdbNewStoreParameters 

    extends 

        JDBCNewStoreParameters 

    implements 

        MdbConnectionParameters 

    {

    private final MdbConnectionParametersHelper helper;

    public MdbNewStoreParameters() {

        super(

            MdbLibrary.NAME + "NewStoreParameters", 

            MdbLibrary.NAME

        );

        this.helper = new MdbConnectionParametersHelper(this);

    }

    @Override

    public String getUrl() {

        return this.helper.getUrl();

    }

    @Override

    public void validate() throws ValidateDataParametersException {

        this.helper.validate();

    }

    @Override

    public Properties getProperties() {

        return this.helper.getProperties();

    }

    @Override

    public File getFile() {

        return this.helper.getFile();

    }

    @Override

    public void setFile(File database) {

        this.helper.setFile(database);

    }

}

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2016 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 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.

 *

 */

package org.gvsig.fmap.dal.store.mdb;

import java.sql.Connection;

import java.sql.SQLException;

import java.text.MessageFormat;

import org.apache.commons.dbcp.BasicDataSource;

import org.apache.commons.io.FilenameUtils;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.fmap.dal.SQLBuilder;

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

import org.gvsig.fmap.dal.store.mdb.operations.MdbOperationsFactory;

import org.gvsig.fmap.dal.store.jdbc.JDBCConnectionParameters;

import org.gvsig.fmap.dal.store.jdbc.JDBCNewStoreParameters;

import org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorerParameters;

import org.gvsig.fmap.dal.store.jdbc.JDBCStoreParameters;

import org.gvsig.fmap.dal.store.jdbc.exception.JDBCDriverClassNotFoundException;

import org.gvsig.fmap.dal.store.jdbc2.OperationsFactory;

import org.gvsig.fmap.dal.store.jdbc2.spi.JDBCHelperBase;

import org.gvsig.fmap.dal.store.jdbc2.spi.JDBCSQLBuilderBase;

import org.gvsig.fmap.dal.store.jdbc2.spi.SRSSolverBase;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class MdbHelper extends JDBCHelperBase {

    static final Logger logger = LoggerFactory.getLogger(MdbHelper.class);

    public static final String MdbJDBCDriver = "org.h2.Driver";

    public static String getConnectionURL(MdbConnectionParameters params) {

        String connectionURL;

        if( StringUtils.isEmpty(params.getHost()) ) {

            // Asumimos que es una conexion directa sobre el filesystem

            String dbname = params.getFile().getAbsolutePath().replace("\\","/");

            if( StringUtils.equalsIgnoreCase(FilenameUtils.getExtension(params.getFile().getName()),"zip") ) {

                connectionURL =  MessageFormat.format(

                    "jdbc:h2:zip:{0}!/{1};MODE=PostgreSQL",

                    dbname,

                    params.getDBName()

                );

            } else {

                if( dbname.endsWith(".mv.db") ) {

                    dbname = dbname.substring(0, dbname.length()-6);

                }

                connectionURL =  MessageFormat.format(

                    "jdbc:h2:file:{0};MODE=PostgreSQL",

                    dbname

                );

            }

        } else if( params.getPort() == null ) {

            connectionURL =  MessageFormat.format(

                "jdbc:h2:tcp://{0}/{1};MODE=PostgreSQL",

                params.getHost(),

                params.getDBName()

            );            

        } else {

            connectionURL =  MessageFormat.format(

                "jdbc:h2:tcp://{0}:{1,number,#######}/{2};MODE=PostgreSQL",

                params.getHost(),

                params.getPort().intValue(),

                params.getDBName()

            );

        }

        logger.debug("connectionURL: {}", connectionURL);

        return connectionURL;

    }

    private static class ConnectionProvider {

        private static boolean needRegisterDriver = true;

        private BasicDataSource dataSource = null;

        private final MdbConnectionParameters connectionParameters;

        public ConnectionProvider(MdbConnectionParameters connectionParameters) {

            this.connectionParameters = connectionParameters;

        }

        @Override

        public String toString() {

            StringBuilder builder = new StringBuilder();

            builder.append(" url=").append(connectionParameters.getUrl());

            builder.append(" driver name=").append(connectionParameters.getJDBCDriverClassName());

            builder.append(" user=").append(connectionParameters.getUser());

            return builder.toString();

        }

        public Connection getConnection() throws SQLException {

            if (this.dataSource == null) {

                this.dataSource = this.createDataSource();               

            }

            Connection conn = this.dataSource.getConnection();

            try {

                conn.createStatement().execute("SELECT TOP 1 SRID FROM SPATIAL_REF_SYS");

            } catch(SQLException ex) {

                H2GISExtension.load(conn);

            }

            return conn;

        }

        private BasicDataSource createDataSource() throws SQLException {

            if (!this.isRegistered()) {

                this.registerDriver();

            }

            MdbConnectionParameters params = connectionParameters;

            BasicDataSource ds = new BasicDataSource();

            ds.setDriverClassName(params.getJDBCDriverClassName());

            if( !StringUtils.isEmpty(params.getUser()) ) {

                ds.setUsername(params.getUser());

            }

            if( !StringUtils.isEmpty(params.getPassword()) ) {

                ds.setPassword(params.getPassword());

            }

            ds.setUrl(params.getUrl());

            ds.setMaxWait(60L * 1000);

            return ds;

        }

        private boolean isRegistered() {

            return needRegisterDriver;

        }

        public void registerDriver() throws SQLException {

            String className = this.connectionParameters.getJDBCDriverClassName();

            if (className == null) {

                return;

            }

            try {

                Class theClass = Class.forName(className);

                if (theClass == null) {

                    throw new JDBCDriverClassNotFoundException(MdbLibrary.NAME, className);

                }

            } catch (Exception e) {

                throw new SQLException("Can't register JDBC driver '" + className + "'.", e);

            }

            needRegisterDriver = false;

        }

    }

//    private static class ConnectionProvider {

//

//        private static boolean needRegisterDriver = true;

//

//

//        private final MdbConnectionParameters connectionParameters;

//

//        public ConnectionProvider(MdbConnectionParameters connectionParameters) {

//            this.connectionParameters = connectionParameters;

//        }

//

//        public Connection getConnection() throws SQLException {

//            if (!this.isRegistered()) {

//                this.registerDriver();

//            }

//            Connection conn;

//            if( !StringUtils.isEmpty(connectionParameters.getUser()) ) {

//                conn = DriverManager.getConnection(

//                    connectionParameters.getUrl(),

//                    connectionParameters.getUser(),

//                    connectionParameters.getPassword()

//                );

//            } else {

//                conn = DriverManager.getConnection(connectionParameters.getUrl());

//            }

//            try {

//                conn.createStatement().execute("SELECT TOP 1 SRID FROM SPATIAL_REF_SYS");

//            } catch(SQLException ex) {

//                H2GISExtension.load(conn);

//            }

//            return conn;

//        }

//

//        private boolean isRegistered() {

//            return needRegisterDriver;

//        }

//

//        public void registerDriver() throws SQLException {

//            String className = this.connectionParameters.getJDBCDriverClassName();

//            if (className == null) {

//                return;

//            }

//            try {

//                Class theClass = Class.forName(className);

//                if (theClass == null) {

//                    throw new JDBCDriverClassNotFoundException(MdbLibrary.NAME, className);

//                }

//            } catch (Exception e) {

//                throw new SQLException("Can't register JDBC driver '" + className + "'.", e);

//            }

//            needRegisterDriver = false;

//        }

//

//    }

    private ConnectionProvider connectionProvider = null;

    public MdbHelper(JDBCConnectionParameters connectionParameters) {

        super(connectionParameters);

        this.srssolver = new SRSSolverBase(this);

    }

    @Override

    public synchronized Connection  getConnection() throws AccessResourceException {

        try {

            if (this.connectionProvider == null) {

                this.connectionProvider = new ConnectionProvider(this.getConnectionParameters());

            }

            Connection connection = this.connectionProvider.getConnection();

            if( logger.isDebugEnabled() ) {

                logger.debug("getConnection: connection = "+connection.hashCode()+ connectionProvider.toString());

            }

            return connection;

        } catch (SQLException ex) {

            throw new AccessResourceException(MdbLibrary.NAME, ex);

        }

    }

    @Override

    public void closeConnection(Connection connection) {

        logger.debug("closeConnection: connection = "+connection.hashCode());

        super.closeConnection(connection);

    }

    @Override

    public MdbConnectionParameters getConnectionParameters() {

        return (MdbConnectionParameters) super.getConnectionParameters();

    }

    @Override

    public String getConnectionURL() {

        return getConnectionURL(this.getConnectionParameters());

    }

    @Override

    protected String getResourceType() {

        return MdbLibrary.NAME;

    }

    @Override

    public String getProviderName() {

        return MdbLibrary.NAME;

    }

    @Override

    public JDBCSQLBuilderBase createSQLBuilder() {

        return new MdbSQLBuilder(this);

    }

    @Override

    public OperationsFactory getOperations() {

        if (this.operationsFactory == null) {

            this.operationsFactory = new MdbOperationsFactory(this);

        }

        return operationsFactory;

    }

    @Override

    public SQLBuilder.GeometrySupportType getGeometrySupportType() {

        return SQLBuilder.GeometrySupportType.WKB;

    }

    @Override

    public boolean hasSpatialFunctions() {

        return true;

    }

    @Override

    public boolean canWriteGeometry(int geometryType, int geometrySubtype) {

        return true;

    }

    @Override

    public String getQuoteForIdentifiers() {

        return "\"";

    }

    @Override

    public boolean allowAutomaticValues() {

        return true;

    }

    @Override

    public boolean supportOffsetInSelect() {

        return true;

    }

    @Override

    public String getQuoteForStrings() {

        return "'";

    }

    @Override

    public String getSourceId(JDBCStoreParameters parameters) {

        return parameters.getDBName() + "." + 

               parameters.getSchema()+ "." + 

               parameters.getTable();

    }

    @Override

    public JDBCNewStoreParameters createNewStoreParameters() {

        return new MdbNewStoreParameters();

    }

    @Override

    public JDBCStoreParameters createOpenStoreParameters() {

        return new MdbStoreParameters();

    }

    @Override

    public JDBCServerExplorerParameters createServerExplorerParameters() {

        return new MdbExplorerParameters();

    }

}

package org.gvsig.fmap.dal.store.mdb;

import org.gvsig.fmap.dal.DataParameters;

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

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

import org.gvsig.fmap.dal.store.jdbc.JDBCConnectionParameters;

import org.gvsig.fmap.dal.store.jdbc.JDBCStoreParameters;

import org.gvsig.fmap.dal.store.jdbc2.JDBCHelper;

import org.gvsig.fmap.dal.store.jdbc2.JDBCStoreProvider;

import org.gvsig.fmap.dal.store.jdbc2.impl.JDBCStoreProviderFactory;

public class MdbStoreProviderFactory extends JDBCStoreProviderFactory {

    private static final String NAME = MdbLibrary.NAME;

    public MdbStoreProviderFactory() {

        super(

                NAME, 

                "Mdb store"

        );

    }

    @Override

    public JDBCStoreProvider createProvider(

            DataParameters parameters,

            DataStoreProviderServices providerServices

    ) throws InitializeException {

        JDBCHelper helper = new MdbHelper((JDBCConnectionParameters) parameters);

        JDBCStoreProvider provider = helper.createProvider(

                (JDBCStoreParameters) parameters, 

                providerServices

        );

        return provider;

    }

    @Override

    public JDBCStoreParameters createParameters() {

        JDBCStoreParameters params = new MdbStoreParameters();

        return params;

    }

}

/* 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.store.mdb;

import java.io.File;

import java.util.Properties;

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

import org.gvsig.fmap.dal.store.jdbc.JDBCStoreParameters;

public class MdbStoreParameters extends JDBCStoreParameters implements MdbConnectionParameters {

    private final MdbConnectionParametersHelper helper;

    public MdbStoreParameters() {

        super(

                MdbLibrary.NAME + "StoreParameters",

                MdbLibrary.NAME

        );

        this.helper = new MdbConnectionParametersHelper(this);

    }

    @Override

    public String getUrl() {

        return this.helper.getUrl();

    }

    @Override

    public void validate() throws ValidateDataParametersException {

        this.helper.validate();

        super.validate();

    }

    @Override

    public Properties getProperties() {

        return this.helper.getProperties();

    }

    @Override

    public File getFile() {

        return this.helper.getFile();

    }

    @Override

    public void setFile(File database) {

        this.helper.setFile(database);

    }

}

package org.gvsig.fmap.dal.store.mdb.operations;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.List;

import org.gvsig.fmap.dal.store.jdbc.JDBCStoreParameters;

import org.gvsig.fmap.dal.store.jdbc2.JDBCHelper;

import org.gvsig.fmap.dal.store.jdbc2.JDBCUtils;

import org.gvsig.fmap.dal.store.jdbc2.spi.operations.ListTablesOperation;

public class MdbListTablesOperation extends ListTablesOperation {

    public MdbListTablesOperation(JDBCHelper helper, int mode, JDBCStoreParameters baseParameters, boolean informationTables) {

        super(helper, mode, baseParameters, informationTables);

    }

    @Override

    public List<JDBCStoreParameters> listTables(

            Connection conn,

            int mode,

            JDBCStoreParameters baseParameters,

            boolean informationTables

    ) {

        ResultSet rs = null;

        List<JDBCStoreParameters> tables = new ArrayList<>();

        try {

            String sql = "SELECT TABLE_CATALOG, TABLE_SCHEMA, TABLE_NAME FROM INFORMATION_SCHEMA.TABLES where table_type in ('TABLE','VIEW','EXTERNAL')";

            rs = conn.createStatement().executeQuery(sql);

            while (rs.next()) {

                JDBCStoreParameters params = baseParameters.getCopy();

                params.setCatalog(rs.getString("TABLE_CATALOG"));

                params.setSchema(rs.getString("TABLE_SCHEMA"));

                params.setTable(rs.getString("TABLE_NAME"));

                tables.add(params);

            }

            return tables;

        } catch (SQLException ex) {

            throw new RuntimeException("Can't fetch tables information",ex);

        } finally {

            JDBCUtils.closeQuietly(rs);

        }

    }

}

package org.gvsig.fmap.dal.store.mdb.operations;

import java.sql.PreparedStatement;

import java.sql.SQLException;

import org.gvsig.fmap.dal.DataTypes;

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

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

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

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

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

import org.gvsig.fmap.dal.store.jdbc.exception.JDBCPreparingSQLException;

import org.gvsig.fmap.dal.store.jdbc2.JDBCHelper;

import org.gvsig.fmap.dal.store.jdbc2.JDBCUtils;

import org.gvsig.fmap.dal.store.jdbc2.spi.operations.AppendOperation;

import org.gvsig.tools.dispose.Disposable;

import org.gvsig.tools.dispose.DisposeUtils;

public class MdbAppendOperation extends AppendOperation {

    public MdbAppendOperation(

            JDBCHelper helper, 

            String database,

            String schema, 

            String table, 

            FeatureType type

        ) {

        super(helper, database, schema, table, type);

    }

    @Override

    public void begin() throws DataException {

        if (this.sqlbuilder != null) {

            throw new AlreadyEditingException(this.helper.getSourceId());

        }

        try {

            this.connection = this.helper.getConnectionWritable();

            this.sqlbuilder = this.helper.createSQLBuilder();

            this.sqlbuilder.insert().table().database(this.database).schema(this.schema).name(this.table);

            for (FeatureAttributeDescriptor attr : type) {

                if( attr.isAutomatic() ) {

                    continue;

                }

                if (attr.getType() == DataTypes.GEOMETRY) {

                    this.sqlbuilder.insert().column().name(attr.getName()).with_value( 

                        sqlbuilder.parameter(attr.getName()).as_geometry_variable().srs( 

                                sqlbuilder.parameter().value(attr.getSRS()) 

                        ) 

                    );

                } else {

                    this.sqlbuilder.insert().column().name(attr.getName()).with_value(

                        sqlbuilder.parameter(attr.getName()).as_variable()

                    );

                }

            }

            PreparedStatement st;

            this.sql = this.sqlbuilder.insert().toString();

            this.preparedStatement = this.connection.prepareStatement(sql);

            this.connection.setAutoCommit(false);

            JDBCUtils.execute(this.connection, "SET LOG 1");

            JDBCUtils.execute(this.connection, "SET LOCK_MODE 1");

            JDBCUtils.execute(this.connection, "SET UNDO_LOG 0");

        } catch (SQLException ex) {

            throw new JDBCPreparingSQLException(this.sqlbuilder.toString(),ex);

        }

    }

    @Override

    protected void clean() {

        JDBCUtils.closeQuietly(this.preparedStatement);

        this.helper.closeConnection(this.connection);

        this.connection = null;

        this.preparedStatement = null;

        this.sqlbuilder = null;

        this.sql = null;        

    }

    @Override

    public void end() {

        try {

            this.connection.commit();

            JDBCUtils.execute(this.connection, "SET LOG 2");

            JDBCUtils.execute(this.connection, "SET LOCK_MODE 3");

            JDBCUtils.execute(this.connection, "SET UNDO_LOG 1");

        } catch (SQLException ex) {

            try {

                this.connection.rollback();

            } catch (SQLException ex1) {

            }

            throw new RuntimeException("Can't commit transaction", ex);

        } finally {

            clean();

        }

    }

    @Override

    public void abort() {        

        try {

            this.connection.rollback();

            JDBCUtils.execute(this.connection, "SET LOG 2");

            JDBCUtils.execute(this.connection, "SET LOCK_MODE 3");

            JDBCUtils.execute(this.connection, "SET UNDO_LOG 1");

        } catch (SQLException ex) {

        }

        clean();

    }

    @Override

    public void append(FeatureProvider feature) throws DataException {

        int n;

        Disposable paramsDisposer = null;

        try {

            paramsDisposer = this.sqlbuilder.setParameters(this.preparedStatement, feature);

            n = JDBCUtils.executeUpdate(this.preparedStatement,this.sql);

        } catch(Exception ex) {

            throw new RuntimeException("Can't insert feature.", ex);

        } finally {

            DisposeUtils.disposeQuietly(paramsDisposer);

        }

        if( n<1 ) {

            throw new RuntimeException("Can't insert feature (n="+n+").");

        }

    }

}

package org.gvsig.fmap.dal.store.mdb.operations;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.ResultSetMetaData;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import org.apache.commons.lang3.StringUtils;

import org.cresques.cts.IProjection;

import org.gvsig.fmap.dal.DataTypes;

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

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

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

import org.gvsig.fmap.dal.store.jdbc2.JDBCHelper;

import org.gvsig.fmap.dal.store.jdbc2.JDBCUtils;

import org.gvsig.fmap.dal.store.jdbc2.spi.SRSSolver;

import org.gvsig.fmap.dal.store.jdbc2.spi.operations.FetchFeatureTypeOperation;

import org.gvsig.fmap.geom.Geometry;

import org.gvsig.fmap.geom.GeometryLocator;

import org.gvsig.fmap.geom.GeometryManager;

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

public class MdbFetchFeatureTypeOperation extends FetchFeatureTypeOperation {

    private static Map<String,GeometryType>h2spatialGeometryTypes = null;

    private Map<String,GeometryColumnInfo> geometry_column;

    private static class GeometryColumnInfo {

        public String columnName;

        public int geometryType;

        public String geometryTypeName;

        public int dimensions;

        public int srid;

        public GeometryColumnInfo(String columnName, int geometryType, String geometryTypeName, int dimensions, int srid) {

            this.columnName = columnName;

            this.geometryType = geometryType;

            this.geometryTypeName = geometryTypeName;

            this.dimensions = dimensions;

            this.srid = srid;

        }

    }

    public MdbFetchFeatureTypeOperation(

            JDBCHelper helper

        ) {

        super(helper);

    }

    private GeometryType getGT(

            GeometryManager manager, 

            int type, 

            int subtype

        ) {

        try {

            return manager.getGeometryType(type, subtype);

        } catch (Exception ex) {

            return null;

        }

    }

    public MdbFetchFeatureTypeOperation(

            JDBCHelper helper,

            EditableFeatureType featureType,

            String dbname,

            String schema,

            String table,

            List<String> primaryKeys,

            String defaultGeometryColumn,

            IProjection crs

        ) {

        super(helper, featureType, dbname, schema, table, primaryKeys, defaultGeometryColumn, crs);

    }            

    @Override

    public void fetch(EditableFeatureType featureType, Connection conn, String dbname, String schema, String table, List<String> pks, String defaultGeometryColumn, IProjection crs) throws DataException {

        geometry_column = new HashMap<>();

        try {

            //

            // https://github.com/orbisgis/h2gis/wiki/1.-Spatial-data#geometry-columns-view

            //

            StringBuilder where = null;

            if( !StringUtils.isEmpty(dbname) ) {

                if( where == null ) {

                    where = new StringBuilder();

                } else {

                    where.append(" AND ");

                }

                where.append("UPPER(F_TABLE_CATALOG) = '");

                where.append(dbname.toUpperCase());

                where.append("'");

            }

            if( !StringUtils.isEmpty(schema) ) {

                if( where == null ) {

                    where = new StringBuilder();

                } else {

                    where.append(" AND ");

                }

                where.append("UPPER(F_TABLE_SCHEMA) = '");

                where.append(schema.toUpperCase());

                where.append("'");

            }

            if( !StringUtils.isEmpty(table) ) {

                if( where == null ) {

                    where = new StringBuilder();

                } else {

                    where.append(" AND ");

                }

                where.append("UPPER(F_TABLE_NAME) = '");

                where.append(table.toUpperCase());

                where.append("'");

            }            

            String sql = "SELECT F_GEOMETRY_COLUMN, GEOMETRY_TYPE, COORD_DIMENSION, SRID, TYPE FROM GEOMETRY_COLUMNS WHERE " + where;

            Statement st = this.getConnection().createStatement();

            ResultSet rs = JDBCUtils.executeQuery(st,sql);

            while( rs.next() ) {

                geometry_column.put(

                    rs.getString("F_GEOMETRY_COLUMN"), 

                    new GeometryColumnInfo(

                        rs.getString("F_GEOMETRY_COLUMN"), 

                        rs.getInt("GEOMETRY_TYPE"), 

                        rs.getString("TYPE"), 

                        rs.getInt("COORD_DIMENSION"), 

                        rs.getInt("SRID")

                    )

                );

            }

        } catch (SQLException ex) {

            logger.warn("Can't read metadata from table '"+table+"'.",ex);

        }

        super.fetch(featureType, conn, dbname, schema, table, pks, defaultGeometryColumn, crs);

    }

    @Override

    protected void fetchGeometryTypeAndSRS(

            EditableFeatureAttributeDescriptor attr,

            ResultSetMetaData rsMetadata,

            int colIndex

        ) {

        try {

            if( attr.getType()==DataTypes.GEOMETRY ) {

                GeometryColumnInfo column_info = this.geometry_column.get(attr.getName());

                String type = "GEOMETRY";

                if( column_info!=null ) {

                    // H2GIS solo soporte 2D y 3D no soporta Ms

                    if( column_info.dimensions==3 ) {

                        type = column_info.geometryTypeName+"Z";

                    } else {

                        type = column_info.geometryTypeName;

                    }

                    SRSSolver solver = this.helper.getSRSSolver();

                    attr.setSRS(

                        solver.getProjection(getConnection(), column_info.srid)

                    );

                }

                GeometryType gt = getGeometryTypeFromMdbType(type);

                if( gt != null ) {

                    attr.setGeometryType(gt);

                }

            }

        } catch(Exception ex) {

            throw new RuntimeException("Can't fetch geometry type and SRS.", ex);

        }

    }

    private GeometryType getGeometryTypeFromMdbType(String typeName) {

        if( h2spatialGeometryTypes==null ) {

            //

            // https://github.com/orbisgis/h2gis/wiki/1.-Spatial-data#geometry-columns-view

            //

            GeometryManager manager = GeometryLocator.getGeometryManager();

            h2spatialGeometryTypes = new HashMap<>();

            h2spatialGeometryTypes.put("POINT", getGT(manager, Geometry.TYPES.POINT,Geometry.SUBTYPES.GEOM2D));

            h2spatialGeometryTypes.put("POINTZ", getGT(manager, Geometry.TYPES.POINT,Geometry.SUBTYPES.GEOM3D));

            h2spatialGeometryTypes.put("LINESTRING", getGT(manager, Geometry.TYPES.LINE,Geometry.SUBTYPES.GEOM2D));

            h2spatialGeometryTypes.put("LINESTRINGZ", getGT(manager, Geometry.TYPES.LINE,Geometry.SUBTYPES.GEOM3D));

            h2spatialGeometryTypes.put("POLYGON", getGT(manager, Geometry.TYPES.POLYGON,Geometry.SUBTYPES.GEOM2D));

            h2spatialGeometryTypes.put("POLYGONZ", getGT(manager, Geometry.TYPES.POLYGON,Geometry.SUBTYPES.GEOM3D));

            h2spatialGeometryTypes.put("MULTIPOINT", getGT(manager, Geometry.TYPES.MULTIPOINT,Geometry.SUBTYPES.GEOM2D));

            h2spatialGeometryTypes.put("MULTIPOINTZ", getGT(manager, Geometry.TYPES.MULTIPOINT,Geometry.SUBTYPES.GEOM3D));

            h2spatialGeometryTypes.put("MULTILINESTRING", getGT(manager, Geometry.TYPES.MULTILINE,Geometry.SUBTYPES.GEOM2D));

            h2spatialGeometryTypes.put("MULTILINESTRINGZ", getGT(manager, Geometry.TYPES.MULTILINE,Geometry.SUBTYPES.GEOM3D));

            h2spatialGeometryTypes.put("MULTIPOLYGON", getGT(manager, Geometry.TYPES.MULTIPOLYGON,Geometry.SUBTYPES.GEOM2D));

            h2spatialGeometryTypes.put("MULTIPOLYGONZ", getGT(manager, Geometry.TYPES.MULTIPOLYGON,Geometry.SUBTYPES.GEOM3D));

            h2spatialGeometryTypes.put("GEOMETRY", getGT(manager, Geometry.TYPES.GEOMETRY,Geometry.SUBTYPES.GEOM2D));

            h2spatialGeometryTypes.put("GEOMETRYZ", getGT(manager, Geometry.TYPES.GEOMETRY,Geometry.SUBTYPES.GEOM3D));

            h2spatialGeometryTypes.put("GEOMCOLLECTION", getGT(manager, Geometry.TYPES.GEOMETRY,Geometry.SUBTYPES.GEOM2D));

            h2spatialGeometryTypes.put("GEOMCOLLECTIONZ", getGT(manager, Geometry.TYPES.GEOMETRY,Geometry.SUBTYPES.GEOM3D));

        }

        return h2spatialGeometryTypes.get(typeName);

    }

}

package org.gvsig.fmap.dal.store.mdb.operations;

import java.util.List;

import org.cresques.cts.IProjection;

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

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

import org.gvsig.fmap.dal.store.jdbc.JDBCStoreParameters;

import org.gvsig.fmap.dal.store.jdbc2.JDBCHelper;

import org.gvsig.fmap.dal.store.jdbc2.spi.operations.AppendOperation;

import org.gvsig.fmap.dal.store.jdbc2.spi.operations.FetchFeatureTypeOperation;

import org.gvsig.fmap.dal.store.jdbc2.spi.operations.ListTablesOperation;

import org.gvsig.fmap.dal.store.jdbc2.spi.operations.OperationsFactoryBase;

public class MdbOperationsFactory extends OperationsFactoryBase {

    public MdbOperationsFactory(JDBCHelper helper) {

        super(helper);

    }

    @Override

    public FetchFeatureTypeOperation createFetchFeatureType(EditableFeatureType type, String database, String schema, String table, List<String> primaryKeys, String defaultGeometryField, IProjection crs) {

        return new MdbFetchFeatureTypeOperation(

                helper, type, database, schema, table, primaryKeys, 

                defaultGeometryField, crs

        );

    }  

    @Override

    public ListTablesOperation createListTables(int mode, JDBCStoreParameters baseParameters, boolean informationTables) {

        return new MdbListTablesOperation(helper, mode, baseParameters, informationTables);

    }

    @Override

    public AppendOperation createAppend(String database, String schema, String table, FeatureType type) {

        return new MdbAppendOperation(helper, database, schema, table, type);

    }

}

package org.gvsig.fmap.dal.store.mdb;

import java.util.Properties;

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

import org.gvsig.fmap.dal.store.jdbc.JDBCConnectionParameters;

public interface MdbConnectionParameters extends JDBCConnectionParameters, FilesystemStoreParameters {

    public Properties getProperties();

}

package org.gvsig.fmap.dal.store.mdb;

import java.io.File;

import java.util.Properties;

import org.apache.commons.io.FilenameUtils;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.fmap.dal.DataParameters;

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

import org.gvsig.fmap.dal.resource.db.DBParameters;

import org.gvsig.fmap.dal.store.jdbc.JDBCConnectionParameters;

public class MdbConnectionParametersHelper {

    private final JDBCConnectionParameters parameters;

    private static final String DATABASE_FILE = "database_file";

    public MdbConnectionParametersHelper(JDBCConnectionParameters parameters) {

        this.parameters = parameters;

    }

    public String getUrl() {

        String url = (String) this.getDynValue(JDBCConnectionParameters.URL_PARAMTER_NAME);

        if( StringUtils.isEmpty(url) ) {

            url = MdbHelper.getConnectionURL((MdbConnectionParameters) this.parameters);

            this.setDynValue(JDBCConnectionParameters.URL_PARAMTER_NAME, url);

        }

        return url;

    }

    public void validate() throws ValidateDataParametersException {

        if( this.getDynValue(JDBCConnectionParameters.JDBC_DRIVER_CLASS_PARAMTER_NAME) == null ) {

            this.setDynValue(

                JDBCConnectionParameters.JDBC_DRIVER_CLASS_PARAMTER_NAME,

                MdbHelper.MdbJDBCDriver

            );

        }

        if( getFile() == null ) {

            if( this.getDynValue(JDBCConnectionParameters.DBNAME_PARAMTER_NAME) == null ) {

                throw new ValidateDataParametersException();

            } else {

                setFile(new File((String) this.getDynValue(JDBCConnectionParameters.DBNAME_PARAMTER_NAME)));

            }

        } else {

            String dbName = (String) this.getDynValue(JDBCConnectionParameters.DBNAME_PARAMTER_NAME);

            if( StringUtils.isEmpty(dbName) ) {

                dbName = getDbNameFromFile(getFile());

                this.setDynValue(

                    JDBCConnectionParameters.DBNAME_PARAMTER_NAME,

                    dbName.toUpperCase()

                );

            }

        }

        if( this.getDynValue(JDBCConnectionParameters.URL_PARAMTER_NAME) == null ) {

            String url = MdbHelper.getConnectionURL((MdbConnectionParameters) this.parameters);

            this.setDynValue(JDBCConnectionParameters.URL_PARAMTER_NAME, url);

        }

    }

    private Object getDynValue(String name) {

        return ((DataParameters) this.parameters).getDynValue(name);

    }

    private void setDynValue(String name, Object value) {

        ((DataParameters) this.parameters).setDynValue(name, value);

    }

    public File getFile() {

        File f = (File) this.getDynValue(DATABASE_FILE);

        if( this.getDynValue(DBParameters.DBNAME_PARAMTER_NAME) == null

            && f != null ) {

            String dbname = getDbNameFromFile(f);

            this.setDynValue(DBParameters.DBNAME_PARAMTER_NAME, dbname);

        }

        return f;

    }

    public void setFile(File database) {

        this.setDynValue(DATABASE_FILE, database);

        if( this.getDynValue(DBParameters.DBNAME_PARAMTER_NAME) == null

            && database != null ) {

            String dbname = getDbNameFromFile(database);

            this.setDynValue(DBParameters.DBNAME_PARAMTER_NAME, dbname);

        }

    }

    public Properties getProperties() {

        Properties props = new Properties();

        return props;

    }

    private String getDbNameFromFile(File f) {

        String fname = f.getName();

        if( fname.toLowerCase().endsWith(".mv.db") ) {

            fname = fname.substring(0, fname.length()-6);

        } else {

            fname = FilenameUtils.getBaseName(fname);

        }

        return fname;

    }

}

package org.gvsig.fmap.dal.store.mdb;

import com.vividsolutions.jts.geom.Geometry;

import com.vividsolutions.jts.io.WKBReader;

import java.sql.Blob;

import java.sql.Connection;

import java.sql.SQLException;

import net.ucanaccess.converters.TypesMap.AccessType;

import net.ucanaccess.ext.FunctionType; 

import net.ucanaccess.jdbc.UcanaccessConnection;

import org.gvsig.fmap.dal.ExpressionBuilder;

public class SpatialFunctions {

    public static void selfRegister(Connection conn) throws SQLException {

        UcanaccessConnection uc=(UcanaccessConnection)conn; 

        uc.addFunctions(SpatialFunctions.class);

    }

    private static Geometry toGeometry(Blob blob) {

        try {

            WKBReader reader = new WKBReader();

            Geometry geom = reader.read(blob.getBytes(1, (int) blob.length()));

            return geom;

        } catch (Exception ex) {

            return null;

        }

    }

    @FunctionType(functionName="ST_AsText", argumentTypes={AccessType.OLE},returnType=AccessType.TEXT) 

    public static String ST_AsText(Blob arg) {

        Geometry geom = toGeometry(arg);

        if( geom == null ) {

            return null;

        }

        return geom.toText();

    }

    @FunctionType(functionName="ST_AsBinary", argumentTypes={AccessType.OLE},returnType=AccessType.OLE) 

    public static Blob ST_AsBinary(Blob arg) {

        return arg;

    }

    @FunctionType(functionName="ST_Envelope", argumentTypes={AccessType.OLE},returnType=AccessType.OLE) 

    public static Blob ST_Envelope(Blob arg) {

        Geometry geom = toGeometry(arg);

        if( geom == null ) {

            return null;

        }

        Geometry env = geom.getEnvelope();

        return arg;

    }

    @FunctionType(functionName="ST_Touches", argumentTypes={AccessType.OLE,AccessType.OLE},returnType=AccessType.YESNO) 

    public static boolean ST_Touches(Blob arg1, Blob arg2) {

        Geometry geom1 = toGeometry(arg1);

        if( geom1 == null ) {

            return false;

        }

        Geometry geom2 = toGeometry(arg2);

        if( geom2 == null ) {

            return false;

        }

        return geom1.touches(geom2);

    }

  /*

    public ExpressionBuilder.Function ST_SRID(ExpressionBuilder.Value geom);

    public ExpressionBuilder.Function ST_AsEWKB(ExpressionBuilder.Value geom);

    public ExpressionBuilder.Function ST_Envelope(ExpressionBuilder.Value geom);

    public ExpressionBuilder.Function ST_GeomFromText(ExpressionBuilder.Value geom, ExpressionBuilder.Value crs);

    public ExpressionBuilder.Function ST_GeomFromWKB(ExpressionBuilder.Value geom, ExpressionBuilder.Value crs);

    public ExpressionBuilder.Function ST_GeomFromEWKB(ExpressionBuilder.Value geom, ExpressionBuilder.Value crs);

    public ExpressionBuilder.Function ST_Simplify(ExpressionBuilder.Value geom, ExpressionBuilder.Value tolerance);

    public ExpressionBuilder.Function ST_Equals(ExpressionBuilder.Value geom1, ExpressionBuilder.Value geom2);

    public ExpressionBuilder.Function ST_Intersects(ExpressionBuilder.Value geom1, ExpressionBuilder.Value geom2);

    public ExpressionBuilder.Function ST_Contains(ExpressionBuilder.Value geom1, ExpressionBuilder.Value geom2);

    public ExpressionBuilder.Function ST_Disjoint(ExpressionBuilder.Value geom1, ExpressionBuilder.Value geom2);

    public ExpressionBuilder.Function ST_Crosses(ExpressionBuilder.Value geom1, ExpressionBuilder.Value geom2);

    public ExpressionBuilder.Function ST_IsClosed(ExpressionBuilder.Value geom1);

    public ExpressionBuilder.Function ST_Overlaps(ExpressionBuilder.Value geom1, ExpressionBuilder.Value geom2);

    public ExpressionBuilder.Function ST_Within(ExpressionBuilder.Value geom1, ExpressionBuilder.Value geom2);

  */  

 }

/* 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.store.mdb;

import java.io.File;

import java.util.Properties;

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

import org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorerParameters;

public class MdbExplorerParameters extends

        JDBCServerExplorerParameters 

    implements

        MdbConnectionParameters

    {

    private final MdbConnectionParametersHelper helper;

    public MdbExplorerParameters() {

        super(

                MdbLibrary.NAME + "ServerExplorerParameters",

                MdbLibrary.NAME

        );

        this.helper = new MdbConnectionParametersHelper(this);

    }

    @Override

    public String getUrl() {

        return this.helper.getUrl();

    }

    @Override

    public void validate() throws ValidateDataParametersException {

        this.helper.validate();

        super.validate();

    }

    @Override

    public Properties getProperties() {

        return this.helper.getProperties();

    }

    @Override

    public File getFile() {

        return this.helper.getFile();

    }

    @Override

    public void setFile(File database) {

        this.helper.setFile(database);

    }

}

/* 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.store.mdb;

import org.gvsig.fmap.dal.DALLibrary;

import org.gvsig.fmap.dal.DALLocator;

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

import org.gvsig.fmap.dal.store.db.DBHelper;

import org.gvsig.fmap.dal.store.jdbc2.JDBCLibrary;

import org.gvsig.fmap.dal.store.jdbc2.spi.JDBCStoreProviderBase;

import org.gvsig.metadata.exceptions.MetadataException;

import org.gvsig.tools.library.AbstractLibrary;

import org.gvsig.tools.library.LibraryException;

public class MdbLibrary extends AbstractLibrary {

    public static final String NAME = "Mdb";

    @Override

    public void doRegistration() {

        registerAsServiceOf(DALLibrary.class);

        require(JDBCLibrary.class);

    }

    @Override

    protected void doInitialize() throws LibraryException {

    }

    @Override

    protected void doPostInitialize() throws LibraryException {

        LibraryException ex = null;

        DataManagerProviderServices dataman = 

                (DataManagerProviderServices) DALLocator.getDataManager();

        try {

            Class.forName(MdbHelper.MdbJDBCDriver);

        } catch(Throwable th) {

            MdbHelper.logger.warn("Can't load Mdb JDBC Driver.",th);

        }