/trunk/libraries/libFMap/src/com/iver/cit/gvsig/fmap/drivers/DefaultDBDriver.java - Diff - | gvSIG desktop 1 - gvSIG

Revision 10627 trunk/libraries/libFMap/src/com/iver/cit/gvsig/fmap/drivers/DefaultDBDriver.java

     package com.iver.cit.gvsig.fmap.drivers;
     import java.awt.geom.Rectangle2D;
     import java.io.IOException;
     import java.sql.Connection;
     import java.sql.DatabaseMetaData;
     import java.sql.Driver;
-...
     import java.sql.SQLException;
     import java.sql.Statement;
     import java.sql.Types;
     import java.util.ArrayList;
     import java.util.Hashtable;
     import java.util.TreeMap;
     import org.apache.log4j.Logger;
     import com.hardcode.gdbms.driver.exceptions.BadFieldDriverException;
     import com.hardcode.gdbms.driver.exceptions.ReadDriverException;
     import com.hardcode.gdbms.driver.exceptions.ReloadDriverException;
     import com.hardcode.gdbms.engine.data.DataSourceFactory;
     import com.hardcode.gdbms.engine.data.driver.DriverException;
     import com.hardcode.gdbms.engine.data.driver.ObjectDriver;
     import com.hardcode.gdbms.engine.values.Value;
     import com.hardcode.gdbms.engine.values.ValueFactory;
     import com.iver.cit.gvsig.fmap.DriverException;
     import com.iver.cit.gvsig.exceptions.expansionfile.ExpansionFileReadException;
     import com.iver.cit.gvsig.fmap.DriverJdbcNotFoundExceptionType;
     import com.iver.cit.gvsig.fmap.MapContext;
     import com.iver.cit.gvsig.fmap.Messages;
     import com.iver.cit.gvsig.fmap.SqlDriveExceptionType;
     import com.iver.cit.gvsig.fmap.core.IFeature;
     import com.iver.cit.gvsig.fmap.core.IGeometry;
     import com.iver.cit.gvsig.fmap.drivers.jdbc.utils.ConnectionWithParams;
-...
         protected String whereClause;
         protected String strSRID;
     	//private double flatness;
         protected String host, port, dbName, connName;
         private MapContext mapContext = null;
         abstract public void setData(Connection conn, DBLayerDefinition lyrDef);
-...
     	 * @throws DriverException
     	 * @see com.iver.cit.gvsig.fmap.layers.ReadableVectorial#getShapeCount()
     	 */
     	public int getShapeCount() throws IOException {
     	public int getShapeCount() throws ReadDriverException {
     	    	if (numReg == -1)
+    	    	{
     	    	    try
-...
+    	            }
     	    	    catch (SQLException e)
+    	    	    {
     	    	        throw new IOException(e.getMessage());
     	    	        throw new ReadDriverException(getName(),e);
+    	    	    }
+    	    	}
-...
+    	}
         /**
          * @throws ReadDriverException
          * @throws ExpansionFileReadException
          * @see com.iver.cit.gvsig.fmap.layers.ReadableVectorial#getFullExtent()
          */
         public Rectangle2D getFullExtent(){
         public Rectangle2D getFullExtent() throws ReadDriverException, ExpansionFileReadException{
             // Por defecto recorremos todas las geometrias.
             // Las bases de datos como PostGIS pueden y deben
             // sobreescribir este m?todo.
             if (fullExtent == null)
+            {
                 try
+                {
                     IFeatureIterator itGeom = getFeatureIterator("SELECT " +
                             getGeometryField(getLyrDef().getFieldGeometry()) + ", " + getLyrDef().getFieldID() + " FROM " +
                             getLyrDef().getTableName() +  " " + getCompleteWhere());
-...
                             fullExtent.add(geom.getBounds2D());
                         cont++;
+                    }
+                }
                 catch (DriverException e) {
                     // TODO Auto-generated catch block
                     e.printStackTrace();
+                }
+            }
             return fullExtent;
+        }
-...
     		return lyrDef.getShapeType();
+    	}
     	public int getFieldType(int idField) throws com.hardcode.gdbms.engine.data.driver.DriverException
+    	{
     	public int getFieldType(int idField) throws ReadDriverException{
     	    String str = "";
     	    try {
     	        int i = idField + 2; // idField viene basado en 1, y
-...
     		    if (metaData.getColumnType(i) == Types.SMALLINT)
     		        return Types.SMALLINT;
     		    if (metaData.getColumnType(i) == Types.TINYINT)
     		        return Types.TINYINT;
     		        return Types.TINYINT;
     		    if (metaData.getColumnType(i) == Types.BIGINT)
     		        return Types.BIGINT;
     		    if (metaData.getColumnType(i) == Types.BIT)
-...
                     return Types.TIMESTAMP;
     	    } catch (SQLException e) {
     	    	throw new com.hardcode.gdbms.engine.data.driver.DriverException(e);
     	    	throw new BadFieldDriverException(getName(),e,String.valueOf(idField));
+        	}
     	    return Types.OTHER;
             // throw new com.hardcode.gdbms.engine.data.driver.DriverException("Tipo no soportado: " + str);
-...
          * @throws DriverException Si se produce un error accediendo al DataSource
          */
         public Value getFieldValue(long rowIndex, int idField)
             throws com.hardcode.gdbms.engine.data.driver.DriverException
             throws ReadDriverException
+            {
             	int i = (int) (rowIndex + 1);
             	int fieldId = idField+2;
-...
         		    if (metaData.getColumnType(fieldId) == Types.DATE)
         		        return ValueFactory.createValue(rs.getDate(fieldId));
         	    } catch (SQLException e) {
                     throw new com.hardcode.gdbms.engine.data.driver.DriverException("Tipo no soportado: columna " + fieldId );
                     throw new BadFieldDriverException(getName(),e,String.valueOf(fieldId));
+            	}
             	return null;
-...
          * @throws DriverException Si se produce alg?n error accediendo al
          *         DataSource
          */
         public int getFieldCount() throws com.hardcode.gdbms.engine.data.driver.DriverException
         public int getFieldCount() throws ReadDriverException
+        {
             try {
                 // Suponemos que el primer campo es el de las geometries, y no lo
                 // contamos
                 return rs.getMetaData().getColumnCount()-1;
             } catch (SQLException e) {
                 throw new com.hardcode.gdbms.engine.data.driver.DriverException(e);
                 throw new ReadDriverException(getName(),e);
+            }
+        }
-...
          * @throws DriverException Si se produce alg?n error accediendo al
          *         DataSource
          */
         public String getFieldName(int fieldId) throws com.hardcode.gdbms.engine.data.driver.DriverException
         public String getFieldName(int fieldId) throws ReadDriverException
+        {
             try {
                 return rs.getMetaData().getColumnName(fieldId+2);
             } catch (SQLException e) {
                 throw new com.hardcode.gdbms.engine.data.driver.DriverException(e);
                 throw new ReadDriverException(getName(),e);
+            }
+        }
-...
          * Obtiene el n?mero de registros del DataSource
+         *
          * @return
          * @throws ReadDriverException
+         *
          * @throws DriverException Si se produce alg?n error accediendo al
          *         DataSource
          */
         public long getRowCount()
+        {
             try {
                 return getShapeCount();
             } catch (IOException e) {
                 // TODO Auto-generated catch block
                 e.printStackTrace();
+            }
             return -1;
         public long getRowCount() throws ReadDriverException{
             return getShapeCount();
+        }
         public void close() {
-...
+        }
         public void load() throws DriverException {
         public void load() throws ReadDriverException {
         	try {
                 Class.forName(driverClass);
                 String _drvName = getName();
                 String keyPool = _drvName.toLowerCase() + "_" + host.toLowerCase()
                 + "_" + port + "_" + dbName.toLowerCase()
                 + "_" + userName.toLowerCase();
                 Connection newConn = null;
                 String clave = null;
                 ConnectionWithParams cwp = null;
                 if (poolPassw.containsKey(keyPool)) {
                     clave = (String) poolPassw.get(keyPool);
                     cwp = SingleJDBCConnectionManager.instance().getConnection(
      					_drvName, userName, clave, connName,
      					host, port, dbName, true);
                 } else {
                     cwp = SingleJDBCConnectionManager.instance().getConnection(
          					_drvName, userName, null, connName,
          					host, port, dbName, false);
                     if (cwp.isConnected()) {
                     	poolPassw.put(keyPool, cwp.getPw());
                     } else {
                         JPasswordDlg dlg = new JPasswordDlg();
                         String strMessage = Messages.getString("conectar_jdbc");
                         String strPassword = Messages.getString("password");
-...
                         if (clave == null)
                             return;
                         poolPassw.put(keyPool, clave);
                         cwp.connect(clave);
+                    }
+                }
-...
                 setData(newConn, lyrDef);
             } catch (ClassNotFoundException e) {
                 logger.debug(e);
                 DriverJdbcNotFoundExceptionType type =
                 	new DriverJdbcNotFoundExceptionType();
                 type.setDriverJdbcClassName(driverClass);
                 type.setLayerName(this.getTableName());
                 throw new DriverException("Driver JDBC no encontrado", e,  type);
     //            logger.debug(e);
     //            DriverJdbcNotFoundExceptionType type =
     //            	new DriverJdbcNotFoundExceptionType();
     //            type.setDriverJdbcClassName(driverClass);
     //            type.setLayerName(this.getTableName());
                 throw new ReadDriverException(getName(),e);
             } catch (SQLException e) {
             	throw new DriverException(e.getMessage());
             	throw new ReadDriverException(getName(),e);
+    		}
+        }
         /* (non-Javadoc)
-...
             try {
                 DatabaseMetaData metadata = getConnection().getMetaData();
                 xml.putProperty("catalog", getLyrDef().getCatalogName());
                 // TODO: NO DEBEMOS GUARDAR EL NOMBRE DE USUARIO Y CONTRASE?A
                 // AQUI. Hay que utilizar un pool de conexiones
                 // y pedir al usuario que conecte a la base de datos
-...
         /* (non-Javadoc)
          * @see com.iver.cit.gvsig.fmap.drivers.VectorialDriver#reLoad()
          */
         public void reload() throws IOException
         public void reload() throws ReloadDriverException
+        {
     		try {
     	    	if (conn == null) this.load();
-...
     	    	setData(conn, lyrDef);
     		} catch (SQLException e) {
     			throw new IOException(e.getMessage());
     		} catch (DriverException e) {
     			throw new IOException(e.getMessage());
     			throw new ReloadDriverException(getName(),e);
     		} catch (ReadDriverException e) {
     			throw new ReloadDriverException(getName(),e);
+    		}
+        }
-...
     //	public void setFlatness(double flatness) {
     //		this.flatness = flatness;
     //	}
         // -----------------------------------------------------------
         // ----  EXT JDBC NUEVA                           ---
         // -----------------------------------------------------------
         /**
          * Gets the drivers connection string given its parameters (this can be different for
          * different driver, so it should be overwritten in that case.)
-...
         		String dbname,
         		String user,
         		String pw) {
     		String resp = getConnectionStringBeginning() + "//" + host.toLowerCase();
     		if (dbname.trim().length() > 0) {
-...
     		resp += "/" + dbname.toLowerCase();
     		return resp;
+        }
         /**
          * Gets available table names. Should be overwritten by subclasses if its
          * not compatible or if it can be refined
+         *
+         *
          * @param conn connection object
          * @param catalog catalog name
          * @return array of strings with available table names
          * @throws SQLException
          */
         public String[] getTableNames(Connection conn, String catalog) throws SQLException {
         	DatabaseMetaData dbmd = conn.getMetaData();
             String[] types = {"TABLE", "VIEW"};
     		ResultSet rs = dbmd.getTables(catalog, null, null, types);
-...
     		rs.close();
     		return (String[]) ret.keySet().toArray(new String[0]);
+        }
         /**
          *       Gets all field names of a given table
          * @param conn connection object
-...
          * @throws SQLException
          */
         public String[] getAllFields(Connection conn, String table_name) throws SQLException {
     		Statement st = conn.createStatement();
     		ResultSet rs = st.executeQuery("select * from " + table_name + " LIMIT 1");
     		ResultSetMetaData rsmd = rs.getMetaData();
-...
          * @throws SQLException
          */
         public String[] getAllFieldTypeNames(Connection conn, String table_name) throws SQLException {
     		Statement st = conn.createStatement();
     		ResultSet rs = st.executeQuery("select * from " + table_name + " LIMIT 1");
     		ResultSetMetaData rsmd = rs.getMetaData();
-...
+        }
         /**
          * Gets the table's possible id fields. By default, all fields can be id.
          * Gets the table's possible id fields. By default, all fields can be id.
          * It should be overwritten by subclasses.
+         *
+         *
          * @param conn conenction object
          * @param table_name table name
          * @return the table's possible id fields
-...
         public String[] getIdFieldsCandidates(Connection conn, String table_name) throws SQLException {
         	return getAllFields(conn, table_name);
+        }
         /**
          * Gets the table's possible geometry fields. By default, all fields can be geometry
          * fields. It should be overwritten by subclasses.
+         *
+         *
          * @param conn conenction object
          * @param table_name table name
          * @return the table's possible geometry fields
-...
         public String[] getGeometryFieldsCandidates(Connection conn, String table_name) throws SQLException {
         	return getAllFields(conn, table_name);
+        }
         /**
          * Tells if it's an empty table (with no records)
          * @param conn conenction object
-...
          * @return whether it's an empty table (with no records) or not
          */
     	public boolean isEmptyTable(Connection conn, String tableName) {
     		boolean res = true;
     		try {
-...
     	/**
     	 * Utility method to allow the driver to do something with the geometry field.
     	 * By default does nothing.
+    	 *
+    	 *
     	 * @param flds user-selected fields
     	 * @param geomField geometry field
     	 * @return new user-selected fields
-...
     	public String[] manageGeometryField(String[] flds, String geomField) {
     		return flds;
+    	}
     	/**
     	 * Empty method called when the layer is going to be removed from the view.
     	 * Subclasses can overwrite it if needed.
+    	 *
     	 */
     	public void remove() {
+    	}
+    }

Also available in: Unified diff