/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 1358

Added by Jing Tao about 22 years ago

Merge the branch for monarch.

     import java.net.URLConnection;
     import java.net.MalformedURLException;
     /**
      * A database aware Class implementing EntityResolver interface for the SAX
      * parser to call when processing the XML stream and intercepting any
      * external entities (including the external DTD subset and external
     /**
      * A database aware Class implementing EntityResolver interface for the SAX
      * parser to call when processing the XML stream and intercepting any
      * external entities (including the external DTD subset and external
      * parameter entities, if any) before including them.
      */
     public class DBEntityResolver implements EntityResolver
-...
       private String systemid = null;
       private Reader dtdtext = null;
       /**
       /**
        * Construct an instance of the DBEntityResolver class
+       *
        * @param conn the JDBC connection to which information is written
-...
+      {
         this.connection= conn;
+      }
       /**
       /**
        * Construct an instance of the DBEntityResolver class
+       *
        * @param conn the JDBC connection to which information is written
-...
         this.handler = handler;
         this.dtdtext = dtd;
+      }
       /**
        * The Parser call this method before opening any external entity
       /**
        * The Parser call this method before opening any external entity
        * except the top-level document entity (including the external DTD subset,
        * external entities referenced within the DTD, and external entities
        * external entities referenced within the DTD, and external entities
        * referenced within the document element)
        */
       public InputSource resolveEntity (String publicId, String systemId)
-...
+      {
         String dbSystemID;
         String doctype = null;
         // Won't have a handler under all cases
         if ( handler != null ) {
           if ( handler instanceof DBSAXHandler ) {
-...
             dhandler = (DBSAXHandler)handler;
             if ( dhandler.processingDTD() ) {
               // public ID is doctype
               if (publicId != null) {
               if (publicId != null) {
                 doctype = publicId;
               // assume public ID (doctype) is docname
               } else if (systemId != null) {
-...
             ahandler = (AccessControlList)handler;
             //if ( ahandler.processingDTD() ) {
               // public ID is doctype
               if (publicId != null) {
               if (publicId != null) {
                 doctype = publicId;
               // assume public ID (doctype) is docname
               } else if (systemId != null) {
-...
         // get System ID for doctype
         if (doctype != null) {
           // look at db XML Catalog for System ID
           // look at db XML Catalog for System ID
           dbSystemID = getDTDSystemID(doctype);
           boolean doctypeIsInDB = true;
           // no System ID found in db XML Catalog
-...
               dbSystemID = systemId;
+            }
+          }
           // there are dtd text provided; try to upload on Metacat
           if ( dtdtext != null ) {
             dbSystemID = uploadDTD(dbSystemID);
-...
+            }
             registerDTD(doctype, dbSystemID);
+          }
           // return a byte-input stream for use
           InputSource is = new InputSource(dbSystemID);
           InputSource is = new InputSource(dbSystemID);
           // close and open URLConnection again
           try {
             istream.close();
           } catch (IOException e) {
             throw new SAXException
             throw new SAXException
             ("DBEntityResolver.resolveEntity(): " + e.getMessage());
+          }
+          }
           istream = checkURLConnection(dbSystemID);
           is.setByteStream(istream);
           return is;
         } else {
           // use provided systemId for the other cases
           InputStream istream = checkURLConnection(systemId);
           return null;
+        }
+      }
       /**
       /**
        * Look at db XML Catalog to get System ID (if any) for @doctype.
        * Return null if there are no System ID found for @doctype
        */
-...
           //check out DBConnection
           conn=DBConnectionPool.getDBConnection("DBEntityResolver.getDTDSystemID");
           serialNumber=conn.getCheckOutSerialNumber();
           stmt = conn.createStatement();
           stmt.execute("SELECT system_id FROM xml_catalog " +
           stmt.execute("SELECT system_id FROM xml_catalog " +
                        "WHERE entry_type = 'DTD' AND public_id = '" +
                        doctype + "'");
           ResultSet rs = stmt.getResultSet();
-...
         return systemid;
+      }
       /**
        * Register new DTD identified by @systemId in Metacat XML Catalog
       /**
        * Register new DTD identified by @systemId in Metacat XML Catalog
        * . make a reference with @systemId for @doctype in Metacat DB
        */
       private void registerDTD ( String doctype, String systemId )
-...
           //check out DBConnection
           //conn=DBConnectionPool.getDBConnection("DBEntityResolver.registerDTD");
           //serialNumber=conn.getCheckOutSerialNumber();
           pstmt = connection.prepareStatement(
                  "INSERT INTO xml_catalog " +
                  "(catalog_id, entry_type, public_id, system_id) " +
-...
           }//catch
           //DBConnectionPool.returnDBConnection(conn, serialNumber);
         }//finally
+      }
       /**
       /**
        * Upload new DTD text identified by @systemId to Metacat file system
        */
       private String uploadDTD ( String systemId )
-...
         MetaCatUtil util = new MetaCatUtil();
         String dtdPath = util.getOption("dtdPath");
         String dtdURL = util.getOption("dtdURL");
         // get filename from systemId
         String filename = systemId;
         int slash = Math.max(filename.lastIndexOf('/'), filename.lastIndexOf('\\'));
-...
           // open file writer to write the input into it
           //String dtdPath = "/opt/tomcat/webapps/bojilova/dtd/";
           File f = new File(dtdPath, filename);
          synchronized (f) {
          synchronized (f) {
           try {
             if ( f.exists() ) {
               throw new IOException("File already exist: " + f.getCanonicalFile());
-...
           BufferedWriter out = new BufferedWriter(fw);
           // read the input and write into the file writer
     	    String inputLine;
     	    while ( (inputLine = in.readLine()) != null ) {
     	      out.write(inputLine, 0, inputLine.length());
       	    out.newLine(); //instead of out.write('\r\n');
+    	    }
           String inputLine;
           while ( (inputLine = in.readLine()) != null ) {
             out.write(inputLine, 0, inputLine.length());
             out.newLine(); //instead of out.write('\r\n');
+          }
           // the input and the output streams must be closed
     	    in.close();
     	    out.flush();
     	    out.close();
     	    fw.close();
          } // end of synchronized
           in.close();
           out.flush();
           out.close();
           fw.close();
          } // end of synchronized
         } catch (MalformedURLException e) {
           throw new SAXException
           ("DBEntityResolver.uploadDTD(): " + e.getMessage());
-...
           throw new SAXException
           ("DBEntityResolver.uploadDTD(): " + e.getMessage());
+        }
         //String dtdURL = "http://dev.nceas.ucsb.edu/bojilova/dtd/";
         return  dtdURL + filename;
+      }
       /**
       /**
        * Upload new DTD located at outside URL to Metacat file system
        */
       private String uploadDTDFromURL(InputStream istream, String systemId)
-...
         MetaCatUtil util = new MetaCatUtil();
         String dtdPath = util.getOption("dtdPath");
         String dtdURL = util.getOption("dtdURL");
         // get filename from systemId
         String filename = systemId;
         int slash = Math.max(filename.lastIndexOf('/'), filename.lastIndexOf('\\'));
-...
           // open file writer to write the input into it
           //String dtdPath = "/opt/tomcat/webapps/bojilova/dtd/";
           File f = new File(dtdPath, filename);
          synchronized (f) {
          synchronized (f) {
           try {
             if ( f.exists() ) {
               throw new IOException("File already exist: " + f.getCanonicalFile());
-...
           BufferedWriter out = new BufferedWriter(fw);
           // read the input and write into the file writer
     	    int inputByte;
     	    while ( (inputByte = in.read()) != -1 ) {
     	      out.write(inputByte);
       	    //out.newLine(); //instead of out.write('\r\n');
+    	    }
           int inputByte;
           while ( (inputByte = in.read()) != -1 ) {
             out.write(inputByte);
             //out.newLine(); //instead of out.write('\r\n');
+          }
           // the input and the output streams must be closed
     	    in.close();
     	    out.flush();
     	    out.close();
     	    fw.close();
           in.close();
           out.flush();
           out.close();
           fw.close();
          } // end of synchronized
         } catch (MalformedURLException e) {
           throw new SAXException
-...
           throw new SAXException
           ("DBEntityResolver.uploadDTDFromURL(): " + e.getMessage());
+        }
         //String dtdURL = "http://dev.nceas.ucsb.edu/bojilova/dtd/";
         return  dtdURL + filename;
+      }
       /**
       /**
        * Check URL Connection for @systemId, and return an InputStream
        * that can be used to read from the systemId URL.  The parser ends
        * up using this via the InputSource to read the DTD.
-...
         } catch (IOException e) {
           throw new SAXException
           ("DBEntityResolver.checkURLConnection(): " + e.getMessage());
+        }
+      }
+        }
+      }
+    }

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 1358

Added by Jing Tao about 22 years ago