/src/edu/ucsb/nceas/metacat/DBWriter.java - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 203

Added by Matt Jones almost 24 years ago

Merged in substantial changes to DBWriter and associated classes and to
the MetaCatServlet in order to accomodate the new UPDATE and DELETE
functions. The command line tools and the parameters for the
servlet have changed substantially.

     /**
      *      Name: DBWriter.java
      *   Purpose: A Class that reads in an XML text document and
      *            write its contents to a database connection using SAX
      * Copyright: 2000 Regents of the University of California and the
      *            National Center for Ecological Analysis and Synthesis
      *   Authors: Matt Jones
      *  '$RCSfile$'
      *    Purpose: A Class that reads in an XML text document and
      *             write its contents to a database connection using SAX
      *  Copyright: 2000 Regents of the University of California and the
      *             National Center for Ecological Analysis and Synthesis
      *    Authors: Matt Jones
+     *
      *   Version: '$Id$'
      *   '$Author$'
      *     '$Date$'
      * '$Revision$'
      */
     package edu.ucsb.nceas.metacat;
-...
       private Connection	conn = null;
       private String parserName = null;
       /** Default parser name. */
       private static final String
           DEFAULT_PARSER = "org.apache.xerces.parsers.SAXParser";
           //DEFAULT_PARSER = "oracle.xml.parser.v2.SAXParser";
       /**
        * the main routine used to test the DBWriter utility.
        * <p>
        * Usage: java DBWriter <filename>
        * Usage: java DBWriter <-f filename -a action -d docid>
+       *
        * @param filename the filename to be loaded into the database
        */
       static public void main(String[] args) {
          if (args.length < 1)
+         {
         try {
           String filename = null;
           String action   = null;
           String docid    = null;
           for ( int i=0 ; i < args.length; ++i ) {
             if ( args[i].equals( "-f" ) ) {
               filename =  args[++i];
             } else if ( args[i].equals( "-a" ) ) {
               action =  args[++i];
             } else if ( args[i].equals( "-d" ) ) {
               docid =  args[++i];
             } else {
               System.err.println
                 ( "   args[" +i+ "] '" +args[i]+ "' ignored." );
+            }
+          }
           boolean argsAreValid = false;
           if (action != null) {
             if (action.equals("INSERT")) {
               if (filename != null) {
                 argsAreValid = true;
+              }
             } else if (action.equals("UPDATE")) {
               if ((filename != null) && (docid != null)) {
                 argsAreValid = true;
+              }
             } else if (action.equals("DELETE")) {
               if (docid != null) {
                 argsAreValid = true;
+              }
+            }
+          }
           if (!argsAreValid) {
             System.err.println("Wrong number of arguments!!!");
             System.err.println("USAGE: java DBWriter <filename>");
             System.err.println(
                   "USAGE: java DBWriter <-f filename -a action -d docid>");
             return;
          } else {
             try {
               String filename = args[0];
+          }
           // Open a connection to the database
           MetaCatUtil   util = new MetaCatUtil();
           Connection dbconn = util.openDBConnection();
               // Open a connection to the database
               MetaCatUtil   util = new MetaCatUtil();
               Connection dbconn = util.openDBConnection();
           DBWriter dbw = new DBWriter(dbconn, util.getOption("saxparser"));
           if (action.equals("DELETE")) {
             dbw.delete(docid);
             System.out.println("Document deleted: " + docid);
           } else {
             String newdocid = dbw.write(filename, action, docid);
             if ((docid != null) && (!docid.equals(newdocid))) {
               if (action.equals("INSERT")) {
                 System.out.println("New document ID generated!!! ");
               } else if (action.equals("UPDATE")) {
                 System.out.println("ERROR: Couldn't update document!!! ");
+              }
             } else if ((docid == null) && (action.equals("UPDATE"))) {
                 System.out.println("ERROR: Couldn't update document!!! ");
+            }
             System.out.println("Document processing finished for: " + filename
                   + " (" + newdocid + ")");
+          }
               new DBWriter(filename, dbconn, DEFAULT_PARSER);
               System.out.println("Document processing finished for: " + filename);
             } catch (Exception e) {
               System.err.println("EXCEPTION HANDLING REQUIRED");
               System.err.println(e.getMessage());
               e.printStackTrace(System.err);
+            }
+         }
         } catch (AccessionNumberException ane) {
           System.out.println("ERROR: Couldn't delete document!!! ");
           System.out.println(ane.getMessage());
         } catch (Exception e) {
           System.err.println("EXCEPTION HANDLING REQUIRED");
           System.err.println(e.getMessage());
           e.printStackTrace(System.err);
+        }
+      }
       /**
        * construct a new instance of the class to write an XML file to the database
+       *
        * @param xml the xml stream to be loaded into the database
        * @param conn the database connection to which to write the XML file
        * @param parserName the name of a SAX2 compliant parser class
        */
       public DBWriter( Reader xml, Connection conn, String parserName)
                       throws IOException,
                              SQLException,
                              ClassNotFoundException {
       public DBWriter(Connection conn, String parserName) {
         this.conn = conn;
         this.parserName = parserName;
+      }
       /**
        * Insert XML stream to the database
+       *
        * @param xml the xml stream to be loaded into the database
        */
       public String write( Reader xml, String action, String docid )
                       throws IOException, SQLException, ClassNotFoundException {
         try {
             XMLReader parser = initializeParser();
             XMLReader parser = initializeParser(action, docid);
             conn.setAutoCommit(false);
             parser.parse(new InputSource(xml));
             conn.commit();
             conn.setAutoCommit(true);
             return docid;
           } catch (SAXParseException e) {
             conn.rollback();
             System.err.println(e.getMessage());
             return null;
           } catch (SAXException e) {
             conn.rollback();
             System.err.println(e.getMessage());
             // WHAT HAPPENS HERE IF THIS ISNT ACTUALLY AN AccessionNumberException?
             // IT CAUSES PROBLEMS!
             AccessionNumberException ane = null;
             try {
               ane = (AccessionNumberException)e.getException();
             } catch (ClassCastException cce) {
               return (e.getMessage());
+            }
             if (ane != null) {
               MetaCatUtil.debugMessage("DBWRITER LINE 120");
               MetaCatUtil.debugMessage(ane.getMessage());
               conn.commit();
               conn.setAutoCommit(true);
               return (ane.getMessage());
             } else {
               System.err.println(e.getMessage());
               conn.rollback();
               return null;
+            }
           } catch (Exception e) {
             conn.rollback();
             System.err.println(e.toString());
             return null;
+          }
+      }
       /**
        * construct a new instance of the class to write an XML file to the database
        * Insert an XML file to the database
+       *
        * @param filename the filename to be loaded into the database
        * @param conn the database connection to which to write the XML file
        * @param parserName the name of a SAX2 compliant parser class
        */
       public DBWriter( String filename, Connection conn, String parserName)
                       throws IOException,
                              SQLException,
                              ClassNotFoundException {
          this(new FileReader(new File(filename).toString()), conn, parserName);
       public String write( String filename, String action, String docid )
                       throws IOException, SQLException, ClassNotFoundException {
          return write(new FileReader(new File(filename).toString()), action, docid);
+      }
       private XMLReader initializeParser() {
       private XMLReader initializeParser(String action, String docid) {
         XMLReader parser = null;
         //
         // Set up the SAX document handlers for parsing
         //
         try {
           ContentHandler xmlDocHandler = new DBSAXHandler(conn);
           ContentHandler xmlDocHandler     = new DBSAXHandler(conn, action, docid);
           EntityResolver xmlEntityResolver = new DBEntityResolver(conn);
           DTDHandler xmlDTDHandler         = new DBDTDHandler(conn);
-...
         return parser;
+      }
       /**
        * Delete an XML file from the database (actually, just make it a revision
        * in the xml_revisions table)
+       *
        * @param docid the ID of the document to be deleted from the database
        */
       public void delete( String docid )
                       throws IOException, SQLException,
                              ClassNotFoundException, AccessionNumberException {
         String newdocid = AccessionNumber.generate(docid, "DELETE");
         conn.setAutoCommit(false);
         // Copy the record to the xml_revisions table
         DBSAXDocument document = new DBSAXDocument(conn);
         document.saveDocument( docid );
         // Now delete it from the xml_documents table
         Statement stmt = conn.createStatement();
         stmt.execute("DELETE FROM xml_documents WHERE docid LIKE '" + docid + "'");
         stmt.close();
         conn.commit();
+      }
+    }
     /**
      * '$Log$
      * 'Revision 1.20.2.7  2000/06/26 10:18:06  jones
      * 'Partial fix for MetaCatServlet INSERT?UPDATE bug.  Only will work on
      * 'the first call to the servlet.  Subsequent calls fail.  Seems to be
      * 'related to exception handling.  Multiple successive DELETE actions
      * 'work fine.
      * '
      * 'Revision 1.20.2.6  2000/06/26 08:38:02  jones
      * 'Added DELETE feature to DBWriter.  Now takes an action "DELETE" and a
      * 'docid and will move the record from the xml_documents table to the
      * 'xml_revisions table.
      * 'Modified option parsing to support option symbols on command line.
      * '
      * 'Revision 1.20.2.5  2000/06/26 02:02:20  jones
      * 'Continued fixing problems with exception handling that deals
      * 'with INSERT and UPDATE actions and the docid passed to DBWriter
      * '
      * 'Revision 1.20.2.4  2000/06/26 00:51:06  jones
      * 'If docid passed to DBWriter.write() is not unique, classes now generate
      * 'an AccessionNumberException containing the new docid generated as a
      * 'replacement.  The docid is then extracted from the exception and
      * 'returned to the calling application for user feedback or client processing.
      * '
      * 'Revision 1.20.2.3  2000/06/25 23:38:16  jones
      * 'Added RCSfile keyword
      * '
      * 'Revision 1.20.2.2  2000/06/25 23:34:18  jones
      * 'Changed documentation formatting, added log entries at bottom of source files
      * ''
      */

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 203

Added by Matt Jones almost 24 years ago