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

    {

      this.conn = util.openDBConnection();

    }

    catch(Exception e)

    {

                         "relationHandler.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

   */

  public void run()

  {

    // 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

    {

      PreparedStatement pstmt = conn.prepareStatement(

                                QuerySpecification.printPackageSQL(docid));

      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;

        }

        DocumentImpl subDoc = new DocumentImpl(conn, paramDocid);

        subjectDoctype = subDoc.getDoctype();

        String object = rs.getString(3);

        //compare r to each relation in xml_relation

                                      "relationship, object, objdoctype " +

                                      "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(subjectDoctype).append("', ");

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

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

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

            pstmt.execute();

          }

        //get the current relations information

        String objDocid = null;

        String objDoctype = null;

        try

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

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

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

          subDocid = subject;

        }

        try

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

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

        { //assume this is just a docid

          objDocid = object;

        }

        subDoc = new DocumentImpl(conn, subDocid);

        subDoctype = subDoc.getDoctype();

        DocumentImpl objDoc = new DocumentImpl(conn, objDocid);

        //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("')");

        pstmt.execute();

        hasmorerows = rs.next();

      }

      conn.commit();

    catch(Exception e)

    {

      try

      {

      catch (SQLException sqle) {}

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

      btThread = null;

    }

  }

  /**

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

   * @param docid the docid to delete.

   */

    try

    {

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

                             "xml_relation where docid like '" + docid + "'");

      pstmt.execute();

    catch(Exception e)

    {

      {

        conn.rollback();

      }

      catch (SQLException sqle) {}

                          e.getMessage());

    }

  }