Application: gvSIG desktop

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

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

  <modelVersion>4.0.0</modelVersion>

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

  <name>${project.artifactId}</name>

  <packaging>pom</packaging>

  <description>This library has the implementation of the provider of te Data Access Library for accesing to database resources, like JDBC, PostgreSQL or H2.</description>

  <parent>

      <groupId>org.gvsig</groupId>

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

      <version>2.0.343</version>

  </parent>  

  <modules>

    <module>org.gvsig.fmap.dal.db.lib</module>

    <module>org.gvsig.fmap.dal.db.jdbc</module>

    <module>org.gvsig.fmap.dal.db.mdb</module>

  </modules>

</project>

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2020 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.fmap.dal.store.jdbc2;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.List;

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

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

public interface ResulSetControler extends AutoCloseable {

    public interface ResultSetEntry extends AutoCloseable {

        public ResultSet get();

        public int getID();

        public boolean isZombie();

        public String getSQL();

        public FeatureAttributeDescriptor[] getColumns();

        public String[] getExtraValueNames();

        public Object getObject(int columnIndex) throws SQLException;

        public byte[] getBytes(int columnIndex) throws SQLException;

        public boolean next() throws SQLException;

    }

    public void setTimeToZombie(long mlSeconds);

    public long getTimeToZombie();

    public ResultSetEntry create(String sql, int fetchSize, FeatureAttributeDescriptor[] columns, String[] extraValueNames ) throws DataException;

    public ResultSetEntry create(String sql, List<Object> values, int fetchSize, FeatureAttributeDescriptor[] columns, String[] extraValueNames) throws DataException;

    public int getOpenCount();

    public void closeAll();

    public void pack();    

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2013 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.fmap.dal.store.jdbc2.impl;

import java.util.ArrayList;

import java.util.List;

import java.util.NoSuchElementException;

import org.apache.commons.collections.CollectionUtils;

import org.apache.commons.lang3.BooleanUtils;

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

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

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

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

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

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

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

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

import org.gvsig.fmap.dal.store.jdbc2.ResulSetControler.ResultSetEntry;

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

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

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

import org.gvsig.tools.evaluator.Evaluator;

import org.gvsig.tools.exception.BaseException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class JDBCSetProvider extends AbstractFeatureSetProvider {

    final static protected Logger LOGGER = LoggerFactory.getLogger(JDBCSetProvider.class);

    private class EmptyJDBCIterator extends JDBCIterator {

        protected EmptyJDBCIterator(JDBCStoreProvider store) throws DataException {

            super(store, null, null, null);

        }

        @Override

        protected boolean internalHasNext() {

            return false;

        }

        @Override

        protected Object internalNext() {

            throw new NoSuchElementException();

        }

        @Override

        protected void doDispose() throws BaseException {

            // nothing to do

        }

    }

    protected Long size = null;

    protected Boolean isEmpty = null;

    protected List<ResultSetEntry> resultSets;

    private int defaultFetchSize = 1000;

    public JDBCSetProvider(

            AbstractFeatureStoreProvider store,

            JDBCHelper helper,

            FeatureQuery query,

            FeatureType featureType

    ) throws DataException {

        super(store, query, featureType);

        this.resultSets = new ArrayList<>();

    }

    /**

     * @return the defaultFetchSize

     */

    public int getDefaultFetchSize() {

        return defaultFetchSize;

    }

    /**

     * @param defaultFetchSize the defaultFetchSize to set

     */

    public void setDefaultFetchSize(int defaultFetchSize) {

        this.defaultFetchSize = defaultFetchSize;

    }

//    @Override

//    protected JDBCStoreProvider getStore() {

//        return (JDBCStoreProvider) super.getStore();

//    }

    protected JDBCStoreProvider getJDBCStore() {

//        Corregido el problema en AbstractFeatureSetProvider, de que getStore

//        debe ser un FeatureStoreProvider y no un AbstractFeatureStoreProvider

//        este metodo debe desaparecer y quedar el getStore de arriba que esta

//          comentarizado

        return (JDBCStoreProvider) super.getStore();

    }    

    protected JDBCHelper getHelper() {

        return this.getJDBCStore().getHelper();

    }

    protected OperationsFactory getOperations() {

        return this.getHelper().getOperations();

    }

    @Override

    public boolean canIterateFromIndex() {

        return this.getHelper().supportOffsetInSelect();

    }

    @Override

    public boolean canFilter() {

        return this.getHelper().supportFilter(this.getFeatureType(), getQuery().getFilter());

    }

    @Override

    public boolean canOrder() {

        return this.getHelper().supportOrder(this.getFeatureType(), getQuery().getOrder());

    }

    public ResulSetControler getResulSetControler() {

        return this.getHelper().getResulSetControler();

    }

    @Override

    protected void doDispose() throws BaseException {

        if( ! CollectionUtils.isEmpty(this.resultSets) ) {

            for( ResultSetEntry resulset : this.resultSets ) {

               JDBCUtils.closeQuietly(resulset);

            }

        }

        size = null;

        isEmpty = null;

    }

    protected int getFetchSize() {

        long pageSize = -1;

        if (getQuery() != null) {

            pageSize = getQuery().getPageSize();

            pageSize = pageSize > Integer.MAX_VALUE ? Integer.MAX_VALUE : pageSize;

        }

        return (pageSize > 0 ? (int) pageSize : defaultFetchSize);

    }

    @Override

    public long getSize() throws DataException {

        if (size == null) {

            JDBCStoreParameters params = this.getJDBCStore().getParameters();

            CountOperation selectCount = this.getOperations().createCount(

                    this.getFeatureType(),

                    this.getOperations().createTableReference(params),

                    params.getBaseFilter(), 

                    this.getQuery()

            );

            size = (Long) selectCount.perform();              

        }

        return size;

    }

    @Override

    public boolean isEmpty() throws DataException {

        if (this.isEmpty == null) {

            if (this.size == null) {

                JDBCStoreParameters params = this.getJDBCStore().getParameters();

//                String filtersql = null;

//                Evaluator filter = this.getQuery().getFilter();

//                if( filter != null ) {

//                    filtersql = filter.getSQL();

//                }

                TableIsEmptyOperation isEmpty_ = this.getOperations().createTableIsEmpty(

                        this.getFeatureType(),

                        this.getOperations().createTableReference(params),

                        params.getBaseFilter(), 

                        this.getQuery()

                );

                this.isEmpty = (Boolean) isEmpty_.perform();   

            } else {

                this.isEmpty = (this.size < 1);

            }

        }

        return isEmpty;

    }

    @Override

    protected JDBCIterator createFastIterator(long index) throws DataException {

        return createFastIterator(index, 0);

    }

    @Override

    protected JDBCIterator createFastIterator(long index, long elements) throws DataException {

        if( BooleanUtils.isTrue(isEmpty) ) {

            return new EmptyJDBCIterator(this.getJDBCStore());

        }

        JDBCStoreParameters params = this.getJDBCStore().getParameters();

        FeatureType storeType = this.getStore()

                .getStoreServices()

		.getProviderFeatureType(this.getFeatureType().getId());

        ResultSetForSetProviderOperation createResultSet 

            = getOperations().createResultSetForSetProvider(

                    this.getOperations().createTableReference(params),

                    params.getBaseFilter(), 

                    params.getBaseOrder(), 

                    this.getQuery(), 

                    storeType, 

                    this.getFeatureType(), 

                    elements, 

                    index, 

                    this.getFetchSize()

            );

        ResultSetEntry resultSetEntry = (ResultSetEntry) createResultSet.perform();

        this.resultSets.add(resultSetEntry);

        return new JDBCFastIterator(

                this.getJDBCStore(), 

                this, 

                this.getFeatureType(),

                resultSetEntry

        );

    }

    @Override

    protected JDBCIterator createIterator(long index) throws DataException {

        return createIterator(index, -1);

    }

    @Override

    protected JDBCIterator createIterator(long index, long elements) throws DataException {

        if( BooleanUtils.isTrue(isEmpty) ) {

            return new EmptyJDBCIterator(this.getJDBCStore());

        }

        JDBCStoreParameters params = this.getJDBCStore().getParameters();

        FeatureType storeType = this.getStore()

                .getStoreServices()

		.getProviderFeatureType(this.getFeatureType().getId());

        ResultSetForSetProviderOperation createResultSet 

            = getOperations().createResultSetForSetProvider(

                    this.getOperations().createTableReference(params),

                    params.getBaseFilter(), 

                    params.getBaseOrder(), 

                    this.getQuery(), 

                    storeType, 

                    this.getFeatureType(), 

                    elements, 

                    index, 

                    this.getDefaultFetchSize()

            );

        ResultSetEntry resultSetEntry = (ResultSetEntry) createResultSet.perform();

        this.resultSets.add(resultSetEntry);

        return new JDBCIterator(

                this.getJDBCStore(), 

                this, 

                this.getFeatureType(),

                resultSetEntry

        );

    }

}

package org.gvsig.fmap.dal.store.jdbc2.impl;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

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

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

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

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

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

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

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

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

import org.gvsig.tools.dispose.Disposable;

import org.gvsig.tools.dispose.DisposeUtils;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class ResulSetControlerBase implements ResulSetControler {

    final static private Logger LOGGER = LoggerFactory.getLogger(ResulSetControlerBase.class);

    public class ResultSetEntryBase implements ResultSetEntry {

        private ResultSet resultSet = null;

        private final int id;

        private long lastUse = 0;

        private final String sql;

        private final FeatureAttributeDescriptor[] columns;

        private final String[] extraValueNames;

        private Throwable closeCause ;

        private final String connId;

        private final String hexId;

        public ResultSetEntryBase(ResultSet resulSet, String sql, FeatureAttributeDescriptor[] columns, String[] extraValueNames) {

            this.closeCause = null;

            this.resultSet = resulSet;

            this.connId = JDBCUtils.getConnId(this.resultSet);

            this.hexId = JDBCUtils.getHexId(this);

            this.id = nextid++;

            this.sql = sql;

            this.columns = columns;

            this.extraValueNames = extraValueNames;

            used();

            synchronized(resulSets){

                resulSets.put(this.getID(), this);

            }

            if( LOGGER.isDebugEnabled() ) {

                LOGGER.debug("["+JDBCUtils.getConnId(resulSet)+"] ResultSetEntryBase "+this.hexId+" "+sql);

            }

            LOGGER.debug(((JDBCHelperBase)helper).getConnectionProviderStatus());

        }

        private void used() {

            lastUse = System.currentTimeMillis();

        }

        @Override

        public ResultSet get() {

            used();

            return resultSet;

        }

        @Override

        public int getID() {

            return this.id;

        }

        @Override

        public boolean isZombie() {

            if( this.resultSet == null ) {

                return true;

            }

            return System.currentTimeMillis() - lastUse > mlsecondsToZombie;

        }

        @Override

        public String getSQL() {

            return this.sql;

        }

        @Override

        public String[] getExtraValueNames() {

            return this.extraValueNames;

        }

        @Override

        public FeatureAttributeDescriptor[] getColumns() {

            return this.columns;

        }

        @Override

        public Object getObject(int columnIndex) throws SQLException {

            used();

            return this.resultSet.getObject(columnIndex);

        }

        @Override

        public byte[] getBytes(int columnIndex) throws SQLException {

            used();

            return this.resultSet.getBytes(columnIndex);

        }

        @Override

        public boolean next() throws SQLException {

            if( this.closeCause!=null ) {

                LOGGER.debug("["+this.connId+"] ResultSetEntryBase already closed "+this.hexId);

                throw new IllegalStateException("ResultSetEntryBase already closed, connId="+this.connId+", id="+this.hexId+" (sql="+sql+")", closeCause);

            }

            return this.resultSet.next();

        }

        @Override

        public void close() throws Exception {

            if( LOGGER.isDebugEnabled() ) {

                LOGGER.debug("["+this.connId+"] ResultSetEntryBase close "+this.hexId);

            }

            if( this.resultSet == null ) {

                // Already close

                return;

            }

            this.closeCause = new Throwable();

            Statement st = null;

            Connection con = null;

            try {

                synchronized(resulSets){

                    resulSets.remove(this.getID());

                }

                st = this.resultSet.getStatement();

                if( st != null ) {

                    con = st.getConnection();

                }

            } catch(Exception ex) {

                LOGGER.warn("Problems closing ResulSetEntryBase.",ex);

            }

            JDBCUtils.closeQuietly(this.resultSet);

            JDBCUtils.closeQuietly(st);

            helper.closeConnection(con);

            this.resultSet = null;

            LOGGER.debug(

                    "Close ResulSetEntryBase id {} (total {})",

                    this.getID(),

                    getOpenCount()

            );

            LOGGER.debug(((JDBCHelperBase)helper).getConnectionProviderStatus());

            pack();

        }

    }

    private int nextid = 1;

    private final Map<Integer, ResultSetEntryBase> resulSets;

    private long mlsecondsToZombie = 1000 * 60 * 10; // 10 Min

    private JDBCHelper helper = null;

    public ResulSetControlerBase(JDBCHelper helper) {

        this.helper = helper;

        this.resulSets = new HashMap<>();

        this.nextid = 1;

    }

    @Override

    public long getTimeToZombie() {

        return mlsecondsToZombie;

    }

    @Override

    public void setTimeToZombie(long mlSeconds) {

        mlsecondsToZombie = mlSeconds;

    }

    @Override

    public void close() throws Exception {

        this.closeAll();

        this.helper = null;

        this.resulSets.clear();

        this.nextid = -10;

    }

    @Override

    public ResultSetEntryBase create(

            String sql, 

            int fetchSize, 

            FeatureAttributeDescriptor[] columns,

            String[] extraValueNames) throws DataException {

        return create(sql, null, fetchSize, columns, extraValueNames);

    }

    @Override

    public synchronized ResultSetEntryBase create(

            String sql, 

            List<Object> values, 

            int fetchSize, 

            FeatureAttributeDescriptor[] columns, 

            String[] extraValueNames) throws DataException {

        this.pack();

        ResultSet rs = null;

        Connection conn = null;

        PreparedStatement st = null;

        Disposable paramsDisposer = null;

        try {

            conn = helper.getConnection();

            conn.setAutoCommit(false);

            st = conn.prepareStatement(sql);

            JDBCSQLBuilderBase sqlbuilder = helper.createSQLBuilder();

            paramsDisposer = sqlbuilder.setStatementParameters(st, values, helper.getGeometrySupportType());

            if (fetchSize > 0) {

                // See parameter "SelectMethod" of SQL Server Connection Properties

                // https://docs.oracle.com/cd/E13157_01/wlevs/docs30/jdbc_drivers/mssqlserver.html

                st.setFetchSize(fetchSize);

            }

            rs = JDBCUtils.executeQuery(st, sql);

            if (fetchSize > 0) {

                rs.setFetchSize(fetchSize);

            }

            ResultSetEntryBase rsentry = new ResultSetEntryBase(rs, sql, columns,  extraValueNames);

            return rsentry;

        } catch (SQLException e) {

            JDBCUtils.closeQuietly(rs);

            JDBCUtils.closeQuietly(st);

            this.helper.closeConnectionQuietly(conn);

            throw new JDBCExecutePreparedSQLException(sql, values, e);

        } finally {

            DisposeUtils.disposeQuietly(paramsDisposer);

        }

    }

    private List<ResultSetEntryBase> getResultSetValues() {

        synchronized(this.resulSets){

            List<ResultSetEntryBase> values = new ArrayList<>();

            values.addAll(this.resulSets.values());

            return values;

        }

    }

    @Override

    public synchronized void closeAll() {

        List<ResultSetEntryBase> values = getResultSetValues();

        for (ResultSetEntryBase entry : values) {

            JDBCUtils.closeQuietly(entry);

        }

    }

    @Override

    public synchronized void pack() {

        List<ResultSetEntryBase> values = getResultSetValues();

        int maxID = 0;

        for (ResultSetEntryBase entry : values) {

            if (entry.isZombie()) {

                JDBCUtils.closeQuietly(entry);

            } else {

                if (entry.getID() > maxID) {

                    maxID = entry.getID();

                }

            }

        }

        this.nextid = maxID + 1;

    }

    @Override

    public int getOpenCount() {

        synchronized(resulSets){

            return this.resulSets.size();

        }

    }

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2013 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.fmap.dal.store.jdbc2.impl;

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

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

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

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

import org.gvsig.fmap.dal.store.jdbc2.ResulSetControler.ResultSetEntry;

import org.gvsig.tools.exception.BaseException;

public class JDBCFastIterator extends JDBCIterator {

	protected FeatureProvider featureProvider;

	protected JDBCFastIterator(

                JDBCStoreProvider store, 

                JDBCSetProvider set,

		FeatureType featureType, 

                ResultSetEntry resultSetEntry 

            ) throws DataException {

            super(store, set, featureType, resultSetEntry);

            this.featureProvider = super.createFeatureProvider();

	}

        @Override

	protected FeatureProvider createFeatureProvider() throws DataException {

		return this.featureProvider;

	}

	@Override

	protected void doDispose() throws BaseException {

		super.doDispose();

		featureProvider = null;

	}

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2013 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.fmap.dal.store.jdbc2.impl;

import java.sql.SQLException;

import java.util.NoSuchElementException;

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

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

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

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

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

import org.gvsig.fmap.dal.store.jdbc2.ResulSetControler.ResultSetEntry;

import org.gvsig.tools.exception.BaseException;

public class JDBCIterator extends AbstractFeatureProviderIterator {

    protected ResultSetEntry resulsetEntry;

    protected Boolean hasNext = null;

    protected FeatureType featureType;

    protected JDBCSetProvider set;

    protected JDBCIterator(

            JDBCStoreProvider store, 

            JDBCSetProvider set,

            FeatureType featureType,

            ResultSetEntry resulsetEntry

        ) throws DataException {

        super(store);

        this.resulsetEntry = resulsetEntry;

        this.featureType = featureType;

        this.set = set;

        this.hasNext = null;

    }

    @Override

    protected JDBCStoreProvider getFeatureStoreProvider() {

        return (JDBCStoreProvider) super.getFeatureStoreProvider();

    }

    @Override

    public final Object next() {

        return internalNext();

    }

    @Override

    public final boolean hasNext() {

        return internalHasNext();

    }

    @Override

    protected boolean internalHasNext() {

        if (hasNext == null) {

            try {

                if ( resulsetEntry.next() ) {

                    hasNext = Boolean.TRUE;

                } else {

                    hasNext = Boolean.FALSE;

                    this.close();

                }

            } catch (SQLException e) {

                throw new RuntimeException(e);

            }

        }

        return hasNext;

    }

    @Override

    protected Object internalNext() {

        if (!hasNext()) {

            throw new NoSuchElementException();

        }

        FeatureProvider data;

        try {

            data = getFeatureProvider();

        } catch (DataException e) {

            throw new RuntimeException(e);

        }

        hasNext = null;

        return data;

    }

    @Override

    public void remove() {

        throw new UnsupportedOperationException();

    }

    protected FeatureProvider createFeatureProvider() throws DataException {

        return getFeatureStoreProvider().createFeatureProvider(featureType);

    }

    protected FeatureProvider getFeatureProvider() throws DataException {

        FeatureProvider data = createFeatureProvider();

        this.getFeatureStoreProvider().getHelper().fetchFeature(data, this.resulsetEntry);

        return data;

    }

    @Override

    protected void doDispose() throws BaseException {

        if (this.resulsetEntry!=null) {

            this.close();

        }

        this.featureType = null;

    }

    protected void close() {

        try {

            this.resulsetEntry.close();

            this.resulsetEntry = null;

        } catch (Exception e) {

            throw new RuntimeException(e);

        }

    }

}

package org.gvsig.fmap.dal.store.jdbc2.impl;

import org.apache.commons.lang3.StringUtils;

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

import org.gvsig.fmap.dal.DataServerExplorerParameters;

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

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

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.spi.JDBCHelperBase;

public class JDBCServerExplorerFactory extends AbstractDataServerExplorerFactory {

    private static final String NAME = JDBCLibrary.NAME;

    public JDBCServerExplorerFactory() {

        this(

                NAME,

                "JDBC generic server (2)"

        );

    }

    protected JDBCServerExplorerFactory(String name, String description) {

        super(name,description);

    }

    protected JDBCServerExplorerFactory(String name, String description, boolean hidden) {

        super(name,description, hidden);

    }

    @Override

    public JDBCServerExplorer create(

            DataServerExplorerParameters parameters, 

            DataServerExplorerProviderServices providerServices

        ) throws InitializeException {

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

        JDBCServerExplorer server = helper.createServerExplorer(

                (JDBCServerExplorerParameters) parameters, 

                providerServices

        );

        return server;

    }

    @Override

    public JDBCServerExplorerParameters createParameters() {

        JDBCServerExplorerParameters params = new JDBCServerExplorerParameters(

                NAME + "ServerExplorerParameters",

                NAME 

        );

        return params;    

    }

    @Override

    public boolean isStoreSupported(String name) {

        return StringUtils.equalsIgnoreCase(name, this.getName());

    }

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2013 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.fmap.dal.store.jdbc2.impl;

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

import org.gvsig.fmap.dal.DataParameters;

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.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.spi.JDBCHelperBase;

public class JDBCStoreProviderFactory 

    extends AbstractFeatureStoreProviderFactory 

    {

    private static final String NAME = JDBCLibrary.NAME;

    public static final int CASE_IDENTIFIERS_INDIFERENT = 0;

    public static final int CASE_IDENTIFIERS_UPPERCASE = 1;

    public static final int CASE_IDENTIFIERS_LOWERCASE = 2;

    public JDBCStoreProviderFactory() {

        this(

                NAME, 

                "JDBC generic store (2)"

        );

    }

    @Override

    public int hasTabularSupport() {

        return YES;

    }    

    @Override

    public int hasSQLSupport() {

        return YES;

    }

    protected JDBCStoreProviderFactory(String name, String description) {

        super(name, description);

    }

    protected JDBCStoreProviderFactory(String name, String description, boolean hidden) {

        super(name, description, hidden);

    }

    @Override

    public JDBCStoreProvider createProvider(

            DataParameters parameters,

            DataStoreProviderServices providerServices

    ) throws InitializeException {

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

        JDBCStoreProvider provider = helper.createProvider(

                (JDBCStoreParameters) parameters, 

                providerServices

        );

        return provider;

    }

    @Override

    public JDBCStoreParameters createParameters() {

        JDBCStoreParameters params = new JDBCStoreParameters(

                NAME + "StoreParameters",

                NAME 

        );

        return params;

    }

    @Override

    public int isOptimalRecoverFeaturesByReference() {

        return NO;

    }

    public int useLocalIndexesCanImprovePerformance() {

        return NO;

    }

    @Override

    public boolean allowSpatialIndexSupport() {

        if (this.hasVectorialSupport() == YES) {

            return true;

        }

        return false;

    }

    public int caseIndentifierPreferedMode() {

        return CASE_IDENTIFIERS_UPPERCASE;

    }

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2020 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.fmap.dal.store.jdbc2.impl.expressionevaluator;

import org.gvsig.expressionevaluator.spi.AbstractSymbolTable;

import static org.gvsig.fmap.dal.store.jdbc2.impl.expressionevaluator.JDBCSymbolTableFactory.SYMBOLTABLE_NAME;

/**

 *

 * @author jjdelcerro

 */

public class JDBCSymbolTable 

        extends AbstractSymbolTable

    {   

    public JDBCSymbolTable() {

        super(SYMBOLTABLE_NAME);

        this.initFunctions();

    }

    private void initFunctions() {

        this.addFunction(new ExecuteSQLFunction());

    }    

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2020 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.fmap.dal.store.jdbc2.impl.expressionevaluator;

import org.apache.commons.lang3.Range;

import org.gvsig.expressionevaluator.Interpreter;

import org.gvsig.expressionevaluator.spi.AbstractFunction;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import org.gvsig.fmap.dal.DataServerExplorerParameters;

import org.gvsig.fmap.dal.DataServerExplorerPoolEntry;

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

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

import static org.gvsig.fmap.dal.store.jdbc2.impl.expressionevaluator.JDBCSymbolTableFactory.GROUP_JDBC;

/**

 *

 * @author jjdelcerro

 */

public class ExecuteSQLFunction extends AbstractFunction {

  public static final String FUNCTION_EXECUTESQL = "EXECUTESQL";

  public ExecuteSQLFunction() {

    super(  GROUP_JDBC,

            FUNCTION_EXECUTESQL,

            Range.between(1,2),

            "Receive a connection and SQL string as argument.",

            FUNCTION_EXECUTESQL + "({{connection}}, sql)",

            new String[]{

              "connection - conextion string (optional)",

              "sql - sql string"

            },

            "Object",

            false

    );

  }

  @Override

  public boolean allowConstantFolding() {

    return false;

  }

  @Override

  public boolean useArgumentsInsteadObjects() {

    return false;

  }

  @Override

  public Object call(Interpreter interpreter, Object[] args) throws Exception {

      String connectionName;

      String sql;

      JDBCServerExplorer explorer;

      if (args.length==1) {

          sql = this.getStr(args, 0);

          FeatureStore store = (FeatureStore) interpreter.getSymbolTable().function(DataManager.FUNCTION_CURRENT_STORE).call(interpreter,(Object[]) null);

          explorer = (JDBCServerExplorer) store.getExplorer();

      } else {

        connectionName = this.getStr(args, 0);

        sql = this.getStr(args, 1);

        if (this.getObject(args, 0) instanceof JDBCServerExplorer) {

            explorer = (JDBCServerExplorer) this.getObject(args, 0);

        } else if (this.getObject(args, 0) instanceof FeatureStore) {

            explorer = (JDBCServerExplorer) ((FeatureStore) this.getObject(args, 0)).getExplorer();

        } else {

            DataManager dalManager = DALLocator.getManager();

            DataServerExplorerPoolEntry poolEntry = dalManager.getDataServerExplorerPool().get(connectionName);

            DataServerExplorerParameters explorerParameters = poolEntry.getExplorerParameters();

            explorer = (JDBCServerExplorer) dalManager.openServerExplorer(explorerParameters.getProviderName(), explorerParameters);

        }

      }

      Object result = explorer.execute(sql);

      return result;

  }

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2020 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.fmap.dal.store.jdbc2.impl.expressionevaluator;

import org.gvsig.expressionevaluator.ExpressionEvaluatorLocator;

import org.gvsig.expressionevaluator.ExpressionEvaluatorManager;

import org.gvsig.expressionevaluator.SymbolTable;

import org.gvsig.expressionevaluator.spi.AbstractSymbolTableFactory;

/**

 *

 * @author jjdelcerro

 */

public class JDBCSymbolTableFactory extends AbstractSymbolTableFactory {

    private SymbolTable symbolTable;

    public static final String SYMBOLTABLE_NAME = "JDBC";

    public static final String GROUP_JDBC = "Data access";

    public JDBCSymbolTableFactory() {

        super(SYMBOLTABLE_NAME, true);

    }

    @Override

    public SymbolTable create(Object... args) {

        if( this.symbolTable==null ) {

            this.symbolTable = new JDBCSymbolTable();

        }

        return this.symbolTable;

    }

    public static final void selfRegister() {

        ExpressionEvaluatorManager manager = ExpressionEvaluatorLocator.getManager();

        manager.registerSymbolTable(new JDBCSymbolTableFactory());

    }

}

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2020 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.fmap.dal.store.jdbc2;

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

import java.sql.Connection;

import java.sql.ResultSet;

import java.util.List;

import org.gvsig.expressionevaluator.GeometryExpressionBuilderHelper.GeometrySupportType;

import org.gvsig.fmap.dal.SQLBuilder;

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

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

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

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

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

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

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

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

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

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

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

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.jdbc2.ResulSetControler.ResultSetEntry;

import org.gvsig.fmap.geom.Geometry;

import org.gvsig.fmap.geom.GeometryManager;

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

import org.gvsig.tools.evaluator.Evaluator;

public interface JDBCHelper extends AutoCloseable {

    /**

     * Return the name of the driver.

     * 

     * By default rerturn "JDBC".

     * 

     * @return 

     */

    public String getProviderName();

    /**

     * Indica como deben ser guardadas las geometrias en la BBDD. Pueden

     * guardarse en WKT, WKB o EWKB.

     *

     * @return

     */

    public GeometrySupportType getGeometrySupportType();

    /**

     * Devuelve un SQLBuilder adaptado al proveedor. Por ejemplo, uno especifico

     * para PostgreSQL, MySQL, Oracle, MSSQLServer...

     *

     * @return

     */

    public JDBCSQLBuilderBase createSQLBuilder();

    /**

     * Devuelve las comillas que han de usaese para los identificadores.

     *

     * @return

     */

    public String getQuoteForIdentifiers();

    /**

     * Devuelve las comillas que han de usaese en las constantes de cadena.

     *

     * @return

     */

    public String getQuoteForStrings();

    public FeatureType getProviderFeatureType();

    /**

     * @param providerFeatureType the providerFeatureType to set

     */

    public void setProviderFeatureType(FeatureType providerFeatureType);

    /**

     * Indica si la BBDD soporta valores automaticos, tipo serial.

     *

     * @return

     */

    public boolean allowAutomaticValues();

    /**

     * Indica si la BBDD soporta el uso de OFFSET en la sentencia select.

     *

     * @return

     */

    public boolean supportOffsetInSelect();

    /**

     * Indica si se especifico un subquery al abrir el proveedor.

     *

     * @return

     */

    public boolean useSubquery();

    /**

     * Indica si la BBDD tiene soporte espacial.

     *

     * @return

     */

    public boolean hasSpatialFunctions();

    public boolean supportFilter(FeatureType type, Evaluator evaluator);

    public boolean supportExpression(final FeatureType type, String sql);

    public boolean supportOrder(FeatureType type, FeatureQueryOrder order);

    public boolean allowNestedOperations();

    /**

     * Indica si podemos escribir el tipo de geometria indicado.

     *

     * @param geometryType

     * @param geometrySubtype

     * @return

     */

    public boolean canWriteGeometry(

            int geometryType, 

            int geometrySubtype

    );

    public Connection getConnection() throws AccessResourceException;

    public Connection getConnectionWritable() throws AccessResourceException;

    public String getConnectionURL();

    public JDBCConnectionParameters getConnectionParameters();

    public void closeConnection(Connection connection);

    public void closeConnectionQuietly(Connection connection);

    public GeometryManager getGeometryManager();

    public ResulSetControler getResulSetControler();

    public String getSourceId();

    public ResourceProvider getResource();

    public void dispose();

    public void fetchFeature(

            FeatureProvider feature, 

            ResultSet rs,

            FeatureAttributeDescriptor[] columns,

            String[] extraValueNames

    ) throws DataException;

    public void fetchFeature(

            FeatureProvider feature, 

            ResultSetEntry rs

    ) throws DataException;

    public Geometry getGeometryFromColumn(

            ResultSet rs, 

            int index

    ) throws DataException;

    public Geometry getGeometryFromColumn(

            ResultSetEntry rs, 

            int index

    ) throws DataException;

    public OperationsFactory getOperations();

    public FeatureProvider createFeature(

            FeatureType featureType

    ) throws DataException;

    public JDBCStoreProvider createProvider(

            JDBCStoreParameters parameters,

            DataStoreProviderServices providerServices

    ) throws InitializeException;

    public JDBCServerExplorer createServerExplorer(

            JDBCServerExplorerParameters parameters, 

            DataServerExplorerProviderServices providerServices

    ) throws InitializeException;

    public SRSSolver getSRSSolver();

    public JDBCNewStoreParameters createNewStoreParameters();

    public JDBCStoreParameters createOpenStoreParameters();