Application: gvSIG desktop

/*

 * Created on 11-abr-2007

 *

 * 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

 */

/* CVS MESSAGES:

*

* $Id$

* $Log$

* Revision 1.1  2007-04-19 17:27:58  azabala

* first version in cvs

*

*

*/

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

import org.cresques.cts.ICoordTrans;

import org.cresques.cts.IProjection;

import com.hardcode.gdbms.driver.exceptions.ReadDriverException;

import com.hardcode.gdbms.engine.values.Value;

import com.iver.cit.gvsig.exceptions.expansionfile.ExpansionFileReadException;

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

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

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

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

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

/**

 * 

 * Iterator over all the features of a vectorial adapter.

 * It is thinked for data sources which dont have capabilities

 * of querying or reprojection.

 * 

 * 

 * @author Alvaro Zabala

 * */

public class DefaultFeatureIterator implements IFeatureIterator {

	/**

	 * Projection of the layer on which this iterator iterates.

	 * TODO Move projection from layer to adapter or driver

	 * */

	protected IProjection sourceProjection;

    /**

     * If its setted, all features returned by this iterator

     * will be previously reprojected to this target projection

     */

	protected IProjection targetProjection;

	/**

	 * If its setted, returned features only will have these alphanumeric attributes

	 */

	protected String[] fieldNames;

	/**

	 * vectorial data source. It reads geometries

	 * and has the recordset

	 */

	protected ReadableVectorial source;

	/**

	 * recordset, it reads alphanumeric attributes

	 */

	protected SelectableDataSource recordset;

	/**

	 * index of the next feature that will be returned by this

	 * iterator

	 */

	protected int currentFeature;

	/**

	 * Default constructor. 

	 * Creates an iterator which will return features in the data source projection

	 * (without reprojection) and with all the alphanumeric attributes

	 * @throws ReadDriverException 

	 *

	 */

	public DefaultFeatureIterator( ReadableVectorial source) throws ReadDriverException{

		this.source = source;

		this.recordset = source.getRecordset();

		currentFeature = 0;

	}

	/**

	 * Constructor.

	 * The iterator will reproject the geometry of the features to the specified target projection,

	 * and with the specified attribute fields.

	 * */

	public DefaultFeatureIterator(ReadableVectorial source, 

									IProjection sourceProj, 

									IProjection targetProj, 

									String[] fieldNames) throws ReadDriverException{

		this(source);

		this.sourceProjection = sourceProj;

		this.targetProjection = targetProj;

		this.fieldNames = fieldNames;

	}

	public boolean hasNext() throws ReadDriverException,

			ExpansionFileReadException {

		boolean bMore = (currentFeature < source.getShapeCount());

		return bMore;

	}

	public IFeature next() throws ReadDriverException {

		try {

			IGeometry geom = getGeometry(currentFeature);

			Value[] regAtt = getValues(currentFeature);

			IFeature feat  = new DefaultFeature(geom, regAtt, currentFeature + "");

			currentFeature++;

			return feat;

		} catch (ExpansionFileReadException e) {

			throw new ReadDriverException("",e);

		} 

	}

	public void closeIterator() throws ReadDriverException {

	}

	public String[] getFieldNames() {

		return fieldNames;

	}

	public void setFieldNames(String[] fieldNames) {

		this.fieldNames = fieldNames;

	}

	public IProjection getTargetProjection() {

		return targetProjection;

	}

	public void setTargetProjection(IProjection targetProjection) {

		this.targetProjection = targetProjection;

	}

	public IProjection getSourceProjection() {

		return sourceProjection;

	}

	public void setSourceProjection(IProjection sourceProjection) {

		this.sourceProjection = sourceProjection;

	}

	protected IGeometry getGeometry(int geomIdx) throws ExpansionFileReadException, 

																ReadDriverException{

		IGeometry geom = source.getShape(geomIdx); 

		if(this.targetProjection != null && this.sourceProjection != null){

			ICoordTrans trans = sourceProjection.getCT(targetProjection);

			geom.reProject(trans);

		}

		return geom;

	}

	protected Value[] getValues(int featureIdx) throws ReadDriverException{

		Value[] regAtt = null;

		if(fieldNames == null){

			regAtt = new Value[recordset.getFieldCount()];

			for (int fieldId = 0; fieldId < recordset.getFieldCount(); fieldId++) {

				regAtt[fieldId] = recordset.getFieldValue(featureIdx, fieldId);

			}

		}else{

			regAtt = new Value[fieldNames.length];

			for (int fieldId = 0; fieldId < fieldNames.length; fieldId++) {

				int fieldCode = recordset.getFieldIndexByName(fieldNames[fieldId]);

				regAtt[fieldId] = recordset.getFieldValue(featureIdx, fieldCode);

			}

		}

		return regAtt;

	}

}

/*

 * Created on 12-abr-2007

 *

 * 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

 */

/* CVS MESSAGES:

*

* $Id$

* $Log$

* Revision 1.1  2007-04-19 17:27:58  azabala

* first version in cvs

*

*

*/

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

import java.awt.geom.Rectangle2D;

import java.util.List;

import org.cresques.cts.IProjection;

import com.hardcode.gdbms.driver.exceptions.ReadDriverException;

import com.hardcode.gdbms.engine.values.Value;

import com.iver.cit.gvsig.exceptions.expansionfile.ExpansionFileReadException;

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

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

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

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

import com.iver.cit.gvsig.fmap.spatialindex.ISpatialIndex;

/**

 * Feature iterator for a spatial query resolved with an spatial index.

 * @author azabala

 *

 */

public class IndexedSptQueryFeatureIterator extends SpatialQueryFeatureIterator {

	private ISpatialIndex spatialIndex;

	List resultIdx;

	public IndexedSptQueryFeatureIterator(ReadableVectorial source, 

											IProjection sourceProj, 

											IProjection targetProj, 

											String[] fieldNames, 

											Rectangle2D spatialQuery,

											ISpatialIndex spatialIndex) throws ReadDriverException {

		super(source, sourceProj, targetProj, fieldNames, spatialQuery);

		this.spatialIndex = spatialIndex;

		this.resultIdx = this.spatialIndex.query(spatialQuery);

	}

	public boolean hasNext(){

		if(resultIdx != null && currentFeature < resultIdx.size())

			return true;

		else

			return false;

	}

	public IFeature next() throws ReadDriverException {

		Integer nextFeatureIdx = (Integer) resultIdx.get(currentFeature);

		IGeometry geom;

		try {

			geom = getGeometry(nextFeatureIdx.intValue());

		} catch (ExpansionFileReadException e) {

			throw new ReadDriverException("Error accediendo al driver", e);

		} 

		Value[] regAtt = getValues(nextFeatureIdx.intValue());

		DefaultFeature feat = new DefaultFeature(geom, regAtt, currentFeature + "");

		currentFeature++;

		return feat;

	}

}

/*

 * Created on 12-abr-2007

 *

 * 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

 */

/* CVS MESSAGES:

*

* $Id$

* $Log$

* Revision 1.1  2007-04-19 17:27:58  azabala

* first version in cvs

*

*

*/

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

import org.cresques.cts.IProjection;

import com.hardcode.driverManager.DriverLoadException;

import com.hardcode.gdbms.driver.exceptions.ReadDriverException;

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

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

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

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

import com.hardcode.gdbms.engine.values.Value;

import com.hardcode.gdbms.parser.ParseException;

import com.iver.cit.gvsig.exceptions.expansionfile.ExpansionFileReadException;

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

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

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

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

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

/**

 * Iterates over the features of a vectorial data source

 * (readablevectorial, or vectorialadapter) which verify a SQL statement.

 * <br>

 * SQL sintax is very extrict, GDBMS based.

 * (for example, % character is not allowed to build strings expressions,

 * all SQL statement must end with ;, etc)

 * 

 * 

 * 

 * 

 * @author azabala

 *

 */

public class AttrQueryFeatureIterator extends DefaultFeatureIterator {

	private String sqlQuery;

	private long[] indexes;

	public AttrQueryFeatureIterator(ReadableVectorial source, 

										IProjection sourceProj, 

										IProjection targetProj, 

										String sqlQuery) throws ReadDriverException {

		super(source, sourceProj, targetProj, null);

		this.sqlQuery = sqlQuery;

		try {

			if(hasWhere(sqlQuery)){

				DataSource datasource = LayerFactory.getDataSourceFactory().executeSQL(sqlQuery,

						DataSourceFactory.MANUAL_OPENING);

				indexes = datasource.getWhereFilter();

			}else{

				//TODO This is not very elegant: rethink

				indexes = new long[source.getShapeCount()];

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

					indexes[i] = i;

				}

			}

		} catch (Exception e){

			throw new ReadDriverException("error ejecutando consulta sql para iterador", e);

		}

	}

	public boolean hasNext(){

		if(indexes != null && currentFeature < indexes.length)

			return true;

		else

			return false;

	}

	private boolean hasWhere(String expression) {

		String subExpression = expression.trim();

		int pos;

		// Remove last ';' if exists

		if (subExpression.charAt(subExpression.length() -1) == ';')

			subExpression = subExpression.substring(0, subExpression.length() -1).trim();

		// If there is no 'where' clause

		if ((pos = subExpression.indexOf("where")) == -1)

			return false;

		// If there is no subexpression in the WHERE clause -> true

		subExpression = subExpression.substring(pos + 5, subExpression.length()).trim(); // + 5 is the length of 'where'

		if ( subExpression.length() == 0 )

			return false;

		else

			return true;

	}

	public IFeature next() throws ReadDriverException {

		IGeometry geom;

		try {

			geom = getGeometry((int)indexes[currentFeature]);

		} catch (ExpansionFileReadException e) {

			throw new ReadDriverException("Error accediendo al driver", e);

		} 

		Value[] regAtt = getValues((int)indexes[currentFeature]);

		DefaultFeature feat = new DefaultFeature(geom, regAtt, currentFeature + "");

		currentFeature++;

		return feat;

	}

}

/*

 * Created on 12-abr-2007

 *

 * 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

 */

/* CVS MESSAGES:

*

* $Id$

* $Log$

* Revision 1.1  2007-04-19 17:27:58  azabala

* first version in cvs

*

*

*/

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

import java.awt.geom.Rectangle2D;

import org.cresques.cts.IProjection;

import com.hardcode.gdbms.driver.exceptions.ReadDriverException;

import com.hardcode.gdbms.engine.values.Value;

import com.iver.cit.gvsig.exceptions.expansionfile.ExpansionFileReadException;

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

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

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

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

public class SpatialQueryFeatureIterator extends DefaultFeatureIterator {

	/**

	 * region for which features we are iterating

	 */

	protected Rectangle2D rect;

	/**

	 * Feature which will be returned the next time

	 */

	IFeature nextFeature = null;

	/**

	 * Constructor.

	 * @param source vectorial data source

	 * @param sourceProj original projection of the data (it could be null)

	 * @param targetProj projection of the returned features

	 * @param fieldNames

	 * @param spatialQuery

	 * @throws ReadDriverException

	 */

	public SpatialQueryFeatureIterator(ReadableVectorial source, 

									   IProjection sourceProj, 

									   IProjection targetProj, 

									   String[] fieldNames,

									   Rectangle2D spatialQuery) throws ReadDriverException {

		super(source, sourceProj, targetProj, fieldNames);

		setRect(spatialQuery);

	}

	public Rectangle2D getRect() {

		return rect;

	}

	public void setRect(Rectangle2D rect) {

		this.rect = rect;

	}

	public boolean hasNext() throws ReadDriverException {

		try {

			IGeometry geom = getGeometry(currentFeature);

			IFeature feat = null;

			while (!(geom.fastIntersects(rect.getMinX(), 

											rect.getMinY(),

											rect.getWidth(), 

											rect.getHeight()))){

					currentFeature++;

					if (currentFeature < source.getShapeCount())

						geom = getGeometry(currentFeature);

					else

						return false;

			}//while

			Value[] regAtt = getValues(currentFeature);

			feat = new DefaultFeature(geom, regAtt, currentFeature + "");

			currentFeature++;

			nextFeature = feat;

			return true;

		} catch (ExpansionFileReadException e) {

			throw new ReadDriverException("Error accediendo a datos del driver durante la iteracion", e);		

		} 

	}

	public IFeature next() throws ReadDriverException {

		return nextFeature;

	}

}

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

import java.awt.geom.Rectangle2D;

import com.hardcode.gdbms.driver.exceptions.ReadDriverException;

import com.hardcode.gdbms.engine.values.Value;

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

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

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

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

public class RandomAccessFeatureIterator implements IFeatureIterator {

	VectorialDriver drv;

	SelectableDataSource ds;

	Rectangle2D r = null;

	String epsg;

	int numRec = 0;

	public RandomAccessFeatureIterator(VectorialDriver driver, SelectableDataSource sds, Rectangle2D r, String strEPSG) {

		this.drv = driver;

		this.ds = sds;

		this.r = r;

		this.epsg = strEPSG;

	}

	public RandomAccessFeatureIterator(VectorialDriver driver, SelectableDataSource sds, String strEPSG) {

		this.drv = driver;

		this.ds = sds;

		this.epsg = strEPSG;

	}

	public boolean hasNext() throws ReadDriverException {

		boolean bMore = (numRec < drv.getShapeCount());

		return bMore;

	}

	public IFeature next() throws ReadDriverException {

		IGeometry geom;

		IFeature feat = null;

		geom = drv.getShape(numRec);

		// Si pedimos solo las que entran en un rect?ngulo....

		// ?QUE PASA SI TENEMOS UN ?NDICE ESPACIAL?

		if (r != null){

			while (!(geom.fastIntersects(r.getMinX(), r.getMinY(),

					r.getWidth(), r.getHeight()))){

				numRec++;

				if (numRec < drv.getShapeCount())

					geom = drv.getShape(numRec);

				else

					return null;

				}

		}

		Value[] regAtt = new Value[ds.getFieldCount()];

		for (int fieldId = 0; fieldId < ds.getFieldCount(); fieldId++) {

			regAtt[fieldId] = ds.getFieldValue(numRec, fieldId);

		}

		feat = new DefaultFeature(geom, regAtt, numRec + "");

		numRec++;

		return feat;

	}

	public void closeIterator() throws ReadDriverException {

	}

}