Application: gvSIG desktop » gvSIG projections

/**

 * gvSIG. Desktop Geographic Information System.

 *

 * Copyright (C) 2007-2018 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 2

 * 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.geotools.proj.esri;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.text.ParseException;

import java.util.Hashtable;

import java.util.LinkedHashSet;

import java.util.Map;

import java.util.Set;

import java.util.regex.Matcher;

import java.util.regex.Pattern;

import javax.sql.DataSource;

import org.geotools.factory.Hints;

import org.geotools.metadata.iso.citation.Citations;

import org.geotools.referencing.factory.epsg.DirectEpsgFactory;

import org.geotools.referencing.factory.epsg.FactoryUsingAnsiSQL;

import org.geotools.referencing.wkt.Parser;

import org.geotools.resources.i18n.ErrorKeys;

import org.geotools.resources.i18n.Errors;

import org.opengis.metadata.citation.Citation;

import org.opengis.referencing.FactoryException;

import org.opengis.referencing.IdentifiedObject;

import org.opengis.referencing.NoSuchAuthorityCodeException;

import org.opengis.referencing.crs.CRSFactory;

import org.opengis.referencing.crs.CompoundCRS;

import org.opengis.referencing.crs.CoordinateReferenceSystem;

import org.opengis.referencing.crs.GeocentricCRS;

import org.opengis.referencing.crs.GeographicCRS;

import org.opengis.referencing.cs.CartesianCS;

import org.opengis.referencing.cs.CoordinateSystem;

import org.opengis.referencing.cs.EllipsoidalCS;

import org.opengis.referencing.cs.SphericalCS;

import org.opengis.referencing.cs.VerticalCS;

import org.opengis.referencing.datum.EngineeringDatum;

import org.opengis.referencing.datum.GeodeticDatum;

import org.opengis.referencing.datum.VerticalDatum;

import org.opengis.referencing.operation.Conversion;

import org.opengis.referencing.operation.CoordinateOperation;

import org.opengis.referencing.operation.Projection;

/**

 * A factory to retrieve and create CRSs from ESRI HSQL database.

 *

 * @author Cesar Martinez Izquierdo

 */

class EsriFactoryUsingHSQL extends DirectEpsgFactory {

    /** Cache of parsed CoordinateReferenceSystem WKT by ESRI_NUMBER */

    private Hashtable cache = new Hashtable();

    /** Constructs the factory for the given connection to the HSQL database. */

    public EsriFactoryUsingHSQL(final Hints hints, final Connection connection) {

        super(hints, connection);

    }

    public EsriFactoryUsingHSQL(final Hints hints, final DataSource dataSource) {

        super(hints, dataSource);

    }

    @Override

    public String adaptSQL(String query) {

        return query;

    }

    /**

     * Shutdown the HSQL database engine. This method is invoked automatically at JVM shutdown time

     * just before to close the connection.

     */

    protected void shutdown(final boolean active) throws SQLException {

        if (active) {

            final Statement statement = getConnection().createStatement();

            statement.execute("SHUTDOWN");

            statement.close();

        }

        super.shutdown(active);

    }

    @Override

    public Citation getAuthority() {

            return Citations.ESRI;

    }

    @Override

        public synchronized CoordinateReferenceSystem createCoordinateReferenceSystem(String code) throws FactoryException {

                String wkt = null;

                String ESRI_NUMBER = code.substring(code.indexOf(":")+1, code.length());

                int cod = Integer.parseInt(ESRI_NUMBER);

                if( cache.contains( ESRI_NUMBER ) ){

            Object value = cache.get( ESRI_NUMBER );

            if( value instanceof Throwable ){

                throw new FactoryException( "WKT for "+code+" could not be parsed", (Throwable) value );

            }

            if( value instanceof CoordinateReferenceSystem){

                return (CoordinateReferenceSystem) value;

            }

        }

                ResultSet result = null;

                try {

            String sentence = "SELECT ESRI_WKT"

            + " FROM ESRI"

            + " WHERE ESRI_CODE = ?";

            String codeStr = code.substring(code.indexOf(":")+1, code.length());

            int codeInt = Integer.parseInt(codeStr);

                PreparedStatement st = null;

                st = getConnection().prepareStatement(sentence);

                st.setInt(1, codeInt);

                        result = st.executeQuery();

                        st.close();

                if (result.next()) {

                wkt    = result.getString("esri_wkt");

                if( wkt.indexOf( cod ) == -1){

                        wkt = wkt.trim();

                        wkt = wkt.substring(0, wkt.length()-1 );

                        wkt += ",AUTHORITY[\"ESRI\",\""+cod+"\"]]";

                }

                Parser parser = new Parser();

                return parser.parseCoordinateReferenceSystem(wkt);

            }

        } catch (SQLException exception) {

                throw new FactoryException(exception);

        } catch (ParseException exception) {

                throw new FactoryException(exception);

        } finally {

                if (result!=null) {

                        try {

                                        result.close();

                                } catch (SQLException e) {}

                }

        };

        throw new NoSuchAuthorityCodeException("No such authority code", "ESRI", code);

        }

    @Override

    public Set<String> getAuthorityCodes(Class<? extends IdentifiedObject> type) throws FactoryException {

            LinkedHashSet<String> codes = new LinkedHashSet<String>(); 

                ResultSet result = null;

                try {

            String sentence = "SELECT ESRI_CODE"

            + " FROM ESRI ORDER BY ESRI_CODE ASC";

                Statement st = null;

                st = getConnection().createStatement();

                result = st.executeQuery(sentence);

                        st.close();

                while (result.next()) {

                int code = result.getInt(1);

                codes.add(Integer.toString(code));

            }

        } catch (SQLException exception) {

                throw new FactoryException(exception);

        } finally {

                if (result!=null) {

                        try {

                                        result.close();

                                } catch (SQLException e) {}

                }

        };

            return codes;

    }

}