| gvSIG desktop 1

	/*

	 * (non-Javadoc)

	 * @see

	 * com.iver.cit.gvsig.fmap.drivers.VectorialDriver#getDriverAttributes()

	 */

	/*

	 * (non-Javadoc)

	 * @see com.hardcode.driverManager.Driver#getName()

	 */

	public String getName() {

			// geom = parser.read(strAux);

			if (rs != null) {

				byte[] data = rs.getBytes(1);

				geom = parser.parse(data);

			}

		} catch (SQLException e) {

	/**

	 * First, the geometry field. After, the rest of fields

	 * @return

	 */

	/*

	/**

	 * Antes de llamar a esta funci?n hay que haber fijado el workingArea si se

	 * quiere usar.

	 * @param conn

	 * @throws DBException

	 */

			myCursorId++;

			cursorName = "wkb_cursor_" + myCursorId + getTableName();

			st.execute("declare " + cursorName + " binary scroll cursor with hold for " + sqlTotal);

			rs = st.executeQuery("fetch forward " + FETCH_SIZE + " in " + cursorName);

			fetch_min = 0;

			fetch_max = FETCH_SIZE - 1;

			writer.initialize(lyrDef);

		} catch (SQLException e) {

			try {

				((ConnectionJDBC) conn).getConnection().rollback();

			} catch (SQLException e1) {

				logger.warn("Unable to rollback connection after problem (" + e.getMessage() + ") in setData()");

			}

			try {

				if (rs != null) { rs.close(); }

			} catch (SQLException e1) {

	/*

	 * (non-Javadoc)

	 * @see

	 * com.iver.cit.gvsig.fmap.drivers.VectorialDatabaseDriver#getGeometryIterator

	 * (java.lang.String)

	    String provCursorName = "wkb_cursor_prov_"

		    + Long.toString(Math.abs(new Random().nextLong()))

		    + getTableName();

	    bCursorActivo = true;

	    geomIterator = new PostGisFeatureIterator(

		    ((ConnectionJDBC) conn).getConnection(), provCursorName,

	 * Le pasas el rect?ngulo que quieres pedir. La primera vez es el

	 * workingArea, y las siguientes una interseccion de este rectangulo con el

	 * workingArea

	 * @param r

	 * @param strEPSG

	 * @return

	 */

	private String getCompoundWhere(String sql, Rectangle2D r, String strEPSG) {

		double xMin = r.getMinX();

		double yMin = r.getMinY();

		+ ", " + xMax + " " + yMin + ", " + xMax + " " + yMax + ", "

		+ xMin + " " + yMax + ")', " + strEPSG + ")";

		String sqlAux;

		    sqlAux = getWhereClause() + " AND \"" + getLyrDef().getFieldGeometry() + "\" && " + wktBox;

		    sqlAux = "WHERE \"" + getLyrDef().getFieldGeometry() + "\" && "

			+ wktBox;

		return sqlAux;

	}

	/*

	 * (non-Javadoc)

	 * @see com.iver.cit.gvsig.fmap.drivers.DefaultDBDriver#getFieldValue(long,

	 * int)

	 */

	static Value getFieldValue(ResultSet aRs, int fieldId) throws SQLException {

		ResultSetMetaData metaData = aRs.getMetaData();

		byte[] byteBuf = aRs.getBytes(fieldId);

			ByteBuffer buf = ByteBuffer.wrap(byteBuf);

			if (metaData.getColumnType(fieldId) == Types.CHAR){

				String character = aRs.getString(fieldId);

				if (character != null){

					return ValueFactory.createValue(character);

				}

			}

			if (metaData.getColumnType(fieldId) == Types.DATE) {

				long daysAfter2000 = buf.getInt();

				DateTime year2000 = new DateTime(2000, 1,1,0,0,0);

				throw new SQLException(e);

			}

		}

		// FILAS, ASI QUE MONTAMOS ESTA HISTORIA PARA QUE

		// LO HAGA

		if ((index >= fetch_min) && (index <= fetch_max)) {

			// Est? en el intervalo, as? que lo podemos posicionar

		} else {

			// calculamos el intervalo correcto

			fetch_min = (index / FETCH_SIZE) * FETCH_SIZE;

			fetch_max = fetch_min + FETCH_SIZE - 1;

			// y cogemos ese cacho

			rs.close();

			Statement st = ((ConnectionJDBC)conn).getConnection().createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,

			ResultSet.CONCUR_READ_ONLY);

//			myCursorId++;

//			st.execute("declare "

//					+ getTableName()

			st.executeQuery("fetch absolute " + fetch_min + " in " + cursorName);

//					+ getTableName() + myCursorId

//					+ "_wkb_cursorAbsolutePosition");

			rs = st.executeQuery("fetch forward " + FETCH_SIZE + " in " + cursorName);

//					+ getTableName() + myCursorId

//					+ "_wkb_cursorAbsolutePosition");

		}

		rs.absolute(index - fetch_min + 1);

	/*

	 * (non-Javadoc)

	 * @see com.iver.cit.gvsig.fmap.core.ICanReproject#getSourceProjection()

	 */

	public String getSourceProjection(IConnection conn, DBLayerDefinition dbld) {

		return originalEPSG;

	}

				originalEPSG = "" + rs.getInt("SRID");

				String geometryType = rs.getString("TYPE");

				int shapeType = FShape.MULTI;

				dbld.setShapeType(shapeType);

				//jomarlla

				int dimension  = rs.getInt("COORD_DIMENSION");

				dbld.setDimension(dimension);

	/*

	 * (non-Javadoc)

	 * @see com.iver.cit.gvsig.fmap.core.ICanReproject#getDestProjection()

	 */

	public String getDestProjection() {

	/*

	 * (non-Javadoc)

	 * @see

	 * com.iver.cit.gvsig.fmap.core.ICanReproject#setDestProjection(java.lang

	 * .String)

	/*

	 * (non-Javadoc)

	 * @see

	 * com.iver.cit.gvsig.fmap.core.ICanReproject#canReproject(java.lang.String)

	 */

	/*

	 * (non-Javadoc)

	 * @see com.iver.cit.gvsig.fmap.drivers.DefaultDBDriver#doRelateID_FID()

	 */

	protected void doRelateID_FID() throws DBException {

			String gid;

			while (r.next()) {

				gid = r.getString(1);

				if (gid == null) {

					throw new SQLException(

							PluginServices.getText(null, "Found_null_id_in_table") + ": " +

							getLyrDef().getComposedTableName());

				}

				Value aux = ValueFactory.createValue(gid);

				hashRelate.put(aux, new Integer(id));

				// System.out.println("ASOCIANDO CLAVE " + aux + " CON VALOR " +

			 */

			/*

			 * int index = 0;

			 * while (rs.next()) { Value aux = getFieldValue(index,

			 * idFID_FieldName-2); hashRelate.put(aux, new Integer(index));

			 * index++; System.out.println("Row " + index + " clave=" + aux); }

	/*

	 * (non-Javadoc)

	 * @see com.iver.cit.gvsig.fmap.drivers.DefaultDBDriver#close()

	 */

	public void close() {

	/*

	 * (non-Javadoc)

	 * @see

	 * com.iver.cit.gvsig.fmap.drivers.VectorialDatabaseDriver#getFeatureIterator

	 * (java.awt.geom.Rectangle2D, java.lang.String, java.lang.String[])

																						// new

																						// FieldDescription[alphaNumericFieldsNeeded.length+1];

		try {

			// if (getLyrDef()==null){

			// load();

			// throw new DriverException("Fallo de la conexi?n");

	/*

	 * public void preProcess() throws EditionException { writer.preProcess(); }

	 * public void process(IRowEdited row) throws EditionException {

	 * writer.process(row); }

	 * public void postProcess() throws EditionException { writer.postProcess();

	 * }

	 * public String getCapability(String capability) { return

	 * writer.getCapability(capability); }

	 * public void setCapabilities(Properties capabilities) {

	 * writer.setCapabilities(capabilities); }

	 * public boolean canWriteAttribute(int sqlType) { return

	 * writer.canWriteAttribute(sqlType); }

	 * public boolean canWriteGeometry(int gvSIGgeometryType) { return

	 * writer.canWriteGeometry(gvSIGgeometryType); }

	 * public void initialize(ITableDefinition layerDef) throws EditionException

	 * { writer.setCreateTable(false); writer.setWriteAll(false); // Obtenemos

	 * el DBLayerDefinition a partir del driver

	 * DBLayerDefinition dbLyrDef = getLyrDef();

	 * writer.initialize(dbLyrDef); }

	 */

	public boolean isWritable() {

	/**

	 * Gets all field names of a given table.

	 * This method comes from DefaultJDBC.java class. Postgis driver has no method to check

	 *  on the proper method will solve the problems related to an invalid status.

	 * @param conn connection object

	 * @param table_name table name

	 * @return all field names of the given table

	/**

	 * Gets all field type names of a given table.

	 * This method comes from DefaultJDBC.java class. Postgis driver has no method to check

	 *  on the proper method will solve the problems related to an invalid status.

	 * @param conn connection object

	 * @param table_name table name

	 * @return all field type names of the given table

	/**

	 * Tells if user can read contents of the table.

	 *  @param iconn connection with the database where the user is connected

	 *  @param tablename to get the permissions over

	 *  @return true if can read, either false

			} else {

				return false;

			}

	}

	private Integer getGidFieldIndex(String ret[]){

	    for (int i=0; i<ret.length; i++) {

	        if (ret[i].equalsIgnoreCase("gid")) {

	            return new Integer(i);

	    }

	    return null;

	}

	private void swapIndexes(String[] ret, int i, int j){

	    if(i!=j && i>=0 && i<ret.length && j>=0 && j<ret.length){

	        String aux = ret[i];

	        for (int i = 0; i < ret.length; i++) {

	            if (pk.equals(ret[i])) {

	                    //swap possible gid col with the first element

	                    //combobox

	                    swapIndexes(ret, i, 0);

	                    break;

	        Integer gidFieldIndex = getGidFieldIndex(ret);

	        if (gidFieldIndex!=null){

	            //swap possible gid col with the first element

	            //combobox

	            int index = gidFieldIndex.intValue();

	            swapIndexes(ret, index, 0);

	            for (int i = 0; i < ret.length; i++) {

	                if (isAutoIncrement(conn, table_name, ret[i])) {

	                    //swap possible gid col with the first element

	                    //combobox

	                    swapIndexes(ret, i, 0);

	                    break;

	}

	private boolean isAutoIncrement(IConnection con, String table_name, String colName) {

		String query = "SELECT column_default SIMILAR TO 'nextval%regclass%' AS isautoincremental "

			+ "AND column_name=?";

		try {

			// get schema and table from the composed tablename

			String[] tokens = table_name.split("\\u002E", 2);

				schema = tokens[0];

				tableName = tokens[1];

			}

			Connection c = ((ConnectionJDBC)con).getConnection();

			PreparedStatement st = c.prepareStatement(query);

			st.setString(1, tableName);

			st.setString(2, schema);

			st.setString(3, colName);

			ResultSet rs = st.executeQuery();

			boolean isAutoincrement = false;

			if (rs.next()) {

				isAutoincrement = rs.getBoolean("isautoincremental");

			}

			rs.close();

			st.close();

			return isAutoincrement;

		} catch (SQLException e) {

			try {

			} catch (DBException e2) {

				// TODO Auto-generated catch block

				e.printStackTrace();

			return false;

		}

	}

	   private String getPrimaryKey(IConnection con, String table_name) {

	                schema = tokens[0];

	                tableName = tokens[1];

	            }

	            Connection c = ((ConnectionJDBC)con).getConnection();

	            PreparedStatement st = c.prepareStatement(query);

	            st.setString(1, tableName);

	            st.setString(2, schema);

	            st.setString(3, tableName+"_pkey");

	            ResultSet rs = st.executeQuery();

	            String primaryKey = "";

	            if (rs.next()) {

	                primaryKey = rs.getString("column_name");

	            }

	            rs.close();

	            st.close();

	            return primaryKey;

	        } catch (SQLException e) {

	            try {

	            } catch (DBException e2) {

	                // TODO Auto-generated catch block

	                e.printStackTrace();

	            return "";

	        }

	    }

		public void validateData(IConnection _conn, DBLayerDefinition lyrDef) throws DBException {

			this.conn = _conn;

			lyrDef.setConnection(conn);

			setLyrDef(lyrDef);

						ResultSet.CONCUR_READ_ONLY);

				// st.setFetchSize(FETCH_SIZE);

				// myCursorId++;

				st.execute("declare " + temp_index_name + " binary scroll cursor with hold for "

						+ sqlAux);

				rs = st.executeQuery("fetch forward 50 in " + temp_index_name);

				st.close();

			} catch (SQLException e) {

				try {

					((ConnectionJDBC) conn).getConnection().rollback();

				} catch (SQLException e1) {

					logger.warn("Unable to rollback connection after problem (" + e.getMessage() + ") in setData()");

				}

				try {

					if (rs != null) { rs.close(); }

				} catch (SQLException e1) {

	String cursorName;

	/**

	 * @throws SQLException

	 * @throws SQLException

		// de geometria

		// Debe ser forward only

		st = conn.createStatement();

		// CodeSprint 2010 (Manuel L?pez S?nchez)

		try{

		}catch(SQLException e){

			st.execute("END"); // Cerramos la transacci?n para anular los cursores binarios

			st.execute("BEGIN"); // Si salta otra excepci?n, no la capturamos

		}

		// End CodeSprint 2010

		this.rs = st.executeQuery("fetch forward " + FETCH_SIZE + " in "

				+ cursorName);

	 */

	public boolean hasNext() throws ReadDriverException {

		try {

			// System.out.println("hasNext con numReg=" + numReg);

				closeIterator();

				return false;

			}

	 */

    public void closeIterator() throws ReadDriverException {

	try {

	} catch (SQLException e) {

	    throw new ReadDriverException("PostGIS Driver", e);

	}

    }

	public void setLyrDef(DBLayerDefinition lyrDef) {

		this.lyrDef = lyrDef;

		// Aunque no nos hayan pedido todos los campos, devolveremos