| gvSIG desktop 1

/*

 * Created on 13-may-2005

 *

 * 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

 */

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

import java.util.Vector;

import com.esri.sde.sdk.client.SeColumnDefinition;

import com.esri.sde.sdk.client.SeConnection;

import com.esri.sde.sdk.client.SeException;

import com.esri.sde.sdk.client.SeLayer;

import com.esri.sde.sdk.client.SeObjectId;

import com.esri.sde.sdk.client.SeQuery;

import com.esri.sde.sdk.client.SeRow;

import com.esri.sde.sdk.client.SeShape;

import com.esri.sde.sdk.client.SeSqlConstruct;

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

public class testSDE {

    public static void main(String[] args)

    {

        // Conexi?n:

        SeConnection conn = null;

        String server     = "192.168.0.114";

        int instance      = 5151;

        String database   = "ProvinciasPruebas";

        String user       = "sde";

        String password   = "iver";

        try {

            conn = new SeConnection(server, instance, database, user, password);

        }catch (SeException e) {

            e.printStackTrace();

            return;

        }

        // Fetching data

        String layerName = "EJES";

        SeObjectId layerID = null;

        String strSpatialColumn = "";

        try {

            Vector theLayers = conn.getLayers();

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

            {

                SeLayer layer = (SeLayer)theLayers.elementAt(i);

                if (layer.getName().equals(layerName)){

                    layerID = layer.getID();

                    strSpatialColumn = layer.getSpatialColumn();

                    System.err.println("Nombre de la capa= " + layer.getName());

                    for (int k=0;k<layerID.longValue();k++){

                            layer.getAccess();

                            layer.getQualifiedName();

                            layer.getArraySize();

                            layer.getDescription();

                            layer.getInfo();

                            layer.getShapeTypes();

//                            try{

                                    System.err.println("Nombre campo= " + layerID.longValue());

//                            } catch( SeException e ) {

//                                    //System.out.println(e.getSeError().getErrDesc());

//                            }

                    }

                }

            }

            if (layerID == null)

            {

                System.err.println("Capa no encontrada");

                return;

            }

            SeLayer layer = new SeLayer( conn, layerName, strSpatialColumn );

            SeSqlConstruct sqlConstruct = new SeSqlConstruct( layerName);

            long t1 = System.currentTimeMillis();

    //      Create a query stream between the client and server

            String[] cols = new String[2];

            cols[0] = new String("FID");

            cols[1] = layer.getSpatialColumn();

            SeQuery query = new SeQuery( conn, cols, sqlConstruct );

            query.prepareQuery();

            query.execute();

            long t2 = System.currentTimeMillis();

            System.out.println("Tiempo de consulta:" + (t2 - t1) + " milisegundos");

            t1 = System.currentTimeMillis();

            int cont = 0;

            SeRow row = query.fetch();

            if( row == null ) {

                System.out.println(" No rows fetched");

                return;

            }

            // String rowID = "2";

            // Get the definitions of all the columns retrieved

            SeColumnDefinition[] colDefs = row.getColumns();

            while (row != null)

            {

                evaluateRow(row, colDefs);

                row = query.fetch();

                cont++;

            }

            // Close the query.

            query.close();

            t2 = System.currentTimeMillis();

            System.out.println("Tiempo de recorrido:"  + (t2 - t1) + " milisegundos. " + cont + " registros.");

            /* SeQuery extentQuery = new SeQuery( conn, cols, sqlConstruct );

            SeQueryInfo queryInfo = new SeQueryInfo();

            queryInfo.setConstruct(sqlConstruct);

            // queryInfo.setQueryType(SeQueryInfo.SE_QUERYTYPE_JFA);

            // query.prepareQueryInfo(queryInfo);

            SeExtent seExtent = extentQuery.calculateLayerExtent(queryInfo);

            extentQuery.close();

            System.out.println(seExtent.toString());

            SeQuery queryAux;

            t1 = System.currentTimeMillis();

            // queryAux = new SeQuery( conn, cols, sqlConstruct );

            for (int i=0; i < 250; i++)

            {

                queryAux = new SeQuery( conn, cols, sqlConstruct );

                SeObjectId rowID = new SeObjectId(i+1);

                row = queryAux.fetchRow("provin", rowID, cols);

                evaluateRow(row, colDefs);

                queryAux.close();

            }

            // queryAux.close();

            t2 = System.currentTimeMillis();

            System.out.println("Tiempo de recorrido:"  + (t2 - t1) + " milisegundos. "); */

            /* queryAux = new SeQuery( conn, cols, sqlConstruct );

            SeObjectId rowID = new SeObjectId(1);

            row = queryAux.fetchRow("provin", rowID, cols);

            evaluateRow(row, colDefs);

            row = queryAux.fetch();

            evaluateRow(row, colDefs);

            queryAux.close(); */

        } catch( SeException e ) {

            System.out.println(e.getSeError().getErrDesc());

        }

    }

    static GeneralPathX convertSeShapeToGeneralPathX(SeShape spVal) throws SeException

    {

        double[][][] points = spVal.getAllCoords();

        GeneralPathX gpx = new GeneralPathX();

        // Display the X and Y values

        boolean bStartPart;

        for( int partNo = 0 ; partNo < points.length ; partNo++)

        {

            bStartPart = true;

            for( int subPartNo = 0 ; subPartNo < points[partNo].length ; subPartNo++)

                for( int pointNo = 0 ; pointNo < points[partNo][subPartNo].length ; pointNo+=2)

                {

                    if (bStartPart)

                    {

                        bStartPart = false;

                        gpx.moveTo(points[partNo][subPartNo][pointNo],

                                points[partNo][subPartNo][(pointNo+1)]);

                    }

                    else

                        gpx.lineTo(points[partNo][subPartNo][pointNo],

                                points[partNo][subPartNo][(pointNo+1)]);

                }

        }

        return gpx;

    }

    static void evaluateRow(SeRow row, SeColumnDefinition[] colDefs)

    {

        try

        {

            for (int colNum = 0; colNum < colDefs.length; colNum++)

            {

                SeColumnDefinition colDef = colDefs[colNum];

                int dataType = colDef.getType();

                if ( row.getIndicator((short)colNum) != SeRow.SE_IS_NULL_VALUE)

                {

                    switch( dataType )

                    {

                        case SeColumnDefinition.TYPE_SMALLINT:

                            break;

                        case SeColumnDefinition.TYPE_DATE:

                            break;

                        case SeColumnDefinition.TYPE_INTEGER:

                            break;

                        case SeColumnDefinition.TYPE_FLOAT:

                            break;

                        case SeColumnDefinition.TYPE_DOUBLE:

                            break;

                        case SeColumnDefinition.TYPE_STRING:

                            // System.out.println(row.getString(colNum));

                            break;

                        case SeColumnDefinition.TYPE_SHAPE:

                            SeShape spVal = row.getShape(colNum);

                            convertSeShapeToGeneralPathX(spVal);

                            // GeneralPath gp = spVal.toGeneralPath();

                            // GeneralPathX gpx = new GeneralPathX(gp);

                            // System.out.println("spVal.FID = " + spVal.getFeatureId().longValue());

                            // getShapeDetails(spVal);

                            break;

                    } // End switch

                } // End if

            } // for

        } catch (SeException e)

        {

            e.printStackTrace();

        }

    }

}