Application: gvSIG desktop

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

		private IVectorialDatabaseDriver dbDriver;

			dbDriver = (IVectorialDatabaseDriver) getOriginalDriver();

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

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

                ((IVectorialDatabaseDriver)driver).open();

	    ((IVectorialDatabaseDriver)driver).close();

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

        return ((IVectorialDatabaseDriver)driver).getFeatureIterator(r, strEPSG, alphaNumericFieldsNeeded);

	    return ((IVectorialDatabaseDriver)driver).getFields();

	    return ((IVectorialDatabaseDriver)driver).getWhereClause();

	    return ((IVectorialDatabaseDriver)driver).getTableName();

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

		return ((IVectorialDatabaseDriver)driver).getShapeType();

        return ((IVectorialDatabaseDriver)driver).getLyrDef();

		return ((IVectorialDatabaseDriver) driver).getRowIndexByFID(feat); 

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

 *

 * Copyright (C) 2006 Prodevelop 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

 *

 *   Prodevelop Integraci?n de Tecnolog?as SL

 *   Conde Salvatierra de ?lava , 34-10

 *   46004 Valencia

 *   Spain

 *

 *   +34 963 510 612

 *   +34 963 510 968

 *   gis@prodevelop.es

 *   http://www.prodevelop.es

 */

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

import com.hardcode.gdbms.engine.instruction.FieldNotFoundException;

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

import com.iver.cit.gvsig.fmap.crs.CRSFactory;

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

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

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

import com.iver.cit.gvsig.fmap.rendering.LegendFactory;

import com.iver.cit.gvsig.fmap.rendering.VectorialLegend;

import com.iver.utiles.XMLEntity;

import org.cresques.cts.IProjection;

public class FLayerVectorialDB extends FLyrVect {

    private boolean loaded = false;

    private IVectorialDatabaseDriver dbDriver = null;

    /* Esto deberia ir en el FLyrDefault */

    public void setProjectionByName(String projectionName)

        throws Exception {

        IProjection proj = CRSFactory.getCRS(projectionName);

        if (proj == null) {

            throw new Exception("No se ha encontrado la proyeccion: " +

                projectionName);

        }

        this.setProjection(proj);

    }

    public void setDriver(IVectorialDatabaseDriver driver) {

        this.dbDriver = driver;

    }

    public void setDriverByName(String driverName) {

        this.setDriver((IVectorialDatabaseDriver) LayerFactory.getDM()

                                                             .getDriver(driverName));

    }

    public IVectorialDatabaseDriver getDriver() {

        return this.dbDriver;

    }

    /* FIXME: esto tendria que tener declarado un throws de algo*/

    public void wakeUp() {

        if (!loaded) {

            try {

                this.load();

            }

            catch (DriverIOException e) {

                // TODO Auto-generated catch block

                e.printStackTrace();

            }

        }

    }

    public void load() throws DriverIOException {

        if ((this.getName() == null) || (this.getName().length() == 0)) {

            this.setAvailable(false);

            //TODO: traducir???

            throw new DriverIOException("No se ha especificado nombre de capa");

        }

        if (this.dbDriver == null) {

            this.setAvailable(false);

            //TODO: traducir???

            throw new DriverIOException("No se ha especificado driver");

        }

        if (this.getProjection() == null) {

            this.setAvailable(false);

            //TODO: traducir???

            throw new DriverIOException("No se ha especificado proyeccion");

        }

        try {

            ((IVectorialDatabaseDriver) this.dbDriver).load();

        }

        catch (Exception e) {

            this.setAvailable(false);

            throw new DriverIOException(e);

        }

        try {

            VectorialDBAdapter dbAdapter = new VectorialDBAdapter();

            dbAdapter.setDriver(this.dbDriver);

            this.setSource(dbAdapter);

        }

        catch (Exception e) {

            this.setAvailable(false);

            throw new DriverIOException(e);

        }

        try {

            this.putLoadSelection();

            this.putLoadLegend();

            this.initializeLegendDefault();

        }

        catch (Exception e) {

            this.setAvailable(false);

            //TODO: traducir???

            throw new DriverIOException(e);

        }

        this.cleanLoadOptions();

    }

    /* Esto deberia ir en FLyrVect */

    private void initializeLegendDefault()

        throws FieldNotFoundException, DriverException {

        if (this.getLegend() == null) {

            if (this.getRecordset().getDriver() instanceof WithDefaultLegend) {

                WithDefaultLegend aux = (WithDefaultLegend) this.getRecordset()

                                                                .getDriver();

                this.setLegend((VectorialLegend) aux.getDefaultLegend());

            }

            else {

                this.setLegend(LegendFactory.createSingleSymbolLegend(

                        this.getShapeType()));

            }

        }

    }

    public void setXMLEntity(XMLEntity xml) throws XMLException {

        IProjection proj = null;

        if (xml.contains("proj")) {

            proj = CRSFactory.getCRS(xml.getStringProperty("proj"));

        }

        else {

            proj = this.getMapContext().getViewPort().getProjection();

        }

        this.setName(xml.getName());

        this.setProjection(proj);

        String driverName = xml.getStringProperty("db");

        IVectorialDatabaseDriver driver;

        try {

            driver = (IVectorialDatabaseDriver) LayerFactory.getDM()

                                                           .getDriver(driverName);

            //Hay que separar la carga de los datos del XMLEntity del load.

            driver.setXMLEntity(xml.getChild(2));

            this.setDriver(driver);

        }

        catch (Exception e) {

            throw new XMLException(e);

        }

        super.setXMLEntityNew(xml);

    }

}

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

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

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

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

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

		} else if (d instanceof IVectorialJDBCDriver) {

			IVectorialDatabaseDriver driver, IProjection proj) {

	public static FLayer createLayer(IVectorialDatabaseDriver driver,

	public static FLayer createDBLayer(IVectorialDatabaseDriver driver,

	public static FLayer createDisconnectedDBLayer(IVectorialDatabaseDriver driver,

			throws DBException, IOException, DriverIOException,

		String dsName=null;

		try {

			dsName = dataSourceFactory.createTable(database,

					ds.getPKNames(), fieldNames, types);

		} catch (SQLException e) {

			throw new DBException(e);

		}

		IVectorialJDBCDriver cacheDriver = (IVectorialJDBCDriver) LayerFactory

		IConnection conn=ConnectionFactory.createConnection("jdbc:hsqldb:file:" + database, "sa", "");

		cacheDriver.setData(conn, lyrDef);

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

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

                    IVectorialDatabaseDriver driver;

                        driver = (IVectorialDatabaseDriver) LayerFactory.getDM().getDriver(driverName);

//                        if (driver instanceof DefaultJDBCDriver) {

								((IVectorialDatabaseDriver) driver).load();

								if (((IVectorialDatabaseDriver) driver)

//						} else {

//							try{

//								((IVectorialDatabaseDriver)driver).load();

//								loadOk=true;

//							}catch (Exception e) {

//								loadOk=false;

//							}

//						}

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

	    ((IVectorialDatabaseDriver)driver).close();

            return ((IVectorialDatabaseDriver)driver).getShape(index);

	    return ((IVectorialDatabaseDriver)driver).getTableName();

				IVectorialDatabaseDriver d = (IVectorialDatabaseDriver) VectorialDisconnectedDBAdapter.this.driver;

package com.iver.cit.gvsig.fmap.drivers.db.utils;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.Iterator;

import org.apache.log4j.Logger;

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

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

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

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

import com.iver.cit.gvsig.fmap.layers.LayerFactory;

/**

 * Utility class to handle connections properly. One connection instance per

 * (db, user, gvsig session)

 *

 * @author jldominguez

 *

 */

public class SingleVectorialDBConnectionManager {

	private static Logger logger = Logger.getLogger(SingleVectorialDBConnectionManager.class.getName());

	private static SingleVectorialDBConnectionManager single_instance = null;

	private HashMap connections = new HashMap();

	/**

	 * Non-public to avoid unwanted instances.

	 *

	 */

	protected SingleVectorialDBConnectionManager() {

	}

	/**

	 * Singleton model to keep single instances.

	 *

	 * @return single instance

	 */

	public static SingleVectorialDBConnectionManager instance() {

		if (single_instance == null) {

			single_instance = new SingleVectorialDBConnectionManager();

		}

		return single_instance;

	}

	/**

	 * Utility metho to find a connection with its parameters

	 * given the connection object.

	 *

	 * @param co the connection object

	 * @return

	 */

	public ConnectionWithParams findConnection(IConnection co) {

		Iterator iter = connections.keySet().iterator();

		while (iter.hasNext()) {

			String keyitem = (String) iter.next();

			ConnectionWithParams cwp = (ConnectionWithParams) connections.get(keyitem);

			if (cwp.getConnection() == co) {

				return cwp;

			}

		}

		return null;

	}

	/**

	 * Creates a new connection with its parameters if not created yet.

	 *

	 * @param _drvName driver name

	 * @param _user user name

	 * @param _pw password

	 * @param _name connection name

	 * @param _host host url

	 * @param _port port number as string

	 * @param _db database name

	 * @param _connected whether or not to connect the connection

	 * @return the connection with parameters object

	 * @throws SQLException

	 */

	public ConnectionWithParams getConnection (

			String _drvName,

			String _user,

			String _pw,

			String _name,

			String _host,

			String _port,

			String _db,

			boolean _connected

			) throws DBException {

		IVectorialDatabaseDriver drv = getInstanceFromName(_drvName);

		if (drv==null)return null;

		String conn_str = drv.getConnectionString(_host, _port, _db, _user, _pw);

		String key = getConnectionKey(_drvName, _host, _db, _port, _user);

		if (!connections.containsKey(key)) {

			ConnectionWithParams cwp = null;

			if (_connected) {

				IConnection new_connection = null;

				new_connection = ConnectionFactory.createConnection(conn_str, _user, _pw);

//				new_connection.setAutoCommit(false);

				cwp = new ConnectionWithParams(

						conn_str,

						new_connection,

						_drvName,

						_user,

						_pw,

						_name,

						_host,

						_port,

						_db,

						true);

			} else {

				cwp = new ConnectionWithParams(

						conn_str,

						null,

						_drvName,

						_user,

						null,

						_name,

						_host,

						_port,

						_db,

						false);

			}

			connections.put(key, cwp);

		}

		ConnectionWithParams _cwp = (ConnectionWithParams) connections.get(key);

		if (_cwp.getName().compareTo(_name) != 0) {

			// connections.remove(key);

			_cwp.setName(_name);

			connections.put(key, _cwp);

		}

		if ((!_cwp.isConnected()) && (_connected)) {

			_cwp.connect(_pw);

		}

		return _cwp;

	}

	/**

	 * Gets available open connections.

	 *

	 * @return array of open connections with parameters

	 */

	public ConnectionWithParams[] getConnectedConnections() {

		Iterator iter = connections.keySet().iterator();

		if (!iter.hasNext()) return null;

		ArrayList aux = new ArrayList();

		while (iter.hasNext()) {

			ConnectionWithParams _cwp =

				(ConnectionWithParams) connections.get(iter.next());

			if (_cwp.isConnected()) {

				aux.add(_cwp);

			}

		}

		ConnectionWithParams[] resp = new ConnectionWithParams[aux.size()];

		for (int i=0; i<aux.size(); i++) {

			resp[i] = (ConnectionWithParams) aux.get(i);

		}

		return resp;

	}

	/**

	 * Gets all available connections.

	 *

	 * @return array of all connections with parameters

	 */

	public ConnectionWithParams[] getAllConnections() {

		Iterator iter = connections.keySet().iterator();

		if (!iter.hasNext()) return null;

		ArrayList aux = new ArrayList();

		while (iter.hasNext()) {

			ConnectionWithParams _cwp =

				(ConnectionWithParams) connections.get(iter.next());

			aux.add(_cwp);

		}

		ConnectionWithParams[] resp = new ConnectionWithParams[aux.size()];

		for (int i=0; i<aux.size(); i++) {

			resp[i] = (ConnectionWithParams) aux.get(i);

		}

		return resp;

	}

	/**

	 * Removes connection with its params.

	 *

	 * @param _cwp connection with params to be removed

	 */

	private void removeConnectionWP(ConnectionWithParams _cwp) {

		ArrayList keysToRemove = new ArrayList();

		Iterator iter = connections.keySet().iterator();

		while (iter.hasNext()) {

			Object key = iter.next();

			ConnectionWithParams cwp = (ConnectionWithParams) connections.get(key);

			if (cwp == _cwp) {

				keysToRemove.add(key);

			}

		}

		for (int i=0; i<keysToRemove.size(); i++) {

			connections.remove(keysToRemove.get(i));

		}

	}

	/**

	 * Closes and removes a connection with params object

	 *

	 * @param _cwp

	 * @return whether the connection was actually closed (false if the

	 * connection was not open at the start)

	 */

	public boolean closeAndRemove(ConnectionWithParams _cwp) {

		boolean it_was_open = true;

		try {

			it_was_open = (_cwp.getConnection() != null) && (!_cwp.getConnection().isClosed());

			if (_cwp.getConnection() != null) _cwp.getConnection().close();

			removeConnectionWP(_cwp);

		} catch (Exception se) {

			logger.error("While closing connection: " + se.getMessage(), se);

			return false;

		}

		logger.info("Connection successfully closed.");

		return it_was_open;

	}

	/**

	 * Called by the extension object when gvsig terminates.

	 *

	 */

	public void closeAllBeforeTerminate() {

		boolean ok = true;

		String key = "";

		ConnectionWithParams cwp = null;

		Iterator iter = connections.keySet().iterator();

		while (iter.hasNext()) {

			key = (String) iter.next();

			cwp = (ConnectionWithParams) connections.get(key);

			if (cwp.getConnection() == null) continue;

			try {

				cwp.getConnection().close();

			} catch (DBException se) {

				ok = false;

				logger.error("While closing connection: " + se.getMessage(), se);

			}

		}

		connections.clear();

		if (ok) {

			logger.info("Successfully closed all connections.");

		} else {

			logger.warn("Problems while closing all connections.");

		}

	}

	/**

	 * Gets the objects key to be used in the inner hashmap

	 * @param _drvName driver name

	 * @param _host host's url

	 * @param _db database name

	 * @param _port port number

	 * @param _user user name

	 * @return

	 */

	private static String getConnectionKey(

			String _drvName,

			String _host,

			String _db,

			String _port, String _user) {

		String resp = "_driver_" + _drvName.toLowerCase();

		resp = resp + "_host_" + _host.toLowerCase();

		resp = resp + "_db_" + _db.toLowerCase(); // ---------------- nueva

		resp = resp + "_port_" + _port;

		resp = resp + "_user_" + _user.toLowerCase();

		return resp;

	}

	/**

	 * Utility method to instantiate a driver given its name.

	 *

	 * @param drvname driver name

	 * @return driver instance

	 */

	public static IVectorialDatabaseDriver getInstanceFromName(String drvname) {

		IVectorialDatabaseDriver _driver = null;

        try {

            _driver = (IVectorialDatabaseDriver) LayerFactory.getDM().getDriver(drvname);

        } catch (Exception e) {

        	logger.error("While getting driver instance: " + e.getMessage(), e);

        }

        return _driver;

	}

}

package com.iver.cit.gvsig.fmap.drivers.db.utils;

import org.apache.log4j.Logger;

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

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

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

/**

 * Utility class to keep the connection parameters. It is used as a item in the

 * single connections manager tree and in the available connections combo box

 * (wizard db)

 *

 * @author jldominguez

 *

 */

public class ConnectionWithParams {

	private static Logger logger = Logger.getLogger(ConnectionWithParams.class.getName());

	private IConnection conn = null;

	private String connectionStr = "";

	private String drvName = "";

	private String user = "";

	private String pw = "";

	private String name = "";

	private boolean connected = false;

	private String host;

    private String port;

    private String db;

    private String schema;

    private boolean isNull = false;

    /**

     * Utility constructor to indicate an empty item.

     * It is used as the first item in the wizard's combo box

     * so that when the wizard is loaded, no query is done to any database.

     *

     */

	public ConnectionWithParams() {

		isNull = true;

	}

	/**

	 * Class Constructor.

	 *

	 * @param _conn_str connection string

	 * @param _c connection object

	 * @param _drvName driver name

	 * @param _user user name

	 * @param _pw password

	 * @param _name connection name (freely chosen by user)

	 * @param _host host's url

	 * @param _port port number as a string

	 * @param _db database name

	 * @param _isConn whether the connection is open or not

	 */

	public ConnectionWithParams(

			String _conn_str,

			IConnection _c,

			String _drvName,

			String _user,

			String _pw,

			String _name,

			String _host,

			String _port,

			String _db,

			boolean _isConn) {

		connectionStr = _conn_str;

		connected = _isConn;

		conn = _c;

		drvName = _drvName;

		user = _user;

		pw = _pw;

		name = _name;

		host = _host;

		port = _port;

		db = _db;

		if (!connected) {

			pw = null;

			conn = null;

		}

	}

	public IConnection getConnection() {

		return conn;

	}

	public String getDrvName() {

		return drvName;

	}

	public String getPw() {

		return pw;

	}

	public String getUser() {

		return user;

	}

	/**

	 * Used to paint the object in lists and trees

	 */

	public String toString() {

		if (isNull) {

			return "";

		}

		if (connected) {

			return "[C] " + name + " (" + drvName + ")";

		} else {

			return name + " (" + drvName + ")";

		}

	}

	public boolean isConnected() {

		return connected;

	}

	public void setConnected(boolean c) {

		connected = c;

	}

	/**

	 * Tries to connects the connection object with the given password.

	 * @param _pw password

	 * @throws SQLException

	 */

	public void connect(String _pw) throws DBException {

		try {

			conn = ConnectionFactory.createConnection(connectionStr, user, _pw);//DriverManager.getConnection(connectionStr, user, _pw);

		} catch (DBException e) {

			pw = null;

			conn = null;

			connected = false;

			throw new DBException(e);

		}

		pw = _pw;

		connected = true;

	}

	/**

	 * Disconnects the connection

	 *

	 */

	public void disconnect() {

			try {

				conn.close();

			} catch (DBException e) {

				logger.error("While closing connection: " + e.getMessage(), e);

			}

			pw = null;

			conn = null;

			connected = false;

	}

	public String getConnectionStr() {

		return connectionStr;

	}

	public void setConnectionStr(String connectionStr) {

		this.connectionStr = connectionStr;

	}

	public String getName() {

		return name;

	}

	public void setName(String name) {

		this.name = name;

	}

	public String getDb() {

		return db;

	}

	public void setDb(String db) {

		this.db = db;

	}

	public String getHost() {

		return host;

	}

	public void setHost(String host) {

		this.host = host;

	}

	public String getPort() {

		return port;

	}

	public void setPort(String port) {

		this.port = port;

	}

	/**

	 *

	 * @return whether or not this is the first item in the combo box.

	 */

	public boolean isNull() {

		return isNull;

	}

	public String getSchema() {

		return schema;

	}

	public void setSchema(String schema) {

		this.schema = schema;

	}

}

import com.iver.cit.gvsig.fmap.drivers.db.utils.ConnectionWithParams;

import com.iver.cit.gvsig.fmap.drivers.db.utils.SingleVectorialDBConnectionManager;

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

        IVectorialDatabaseDriver dbDriver = (IVectorialDatabaseDriver) dbAdapter.getDriver();

         IVectorialDatabaseDriver dbDriver = (IVectorialDatabaseDriver) dbAdapter.getDriver();

        IVectorialDatabaseDriver dbDriver = (IVectorialDatabaseDriver) dbAdapter.getDriver();