Application: gvSIG desktop

        <version>2.0.381-SNAPSHOT</version>

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

      <scope>compile</scope>        

    </dependency>

    <dependency>

      <groupId>org.gvsig</groupId>

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

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

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

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

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

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

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

        return this.parameters.getExplorerParameters().getDataStoreName();

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

            <type>jar</type>

        </dependency>

        <dependency>

            <groupId>org.gvsig</groupId>

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

        <scope>compile</scope>

    </dependency>

     <dependency>

        <groupId>org.gvsig</groupId>

/*

 * 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, see <https://www.gnu.org/licenses/>. 

 * 

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

import org.gvsig.fmap.dal.DataTransaction;

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

import org.gvsig.tools.dispose.Disposable;

/**

 *

 * @author gvSIG Team

 */

public interface DataTransactionServices extends DataTransaction {

    public interface ConnectionService<T> extends Disposable {

        public String getId();

//        public void begin() throws DataException;

        public void finish() throws DataException;

        public void abort() throws DataException;

        public T get();

    }

    public static ConnectionService getConnection(DataTransactionServices transaction, String id) {

        if( transaction==null ) {

            return null;

        }

        return transaction.getConnection(id);

    }

    public void addConnection(ConnectionService connection);

    public ConnectionService getConnection(String id);

    public void removeConnection(String id);

    public boolean existsConnection(String id);

}

    <dependency>

org.gvsig.fmap.dal.store.jdbc.JDBCLibrary

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

import java.util.List;

import org.gvsig.fmap.dal.DataServerExplorer_v2;

import org.gvsig.fmap.dal.DataStore;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.NewDataStoreParameters;

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

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

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

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

public interface JDBCServerExplorer extends DataServerExplorer_v2 {

    @Override

    boolean add(String providerName, NewDataStoreParameters ndsp, boolean overwrite) throws DataException;

    @Override

    boolean canAdd();

    @Override

    JDBCStoreParameters get(String name) throws DataException;

    JDBCNewStoreParameters getAddParameters() throws DataException;

    @Override

    List<String> getDataStoreProviderNames();

    FeatureType getFeatureType(DataStoreParameters dsp) throws DataException;

    DataStoreParameters getOpenParameters() throws DataException;

    @Override

    String getProviderName();

    String getStoreName();

    @Override

    List<DataStoreParameters> list(int mode) throws DataException;

    DataStore open(DataStoreParameters dsp) throws DataException;

    @Override

    void remove(DataStoreParameters dsp) throws RemoveException;

    void updateTableStatistics(String database, String schema, String table) throws JDBCExecuteSQLException;

    public Object execute(String sql);

}

/**

 * 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.jdbc;

import java.sql.Connection;

import java.sql.SQLException;

import java.text.MessageFormat;

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSource;

import org.apache.commons.lang3.StringUtils;

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

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

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

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

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

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

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

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class JDBCResource extends AbstractDBResourceNoBlocker {

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

    public final static String NAME = "JDBCResource";

    public static final String DESCRIPTION = "JDBC Connection";

    protected DataSource dataSource = null;

    public JDBCResource(

            JDBCResourceParameters parameters

    ) throws InitializeException {

        super(parameters);

        registerJDBCDriver();

    }

    /**

     * Registra/Carga el driver de JDBC.

     * 

     * Debe ser sobreescrita en cada proveedor de datos para asegurar que se

     * tegna acceso al driver.

     * 

     * @throws InitializeException 

     */

    protected void registerJDBCDriver() throws InitializeException {

        String className = this.getParameters().getJDBCDriverClassName();

        if (className == null) {

            return;

        }

        try {

            Class theClass = Class.forName(className);

            if (theClass == null) {

                throw new JDBCDriverClassNotFoundException(this.getName(), className);

            }

        } catch (Exception e) {

            throw new InitializeException(e);

        }

    }

    /**

     * Crea el JDBC DataSource a partir de la informacion de los parametros

     * del recurso.

     * 

     * Debe ser sobreescrita en cada proveedor de datos para asegurar que se

     * tenga acceso al driver.

     * 

     * @return 

     */

    protected DataSource createDataSource() {

        JDBCResourceParameters jdbcParams = this.getParameters();

        BasicDataSource dataSource = new BasicDataSource();

        dataSource.setDriverClassName(jdbcParams.getJDBCDriverClassName());

        dataSource.setUsername(jdbcParams.getUser());

        dataSource.setPassword(jdbcParams.getPassword());

        dataSource.setUrl(jdbcParams.getUrl());

        dataSource.setMaxWait(60L * 1000); // FIXME

//                FIXME Set Pool parameters:

//		dataSource.setMaxActive(maxActive);

//		dataSource.setMaxIdle(maxActive);

//		dataSource.setMaxOpenPreparedStatements(maxActive);

//		dataSource.setMaxWait(maxActive);

//		dataSource.setInitialSize(initialSize);

//		dataSource.setDefaultReadOnly(defaultReadOnly);

//		dataSource.setDefaultTransactionIsolation(defaultTransactionIsolation);

//		dataSource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);

//		dataSource.setMinIdle(minIdle);

//		dataSource.setTestOnBorrow(testOnBorrow);

//		dataSource.setTestOnReturn(testOnReturn);

//		dataSource.setTestWhileIdle(testOnReturn);

//		dataSource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);

//

//		dataSource.setAccessToUnderlyingConnectionAllowed(allow);

//		dataSource.setLoginTimeout(seconds);

//		dataSource.setLogWriter(out);

        return dataSource;

    }

    @Override

    public JDBCResourceParameters getParameters() {

        return (JDBCResourceParameters) super.getParameters();

    }

    @Override

    public String getName() throws AccessResourceException {

        JDBCResourceParameters params = this.getParameters();

        return MessageFormat.format("JDBCResource({0},{1},{2},{3},{4})",

                new Object[]{

                    params.getJDBCDriverClassName(),

                    params.getHost(),

                    params.getPort(),

                    params.getUser(),

                    params.getDBName()

                }

        );

    }

    public Connection getJDBCConnection() throws AccessResourceException {

        return (Connection) get();

    }

    public void closeConnection(Connection connection) {

        try {

            logger.trace("before-close connection" + this.getStatusInformation());

            connection.close();

            logger.trace("after close connection " + this.getStatusInformation());

        } catch (Exception ex) {

            logger.warn("Problems closing connection.", ex);

        }

    }

    protected void debugPoolStatus(String src) {

        if (logger.isTraceEnabled()) {

            logger.trace(src + "  " + this.getStatusInformation());

        }

    }

    public String getStatusInformation() {

        if (!(dataSource instanceof BasicDataSource)) {

            return "Connected: " + this.isConnected();

        }

        BasicDataSource ds = (BasicDataSource) dataSource;

        String s = MessageFormat.format("Conneted {0}, actives {1}/{2}, idle {3}/{4}",

            this.isConnected(),

            ds.getNumActive(),

            ds.getMaxActive(),

            ds.getNumIdle(),

            ds.getMaxIdle()

        );

        return s;

    }

    @Override

    protected synchronized Object getTheConnection() throws DataException {

        try {

            Object conn = this.dataSource.getConnection();

            debugPoolStatus("getTheConnection");

            return conn;

        } catch (SQLException e) {

            throw new JDBCSQLException(e);

        }

    }

    @Override

    public boolean isThis(ResourceParameters parameters)

            throws ResourceException {

        if (!super.isThis(parameters)) {

            return false;

        }

        JDBCResourceParameters params = (JDBCResourceParameters) parameters;

        String dbName = params.getDBName();

        String myDbName = this.getParameters().getDBName();

        if ( !StringUtils.equals(dbName, myDbName) ) {

            return false;

        }

        String driver = params.getJDBCDriverClassName();

        String myDriver = getParameters().getJDBCDriverClassName();

        if ( !StringUtils.equals(driver, myDriver) ) {

            return false;

        }

        return true;

    }

    @Override

    public boolean isConnected() {

        if (dataSource == null) {

            return false;

        }

        if (dataSource instanceof BasicDataSource) {

            return ((BasicDataSource) dataSource).getNumActive() > 0

                    || ((BasicDataSource) dataSource).getNumIdle() > 0;

        }

        return true;

    }

    @Override

    protected void connectToDB() throws DataException {

        if (this.dataSource != null) {

            return;

        }

        this.dataSource = this.createDataSource();

    }

    public void beginUse() {

        this.executeBegins();

    }

    public void endUse() {

        this.executeEnds();

    }

}

/**

 * 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.jdbc;

import org.apache.commons.lang3.StringUtils;

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

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

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

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

public class JDBCNewStoreParameters extends DBNewStoreParameters implements

        JDBCConnectionParameters {

    public static final String PARAMETERS_DEFINITION_NAME = "JDBCNewStoreParameters";

    public JDBCNewStoreParameters() {

        super(PARAMETERS_DEFINITION_NAME, JDBCStoreProvider.NAME);

    }

    protected JDBCNewStoreParameters(String parametersDefinitionName, String providerName) {

        super(parametersDefinitionName, providerName);

    }

    /**

     * Set <code>JDBC Driver class name</code> parameter

     *

     * @param className

     */

    public void setJDBCDriverClassName(String className) {

        this.setDynValue(JDBC_DRIVER_CLASS_PARAMTER_NAME, className);

    }

    public String getJDBCDriverClassName() {

        return (String) this.getDynValue(JDBC_DRIVER_CLASS_PARAMTER_NAME);

    }

    public String getCatalog() {

        return (String) this.getDynValue(CATALOG_PARAMTER_NAME);

    }

    /**

     * Set <code>catalog</code> parameter

     *

     * @param className

     */

    public void setCatalog(String catalog) {

        this.setDynValue(CATALOG_PARAMTER_NAME, catalog);

    }

    public String getSchema() {

        return (String) this.getDynValue(SCHEMA_PARAMTER_NAME);

    }

    /**

     * Set <code>schema</code> parameter

     *

     * @param className

     */

    public void setSchema(String schema) {

        this.setDynValue(SCHEMA_PARAMTER_NAME, schema);

    }

    public String getUrl() {

        return (String) this.getDynValue(URL_PARAMTER_NAME);

    }

    @Override

    public int getBatchSize() {

        try {

            return (int) this.getDynValue(BATCH_SIZE_PARAMETER_NAME);

        } catch(Exception ex) {

            return DEFAULT_BATCH_SIZE;

        }

    }

    /**

     * Set <code>JDBC connection url</code> parameter

     *

     * @param url

     */

    public void setUrl(String url) {

        this.setDynValue(URL_PARAMTER_NAME, url);

    }

    /**

     * Return table <code>name</code> or <code>schema.tableName</code> if

     * <code>schema</code> parameter is set.

     *

     * @return

     */

    public String tableID() {

        if (this.getSchema() == null || this.getSchema() == "") {

            return escapeName(this.getTable());

        }

        return escapeName(this.getSchema()) + "." + escapeName(this.getTable());

    }

    protected String escapeName(String name) {

        return "\"".concat(name).concat("\"");

    }

    public String getSelectRole() {

        String value = (String) this.getDynValue("SelectRole");

        return StringUtils.defaultIfBlank(value, null);

    }

    public String getInsertRole() {

        String value = (String) this.getDynValue("InsertRole");

        return StringUtils.defaultIfBlank(value, null);

    }

    public String getUpdateRole() {

        String value = (String) this.getDynValue("UpdateRole");

        return StringUtils.defaultIfBlank(value, null);

    }

    public String getDeleteRole() {

        String value = (String) this.getDynValue("DeleteRole");

        return StringUtils.defaultIfBlank(value, null);

    }

    public String getTruncateRole() {

        String value = (String) this.getDynValue("TruncateRole");

        return StringUtils.defaultIfBlank(value, null);

    }

    public String getReferenceRole() {

        String value = (String) this.getDynValue("ReferenceRole");

        return StringUtils.defaultIfBlank(value, null);

    }

    public String getTriggerRole() {

        String value = (String) this.getDynValue("TriggerRole");

        return StringUtils.defaultIfBlank(value, null);

    }

    public String getAllRole() {

        String value = (String) this.getDynValue("AllRole");

        return StringUtils.defaultIfBlank(value, null);

    }

    public String getPostCreatingStatement() {

        String value = (String) this.getDynValue("PostCreatingStatement");

        return StringUtils.defaultIfBlank(value, null);

    }

    public void setSelectRole(String role) {

        this.setDynValue("SelectRole", role);

    }

    public void setInsertRole(String role) {

        this.setDynValue("InsertRole", role);

    }

    public void setUpdateRole(String role) {

        this.setDynValue("UpdateRole", role);

    }

    public void setDeleteRole(String role) {

        this.setDynValue("DeleteRole", role);

    }

    public void setTruncateRole(String role) {

        this.setDynValue("TruncateRole", role);

    }

    public void setReferenceRole(String role) {

        this.setDynValue("ReferenceRole", role);

    }

    public void setTriggerRole(String role) {

        this.setDynValue("TriggerRole", role);

    }

    public void setAllRole(String role) {

        this.setDynValue("AllRole", role);

    }

    public void setPostCreatingStatement(String statement) {

        this.setDynValue("PostCreatingStatement", statement);

    }

}

/**

 * 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.jdbc;

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

public class JDBCResourceParameters extends DBResourceParameters

		implements JDBCConnectionParameters {

    protected static final String PARAMETERS_DEFINITION_NAME = "JDBCResourceParameters";

	protected JDBCResourceParameters(String parametersDefinitionName, String providerName) {

		super(parametersDefinitionName,providerName);

	}

	public JDBCResourceParameters() {

		this(PARAMETERS_DEFINITION_NAME, JDBCResource.NAME);

	}

    public JDBCResourceParameters(String parametersDefinitionName, String providerName, 

    		String url, String host, Integer port,

			String dbName, String user, String password, 

			String jdbcDriverClassName) {

		this(parametersDefinitionName,providerName);

		this.setUrl(url);

		this.setHost(host);

		this.setPort(port);

		this.setDBName(dbName);

		this.setUser(user);

		this.setPassword(password);

		this.setJDBCDriverClassName(jdbcDriverClassName);

	}

    public JDBCResourceParameters(String url, String host, Integer port,

			String dbName,

			String user, String password, String jdbcDriverClassName) {

		this(PARAMETERS_DEFINITION_NAME, JDBCResource.NAME, url, host, port, dbName, user, password, jdbcDriverClassName);

	}

	public void setJDBCDriverClassName(String className) {

		this.setDynValue(JDBC_DRIVER_CLASS_PARAMTER_NAME, className);

	}

	public String getJDBCDriverClassName() {

		return (String) this.getDynValue(JDBC_DRIVER_CLASS_PARAMTER_NAME);

	}

	public String getCatalog() {

		return (String) this.getDynValue(CATALOG_PARAMTER_NAME);

	}

	public void setCatalog(String catalog) {

		this.setDynValue(CATALOG_PARAMTER_NAME, catalog);

	}

	public String getSchema() {

		return (String) this.getDynValue(SCHEMA_PARAMTER_NAME);

	}

	public void setSchema(String schema) {

		this.setDynValue(SCHEMA_PARAMTER_NAME, schema);

	}

	public String getUrl() {

		return (String) this.getDynValue(URL_PARAMTER_NAME);

	}

	public void setUrl(String url) {

		this.setDynValue(URL_PARAMTER_NAME, url);

	}

        @Override

        public int getBatchSize() {

            try {

                return (int) this.getDynValue(BATCH_SIZE_PARAMETER_NAME);

            } catch(Exception ex) {

                return DEFAULT_BATCH_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.jdbc;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.fmap.dal.DataServerExplorerParameters;

import org.gvsig.fmap.dal.serverexplorer.db.DBServerExplorerParameters;

public class JDBCServerExplorerParameters extends

		DBServerExplorerParameters implements JDBCConnectionParameters {

	public static final String PARAMETERS_DEFINITION_NAME = "JDBCServerExplorerParameters";

	public static final String SHOWINFORMATIONDBTABLES_PARAMTER_NAME = "showInformationDBTables";

	public JDBCServerExplorerParameters() {

		super(PARAMETERS_DEFINITION_NAME, JDBCServerExplorerBase.NAME);

	}

	public JDBCServerExplorerParameters(String parametersDefinitionName, String name) {

		super(parametersDefinitionName, name);

	}

	public void setJDBCDriverClassName(String className) {

		this.setDynValue(JDBC_DRIVER_CLASS_PARAMTER_NAME, className);

	}

	public String getJDBCDriverClassName() {

		return (String) this.getDynValue(JDBC_DRIVER_CLASS_PARAMTER_NAME);

	}

	public String getCatalog() {

		return (String) this.getDynValue(CATALOG_PARAMTER_NAME);

	}

	public void setCatalog(String catalog) {

		this.setDynValue(CATALOG_PARAMTER_NAME, catalog);

	}

	public String getSchema() {

		return (String) this.getDynValue(SCHEMA_PARAMTER_NAME);

	}

	public void setSchema(String schema) {

		this.setDynValue(SCHEMA_PARAMTER_NAME, schema);

	}

	public void setShowInformationDBTables(boolean show){

		this.setShowInformationDBTables(new Boolean(show));

	}

	public void setShowInformationDBTables(Boolean show) {

		this.setDynValue(SHOWINFORMATIONDBTABLES_PARAMTER_NAME, show);

	}

	public Boolean getShowInformationDBTables() {

		return (Boolean) this.getDynValue(SHOWINFORMATIONDBTABLES_PARAMTER_NAME);

	}

	public String getUrl() {

		return (String) this.getDynValue(URL_PARAMTER_NAME);

	}

	public void setUrl(String url) {

		this.setDynValue(URL_PARAMTER_NAME, url);

	}

        @Override

        public int getBatchSize() {

            try {

                return (int) this.getDynValue(BATCH_SIZE_PARAMETER_NAME);

            } catch(Exception ex) {

                return DEFAULT_BATCH_SIZE;

            }

        }

    @Override

    public boolean isTheSameServerExplorer(DataServerExplorerParameters params) {

        if(!(params instanceof JDBCServerExplorerParameters)){

            return false;

        }

        return StringUtils.equals(this.getUrl(), ((JDBCServerExplorerParameters)params).getUrl());

    }

}

/**

 * 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.jdbc;

import java.text.MessageFormat;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.fmap.dal.DataStoreParameters;

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

/**

 * Parameters class for JDBC generic provider

 *

 */

public class JDBCStoreParameters extends DBStoreParameters

		implements JDBCConnectionParameters {

	public static final String BATCHSIZE_PARAMTER_NAME = "batchSize";

//	public static final String PARAMETERS_DEFINITION_NAME = "JDBCStoreParameters";

	public JDBCStoreParameters() {

		super(

                        JDBCLibrary.NAME + "StoreParameters",

                        JDBCLibrary.NAME

                );

	}

	protected JDBCStoreParameters(String parametersDefinitionName) {

		super(

                        parametersDefinitionName,

                        JDBCLibrary.NAME

                );

	}

	public JDBCStoreParameters(String parametersDefinitionName, String providerName) {

		super(parametersDefinitionName,providerName);

	}

	public boolean isValid() {

		return this.getHost() != null;

	}

	public String getHost() {

		return (String) this.getDynValue(HOST_PARAMTER_NAME);

	}

	public Integer getPort() {

		return (Integer) this.getDynValue(PORT_PARAMTER_NAME);

	}

        @Override

        public int getBatchSize() {

            try {

                return (int) this.getDynValue(BATCH_SIZE_PARAMETER_NAME);

            } catch(Exception ex) {

                return DEFAULT_BATCH_SIZE;

            }

        }

	public String getDBName() {

		return (String) this.getDynValue(DBNAME_PARAMTER_NAME);

	}

	public String getUser() {

		return (String) this.getDynValue(USER_PARAMTER_NAME);

	}

	public String getPassword() {

		return (String) this.getDynValue(PASSWORD_PARAMTER_NAME);

	}

	public void setHost(String host) {

		this.setDynValue(HOST_PARAMTER_NAME, host);

	}

	public void setPort(int port) {

		this.setDynValue(PORT_PARAMTER_NAME, new Integer(port));

	}

	public void setPort(Integer port) {

		this.setDynValue(PORT_PARAMTER_NAME, port);

	}

	public void setDBName(String dbName) {

		this.setDynValue(DBNAME_PARAMTER_NAME, dbName);

	}

	public void setUser(String user) {

		this.setDynValue(USER_PARAMTER_NAME, user);

	}

	public void setPassword(String password) {

		this.setDynValue(PASSWORD_PARAMTER_NAME, password);

	}

	/**

	 * Set <code>JDBC Driver class name</code> parameter

	 *

	 * @param className

	 */

	public void setJDBCDriverClassName(String className) {

		this.setDynValue(JDBC_DRIVER_CLASS_PARAMTER_NAME, className);

	}

	public String getJDBCDriverClassName() {

		return (String) this.getDynValue(JDBC_DRIVER_CLASS_PARAMTER_NAME);

	}

	public String getCatalog() {

		return (String) this.getDynValue(CATALOG_PARAMTER_NAME);

	}

	/**

	 * Set <code>catalog</code> parameter

	 *

	 * @param className

	 */

	public void setCatalog(String catalog) {

		this.setDynValue(CATALOG_PARAMTER_NAME, catalog);

	}

	public String getSchema() {

		return (String) this.getDynValue(SCHEMA_PARAMTER_NAME);

	}

	/**

	 * Set <code>schema</code> parameter

	 *

	 * @param className

	 */

	public void setSchema(String schema) {

		this.setDynValue(SCHEMA_PARAMTER_NAME, schema);

	}

	public String getTable() {

		return (String) this.getDynValue(TABLE_PARAMTER_NAME);

	}

	public void setTable(String table) {

		this.setDynValue(TABLE_PARAMTER_NAME, table);

	}

	public String getFieldsString() {

		return (String) this.getDynValue(FIELDS_PARAMTER_NAME);

	}

	public String[] getFields() {

		String fields = (String) this.getDynValue(FIELDS_PARAMTER_NAME);

		if (fields == null) {

			return null;

		}

		// FIXME check for fields with spaces and special chars

		return fields.split(",");

	}

	public void setFields(String fields) {

		this.setDynValue(FIELDS_PARAMTER_NAME, fields);

	}

	public void setFields(String[] fields) {

		StringBuilder str = new StringBuilder();

		for (int i = 0; i < fields.length - 1; i++) {

			str.append(fields[i]);

			str.append(",");

		}

		str.append(fields[fields.length - 1]);

		this.setDynValue(FIELDS_PARAMTER_NAME, str.toString());

	}

	public String getSQL() {

		return (String) this.getDynValue(SQL_PARAMTER_NAME);

	}

	public void setSQL(String sql) {

		this.setDynValue(SQL_PARAMTER_NAME, sql);

	}

	public String getBaseFilter() {

		return (String) this.getDynValue(BASEFILTER_PARAMTER_NAME);

	}

	public void setBaseFilter(String initialFilter) {

		this.setDynValue(BASEFILTER_PARAMTER_NAME, initialFilter);

	}

	public String getBaseOrder() {

		return (String) this.getDynValue(BASEORDER_PARAMTER_NAME);

	}

	public void setBaseOrder(String order) {

		this.setDynValue(BASEORDER_PARAMTER_NAME, order);

	}

	public String getPkFieldsString() {

		return (String) this.getDynValue(PKFIELDS_PARAMTER_NAME);

	}

	public String[] getPkFields() {

		String fields = (String) this.getDynValue(PKFIELDS_PARAMTER_NAME);

		if (fields == null) {

			return null;

		}

		// FIXME check for fields with spaces and special chars

		return fields.split(",");

	}

	public void setPkFields(String fields) {

		this.setDynValue(PKFIELDS_PARAMTER_NAME, fields);

	}

	public void setPkFields(String[] fields) {

		StringBuilder str = new StringBuilder();

		for (int i = 0; i < fields.length - 1; i++) {

			str.append(fields[i]);

			str.append(",");

		}

		str.append(fields[fields.length - 1]);

		this.setDynValue(PKFIELDS_PARAMTER_NAME, str.toString());

	}

	/**

	 * Return table <code>name</code> or <code>schema.tableName</code> if

	 * <code>schema</code> parameter is set.

	 *

	 * @return

	 */

	public String tableID() {

		if (  StringUtils.isEmpty(this.getSchema()) ) {

            return escapeName(this.getTable());

		}

        return escapeName(this.getSchema()) + "." + escapeName(this.getTable());

	}

    protected String escapeName(String name) {

        return "\"".concat(name).concat("\"");

    }

	/**

	 * Compound a string that can identify the source

	 *

	 * @return

	 */

	public String getSourceId() {

		if (getTable() != null) {

			return MessageFormat.format(

					"provider={0}:url=\"{1}\":table=\"{2}\":user={3}:driverclass={4}", 

					this.getDataStoreName(),

					this.getUrl(),

					this.getTable(),

					this.getUser(),

					this.getJDBCDriverClassName()

			);

		}

		return MessageFormat.format(

				"provider={0}:url=\"{1}\":sql=\"{2}\":user={3}:driverclass={4}", 

				this.getDataStoreName(),

				this.getUrl(),

				this.getSQL(),

				this.getUser(),

				this.getJDBCDriverClassName()

		);

	}

	public String getUrl() {

		return (String) this.getDynValue(URL_PARAMTER_NAME);

	}

	/**

	 * Set <code>JDBC connection url</code> parameter

	 *

	 * @param url

	 */

	public void setUrl(String url) {

		this.setDynValue(URL_PARAMTER_NAME, url);

	}

    @Override

    public JDBCStoreParameters getCopy() {

        return (JDBCStoreParameters) super.getCopy();

    }

    public void setBatchSize(int batchSize) {

            this.setDynValue(BATCH_SIZE_PARAMETER_NAME, batchSize);

    }

    @Override

    public boolean isTheSameStore(DataStoreParameters params) {

        if(!(params instanceof JDBCStoreParameters)) {

            return false;

        } 

        if(!(StringUtils.equals(((JDBCStoreParameters)params).getTable(), this.getTable()))){

            return false;

        }

        if(!(StringUtils.equals(((JDBCStoreParameters)params).getSchema(), this.getSchema()))){

            return false;

        }

        if(!(StringUtils.equals(((JDBCStoreParameters)params).getSQL(), this.getSQL()))){

            return false;

        }

        return true;

    }

}

/**

 * 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.jdbc;

import org.gvsig.fmap.dal.serverexplorer.db.DBConnectionParameter;

/**

 * Interface JDBC Store Parameters

 *

 * @author jmvivo

 *

 */

public interface JDBCConnectionParameters extends DBConnectionParameter {

	/**

	 * Parameter name for <code>JDBC driver class name</code>

	 */

	public static final String JDBC_DRIVER_CLASS_PARAMTER_NAME = "jdbcdriverclass";

	/**

	 * Parameter name for <code>catalog</code> 

	 */

	public static final String CATALOG_PARAMTER_NAME = "catalog";

	/**

	 * Parameter name for <code>schema</code> 

	 */

	public static final String SCHEMA_PARAMTER_NAME = "schema";

	/**

	 * Parameter name for <code>JDBC connection URL</code>

	 */

	public static final String URL_PARAMTER_NAME = "url";

	public static final String BATCH_SIZE_PARAMETER_NAME = "batchSize";

        public static final int DEFAULT_BATCH_SIZE = 500;

	/**

	 * Return <code>JDBC driver class name</code> parameter

	 *

	 * @return

	 */

	public String getJDBCDriverClassName();

	/**

	 * Return <code>catalog</code> parameter

	 *

	 * @return

	 */

	public String getCatalog();

	/**

	 * Return <code>schema</code> parameter

	 *

	 * @return

	 */

	public String getSchema();

	/**

	 * Return <code>JDBC connection URL</code> parameter

	 * 

	 * @return

	 */

	public String getUrl();

        public int getBatchSize();

}