Application: gvSIG desktop

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

import java.sql.ResultSet;

import java.sql.Statement;

import java.util.HashMap;

import java.util.Map;

import org.apache.commons.lang3.StringUtils;

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

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

public class JDBCSRSsBase implements JDBCSRSs {

    protected Map<String,String> database2applicationAbbrev;

    protected Map<String,String> applicationAbbrev2database;

    protected JDBCHelper helper;

    public JDBCSRSsBase(JDBCHelper helper) {

        this.helper = helper;

        this.applicationAbbrev2database = new HashMap<>();

        this.database2applicationAbbrev = new HashMap<>();

    }

    public void add(String databaseCode, String applicationAbbrev) {

        this.applicationAbbrev2database.put(applicationAbbrev, databaseCode);

        this.database2applicationAbbrev.put(databaseCode, applicationAbbrev);

    }

    public String getDatabaseCode(String applicationAbbrev) {

        if( this.hasApplicationAbbrev(applicationAbbrev) ) {

            return this.applicationAbbrev2database.get(applicationAbbrev);

        }

        String databaseCode = this.searchDatabaseCode(applicationAbbrev);

        if( StringUtils.isEmpty(databaseCode) ) {

            return null;

        }

        this.add(databaseCode, applicationAbbrev);

        return databaseCode;

    }

    public String getApplicationAbbrev(String databaseCode) {

        if( this.hasDatabaseCode(databaseCode) ) {

            return this.database2applicationAbbrev.get(databaseCode);

        }

        String applicationAbbrev = this.searchApplicationAbbrev(databaseCode);

        if( StringUtils.isEmpty(applicationAbbrev) ) {

            return null;

        }

        this.add(databaseCode, applicationAbbrev);

        return applicationAbbrev;

    }

    public boolean hasDatabaseCode(String databaseCode) {

        return this.database2applicationAbbrev.containsKey(databaseCode);

    }

    public boolean hasApplicationAbbrev(String applicationAbbrev) {

        return this.applicationAbbrev2database.containsKey(applicationAbbrev);

    }

    protected String searchDatabaseCode(String applicationAbbrev) {

        // Initialize sql only for debugging purposes

        String sql = "select srid, auth_name, auth_srid from spatial_ref_sys where auth_name/auth_srid is '"+applicationAbbrev+"'.";

        try {

            String[] s = applicationAbbrev.split(applicationAbbrev);

            sql = "select srid, auth_name, auth_srid from spatial_ref_sys where auth_name = '" + s[0] +"' and auth_srid = '"+s[1]+"' ";

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

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

            if ( rs.next() ) {

                int srid = rs.getInt("srid");

                return String.valueOf(srid);

            }            

            return null;

        } catch (Throwable ex) {

            throw new RuntimeException("Problems with SQL '"+sql+"'.",ex);

        }

    }

    protected String searchApplicationAbbrev(String databaseCode) {

        String sql = "select srid, auth_name, auth_srid from spatial_ref_sys where srid = " + databaseCode;

        try {

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

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

            if ( rs.next() ) {

                int auth_code = rs.getInt("auth_srid");

                String auth_name = rs.getString("auth_name");

                return auth_name + ":" + auth_code;

            }            

            return null;

        } catch (Throwable ex) {

            throw new RuntimeException("Problems with SQL '"+sql+"'.",ex);

        }

    }

}