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

    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);

        logMetacat.info("subject from triple:"+triple.getSubject());

        logMetacat.info("relationship from triple:"+triple.getRelationship());

        logMetacat.info("object from triple: "+triple.getObject());

        {

          //put the new relation into xml_relation

                                docid);

          tstmt.setString(3, subject);

                               subject);

          tstmt.setString(5, relationship);

                                relationship);

                                object);

          tstmt.execute();

        }//if

    }//if

    if ( tstmt != null )

    {

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

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

      connection.increaseUsageCount(1);

                          e.getMessage());

  }

  /**

	 * @param docid the document identifier of the package

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

	 */

	public static String getAccessFileIDWithRevision(String docid) throws SQLException {

		String aclid = null;

		int rev;

		PreparedStatement pstmt = null;

		DBConnection dbConn = null;

		int serialNumber = -1;

		sql

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

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

		sql.append("' AND (");

		Vector accessdoctypes;

		try {

			throw new SQLException("Could not find access doctype: " + pnfe.getMessage());

		}

		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());

		try {

			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);

				rev = rs.getInt(2);

				String sep = ".";

				try {

					logMetacat.error("Could not find account separator.  Setting to '.': " + pnfe.getMessage());

				}

				aclid = sep + rev;

			}

			pstmt.close();

		}//try

		finally {

			try {

				pstmt.close();

			}//try

			finally {

				DBConnectionPool.returnDBConnection(dbConn, serialNumber);

			}//finally

		}//finally

		logMetacat.info("The access docid get from xml_relation is: " + aclid);

		return aclid;

	}