dive4elements/gnv-client: geo-backend/src/main/java/de/intevation/gnv/geobackend/sde/datasources/ArcSDEStatement.java comparison

comparison geo-backend/src/main/java/de/intevation/gnv/geobackend/sde/datasources/ArcSDEStatement.java @ 885:1c3efbd2fc5a

Removes trailing whitespace. geo-backend/trunk@850 c6561f87-3c4e-4783-a992-168aeb5c3f6f

author	Sascha L. Teichmann <sascha.teichmann@intevation.de>
date	Mon, 29 Mar 2010 07:49:16 +0000
parents	12f88239fb33
children	8b442223741c

comparison

equal deleted inserted replaced

-:12f88239fb33
+:1c3efbd2fc5a
 /**
 * the logger, used to log exceptions and additonaly information
 */
 private static Logger log = Logger.getLogger(ArcSDEStatement.class);
 /**
 * The Connection to the ArcSDE-Backend
 */
 private ArcSDEConnection connection = null;
 /**
 * Constructor
 * @param connection the Connection to the ArcSDE-Backend.
 */
 public ArcSDEStatement(ArcSDEConnection connection) {
 */
 public ResultSet executeQuery(String statement) throws SQLException {
 try {
 SeQuery query = null;
 if (statement.toLowerCase().contains("st_astext")  || statement.toLowerCase().contains("intersects")){
 String[] values =  statement.toLowerCase().split("where", 2);
 String where = values.length > 1 ? values[1].trim() : "";
 String[] tableNames = values[0].substring(values[0].indexOf("from")).replaceFirst("from", "").toUpperCase().trim().split(", ");
 String columnValueString = values[0].substring(0, values[0].indexOf("from")).trim();
 columnValueString = columnValueString.replaceFirst("select", "").trim();
 }
 if (byClausePos > 0){
 byClause = where.substring(byClausePos);
 where = where.substring(0,byClausePos);
 }
 for (int i = 0; i < returnFields.length; i++){
 returnFields[i] = returnFields[i].trim();
 if (returnFields[i].startsWith("st_astext(")){
 returnFields[i] = returnFields[i].replaceAll("st_astext", "");
 returnFields[i] = returnFields[i].substring(1, returnFields[i].length()-1);
 geometryColumnName = returnFields[i];
 }
 }
 for (int i = 0; i < tableNames.length; i++){
 tableNames[i] = tableNames[i].trim();
 }
 Geometry g = null;
 int pos = where.indexOf("intersects");
 if (pos >= 0 ){
 String substr =  where.substring(pos);
 where = where.substring(0,where.lastIndexOf("intersects"));
 }
 }else{
 wkt = intersectsStmt.substring(intersectsStmt.indexOf("\""), intersectsStmt.lastIndexOf("\"")).replace("\"", "").trim();
 }
 g = new WKTReader().read(wkt.toUpperCase());
 if (geometryColumnName == null){
 geometryColumnName = "SHAPE"; // TODO dynamisch aus Intersects auslesen.
 }
 }
 return this.executeQuery(this.connection.getSeConnection(), tableNames, geometryColumnName, where, g, returnFields,byClause);
 }else{
 query = new SeQuery(this.connection.getSeConnection());
 query.prepareSql(statement);
 query.execute();
 return this.handleResultSet(query,false,null);
 }
 } catch (Exception e) {
 log.error(e,e);
 throw new SQLException(e.getMessage());
 }
 }
 /**
 * This Methods Executes the ArcSDE Query if Spatial-Restrictions
 * are given
 * @param con The Connection to the ArcSDE-Backend.
 * @param pLayername The Name of tables which should be used in the Query
 * @param pSpatialColumnName the Name of the Spatial Column.
 * @param pWhere The where-Clause to limit the Data
 * @param g the Geometry to limit the Data
 * @param pReturnFields the Fileds that should be fetched from the Database
 * @param byClause the byClaus to order the Results.
 throws SQLException {
 log.debug("executeQuery()");
 try {
 // get the layer for querying
 boolean isRaster = pSpatialColumnName.equalsIgnoreCase("raster");
 SeShapeFilter[] filters  = null;
 if (g != null){
 if (!isRaster){
 SeLayer lLayer = new SeLayer(con, pLayername[0], pSpatialColumnName);
 SeShape shape = new SeShape();
 shape.setCoordRef(lLayer.getCoordRef());
 SDEPoint[] lPoints = new ArcSDEUtils().createPoints(g);
 int searchMode = SeFilter.METHOD_AI;
 if (g instanceof Polygon){
 shape.generatePolygon(lPoints.length, 1, null, lPoints);
 }else if (g instanceof Point){
 shape.generatePoint(1, lPoints);
 searchMode = SeFilter.METHOD_PC;
 }else if (g instanceof LineString){
 shape.generateLine(lPoints.length, 1, null, lPoints);
 searchMode = SeFilter.METHOD_LCROSS;
 }
 SeShapeFilter filter = new SeShapeFilter(pLayername[0],
 pSpatialColumnName, shape,searchMode);
 filters = new SeShapeFilter[1];
 filters[0] = filter;
 }
 }
 SeQuery spatialQuery = null;
 SeSqlConstruct sqlCons = new SeSqlConstruct(pLayername, pWhere);
 spatialQuery = new SeQuery(con);//, pReturnFields, sqlCons);
 SeQueryInfo queryInfo = new SeQueryInfo();
 queryInfo.setColumns(pReturnFields);
 if (byClause != null){
 queryInfo.setByClause(byClause);
 }
 queryInfo.setConstruct(sqlCons);
 spatialQuery.prepareQueryInfo(queryInfo);
 /*
 * Set spatial constraints
 */
 if (filters != null){
 spatialQuery.setSpatialConstraints(SeQuery.SE_OPTIMIZE, false,
 filters);
 }
 if (!isRaster){
 spatialQuery.execute();
 }
 return this.handleResultSet(spatialQuery,isRaster,g);
 } catch (Exception e) {
 if (e instanceof SeException){
 ArcSDEUtils.printError((SeException)e);
 }else{
 log.error(e.getMessage(), e);
 }
 throw new SQLException(e.getMessage());
 }
 }
 /**
 /**
 * @see java.sql.Statement#setQueryTimeout(int)
 */
 public void setQueryTimeout(int arg0) throws SQLException {
 }
 /**
 * This Method fetches all Rows from the SeQuery-Object and convert it into
 * an @see java.sql.ResultSet.
 *
 * @param pSeQuery the Queryobject where the Data should be fetched from.
 * @param isRaster Flag which indicates if the Result is Rasterdata.
 * @param geometry The Geometry which might be used to limit the data.
 * @return an java.sql:ResultSet which contains the Data.
 * @throws SeException
 */
 private ResultSet handleResultSet(SeQuery pSeQuery,
 boolean isRaster,
 Geometry geometry) throws SeException {
 boolean debug = log.isDebugEnabled();
 if (debug) {
 log.debug("ArcSDEStatement.handleResultSet()");
 }
 short lNumCols = row.getNumColumns();
 Row lBackingRow = new Row(lNumCols);
 for (int i = 0; i < lNumCols; i++) {
 lBackingRow.addObject(
 removers[i].filter(row.getObject(i)),
 i);
 }
 lSet.addRow(lBackingRow);
 }
 row = pSeQuery.fetch();
 SeRasterAttr    attr       = row.getRaster(0);
 SeRaster        raster     = attr.getRasterInfo();
 SeRasterBand [] bands      = raster.getBands();
 SeRasterBand    rasterBand = bands[0];
 SeExtent extent = rasterBand.getExtent();
 double x = ((Point)geometry).getX();
 double y = ((Point)geometry).getY();
 boolean isPointInRaster =
 x >= extent.getMinX() && x <= extent.getMaxX()
 &&  y >= extent.getMinY() && y <= extent.getMaxY();
 if (isPointInRaster){
 if (row == null){
 pSeQuery.execute();
 row = pSeQuery.fetch();
 }
 double midX = 0.5d*(extent.getMinX() + extent.getMaxX());
 double midY = 0.5d*(extent.getMinY() + extent.getMaxY());
 SDEPoint origin = rasterBand.getTileOrigin();
 double maxX = origin.getX() < midX
 ? extent.getMaxX()
 : extent.getMinX();
 double maxY = origin.getY() < midY
 ? extent.getMaxY()
 /**
 * @see java.sql.Wrapper#unwrap(java.lang.Class)
 */
 public <T> T unwrap(Class<T> iface) throws SQLException {
 return null;
 }
 }

Mercurial > dive4elements > gnv-client

comparison geo-backend/src/main/java/de/intevation/gnv/geobackend/sde/datasources/ArcSDEStatement.java @ 885:1c3efbd2fc5a