Application: gvSIG desktop

/**

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

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

/**

 * Parameters class for JDBC generic provider

 *

 */

public class JDBCStoreParametersBase extends AbstractDBStoreParameters

                implements JDBCStoreParameters {

        public JDBCStoreParametersBase() {

                super(

                        JDBCLibrary.STOREPARAMETERS_NAME,

                        JDBCLibrary.NAME

                );

        }

        protected JDBCStoreParametersBase(String parametersDefinitionName) {

                super(

                        parametersDefinitionName,

                        JDBCLibrary.NAME

                );

        }

        public JDBCStoreParametersBase(String parametersDefinitionName, String providerName) {

                super(parametersDefinitionName,providerName);

        }

    @Override

        public boolean isValid() {

                return this.getHost() != null;

        }

    @Override

        public String getHost() {

                return (String) this.getDynValue(HOST_PARAMTER_NAME);

        }

    @Override

        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;

            }

        }

    @Override

        public String getDBName() {

                return (String) this.getDynValue(DBNAME_PARAMTER_NAME);

        }

    @Override

        public String getUser() {

                return (String) this.getDynValue(USER_PARAMTER_NAME);

        }

    @Override

        public String getPassword() {

                return (String) this.getDynValue(PASSWORD_PARAMTER_NAME);

        }

    @Override

        public void setHost(String host) {

                this.setDynValue(HOST_PARAMTER_NAME, host);

        }

    @Override

        public void setPort(int port) {

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

        }

    @Override

        public void setPort(Integer port) {

                this.setDynValue(PORT_PARAMTER_NAME, port);

        }

    @Override

        public void setDBName(String dbName) {

                this.setDynValue(DBNAME_PARAMTER_NAME, dbName);

        }

    @Override

        public void setUser(String user) {

                this.setDynValue(USER_PARAMTER_NAME, user);

        }

    @Override

        public void setPassword(String password) {

                this.setDynValue(PASSWORD_PARAMTER_NAME, password);

        }

        /**

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

         *

         * @param className

         */

    @Override

        public void setJDBCDriverClassName(String className) {

                this.setDynValue(JDBC_DRIVER_CLASS_PARAMTER_NAME, className);

        }

    @Override

        public String getJDBCDriverClassName() {

                return (String) this.getDynValue(JDBC_DRIVER_CLASS_PARAMTER_NAME);

        }

    @Override

        public String getCatalog() {

                return (String) this.getDynValue(CATALOG_PARAMTER_NAME);

        }

        /**

         * Set <code>catalog</code> parameter

         *

         * @param className

         */

    @Override

        public void setCatalog(String catalog) {

                this.setDynValue(CATALOG_PARAMTER_NAME, catalog);

        }

    @Override

        public String getSchema() {

                return (String) this.getDynValue(SCHEMA_PARAMTER_NAME);

        }

        /**

         * Set <code>schema</code> parameter

         *

         * @param className

         */

    @Override

        public void setSchema(String schema) {

                this.setDynValue(SCHEMA_PARAMTER_NAME, schema);

        }

    @Override

        public String getTable() {

                return (String) this.getDynValue(TABLE_PARAMTER_NAME);

        }

    @Override

        public void setTable(String table) {

                this.setDynValue(TABLE_PARAMTER_NAME, table);

        }

    @Override

        public String getFieldsString() {

                return (String) this.getDynValue(FIELDS_PARAMTER_NAME);

        }

    @Override

        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(",");

        }

    @Override

        public void setFields(String fields) {

                this.setDynValue(FIELDS_PARAMTER_NAME, fields);

        }

    @Override

        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());

        }

    @Override

        public String getSQL() {

                return (String) this.getDynValue(SQL_PARAMTER_NAME);

        }

    @Override

        public void setSQL(String sql) {

                this.setDynValue(SQL_PARAMTER_NAME, sql);

        }

    @Override

        public String getBaseFilter() {

                return (String) this.getDynValue(BASEFILTER_PARAMTER_NAME);

        }

    @Override

        public void setBaseFilter(String initialFilter) {

                this.setDynValue(BASEFILTER_PARAMTER_NAME, initialFilter);

        }

    @Override

        public String getBaseOrder() {

                return (String) this.getDynValue(BASEORDER_PARAMTER_NAME);

        }

    @Override

        public void setBaseOrder(String order) {

                this.setDynValue(BASEORDER_PARAMTER_NAME, order);

        }

    @Override

        public String getPkFieldsString() {

                return (String) this.getDynValue(PKFIELDS_PARAMTER_NAME);

        }

    @Override

        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(",");

        }

    @Override

        public void setPkFields(String fields) {

                this.setDynValue(PKFIELDS_PARAMTER_NAME, fields);

        }

    @Override

        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

         */

//    @Override

//        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()

//                );

//        }

    @Override

        public String getUrl() {

                return (String) this.getDynValue(URL_PARAMTER_NAME);

        }

        /**

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

         *

         * @param url

         */

    @Override

        public void setUrl(String url) {

                this.setDynValue(URL_PARAMTER_NAME, url);

        }

    @Override

    public JDBCStoreParametersBase getCopy() {

        return (JDBCStoreParametersBase) super.getCopy();

    }

    @Override

    public void setBatchSize(int batchSize) {

            this.setDynValue(BATCH_SIZE_PARAMETER_NAME, batchSize);

    }

    @Override

    public boolean isTheSameStore(DataStoreParameters params) {

        if(!(params instanceof JDBCStoreParametersBase)) {

            return false;

        } 

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

            return false;

        }

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

            return false;

        }

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

            return false;

        }

        return true;

    }

    @Override

    public String getSourceId() {

        StringBuilder builder = new StringBuilder();

        builder.append(this.getTable());

        builder.append("(");

        boolean needComma = false;

        if( StringUtils.isNotBlank(this.getHost()) ) {

            builder.append("host=");

            builder.append(this.getHost());

            needComma = true;

        }

        if( this.getPort()>0 ) {

            if (needComma ) {

                builder.append(", ");

            }

            builder.append("port=");

            builder.append(this.getPort());

            needComma = true;

        }

        if( StringUtils.isNotBlank(this.getDBName()) ) {

            if (needComma ) {

                builder.append(", ");

            }

            builder.append("db=");

            builder.append(this.getDBName());

            needComma = true;

        }

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

            if (needComma ) {

                builder.append(", ");

            }

            builder.append("schema=");

            builder.append(this.getSchema());

            needComma = true;

        }

        builder.append(")");

        return builder.toString();

  }

}