/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 2910

Added by harris over 18 years ago

Implementation of the rubber-bad query that PMARK has implemented through the UI.

+       }
        /**
         * Returns the size (or number of documents) of the dataset
         */
         public int size() {
           return docs.size();
+        }
       /**
        * returns the data set as a flat-ascii table like:
+       *

     import org.apache.log4j.Logger;
     /**
      * Class that reflects a query against Metacat to gatther spatial data  -- this
      * Class that reflects a query against Metacat to gather spatial data  -- this
      * could be a text query that returns a spatial dataset or a spatial query that
      * returns a spatially-referenced dataset.
      */
-...
       public MetacatSpatialQuery() { }
       /// query that returns a dataset constarined by a bounding box
       public MetacatSpatialDataset queryDatasetByCartesianBounds(float _xmin,
                                                                  float _ymin,
                                                                  float _xmax,
                                                                  float _ymax) {
         /** all database querying is carried out in the Query Processor */
         mqp = new  SpatialQueryProcessor();
         // return the proc's results
         return mqp.queryDatasetByCartesianBounds(_xmin, _ymin, _xmax, _ymax);
+      }
       /**
        * returns the metacat spatial document retrieved by this query
        */

     public class SpatialQueryProcessor {
     	private String METACATURL = "http://nebulous.msi.ucsb.edu:9999/knp/metacat";
       private String METACATURL =
           "http://nebulous.msi.ucsb.edu:9999/knp/metacat";
       private File QUERYFILE = null;
     	private String MCUSER = "uid=harris,o=NCEAS,dc=ecoinformatics,dc=org";
       private String MCUSER = "uid=harris,o=NCEAS,dc=ecoinformatics,dc=org";
       private String MCPASS = "yeahRight";
       private  DBConnection dbconn;
       private DBConnection dbconn;
     	private static Logger log = Logger.getLogger(SpatialQueryProcessor.class.getName());
       private static Logger log =
           Logger.getLogger(SpatialQueryProcessor.class.getName());
     	/** constructor that uses the defaults **/
             /** constructor that uses the defaults **/
       public SpatialQueryProcessor() {
         try {
           dbconn = new DBConnection();
         } catch ( java.sql.SQLException se) {
         } catch(java.sql.SQLException se) {
           log.fatal("Error connecting to the database ...");
           se.getMessage();
+        }
+      }
           se.getMessage();
+        }
+      }
       /** call this after the processor is done **/
       protected void close() {
         try {
           dbconn.close();
         } catch ( java.sql.SQLException se) {
         } catch(java.sql.SQLException se) {
           log.fatal("Error closing connecting to the database ...");
           se.getMessage();
+        }
           se.getMessage();
+        }
+      }
       public SpatialQueryProcessor(String mcUser, String mcPass, String metacatUrl,
     	File queryFile) {
     		log.debug("constructor called");
     		this.METACATURL = metacatUrl;
     		this.MCPASS =  mcPass;
     		this.MCUSER = mcUser;
     		this.QUERYFILE = queryFile;
+    	}
     	public String execute() throws IOException {
     		FileReader queryFileReader = new FileReader(QUERYFILE);
     		String res = runQuery((Reader)queryFileReader);
     		return res;
+    	}
       public SpatialQueryProcessor(String mcUser, String mcPass,
                                    String metacatUrl, File queryFile) {
         log.debug("constructor called");
         this.METACATURL = metacatUrl;
         this.MCPASS = mcPass;
         this.MCUSER = mcUser;
         this.QUERYFILE = queryFile;
+      }
       protected  MetacatSpatialExtents queryExtentsForDataset() {
       public String execute() throws IOException {
         FileReader queryFileReader = new FileReader(QUERYFILE);
         String res = runQuery((Reader) queryFileReader);
          return res;
       } protected MetacatSpatialDataset queryDatasetByCartesianBounds(float
                                                                       _xmin,
                                                                       float
                                                                       _ymin,
                                                                       float
                                                                       _xmax,
                                                                       float
                                                                       _ymax) {
         MetacatSpatialDataset _data = new MetacatSpatialDataset();
       String query = "<?xml version=\"1.0\" ?> <pathquery version=\"1.2\"> "
       +"<querytitle>Untitled-Search-2</querytitle>  "
       +"<returndoctype>-//ecoinformatics.org//eml-dataset-2.0.0beta6//EN</returndoctype> "
       +"<returndoctype>-//NCEAS//eml-dataset-2.0//EN</returndoctype> "
       +"<returndoctype>eml://ecoinformatics.org/eml-2.0.0</returndoctype> "
       +"<returnfield>dataset/title</returnfield> "
       +"<returnfield>individualName/surName</returnfield> "
       +"<returnfield>keyword</returnfield><returnfield>westBoundingCoordinate</returnfield>"
       +"<returnfield>eastBoundingCoordinate</returnfield><returnfield>northBoundingCoordinate"
       +"</returnfield><returnfield>southBoundingCoordinate</returnfield>"
       +"<returnfield>westbc</returnfield><returnfield>eastbc</returnfield>"
       +"<returnfield>northbc</returnfield><returnfield>southbc</returnfield>"
       +"<querygroup operator=\"INTERSECT\"><querygroup operator=\"UNION\">"
       +"<querygroup operator=\"UNION\"><queryterm searchmode=\"contains\" casesensitive=\"false\">"
       +"<value>%</value></queryterm></querygroup></querygroup></querygroup></pathquery>";
      StringReader _sr = new StringReader(query);
      String _result = runQuery(_sr);
         // get all docid's
         Vector _docs = queryAllDocids();
      log.info("$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$: result data: " + _result);
         // for each, see if they fall w/in bounds
         for (int i = 0; i < _docs.size(); i++) {
           float _docMaxY =
               queryNorthBoundingCoordinate((String) _docs.elementAt(i));
           float _docMinY =
               querySouthBoundingCoordinate((String) _docs.elementAt(i));
           float _docMaxX =
               queryEastBoundingCoordinate((String) _docs.elementAt(i));
           float _docMinX =
               queryWestBoundingCoordinate((String) _docs.elementAt(i));
       return null;
+     }
           // check if inside the bounding box
           if (_docMaxX <= _xmax && _docMaxX >= _xmin) {
             MetacatSpatialDocument _doc =
                 new MetacatSpatialDocument((String) _docs.elementAt(i));
             _doc.setDocid((String) _docs.elementAt(i));
             // set the extents
             _data.add(_doc);
+          }
+        }
         return _data;
+      }
       /**
        * returns the north bounding coordinate -- this is a single point
        * Returns a Vector of all the docids in the xml_nodes tables
        */
         private float queryNorthBoundingCoordinate(String docid) {
           float _coord = MetacatSpatialConstants.FLOAT_NULL;
           PreparedStatement pstmt = null;
           ResultSet rs = null;
           String query = "select docid, nodedata, nodeid from xml_nodes where "
             +"nodeid =(select  nodeid from  xml_nodes where docid  like '"
             +docid.trim()+"' and nodename like 'north%')+1;";
           try {
             pstmt = dbconn.prepareStatement(query);
             pstmt.execute();
             rs = pstmt.getResultSet();
             if ( rs.next() )
              _coord = rs.getFloat(2);
             rs.close();
             pstmt.close();
           } catch (Exception e){
               log.error("Error getting docids from queryExtentsByDocid");
               e.printStackTrace();
       protected Vector queryAllDocids() {
         Vector _docs = new Vector();
         PreparedStatement pstmt = null;
         ResultSet rs = null;
         String query = "select distinct docid from xml_nodes";
         try {
           pstmt = dbconn.prepareStatement(query);
           pstmt.execute();
           rs = pstmt.getResultSet();
           while (rs.next()) {
             String docid = rs.getString(1);
             log.fatal("adding docid: " + docid);
             _docs.add(docid);
+          }
           return _coord;
           rs.close();
           pstmt.close();
+        }
         catch(Exception e) {
           log.error("Error getting docids from queryAllDocids");
           e.printStackTrace();
+        }
         return _docs;
+      }
       /**
        * returns the north bounding coordinate -- this is a single point
        */
       private float queryNorthBoundingCoordinate(String docid) {
         float _coord = MetacatSpatialConstants.FLOAT_NULL;
         PreparedStatement pstmt = null;
         ResultSet rs = null;
         String query = "select docid, nodedata, nodeid from xml_nodes where "
             + "nodeid =(select  nodeid from  xml_nodes where docid  like '"
             + docid.trim() + "' and nodename like 'north%')+1;";
         try {
           pstmt = dbconn.prepareStatement(query);
           pstmt.execute();
           rs = pstmt.getResultSet();
           if (rs.next())
             _coord = rs.getFloat(2);
           rs.close();
           pstmt.close();
+        }
         catch(Exception e) {
           log.error("Error getting docids from queryExtentsByDocid");
           e.printStackTrace();
+        }
         return _coord;
+      }
       /**
        * returns the east bounding coordinate -- this is a single point
        */
         private float queryEastBoundingCoordinate(String docid) {
           float _coord = MetacatSpatialConstants.FLOAT_NULL;
           PreparedStatement pstmt = null;
           ResultSet rs = null;
           String query = "select docid, nodedata, nodeid from xml_nodes where "
             +"nodeid =(select  nodeid from  xml_nodes where docid  like '"
             +docid.trim()+"' and nodename like 'east%')+1;";
           try {
             pstmt = dbconn.prepareStatement(query);
             pstmt.execute();
             rs = pstmt.getResultSet();
             if ( rs.next() )
              _coord = rs.getFloat(2);
             rs.close();
             pstmt.close();
           } catch (Exception e){
               log.error("Error getting docids from queryExtentsByDocid");
               e.printStackTrace();
+          }
           return _coord;
       private float queryEastBoundingCoordinate(String docid) {
         float _coord = MetacatSpatialConstants.FLOAT_NULL;
         PreparedStatement pstmt = null;
         ResultSet rs = null;
         String query = "select docid, nodedata, nodeid from xml_nodes where "
             + "nodeid =(select  nodeid from  xml_nodes where docid  like '"
             + docid.trim() + "' and nodename like 'east%')+1;";
         try {
           pstmt = dbconn.prepareStatement(query);
           pstmt.execute();
           rs = pstmt.getResultSet();
           if (rs.next())
             _coord = rs.getFloat(2);
           rs.close();
           pstmt.close();
+        }
         catch(Exception e) {
           log.error("Error getting docids from queryExtentsByDocid");
           e.printStackTrace();
+        }
         return _coord;
+      }
       /**
        * returns the south bounding coordinate -- this is a single point
        */
         private float querySouthBoundingCoordinate(String docid) {
           float _coord = MetacatSpatialConstants.FLOAT_NULL;
           PreparedStatement pstmt = null;
           ResultSet rs = null;
           String query = "select docid, nodedata, nodeid from xml_nodes where "
             +"nodeid =(select  nodeid from  xml_nodes where docid  like '"
             +docid.trim()+"' and nodename like 'south%')+1;";
           try {
             pstmt = dbconn.prepareStatement(query);
             pstmt.execute();
             rs = pstmt.getResultSet();
             if ( rs.next() )
              _coord = rs.getFloat(2);
             rs.close();
             pstmt.close();
           } catch (Exception e){
               log.error("Error getting docids from queryExtentsByDocid");
               e.printStackTrace();
+          }
           return _coord;
       private float querySouthBoundingCoordinate(String docid) {
         float _coord = MetacatSpatialConstants.FLOAT_NULL;
         PreparedStatement pstmt = null;
         ResultSet rs = null;
         String query = "select docid, nodedata, nodeid from xml_nodes where "
             + "nodeid =(select  nodeid from  xml_nodes where docid  like '"
             + docid.trim() + "' and nodename like 'south%')+1;";
         try {
           pstmt = dbconn.prepareStatement(query);
           pstmt.execute();
           rs = pstmt.getResultSet();
           if (rs.next())
             _coord = rs.getFloat(2);
           rs.close();
           pstmt.close();
+        }
         catch(Exception e) {
           log.error("Error getting docids from queryExtentsByDocid");
           e.printStackTrace();
+        }
         return _coord;
+      }
       /**
        * returns the west bounding coordinate -- this is a single point
        */
         private float queryWestBoundingCoordinate(String docid) {
           float _coord = MetacatSpatialConstants.FLOAT_NULL;
           PreparedStatement pstmt = null;
           ResultSet rs = null;
           String query = "select docid, nodedata, nodeid from xml_nodes where "
             +"nodeid =(select  nodeid from  xml_nodes where docid  like '"
             +docid.trim()+"' and nodename like 'west%')+1;";
           try {
             pstmt = dbconn.prepareStatement(query);
             pstmt.execute();
             rs = pstmt.getResultSet();
             if ( rs.next() )
              _coord = rs.getFloat(2);
             rs.close();
             pstmt.close();
           } catch (Exception e){
               log.error("Error getting docids from queryExtentsByDocid");
               e.printStackTrace();
+          }
           return _coord;
       private float queryWestBoundingCoordinate(String docid) {
         float _coord = MetacatSpatialConstants.FLOAT_NULL;
         PreparedStatement pstmt = null;
         ResultSet rs = null;
         String query = "select docid, nodedata, nodeid from xml_nodes where "
             + "nodeid =(select  nodeid from  xml_nodes where docid  like '"
             + docid.trim() + "' and nodename like 'west%')+1;";
         try {
           pstmt = dbconn.prepareStatement(query);
           pstmt.execute();
           rs = pstmt.getResultSet();
           if (rs.next())
             _coord = rs.getFloat(2);
           rs.close();
           pstmt.close();
+        }
         catch(Exception e) {
           log.error("Error getting docids from queryExtentsByDocid");
           e.printStackTrace();
+        }
         return _coord;
+      }
-...
        * @param docid -- the docid for which the extents are to be queried
        * @returns spatialextents -- the MetcataSpatialExtents object for this query
        */
         protected MetacatSpatialExtents queryExtentsByDocid(String docid) {
           MetacatSpatialExtents _extents = new MetacatSpatialExtents();
           float _northbc = queryNorthBoundingCoordinate(docid);
           float _eastbc = queryEastBoundingCoordinate(docid);
           float _southbc = querySouthBoundingCoordinate(docid);
           float _westbc = queryWestBoundingCoordinate(docid);
       protected MetacatSpatialExtents queryExtentsByDocid(String docid) {
         MetacatSpatialExtents _extents = new MetacatSpatialExtents();
           if (( _northbc == _southbc) && (_eastbc == _westbc) ) {
            _extents.setIsPoint(true); } else { _extents.setIsPoint(false); }
         float _northbc = queryNorthBoundingCoordinate(docid);
         float _eastbc = queryEastBoundingCoordinate(docid);
         float _southbc = querySouthBoundingCoordinate(docid);
         float _westbc = queryWestBoundingCoordinate(docid);
           _extents.setYMin( (_southbc < _northbc?  _southbc :  _northbc) );
           _extents.setYMax( (_southbc > _northbc?  _southbc :  _northbc) );
           _extents.setXMin( (_westbc < _eastbc?  _westbc :  _eastbc) );
           _extents.setXMax( (_westbc > _eastbc?  _westbc :  _eastbc) );
           _extents.setDocid(docid);
           log.warn("**************************** > " + _extents.toString() );
           return _extents;
         if ((_northbc == _southbc) && (_eastbc == _westbc)) {
           _extents.setIsPoint(true);
         } else {
           _extents.setIsPoint(false);
+        }
     	/**
         _extents.setYMin((_southbc < _northbc ? _southbc : _northbc));
         _extents.setYMax((_southbc > _northbc ? _southbc : _northbc));
         _extents.setXMin((_westbc < _eastbc ? _westbc : _eastbc));
         _extents.setXMax((_westbc > _eastbc ? _westbc : _eastbc));
         _extents.setDocid(docid);
         return _extents;
+      }
             /**
     		* Query the Metacat Server to get a list of documents,
     		* if it doesn't exist there, from the backend storage server.
+    		*
-...
     		* @throws QueryFailedException when any thing happens to prevent a query
     		*  returns
     		*/
       private String runQuery(Reader query)
+      {
       private String runQuery(Reader query) {
         String document = null;
         Reader xdoc = null;
-...
           log.debug("metacat instance: " + m);
           xdoc = m.query(query);
           document = IOUtil.getAsString(xdoc, true);
     			m.logout();
           m.logout();
           if (document == null) {
             throw new QueryFailedException("Document String Was null");
+          }

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 2910

Added by harris over 18 years ago