/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 408

Added by Matt Jones over 24 years ago

Continued code redesign for the DocumentImpl class. Now the "delete" and
"write" methods are static, so a DocumentImpl objject need not be created
in order to initiate a INSERT, UPDATE, or DELETE action (it is created
implicitly by the DBSAXHandler). When doing a "READ" action, one still
creates a new DocumentImpl instance which represents the document that
was read from the db (and calling toString() on it returns an XML
serialized version of the DocumentImpl).

This brings us close to being able to use the DocumentImpl class as a
DOM Implementation of the DOM Document interface.

          MetaCatUtil.debugMessage("start Document");
          // Create the document node representation as root
          rootNode = new DBSAXNode(conn, docname);
          MetaCatUtil.debugMessage("PRINTING DOCNAME FROM ROOTNODE: " +
                                    rootNode.getTagName());
          rootNode = new DBSAXNode(conn);
          // Add the node to the stack, so that any text data can be
          // added as it is encountered
          nodeStack.push(rootNode);
-...
          try {
            parentNode = (DBSAXNode)nodeStack.peek();
          } catch (EmptyStackException e) {
            parentNode = null;
+         }
          // Document representation that points to the root document node
-...
              MetaCatUtil.debugMessage("DOCTYPE-a: " + doctype);
            } else if (doctype == null) {
              doctype = docname;
              //doctype = DBEntityResolver.doctype;
              MetaCatUtil.debugMessage("DOCTYPE-b: " + doctype);
+           }
            rootNode.writeNodename(docname);
            rootNode.writeRootNodeID(rootNode.getNodeID());
            try {
              currentDocument = new DocumentImpl(conn, rootNode.getNodeID(),
                                                docname, doctype, docid, action);
              } catch (AccessionNumberException ane) {
                throw (new SAXException("Error with " + action, ane));
+             }
            } catch (AccessionNumberException ane) {
              throw (new SAXException("Error with " + action, ane));
+           }
            rootNode.writeDocID(currentDocument.getDocID());
+         }

     public class DocumentImpl {
       private Connection conn = null;
       private MetaCatUtil util = null;
       private String docid = null;
       private String docname = null;
       private String doctype = null;
-...
       private long rootnodeid;
       private ElementNode rootNode = null;
       private String doctitle = null;
       private String parserName = null;
       /**
        * Constructor, creates document from database connection, used
-...
       public DocumentImpl (Connection conn)
+      {
         this.conn = conn;
         this.util = new MetaCatUtil();
         this.parserName = util.getOption("saxparser");
+      }
       /**
-...
       /**
        * Write an XML file to the database, given a filename
+       *
        * @param conn the JDBC connection to the database
        * @param filename the filename to be loaded into the database
        * @param action the action to be performed (INSERT OR UPDATE)
        * @param docid the docid to use for the INSERT OR UPDATE
        */
       public String write( String filename, String action, String docid )
       public static String write( Connection conn, String filename, String action,
                                   String docid )
                     throws Exception, IOException, SQLException,
                            ClassNotFoundException, SAXException, SAXParseException {
          return write(new FileReader(new File(filename).toString()), action, docid);
          return write(conn, new FileReader(new File(filename).toString()),
                       action, docid);
+      }
       /**
        * Write an XML file to the database, given a Reader
+       *
        * @param conn the JDBC connection to the database
        * @param xml the xml stream to be loaded into the database
        * @param action the action to be performed (INSERT OR UPDATE)
        * @param docid the docid to use for the INSERT OR UPDATE
        */
       public String write( Reader xml, String action, String docid )
       public static String write( Connection conn, Reader xml, String action,
                                   String docid )
                     throws Exception, IOException, SQLException,
                            ClassNotFoundException, SAXException, SAXParseException {
         try {
             XMLReader parser = initializeParser(action, docid);
             XMLReader parser = initializeParser(conn, action, docid);
             conn.setAutoCommit(false);
             parser.parse(new InputSource(xml));
             conn.commit();
-...
+       *
        * @param docid the ID of the document to be deleted from the database
        */
       public void delete( String docid )
       public static void delete( Connection conn, String docid )
                       throws IOException, SQLException,
                              ClassNotFoundException, AccessionNumberException {
-...
         conn.setAutoCommit(false);
         // Copy the record to the xml_revisions table
         DocumentImpl document = new DocumentImpl(conn);
         document.archiveDocRevision( docid );
         DocumentImpl.archiveDocRevision( conn, docid );
         // Now delete it from the xml_documents table
         Statement stmt = conn.createStatement();
-...
             this.docid = AccessionNumber.generate(docid, "UPDATE");
             // Save the old document entry in a backup table
             archiveDocRevision(docid);
             DocumentImpl.archiveDocRevision( conn, docid );
             // Update the new document to reflect the new node tree
             pstmt = conn.prepareStatement(
-...
+      }
       /** Save a document entry in the xml_revisions table */
       private void archiveDocRevision(String docid) throws SQLException {
       private static void archiveDocRevision(Connection conn, String docid)
                           throws SQLException {
         // First get all of the values we need
         long rnodeid = -1;
         String docname = null;
-...
       /**
        * Set up the parser handlers for writing the document to the database
        */
       private XMLReader initializeParser(String action, String docid) {
       private static XMLReader initializeParser(Connection conn,
                                String action, String docid) {
         XMLReader parser = null;
         //
         // Set up the SAX document handlers for parsing
-...
           DTDHandler dtdhandler     = new DBDTDHandler(conn);
           // Get an instance of the parser
           MetaCatUtil util = new MetaCatUtil();
           String parserName = util.getOption("saxparser");
           parser = XMLReaderFactory.createXMLReader(parserName);
           // Turn off validation
-...
           String action   = null;
           String docid    = null;
           // Parse the command line arguments
           for ( int i=0 ; i < args.length; ++i ) {
             if ( args[i].equals( "-f" ) ) {
               filename =  args[++i];
-...
+            }
+          }
           // Check if the required arguments are provided
           boolean argsAreValid = false;
           if (action != null) {
             if (action.equals("INSERT")) {
-...
+            }
+          }
           // Print usage message if the arguments are not valid
           if (!argsAreValid) {
             System.err.println("Wrong number of arguments!!!");
             System.err.println(
-...
           MetaCatUtil util = new MetaCatUtil();
           Connection dbconn = util.openDBConnection();
           // Execute the action requested (READ, INSERT, UPDATE, DELETE)
           if (action.equals("READ")) {
               DocumentImpl xmldoc = new DocumentImpl( dbconn, docid );
               System.out.println(xmldoc.toString());
           } else if (action.equals("DELETE")) {
             DocumentImpl.delete(dbconn, docid);
             System.out.println("Document deleted: " + docid);
           } else {
             DocumentImpl doc = new DocumentImpl(dbconn);
             if (action.equals("DELETE")) {
               doc.delete(docid);
               System.out.println("Document deleted: " + docid);
             } else {
               String newdocid = doc.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!!! ");
             String newdocid = DocumentImpl.write(dbconn, 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!!! ");
+              }
               System.out.println("Document processing finished for: " + filename
                     + " (" + newdocid + ")");
             } else if ((docid == null) && (action.equals("UPDATE"))) {
               System.out.println("ERROR: Couldn't update document!!! ");
+            }
             System.out.println("Document processing finished for: " + filename
                   + " (" + newdocid + ")");
+          }
         } catch (McdbException me) {

        * Construct a new node instance for DOCUMENT nodes
+       *
        * @param conn the JDBC Connection to which all information is written
        * @param tagname the name of the node
        */
       public DBSAXNode (Connection conn, String tagname) {
         super(tagname);
       public DBSAXNode (Connection conn) {
         super();
         this.conn = conn;
         this.parentNode = null;
         writeChildNodeToDB("DOCUMENT", tagname, null);
         setRootNodeID(getNodeID());
         writeChildNodeToDB("DOCUMENT", null, null);
+      }
       /**
-...
           if (nodetype == "DOCUMENT") {
             pstmt = conn.prepareStatement(
                 "INSERT INTO xml_nodes " +
                 "(nodeid, nodetype, nodename) " +
                 "VALUES (?, ?, ?)");
                 "(nodeid, nodetype, nodename, rootnodeid) " +
                 "VALUES (?, ?, ?, ?)");
             MetaCatUtil.debugMessage("INSERTING DOCNAME: " + nodename);
           } else {
             pstmt = conn.prepareStatement(
                 "INSERT INTO xml_nodes " +
                 "(nodeid, nodetype, nodename, " +
                 "parentnodeid, rootnodeid, docid, nodedata, nodeindex) " +
                 "rootnodeid, parentnodeid, docid, nodedata, nodeindex) " +
                 "VALUES (?, ?, ?, ?, ?, ?, ?, ?)");
+          }
-...
           pstmt.setLong(1, nid);
           pstmt.setString(2, nodetype);
           pstmt.setString(3, nodename);
           if (nodetype != "DOCUMENT") {
           if (nodetype == "DOCUMENT") {
             pstmt.setLong(4, nid);
           } else {
             if (nodetype == "ELEMENT") {
               pstmt.setLong(4, getParentID());
               pstmt.setLong(5, getRootNodeID());
               pstmt.setLong(4, getRootNodeID());
               pstmt.setLong(5, getParentID());
               pstmt.setString(6, getDocID());
               pstmt.setString(7, data);
               pstmt.setInt(8, getNodeIndex());
             } else {
               pstmt.setLong(4, getNodeID());
               pstmt.setLong(5, getRootNodeID());
               pstmt.setLong(4, getRootNodeID());
               pstmt.setLong(5, getNodeID());
               pstmt.setString(6, getDocID());
               pstmt.setString(7, data);
               pstmt.setInt(8, incChildNum());
-...
           pstmt.execute();
           pstmt.close();
           if (nodetype.equals("DOCUMENT")) {
             // Record the root node id that was generated from the database
             setRootNodeID(nid);
+          }
           if (nodetype.equals("DOCUMENT") || nodetype.equals("ELEMENT")) {
             // Record the node id that was generated from the database
-...
+      }
       /**
        * creates SQL code to put root node id for the document node
        * into DB connection
        */
       public void writeRootNodeID(long rootnode_id) {
           try {
             PreparedStatement pstmt;
             pstmt = conn.prepareStatement(
                   "UPDATE xml_nodes set rootnodeid = ? " +
                   "WHERE nodeid = ?");
             // Bind the values to the query
             pstmt.setLong(1, rootnode_id);
             pstmt.setLong(2, getNodeID());
             // Do the insertion
             pstmt.execute();
             pstmt.close();
           } catch (SQLException e) {
             System.out.println(e.getMessage());
+          }
+      }
       /**
        * creates SQL code to put doc ID for the document node and for
        * comment/PI nodes under document node into DB connection
        */

             try {
                 // get a connection from the pool
                 conn = util.getConnection();
                 // write the document to the database
                 DocumentImpl doc = new DocumentImpl(conn);
                 try {
                     String accNumber = docid[0];
                     if (accNumber.equals("")) {
                         accNumber = null;
+                    }
                     newdocid = doc.write(xml, doAction, accNumber);
                     newdocid = DocumentImpl.write(conn, xml, doAction, accNumber);
                 } catch (NullPointerException npe) {
                   newdocid = doc.write(xml, doAction, null);
                   newdocid = DocumentImpl.write(conn, xml, doAction, null);
+                }
             } catch (Exception e) {
               response.setContentType("text/html");
-...
         try {
           // get a connection from the pool
           conn = util.getConnection();
           DocumentImpl doc = new DocumentImpl(conn);
                                           // NOTE -- NEED TO TEST HERE
                                           // FOR EXISTENCE OF PARAM
                                           // FOR EXISTENCE OF DOCID PARAM
                                           // BEFORE ACCESSING ARRAY
           try {
             doc.delete(docid[0]);
             DocumentImpl.delete(conn, docid[0]);
             response.setContentType("text/xml");
             out.println("<?xml version=\"1.0\"?>");
             out.println("<success>");

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 408

Added by Matt Jones over 24 years ago