Application: gvSIG desktop

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

 *

 * Copyright (C) 2004 IVER T.I. 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.

 *

 * For more information, contact:

 *

 *  Generalitat Valenciana

 *   Conselleria d'Infraestructures i Transport

 *   Av. Blasco Ib??ez, 50

 *   46010 VALENCIA

 *   SPAIN

 *

 *      +34 963862235

 *   gvsig@gva.es

 *      www.gvsig.gva.es

 *

 *    or

 *

 *   IVER T.I. S.A

 *   Salamanca 50

 *   46005 Valencia

 *   Spain

 *

 *   +34 963163400

 *   dac@iver.es

 */

package com.iver.cit.gvsig.fmap.layers;

import java.awt.geom.Rectangle2D;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import com.hardcode.driverManager.DriverLoadException;

import com.hardcode.gdbms.engine.data.DataSource;

import com.hardcode.gdbms.engine.data.DataSourceFactory;

import com.hardcode.gdbms.engine.data.NoSuchTableException;

import com.hardcode.gdbms.engine.data.ReadDriver;

import com.iver.cit.gvsig.fmap.DriverException;

import com.iver.cit.gvsig.fmap.core.FShape;

import com.iver.cit.gvsig.fmap.core.IGeometry;

import com.iver.cit.gvsig.fmap.drivers.DriverIOException;

import com.iver.cit.gvsig.fmap.drivers.IFeatureIterator;

import com.iver.cit.gvsig.fmap.drivers.VectorialDatabaseDriver;

/**

 * Adapta un driver de base de datos vectorial a la interfaz vectorial,

 * manteniendo adem?s el estado necesario por una capa vectorial de base de

 * datos (par?metros de la conexi?n)

 */

public class VectorialDBAdapter extends VectorialAdapter {

    private int numReg=-1;

    private DataSource ds = null;

        /**

         * incrementa el contador de las veces que se ha abierto el fichero.

         * Solamente cuando el contador est? a cero pide al driver que conecte con

         * la base de datos

         */

        public void start() {

        }

        /**

         * decrementa el contador de n?mero de aperturas y cuando llega a cero pide

         * al driver que cierre la conexion con el servidor de base de datos

         */

        public void stop() {

            ((VectorialDatabaseDriver)driver).close();

        }

        /**

         * @return devuelve la Conexi?n a la base de datos, para que 

         * el usuario pueda hacer la consulta que quiera, si lo desea.

         * Por ejemplo, esto puede ser ?til para abrir un cuadro de dialogo

         * avanazado y lanzar peticiones del tipo "Devuelveme un buffer

         * a las autopistas", y con el resultset que te venga, escribir

         * un shape, o cosas as?.

         */

        public Connection getConnection()

        {

            return ((VectorialDatabaseDriver)driver).getConnection();

        }

        public IFeatureIterator getFeatureIterator(String sql) throws DriverException

        {

            return ((VectorialDatabaseDriver)driver).getFeatureIterator(sql);

        }

        public IFeatureIterator getFeatureIterator(Rectangle2D r, String strEPSG) throws DriverException

        {

            return ((VectorialDatabaseDriver)driver).getFeatureIterator(r, strEPSG);

        }

        public String getFields()

        {

            return ((VectorialDatabaseDriver)driver).getFields();            

        }

        public String getWhereClause()

        {

            return ((VectorialDatabaseDriver)driver).getWhereClause();

        }

        public String getTableName()

        {

            return ((VectorialDatabaseDriver)driver).getTableName();

        }

        /**

         * @see com.iver.cit.gvsig.fmap.layers.ReadableVectorial#getShape(int)

         */

        public IGeometry getShape(int index) throws DriverIOException {

            IGeometry geom = null;

            geom = ((VectorialDatabaseDriver)driver).getShape(index);

            return geom;

        }

        /**

         * @throws DriverException

         * @see com.iver.cit.gvsig.fmap.layers.ReadableVectorial#getShapeCount()

         */

        public int getShapeCount() throws DriverIOException {

                    if (numReg == -1)

                    {

                        try

                    {

                            Statement s = ((VectorialDatabaseDriver)driver).getConnection().createStatement();                    

                            ResultSet r = s.executeQuery("SELECT COUNT(*) AS NUMREG FROM " + getTableName());

                            r.next();

                            numReg = r.getInt(1);

                            System.err.println("numReg = " + numReg);

                    }

                        catch (SQLException e)

                        {

                            throw new DriverIOException(e);

                        }

                    }

            return numReg;

        }

        /**

         * @see com.iver.cit.gvsig.fmap.layers.ReadableVectorial#getFullExtent()

         */

        public Rectangle2D getFullExtent() {

            return ((VectorialDatabaseDriver)driver).getFullExtent();

        }

        /**

         * @see com.iver.cit.gvsig.fmap.layers.ReadableVectorial#getShapeType()

         */

        public int getShapeType() throws DriverIOException {

                return FShape.MULTI;

        }

        /**

         * @see com.iver.cit.gvsig.fmap.layers.VectorialAdapter#getRecordset()

         */

        public DataSource getRecordset(String name) throws DriverLoadException {

            if (driver instanceof ReadDriver)

            {

                        DataSourceFactory.addDataSource((ReadDriver)driver, name);

                        try {

                ds = DataSourceFactory.createRandomDataSource(name);

            } catch (NoSuchTableException e) {

                throw new DriverLoadException(e);

            }

            }

                return ds;

        }

}