/src/edu/ucsb/nceas/metacat/DBReader.java - Annotate - Metacat - Ecoinformatics Redmine

metacat/src/edu/ucsb/nceas/metacat/DBReader.java @ 184

-            jones
+/**
-            jones
+ *      Name: DBReader.java
  *   Purpose: A Class that creates an XML text document
  *            from a query to a relational DB containing a DOM representation
  * Copyright: 2000 Regents of the University of California and the
  *            National Center for Ecological Analysis and Synthesis
  *   Authors: Matt Jones
             jones
-            jones
+ *   Version: '$Id$'
-            jones
+ */
-            jones
+package edu.ucsb.nceas.metacat;
-            jones
+import java.io.*;
 import java.net.URL;
 import java.net.MalformedURLException;
 import java.sql.*;
 import java.util.Stack;
-            jones
+/**
  * A Class that creates an XML text document
  * from a query to a relational DB containing a DOM representation
  */
-            jones
+public class DBReader {
   private Connection	conn = null;
-            jones
+  /**
    * main routine used for testing.
-            jones
+   * <p>
    * Usage: java DBReader <docid>
             jones
    * @param nodeid the id number of the root of the subtree to display
    */
-            jones
+  static public void main(String[] args) {
-            jones
+     if (args.length < 1)
             jones
         System.err.println("Wrong number of arguments!!!");
-            jones
+        System.err.println("USAGE: java DBReader <docid>");
-            jones
+        return;
      } else {
         try {
-            jones
+          String docid = args[0];
             jones
-            jones
+          // Open a connection to the database
-            jones
+          MetaCatUtil   util = new MetaCatUtil();
           Connection dbconn = util.openDBConnection();
             jones
           DBReader rd = new DBReader( dbconn );
-            jones
+          String xml = rd.readXMLDocument(docid);
-            jones
+          System.out.println(xml);
         } catch (Exception e) {
           System.err.println("EXCEPTION HANDLING REQUIRED");
           System.err.println(e.getMessage());
           e.printStackTrace(System.err);
+        }
+     }
+  }
-            jones
+  /**
    * construct a DBReader instance.
+   *
    * Generally, one calls readXMLDocument() after constructing the instance
+   *
-            jones
+   * @param conn the database connection from which to read the document
-            jones
+   */
-            jones
+  public DBReader( Connection conn )
-            jones
+                  throws IOException,
                          SQLException,
                          ClassNotFoundException
+  {
-            jones
+    this.conn = conn;
             jones
-            jones
+  /**
-            jones
+   * Get the root node id for an XML document given a document id
+   *
    * @param docid the document node contains the root of the document
    * @returns long the nodeid of the root node for this document
    */
-            bojilova
+  public long getRootNode(String docid) {
-            jones
+    // Now look up the root node id
     long rootnodeid = 0;
     try {
       PreparedStatement pstmt =
         conn.prepareStatement("SELECT rootnodeid " +
                 "FROM xml_documents " +
                 "WHERE docid = ?");
       // Bind the values to the query
-            bojilova
+      pstmt.setString(1, docid);
             jones
       pstmt.execute();
       try {
         ResultSet rs = pstmt.getResultSet();
         try {
           boolean tableHasRows = rs.next();
           if (tableHasRows) {
             try {
               rootnodeid = rs.getLong(1);
             } catch (SQLException e) {
               System.out.println("Error with getLong: " + e.getMessage());
+            }
+          }
         } catch (SQLException e) {
           System.out.println("Error with next: " + e.getMessage());
+        }
       } catch (SQLException e) {
         System.out.println("Error with getrset: " + e.getMessage());
+      }
       pstmt.close();
     } catch (SQLException e) {
       System.out.println("Error getting id: " + e.getMessage());
+    }
     return rootnodeid;
+  }
   /**
-            jones
+   * Create an XML document from the database starting with the element
    * having element_id nodeid
+   *
-            jones
+   * @param docid the document that we want retrieved
-            jones
+   */
-            bojilova
+  public String readXMLDocument(String docid) {
-            jones
+    StringBuffer doc = new StringBuffer();
-            jones
+    DoctypeInfo dti = getDoctypeInfo(docid);
             jones
-            jones
+    if (dti != null) {
       String docname = dti.getDocname();
       String doctype = dti.getDoctype();
       String sysid = dti.getSystemID();
       ElementNode element = new ElementNode(conn, getRootNode(docid));
       doc.append("<?xml version=\"1.0\"?>\n");
       if (docname != null) {
         if ((doctype != null) && (sysid != null)) {
           doc.append("<!DOCTYPE " + docname + " PUBLIC \"" + doctype +
                      "\" \"" + sysid + "\">\n");
         } else {
           doc.append("<!DOCTYPE " + docname + ">\n");
+        }
             jones
-            jones
+      doc.append(element.toString());
     } else {
       doc.append("<error>Document " + docid + " not found.</error>");
             jones
             jones
     return (doc.toString());
+  }
             jones
   /**
    * Look up the document type information from the database
+   *
    * @param docid the id of the document to look up
    */
-            bojilova
+  public DoctypeInfo getDoctypeInfo(String docid) {
-            jones
+    PreparedStatement pstmt;
     String doctype = null;
     String docname = null;
     String sysid   = null;
     DoctypeInfo dti = null;
     try {
       pstmt =
         conn.prepareStatement("SELECT docname,doctype " +
                                 "FROM xml_documents " +
                                "WHERE docid = ?");
       // Bind the values to the query
-            jones
+      pstmt.setString(1, docid);
             jones
       pstmt.execute();
       ResultSet rs = pstmt.getResultSet();
       boolean tableHasRows = rs.next();
       if (tableHasRows) {
         docname  = rs.getString(1);
         doctype  = rs.getString(2);
+      }
       pstmt.close();
-            jones
+      if (doctype != null) {
         pstmt =
           conn.prepareStatement("SELECT system_id " +
                                   "FROM xml_catalog " +
                                  "WHERE public_id = ?");
         // Bind the values to the query
         pstmt.setString(1, doctype);
         pstmt.execute();
         rs = pstmt.getResultSet();
         tableHasRows = rs.next();
         if (tableHasRows) {
           sysid  = rs.getString(1);
+        }
         pstmt.close();
+      }
-            jones
+    } catch (SQLException e) {
       System.out.println("Error getting id: " + e.getMessage());
+    }
-            jones
+    if (docname != null) {
       dti = new DoctypeInfo(docname, doctype, sysid);
     } else {
       dti = null;
+    }
-            jones
+    return dti;
+  }
   /**
    * A utility class that encapsulates document type information
    */
   public class DoctypeInfo {
     private String docname = null;
     private String doctype = null;
     private String system_id = null;
     /**
      * Constructor
      */
     public DoctypeInfo(String docname, String doctype, String system_id) {
       this.docname = docname;
       this.doctype = doctype;
       this.system_id = system_id;
+    }
     /**
      * get the document name
      */
     public String getDocname() {
       return docname;
+    }
     /**
      * get the document type
      */
     public String getDoctype() {
       return doctype;
+    }
     /**
      * get the system identifier
      */
     public String getSystemID() {
       return system_id;
+    }
+  }
             jones

Project

General

Profile

Metacat