Metacat

/**

 *   '$Author$'

 *     '$Date$'

 * '$Revision$'

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

package edu.ucsb.nceas.metacat;

import java.sql.*;

import java.util.*;

import java.lang.Thread;

public class RelationHandler implements Runnable

{

  private Thread btThread = null;

  private Connection conn = null;

  private DocumentImpl xmldoc = null;

  MetaCatUtil util = new MetaCatUtil();

  /**

   * Constructor for this class.  finds all of the relations to a single xml

   * document and writes them to the database.  This includes transitive

   * relations.

   * @param xmldoc the xml document to index.

   */

  public RelationHandler(DocumentImpl xmldoc, Connection conn)

  {

    try

    {

                                                "relationHandler");

    catch(Exception e)

    {

                         "relationhandler: " + e.getMessage());

    if(xmldoc.getDoctype().equals(util.getOption("packagedoctype")))

    { //make sure this doctype is a package document then run the thread

      btThread = new Thread(this);

      btThread.setPriority(Thread.MIN_PRIORITY);

      btThread.start();

    }

  }

  /**

   * The thread handler

  {

    // deletes all of the relations with a docid of @docid.

    deleteRelations(docid);

    //for each new relation r in xml_nodes

    //  put r into xml_relation

    //  compare r to each relation already in xml_relation

    //  if r isrelatedto a row in xml_relation

    //    add a new row to xml_relation that represents this new relation

    try

    {

                                                  "run");

      PreparedStatement pstmt = dbconn.prepareStatement(

      pstmt.execute();

      ResultSet rs = pstmt.getResultSet();

      boolean hasmorerows = rs.next();

      while(hasmorerows)

      {

        String subject = rs.getString(1);

        String subjectDoctype = null;

        URL subjectMurl = null;

        try

          subjectDoctype = null;

          Hashtable murlParams = util.parseQuery(subjectMurl.getQuery());

          paramDocid = (String)murlParams.get("docid");

        { //assume this is just a docid not a url

          paramDocid = subject;

        }

        String object = rs.getString(3);

        //compare r to each relation in xml_relation

                                      "from xml_relation");

        pstmt.execute();

        //get each relation in xml_relation for comparison

        ResultSet relations = pstmt.getResultSet();

        boolean hasmorerelations = relations.next();

        while(hasmorerelations)

        {

          String currentSub = relations.getString(1);

          String currentSubDoctype = relations.getString(2);

          String currentRelationship = relations.getString(3);

          String currentObj = relations.getString(4);

          String currentObjDoctype = relations.getString(5);

          if(object.equals(currentObj))

          {//there is a transitive relation so add a new relation to the table

            StringBuffer insertTransRelation = new StringBuffer();

            insertTransRelation.append(" subject, ");

            insertTransRelation.append("objdoctype) values ('");

            insertTransRelation.append(currentSubDoctype).append("', ");

            insertTransRelation.append("'hasTransitiveRelationTo', '");

            insertTransRelation.append(subject).append("', '");

            insertTransRelation.append(subjectDoctype).append("')");

            insertTransRelation = new StringBuffer();

            //put the same relation in with the subject and object switched

            insertTransRelation.append(" subject, ");

            insertTransRelation.append("objdoctype) values ('");

            insertTransRelation.append("'hasTransitiveRelationTo', '");

            insertTransRelation.append(currentSub).append("', '");

            insertTransRelation.append(currentSubDoctype).append("')");

          }

        //get the current relations information

        String objDocid = null;

        String objDoctype = null;

        try

          {

            Hashtable subMurlParams = util.parseQuery(subMurl.getQuery());

            subDocid = (String)subMurlParams.get("docid");

            if(subMurl.getProtocol().equals("metacat"))

            {

            }

          }

          else

          {

            subDocid = subject;

          }

        { //assume this is just a docid not a url

          subDocid = subject;

        }

        try

          {

            Hashtable objMurlParams = util.parseQuery(objMurl.getQuery());

            objDocid = (String)objMurlParams.get("docid");

            if(objMurl.getProtocol().equals("metacat"))

            {

            }

          }

          else

          {

            objDocid = object;

          }

        { //assume this is just a docid

          objDocid = object;

        }

        //into xml_relation

        StringBuffer insertStmt = new StringBuffer();

        insertStmt.append("subdoctype, ");

        insertStmt.append(subDoctype).append("', '");

        insertStmt.append(relationship).append("', '");

        insertStmt.append(object).append("', '");

        insertStmt.append(objDoctype).append("')");

        hasmorerows = rs.next();

      }

    catch(Exception e)

    {

      util.debugMessage("Error in relationHandler.run: " + e.getMessage());

      e.printStackTrace(System.out);

      btThread = null;

      {

      catch (SQLException sqle) {}

  }

  /**

   * Deletes all of the relations with a docid of 'docid'.

   * @param docid the docid to delete.

   */

    {

                                                  "deleteRelations");

    }

    catch(Exception ee)

    {

      System.out.println("error in relationHandler.deleteRelations: " +

                          ee.getMessage());

    }

    try

    {

      PreparedStatement pstmt = dbconn.prepareStatement("delete from " +

      pstmt.execute();

    catch(Exception e)

    {

                          e.getMessage());

      e.printStackTrace(System.out);

      {

        dbconn.close();

      catch (SQLException sqle) {}

  }