tim@129: /**
tim@129:  * Title:           ArcSDEUtils, $Header: /share/gdi/SDI-Suite/Repository/projekte/BSH-GDI/genericViewer/src/main/java/de/conterra/bsh/gdi/gnviewer/datasources/sde/ArcSDEUtils.java,v 1.7 2007/11/28 14:05:39 blume Exp $
tim@129:  * Source:          $Source: /share/gdi/SDI-Suite/Repository/projekte/BSH-GDI/genericViewer/src/main/java/de/conterra/bsh/gdi/gnviewer/datasources/sde/ArcSDEUtils.java,v $
tim@129:  * created by:      Stefan Blume (blume)
tim@129:  * erstellt am:     21.11.2007
tim@129:  * Copyright:       con terra GmbH, 2005
tim@129:  *
tim@129:  * modified by:     $Author: blume $
tim@129:  * modified on:     $Date: 2007/11/28 14:05:39 $
tim@129:  * Version:         $Revision: 1.7 $
tim@129:  * TAG:             $Name:  $
tim@129:  * locked from:     $Locker:  $
tim@129:  * CVS State:       $State: Exp $
tim@129:  * Project:         $ProjectName$
tim@129:  */
tim@129: package de.intevation.gnv.geobackend.sde.datasources;
tim@129: 
tim@129: import java.util.Vector;
tim@129: 
tim@129: import org.apache.log4j.Logger;
tim@129: 
tim@129: import com.esri.sde.sdk.client.SDEPoint;
tim@129: import com.esri.sde.sdk.client.SeColumnDefinition;
tim@129: import com.esri.sde.sdk.client.SeConnection;
tim@129: import com.esri.sde.sdk.client.SeError;
tim@129: import com.esri.sde.sdk.client.SeException;
tim@129: import com.esri.sde.sdk.client.SeQuery;
tim@129: import com.esri.sde.sdk.client.SeQueryInfo;
tim@129: import com.esri.sde.sdk.client.SeSqlConstruct;
tim@129: import com.esri.sde.sdk.client.SeTable;
tim@129: 
tim@129: import de.intevation.gnv.geobackend.sde.datasources.exception.ConnectionException;
tim@129: import de.intevation.gnv.geobackend.sde.datasources.exception.TechnicalException;
tim@129: 
tim@129: /**
tim@129:  * The class <code>ArcSDEUtils</code> fulfills the following purposes:
tim@129:  * <ol>
tim@129:  * <li></li>
tim@129:  * </ol>
tim@129:  *
tim@129:  * @author blume
tim@129:  * @version 1.0
tim@129:  * @serial 1.0
tim@129:  * @see
tim@129:  * @since 21.11.2007 08:20:40
tim@129:  */
tim@129: public class ArcSDEUtils {
tim@129: 
tim@129:     /**
tim@129:      * Default Logging instance
tim@129:      */
tim@129:     private static Logger sLogger = Logger.getLogger(ArcSDEUtils.class);
tim@129: 
tim@129: 
tim@129:     /**
tim@129:      * @param pTable e.g. "BSH.ARCMARINE_TIMESERIES_VIEW"
tim@129:      * @param pWhere where-Clause (can be empty, null-case not tested)
tim@129:      */
tim@129:     public void getTableStats(String pTable, String pWhere) {
tim@129:         sLogger.debug("getTableStats()");
tim@129:         SeConnection conn = null;
tim@129:         SeTable.SeTableStats tableStats;
tim@129:         try {
tim@129:             conn = getConnection();
tim@129:             SeTable table = new SeTable(conn, pTable);
tim@129: 
tim@129:             SeSqlConstruct sqlCons = new SeSqlConstruct(table.getQualifiedName());
tim@129:             sqlCons.setWhere(pWhere);
tim@129:             SeQuery query = new SeQuery(conn);
tim@129:             SeQueryInfo queryInfo = new SeQueryInfo();
tim@129:             queryInfo.setConstruct(sqlCons);
tim@129:             int mask = SeTable.SeTableStats.SE_ALL_STATS;
tim@129:             int maxDistinct = 0;
tim@129: 
tim@129:             SeColumnDefinition[] colDefs = table.describe();
tim@129: 
tim@129:             for (SeColumnDefinition lColDef : colDefs) {
tim@129:                 sLogger.debug(lColDef.getName() + " - " + ArcSDEUtils.resolveType(lColDef.getType()));
tim@129:             }
tim@129: 
tim@129: 
tim@129:             tableStats = query.calculateTableStatistics(colDefs[1].getName(), mask, queryInfo, maxDistinct);
tim@129:             displayStats(tableStats);
tim@129: 
tim@129: 
tim@129:         } catch (SeException e) {
tim@129:             printError(e);
tim@129:         } catch (ConnectionException e) {
tim@129:             sLogger.error(e.getMessage(), e);
tim@129:             e.printError();
tim@129:         } catch (TechnicalException e) {
tim@129:             sLogger.error(e.getMessage(), e);
tim@129:         } finally {
tim@129:             // return connection
tim@129:             returnConnection(conn);
tim@129:         }
tim@129: 
tim@129:     }// End method getTableStats
tim@129: 
tim@129: 
tim@129:     public void displayStats(SeTable.SeTableStats tableStats) {
tim@129: 
tim@129:         sLogger.debug("\n--> Table Statistics\n");
tim@129:         if (tableStats != null) {
tim@129: 
tim@129:             sLogger.debug("Average - " + tableStats.getAverage());
tim@129:             sLogger.debug("No of rows - " + tableStats.getCount());
tim@129:             sLogger.debug("Maximum Value - " + tableStats.getMax());
tim@129:             sLogger.debug("Minimum Value - " + tableStats.getMin());
tim@129:             sLogger.debug("No of distinct values - " + tableStats.getNumDistinct());
tim@129:             sLogger.debug("Standard Deviation - " + tableStats.getStdDev());
tim@129: 
tim@129:             sLogger.debug("Distinct type - " + ArcSDEUtils.resolveType(tableStats.getDistinctType()));
tim@129: 
tim@129:             int[] distinctFreq = tableStats.getDistinctValueFrequencies();
tim@129:             Vector distinctValues = tableStats.getDistinctValues();
tim@129:             sLogger.debug("Distinct values & their frequencies : ");
tim@129:             for (int i = 0; i < distinctFreq.length; i++)
tim@129:                 sLogger.debug(distinctValues.elementAt(i) + " - " + distinctFreq[i]);
tim@129:         }// End if
tim@129: 
tim@129:     }// End displayStats
tim@129: 
tim@129: 
tim@129:     /**
tim@129:      * Takes an integer corresponding to an ArcSDE data type
tim@129:      * and returns a string description of the type.
tim@129:      *
tim@129:      * @param type SDE data type bit-mask.
tim@129:      */
tim@129:     public static String resolveType(int type) {
tim@129: 
tim@129:         String typeName = "Invalid Type";
tim@129:         switch (type) {
tim@129: 
tim@129:             case SeColumnDefinition.TYPE_SMALLINT:
tim@129:                 typeName = "Small Int";
tim@129:                 break;
tim@129:             case SeColumnDefinition.TYPE_INTEGER:
tim@129:                 typeName = "Int";
tim@129:                 break;
tim@129:             case SeColumnDefinition.TYPE_FLOAT:
tim@129:                 typeName = "Float";
tim@129:                 break;
tim@129:             case SeColumnDefinition.TYPE_DOUBLE:
tim@129:                 typeName = "Double";
tim@129:                 break;
tim@129:             case SeColumnDefinition.TYPE_STRING:
tim@129:                 typeName = "String";
tim@129:                 break;
tim@129:             case SeColumnDefinition.TYPE_BLOB:
tim@129:                 typeName = "Blob";
tim@129:                 break;
tim@129:             case SeColumnDefinition.TYPE_DATE:
tim@129:                 typeName = "Date";
tim@129:                 break;
tim@129:             case SeColumnDefinition.TYPE_SHAPE:
tim@129:                 typeName = "Shape";
tim@129:                 break;
tim@129:             case SeColumnDefinition.TYPE_RASTER:
tim@129:                 typeName = "Raster";
tim@129:                 break;
tim@129:         }
tim@129:         return typeName;
tim@129:     }// End method resolveType
tim@129: 
tim@129:     public static void printError(SeException exception) {
tim@129: 
tim@129:         SeError error = exception.getSeError();
tim@129: 
tim@129:         sLogger.debug("\n ArcSDE Error Number        : " + error.getSdeError());
tim@129:         sLogger.debug(" Error Description          : " + error.getErrDesc());
tim@129: 
tim@129:         int extError = error.getExtError();
tim@129:         if (extError != 0)
tim@129:             sLogger.debug(" Extended Error Number      : " + extError);
tim@129: 
tim@129:         String desc = error.getSdeErrMsg();
tim@129:         if (desc != null && desc.length() != 0)
tim@129:             sLogger.debug(" Extended Error Description : " + desc);
tim@129: 
tim@129:         desc = error.getExtErrMsg();
tim@129:         if (desc != null && desc.length() != 0)
tim@129:             sLogger.debug(" Extended Error Description : " + desc);
tim@129: 
tim@129:         sLogger.debug(exception);
tim@129: 
tim@129:     }// End printError
tim@129: 
tim@129:     private SeConnection getConnection() throws TechnicalException {
tim@129:         //DatasourceConnection lConnection = ConnectionPoolManager.getInstance().getConnection(ConnectionPoolManager.CON_SDE);
tim@129:         //return ((SDEConnection) lConnection).getConnection();
tim@129:         return null;
tim@129:     }
tim@129: 
tim@129:     private void returnConnection(SeConnection pConnection) {
tim@129:         //ConnectionPoolManager.getInstance().returnConnection(pConnection);
tim@129:     }
tim@129: 
tim@129:     public static SDEPoint[] createPoints(double[][] pPoints) {
tim@129:         sLogger.debug("createPoints()");
tim@129:         SDEPoint[] lSDEPoints = new SDEPoint[pPoints.length];
tim@129:         for (int i = 0; i < pPoints.length; i++) {
tim@129:             double[] lPoint = pPoints[i];
tim@129:             lSDEPoints[i] = new SDEPoint(lPoint[0], lPoint[1]);
tim@129:         }
tim@129:         return lSDEPoints;
tim@129: 
tim@129:     }
tim@129: }