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 edu.ucsb.nceas.morpho.datapackage.TripleCollection;

import java.io.StringReader;

import java.util.*;

   * 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 conn the db connection

   * @param list the triple list

                        DBConnection conn, TripleCollection list)

    tripleForPackage = list;

  {

    String relationship = null;

    String objDoctype = null;

    PreparedStatement tstmt = null; // to insert each relation into xml_relation

    MetaCatUtil.debugMessage("Running relation handler!", 40);

    deleteRelations(docid);

    //get vector form tripleCollection

    if (tripleForPackage != null)

    {

      tripleList =tripleForPackage.getCollection();

    }

    if (tripleList != null && tripleList.size()>0)

    {

                                    "relationship, object, objdoctype) " +

                                    "VALUES (?, ?, ?, ?, ?, ?, ?)");

      // go through tripe list

      for (int i= 0; i<tripleList.size(); i++)

      {

        //increase usage count

        connection.increaseUsageCount(1);

        // Get the triple

        Triple triple = (Triple)tripleList.elementAt(i);

        MetaCatUtil.debugMessage("Info from triple: ", 30);

        MetaCatUtil.debugMessage("subject from triple:"+triple.getSubject(), 30);

        MetaCatUtil.debugMessage("relationship from triple:"+triple.getRelationship(),30);

        MetaCatUtil.debugMessage("object from triple: "+triple.getObject(),30);

        subject = (new DocumentIdentifier(triple.getSubject())).getIdentifier();

        relationship = triple.getRelationship();

        object = (new DocumentIdentifier(triple.getObject())).getIdentifier();

        MetaCatUtil.debugMessage("Insert into xml_relation table", 30);

        tstmt.setString(1, docid);

        MetaCatUtil.debugMessage("Insert docid into xml_relation table" +

        tstmt.setString(3, subject);

        MetaCatUtil.debugMessage("Insert subject into xml_relation table" +

        tstmt.setString(5, relationship);

        MetaCatUtil.debugMessage("Insert relationship into xml_relation table" +

        MetaCatUtil.debugMessage("Insert object into xml_relation table" +

                                object, 30);

        tstmt.setString(7, objDoctype);

        tstmt.execute();

    }//if

    if ( tstmt != null )

    {

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

                                "WHERE docid = '" + docid + "'");

      connection.increaseUsageCount(1);

  }

  /**

   * Get the access file id for a package

   * @param docid the document identifier of the package

   * @return the document identifier of the access file for that package

   */

    String aclid = null;

    DBConnection dbConn = null;

    int serialNumber = -1;

    StringBuffer sql = new StringBuffer();

    sql.append("SELECT docid FROM xml_documents WHERE docid in (SELECT subject ");

    sql.append("FROM xml_relation WHERE docid='").append(docid);

    sql.append("' AND (");

    Vector accessdoctypes = MetaCatUtil.getOptionList(

                              MetaCatUtil.getOption("accessdoctype"));

    for(int i=0; i<accessdoctypes.size(); i++)

    {

      String atype = (String)accessdoctypes.elementAt(i);

      sql.append("doctype='").append(atype).append("'");

      if(i < accessdoctypes.size()-1)

      {

        sql.append(" OR ");

      }

    }

    sql.append("))");

    //System.out.println("new sql script: " + sql.toString());

    {

      dbConn=DBConnectionPool.

                  getDBConnection("RelationHandler.getAccessFileID");

      serialNumber=dbConn.getCheckOutSerialNumber();

      pstmt = dbConn.prepareStatement(sql.toString());

      pstmt.execute();

      ResultSet rs = pstmt.getResultSet();

      boolean hasRow = rs.next();

      if (hasRow) {

        aclid = rs.getString(1);

      }

      pstmt.close();

    }//try

    finally

    {

      try

      {

        pstmt.close();

      }//try

      finally

      {

        DBConnectionPool.returnDBConnection(dbConn, serialNumber);

      }//finally

    }//finally

                              aclid, 30);

  }