Application: gvSIG desktop » gvSIG projections

/* gvSIG. Sistema de Informaci?n Geogr?fica de la Generalitat Valenciana

 *

 * Copyright (C) 2006 Instituto de Desarrollo Regional and Generalitat Valenciana.

 *

 * 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., 59 Temple Place - Suite 330, Boston, MA  02111-1307,USA.

 *

 */

package es.idr.teledeteccion.connection;

import java.sql.Connection;

import java.sql.SQLException;

import java.sql.Statement;

import org.gvsig.crs.CrsFactory;

import org.hsqldb.jdbc.jdbcDataSource;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import es.idr.teledeteccion.connection.epsg.HSQLDataSource;

/**

 * Clase para la conexi?n con la base de datos de hsqldb.

 * Establece el driver necesario, as? como la cadena de

 * conexi?n a la base de datos de la EPSG y la IAU2000

 *

 * @author Jos? Luis G?mez Mart?nez (jolugomar@gmail.com)

 *

 */

public class EpsgConnection extends jdbcDataSource {

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

    Connection connect = null;

    String connectionType = null;

    public EpsgConnection() {

        /*        try {

         Class.forName("org.hsqldb.jdbcDriver");

         } catch (ClassNotFoundException e) {

         logger.error("Can't create EpsgConnection",e); 

         }*/

    }

    private void setConnection(Connection connection, String type) {

        this.connect = connection;

        this.connectionType = type;

        logger.debug("Created connection to '"+connectionType+"'.");

    }

    public void setConnectionEPSG() {

        HSQLDataSource ds = new HSQLDataSource();

        try {

            setConnection(ds.getConnection(), "EPSG");

        } catch (SQLException e) {

            logger.warn("Cant get conection from HSQLDataSource.", e);

        }

    }

    /**

     * Establece la conexi?n con la base de datos de la IAU2000

     *

     */

    public void setConnectionIAU2000() {

        String db = "jdbc:hsqldb:file:" + CrsFactory.getDataBaseFolder().getAbsolutePath() + "/iau2000";

        setDatabase(db);

        setUser("sa");

        try {

            setConnection(super.getConnection(),"IAU2000");

        } catch (SQLException e) {

            logger.warn("Can't get conection from database '" + db + "'.", e);

        }

    }

    /**

     * Establece la conexi?n con la base de datos de ESRI

     *

     */

    public void setConnectionEsri() {

        String db = "jdbc:hsqldb:file:" + CrsFactory.getDataBaseFolder().getAbsolutePath() + "/esri";

        setDatabase(db);

        setUser("sa");

        try {

            setConnection(super.getConnection(),"Esri");

        } catch (SQLException e) {

            logger.warn("Can't get conection from database '" + db + "'.", e);

        }

    }

    /**

     * Sets connection for CRS:* coordinate reference systems

     * such as CRS:84

     *

     */

    public void setConnectionNoAuth() {

        String db = "jdbc:hsqldb:file:" + CrsFactory.getDataBaseFolder().getAbsolutePath() + "/noauth";

        setDatabase(db);

        setUser("sa");

        try {

            setConnection(super.getConnection(),"NoAuth");

        } catch (SQLException e) {

            logger.warn("Can't get conection from database '" + db + "'.", e);

        }

    }

    /**

     * Establece la conexi?n con la base de datos de USR

     *

     */

    public void setConnectionUsr() {

        String db = "jdbc:hsqldb:file:" + CrsFactory.getDataBaseFolder().getAbsolutePath() + "/usr";

        setDatabase(db);

        setUser("sa");

        try {

            setConnection(super.getConnection(),"Usr");

        } catch (SQLException e) {

            logger.warn("Can't get conection from database '" + db + "'.", e);

        }

    }

    public Connection getConnection() {

        return connect;

    }

    public void close() throws SQLException {

        try {

            connect.close();    // if there are no other open connection

            logger.debug("Shutdown connection to '" + connectionType + "' database.");

        } catch (Exception ex) {

            logger.warn("Can't shutdown the conexion.",ex);

        }

    }

    public void shutdown() throws SQLException {

        // db writes out to files and performs clean shuts down

        // otherwise there will be an unclean shutdown

        // when program ends

        try {

            Statement st = connect.createStatement();

            st.execute("SHUTDOWN");

            connect.close();    // if there are no other open connection

            logger.debug("Shutdown connection to '" + connectionType + "' database.");

        } catch (Exception ex) {

            logger.warn("Can't shutdown the conexion.",ex);

        }

    }

    public synchronized void update(String expression) throws SQLException {

        Statement st = null;

        st = connect.createStatement();

        int i = st.executeUpdate(expression);

        if ( i == -1 ) {

            logger.warn("db("+connectionType+")  error in statement: " + expression);

        }

        st.close();

    }

}