Metacat

/**

 *   Purpose: A Class that implements a metadata catalog as a java Servlet

 * Copyright: 2000 Regents of the University of California and the

 *            National Center for Ecological Analysis and Synthesis

 *   Authors: Matt Jones, Dan Higgins

 *

 *   Version: '$Id$'

package edu.ucsb.nceas.metacat;

import java.io.IOException;

import java.io.StringReader;

import java.util.Hashtable;

import java.util.PropertyResourceBundle;

import java.net.MalformedURLException;

import java.sql.ResultSet;

import javax.servlet.ServletConfig;

import javax.servlet.ServletContext;

import javax.servlet.ServletException;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import oracle.xml.parser.v2.XSLException;

import oracle.xml.parser.v2.XMLDocumentFragment;

import oracle.xml.parser.v2.XSLProcessor;

import java.io.File;

import java.io.FileInputStream;

 * A metadata catalog server implemented as a Java Servlet

 * <p>Valid parameters are:<br>

 * action=query -- query the values of all elements and attributes

 *                     and return a result set of nodes<br>

 * action=query -- search text values for document match<br>

 * doctype -- document type list returned by the query (publicID)

 * qformat=xml -- display resultset from query in XML<br>

 * qformat=html -- display resultset from query in HTML<br>

 * action=getdocument -- display an XML document in XML or HTML<br>

 * docid=34 -- display the document with the document ID number 34<br>

 * action=putdocument -- load an XML document into the database store<br>

 * doctext -- XML text ofthe document to load into the database<br>

 * query -- actual query text (to go with 'action=query')<br>

 * action=validate -- vallidate the xml contained in validatetext<br>

 * valtext -- XML text to be validated

 * action=getdatadoc -- retreive a stored datadocument

 * datadoc -- data document name (id)

public class MetaCatServlet extends HttpServlet {

  private ServletConfig		config = null;

  private ServletContext	context = null;

  String 	password = null;

  String 	defaultDB = null;

  String 	resultStyleURL = null;

                                    // that can be downloaded will be stored

  String    executescript  = null;  // script to get data file and put it

                                    // in defaultdocpath dir

   * Initialize the servlet by creating appropriate database connections

   */

    try {

      super.init( config );

      this.config = config;

      this.context = config.getServletContext();

          PropertyResourceBundle.getBundle("edu.ucsb.nceas.metacat.metacat");

      password = (String)options.handleGetObject("password");

      defaultDB = (String)options.handleGetObject("defaultDB");

      resultStyleURL = (String)options.handleGetObject("resultStyleURL");

      executescript = (String)options.handleGetObject("executescript");

                defaultDB, user, password);

        docreader = new DBReader(conn);

    } catch ( ServletException ex ) {

      throw ex;

    }

  }

    throws ServletException, IOException {

    throws ServletException, IOException {

    // Process the data and send back the response

    HttpServletResponse response)

      System.err.println("Connection to database lost.  Reopening...");

      try {

        // Open a connection to the database

        conn = MetaCatUtil.openDBConnection(

                "oracle.jdbc.driver.OracleDriver",

                defaultDB, user, password);

        queryobj = new DBSimpleQuery(conn);

        docreader = new DBReader(conn);

        dbt = new DBTransform(conn);

      } catch (Exception e) {

        System.err.println("Error opening database connection");

      }

    }

    String[] value = null;

    Enumeration paramlist = request.getParameterNames();

    while (paramlist.hasMoreElements()) {

      name = (String)paramlist.nextElement();

      value = request.getParameterValues(name);

      // Decode the docid and mouse click information

      if (name.endsWith(".y")) {

        docid[0] = name.substring(0,name.length()-2);

        //out.println("docid => " + docid[0]);

        params.put("docid", docid);

        name = "ypos";

      }

      if (name.endsWith(".x")) {

        name = "xpos";

      }

    }

    // if the action parameter is set, use it as a default

    // but if the ypos param is set, calculate the action needed

    try {

      ypos = (new Long(((String[])params.get("ypos"))[0]).longValue());

      //out.println("<P>YPOS IS " + ypos);

      if (ypos <= 13) {

        action = "getdocument";

      } else if (ypos > 13 && ypos <= 27) {

        action = "validate";

      } else if (ypos > 27) {

        action = "transform";

      } else {

        action = "";

      }

    } catch (Exception npe) {

      //out.println("<P>Caught exception looking for Y value.");

    }

      handleQueryAction(out, params, response);

    } else if (action.equals("getdocument")) {

        handleGetDocumentAction(out, params, response);

      } catch (ClassNotFoundException e) {

      handlePutDocumentAction(out, params, response);

      handleValidateAction(out, params, response);

      handleGetDataDocumentAction(out, params, response);

      out.println("Error: action not registered.  Please report this error.");

  }

   * Handle the database query request and return a result set, possibly

   * transformed from XML into HTML

   */

               HttpServletResponse response) {

      // Run the query

      String doctype = null;

      if (doctypeArr != null) {

        doctype = ((String[])params.get("doctype"))[0];

      }

          nodelist = queryobj.findDocuments(query,doctype);

        } else {

          nodelist = queryobj.findDocuments(query);

        }

        out.println("Query Object Init failed.");

        out.println(defaultDB);

        */

        return;

      // Create a buffer to hold the xml result

      StringBuffer resultset = new StringBuffer();

      String document = null;

      //               "\"-//NCEAS//resultset//EN\" \"resultset.dtd\">\n");

      resultset.append("  <query>" + query + "</query>");

      while (rootlist.hasMoreElements()) {

        document = (String)nodelist.get(nodeid);

        resultset.append("  <document>" + document + "</document>");

      String qformat = ((String[])params.get("qformat"))[0];

      if (qformat.equals("xml")) {

        // set content type and other response header fields first

        response.setContentType("text/xml");

        out.println(resultset.toString());

      } else if (qformat.equals("html")) {

        // set content type and other response header fields first

        response.setContentType("text/html");

        //out.println("Converting to HTML...");

        XMLDocumentFragment htmldoc = null;

        try {

          XSLStylesheet style = new XSLStylesheet(new URL(resultStyleURL), null);

          htmldoc = (new XSLProcessor()).processXSL(style,

                     (Reader)(new StringReader(resultset.toString())),null);

          htmldoc.print(out);

        } catch (Exception e) {

          out.println("Error transforming document:\n" + e.getMessage());

        }

      }

   * Handle the database getdocument request and return a XML document,

   * possibly transformed from XML into HTML

   */

               throws ClassNotFoundException, IOException, SQLException {

    long docid = 0;

    String doc = null;

    try {

      docid = (new Long(docidstr)).longValue();

    } catch (NullPointerException npe) {

      response.setContentType("text/html");

      out.println("Error getting document ID: " + docidstr +" (" + docid + ")");

    }

      if (qformat.equals("xml")) {

        // set content type and other response header fields first

        response.setContentType("text/xml");

        out.println(doc);

      } else if (qformat.equals("html")) {

        // set content type and other response header fields first

        response.setContentType("text/html");

        dbt.transformXMLDocument(doc, sourcetype, "-//W3C//HTML//EN", out);

  /**

   * Handle the database putdocument request and write an XML document

   * to the database connection

   */

  private void handlePutDocumentAction(PrintWriter out, Hashtable params,

               HttpServletResponse response) {

      StringReader xml = new StringReader(doctext[0]);

      // write the document to the database

      // set content type and other response header fields first

  /**

   * Handle the validtion request and return the results

  private void handleValidateAction(PrintWriter out, Hashtable params, HttpServletResponse response) {

    String valtext = null;

    try {

      valtext = ((String[])params.get("valtext"))[0];

    } catch (Exception nullpe) {

      long docid = 0;

      try {

        // Find the document id number

        docidstr = ((String[])params.get("docid"))[0];

        docid = (new Long(docidstr)).longValue();

        // Get the document indicated fromthe db

        valtext = docreader.readXMLDocument(docid);

      } catch (NullPointerException npe) {

        response.setContentType("text/html");

        out.println("Error getting document ID: " +

                     docidstr +" (" + docid + ")");

      }

    }

    parser.setValidationMode(true);      // Oracle

    try {

      // set content type and other response header fields first

      out.println("<html>");

      out.println("<head><link rel=\"stylesheet\" type=\"text/css\" " +

                  "href=\"/xmltodb/rowcol.css\" /></head>");

      out.println("<body class=\"emlbody\">");

      if (valid) {

        out.println("The input XML is VALID!");

                    + gxv.returnErrors() + "\n</pre>\n");

        //out.println(valtext);

      // set content type and other response header fields first

      response.setContentType("text/html");

      //out.println(valtext);

      out.println("Error validating document.");

  /**

   * Look up the document type from the database

   *

    String doctype = null;

    try {

      pstmt =

        conn.prepareStatement("SELECT doctype " +

                                "FROM xml_documents " +

                               "WHERE docid = ?");

      // Bind the values to the query

      pstmt.setLong(1, new Long(docid).longValue());

      pstmt.execute();

      try {

        ResultSet rs = pstmt.getResultSet();

        try {

          boolean tableHasRows = rs.next();

          if (tableHasRows) {

            try {

              doctype  = rs.getString(1);

            } catch (SQLException e) {

              System.out.println("Error with getString: " + 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 doctype;

  }

  /**

   * Handle the document request and return the results

  private void handleGetDataDocumentAction(PrintWriter out, Hashtable params, HttpServletResponse response) {

      boolean error_flag = false;

      String error_message = "";

      // Get the document indicated

      String[] datadoc = (String[])params.get("datadoc");

  //    defaultdatapath = "C:\\Temp\\";    // for testing only!!!

   //   executescript = "test.bat";        // for testing only!!!

      // set content type and other response header fields first

      response.setContentType("application/octet-stream");

   if (defaultdatapath!=null) {

        if(!defaultdatapath.endsWith(System.getProperty("file.separator"))) defaultdatapath=defaultdatapath+System.getProperty("file.separator");

      System.out.println("Path= "+defaultdatapath+datadoc[0]);

      if (executescript!=null) {

        String command = null;

        File scriptfile = new File(executescript);

        if (scriptfile.exists()) {

            command=executescript+" "+datadoc[0]; }  // execute script includes path

        else {     // look in defaultdatapath

                command = defaultdatapath+executescript+" "+datadoc[0];  // on Win98 one MUST include the .bat extender

        }

      System.out.println(command);

      try {

      Process proc = Runtime.getRuntime().exec(command);

      proc.waitFor();

      }

      catch (Exception eee) {

        System.out.println("Error running process!");

        error_flag = true;

        error_message = "Error running process!";}

      } // end executescript not null if

      File datafile = new File(defaultdatapath+datadoc[0]);

      try {

      FileInputStream fw = new FileInputStream(datafile);

      int x;

     while ((x = fw.read())!=-1) {

        out.write(x); }

      fw.close();

      }

      catch (Exception e) {

        System.out.println("Error in returning file\n"+e.getMessage());

        error_flag=true;

        error_message = error_message+"\nError in returning file\n"+e.getMessage();}

   } // end defaultdatapath not null if

  }