Application: gvSIG desktop

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

import java.io.File;

import java.util.Properties;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.fmap.dal.DataParameters;

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

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

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

public class H2SpatialConnectionParametersHelper {

    private final JDBCConnectionParameters parameters;

    private static final String DATABASE_FILE = "database_file";

    private static final String MAXSECONDSIDLE = "MaxSecondsIdle";

    private static final String SERVERPORT = "ServerPort";

    private static final String SERVERALLOWOTHERS = "ServerAllowOthers";

    private static final String SPLIT = "Split";

    private static final String MAINTAINGLOBALCONNECTION = "maintainGlobalConnection";

    public H2SpatialConnectionParametersHelper(JDBCConnectionParameters parameters) {

        this.parameters = parameters;

    }

    public String getUrl() {

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

        if( StringUtils.isBlank(url) ) {

            url = H2SpatialUtils.getConnectionURL((H2SpatialConnectionParameters) this.parameters);

            this.setDynValue(JDBCConnectionParameters.URL_PARAMTER_NAME, url);

        }

        return url;

    }

    public void validate() throws ValidateDataParametersException {

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

            this.setDynValue(JDBCConnectionParameters.JDBC_DRIVER_CLASS_PARAMTER_NAME,

                H2SpatialHelper.H2SPATIAL_JDBC_DRIVER

            );

        }

        if( getFile() == null ) {

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

                throw new ValidateDataParametersException();

            } else {

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

            }

        } else {

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

            if( StringUtils.isEmpty(dbName) ) {

                dbName = getDbNameFromFile(getFile());

                this.setDynValue(

                    JDBCConnectionParameters.DBNAME_PARAMTER_NAME,

                    dbName.toUpperCase()

                );

            }

        }        

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

            String url = H2SpatialUtils.getConnectionURL((H2SpatialConnectionParameters) this.parameters);

            this.setDynValue(JDBCConnectionParameters.URL_PARAMTER_NAME, url);

        }

    }

    private Object getDynValue(String name) {

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

    }

    private void setDynValue(String name, Object value) {

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

    }

    public int getMaxSecondsIdle() {

        Integer x = (Integer) this.getDynValue(MAXSECONDSIDLE);

        if( x == null ) {

            return -1;

        }

        return x;

    }

    public int getServerPort() {

        Integer x = (Integer) this.getDynValue(SERVERPORT);

        if( x == null ) {

            return -1;

        }

        return x;

    }

    public boolean getServerAllowOthers() {

        Boolean x = (Boolean) this.getDynValue(SERVERALLOWOTHERS);

        if( x == null ) {

            return false;

        }

        return x;

    }

    public File getFile() {

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

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

            && f != null ) {

            String dbname = getDbNameFromFile(f);

            this.setDynValue(DBParameters.DBNAME_PARAMTER_NAME, dbname);

        }

        return f;

    }

    public void setFile(File database) {

        this.setDynValue(DATABASE_FILE, database);

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

            && database != null ) {

            String dbname = getDbNameFromFile(database);

            this.setDynValue(DBParameters.DBNAME_PARAMTER_NAME, dbname);

        }

    }

    public Properties getProperties() {

        Properties props = new Properties();

        return props;

    }

    private String getDbNameFromFile(File f) {

        String name = H2SpatialUtils.removeH2FileNameExtension(f.getName());

        return name;

    }

    public String getServerPortAsString() {

        int port = this.getServerPort();

        if( port<=0 ) {

            return null;

        }

        String port_s = String.valueOf(port);

        return port_s;

    }

    public int getSplitSize() {

        try {

            Number size = (Number) this.getDynValue(SPLIT);

            if (size == null || size.intValue() < 1) {

                return 0;

            }

            return size.intValue();

        } catch (Exception ex) {

            return 0;

        }

    }

    public boolean getMaintainGlobalConnection() {

        Boolean x = (Boolean) this.getDynValue(MAINTAINGLOBALCONNECTION);

        if( x == null ) {

            return false;

        }

        return x;

    }

}