Metacat

/**

 *  '$RCSfile$'

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

 *              National Center for Ecological Analysis and Synthesis

 *    Authors: @tao@

 *    Release: @release@

 *

 *   '$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.PackageUtil;

import edu.ucsb.nceas.morpho.datapackage.Triple;

import edu.ucsb.nceas.morpho.datapackage.TripleCollection;

import java .io.StringReader;

import java.sql.ResultSet;

import java.sql.PreparedStatement;

import java.sql.SQLException;

import java.util.Vector;

import org.apache.xerces.parsers.DOMParser;

import org.apache.xpath.XPathAPI;

import org.w3c.dom.Attr;

import org.w3c.dom.NamedNodeMap;

import org.w3c.dom.NodeList;

import org.w3c.dom.Document;

import org.w3c.dom.Node;

import org.w3c.dom.NodeList;

import org.w3c.dom.DocumentType;

import org.xml.sax.InputSource;

/**

 * This class is used to clean up access table in knb. It will delete any access

 * control rules which are not in access xml doc (someone add them into table

 * directly). It will update data set doc according new triples in access table.

 */

public class CleanupAccessTable

{

  /**

   * A method to add a new triple to a data set doc and update data set doc

   * in metacat db

   *

   * @param accessionNumber  the accession number of the data set doc

   * @param newTripleVector  the vector containing new triples need to be added 

   *                      into the data set doc

   */

  private static final String TRIPLESTAG = "//triple";

  public static void addNewTripleIntoDataset(String accessionNumber, 

                                             Vector newTripleVector)

  {

    // check parameter

    if (newTripleVector.size()==0 || accessionNumber == null || 

        accessionNumber.equals(""))

    {

      return;

    }

    DocumentImpl doc = null;

    try

    {

      doc = new DocumentImpl(accessionNumber);

    }

    catch (Exception e)

    {

      MetaCatUtil.debugMessage("error in create an document: "

                              + e.getMessage(), 30);

      return;

    }

    String xmlDoc = doc.toString();

    System.out.println("orginal xml file: "+xmlDoc);

    // create new triple collection

    TripleCollection newTripleForDataSet = new TripleCollection();

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

    {

      //Add new tripe

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

      newTripleForDataSet.addTriple(triple);

    }

    xmlDoc = addTriplesToTriplesString(newTripleForDataSet, xmlDoc, TRIPLESTAG);

    System.out.println("add triple xml file: "+xmlDoc);

  }

    /**

   * method to add a collection of triples to a triples string.  this method

   * searches for any triples already in the string and appends the new

   * ones after the existing ones.  

   * @param triples the collection of triples to add

   * @param triplesTag the trip tag in xml docment

   */

  private static String addTriplesToTriplesString(TripleCollection triples,

                                               String dataPackageString, 

                                               String triplesTag)

  {

    //String triplesTag = morpho.getConfiguration().get("triplesTag", 0);

    Document doc = null;

    DOMParser parser = new DOMParser();

    InputSource in;

    StringReader sr;

    try

    { //parse the wizard created file with existing triples

      sr = new StringReader(dataPackageString);

      in = new InputSource(sr);

    }

    catch(Exception fnf)

    {

      fnf.printStackTrace();

      return null;

    }

    try

    {

      parser.parse(in);

      sr.close();

    }

    catch(Exception e1)

    {

      System.err.println(e1.toString());

    }

    doc = parser.getDocument();

    //get the DOM rep of the document with existing triples

    NodeList tripleNodeList = triples.getNodeList();

    NodeList docTriplesNodeList = null;

    try

    {

      //find where the triples go in the file

      docTriplesNodeList = XPathAPI.selectNodeList(doc, triplesTag);

    }

    catch(Exception se)

    {

      System.err.println(se.toString());

    }

    Node docNode = doc.getDocumentElement();

    for(int j=0; j<tripleNodeList.getLength(); j++)

    { //add the triples to the appropriate position in the file

      Node n = doc.importNode(tripleNodeList.item(j), true);

      int end = docTriplesNodeList.getLength() - 1;

      Node triplesNode = docTriplesNodeList.item(end);

      Node parent = triplesNode.getParentNode();

      if(triplesNode.getNextSibling() == null)

      {

        parent.appendChild(n);

      }

      else

      {

        parent.insertBefore(n, triplesNode.getNextSibling());

      }

    }

    String docString = PackageUtil.printDoctype(doc);

    docString += PackageUtil.print(doc.getDocumentElement());

    return docString;

  }

  /*

   *Give a docid to find a package accesssionNumber for it.

   */

   private static String getDataPackageId(String docId)

  {

    String accessNumber = null;

    String packageIdWithoutVersion = null;

    String rev = null;

    PreparedStatement pStmt = null;

    ResultSet rs=null;

    String query="SELECT docId from xml_relation where subject = ?";

    DBConnection dbConn = null;

    int serialNumber = -1;

    try

    {

      dbConn=DBConnectionPool.

                  getDBConnection("DBQuery.getDataPackageId");

      serialNumber=dbConn.getCheckOutSerialNumber();

      pStmt=dbConn.prepareStatement(query);

      //bind the value to query

      pStmt.setString(1, docId);

      //execute the query

      pStmt.execute();

      rs=pStmt.getResultSet();

      //process the result

      if (rs.next()) //There are some records for the id in docId fields

      {

        packageIdWithoutVersion=rs.getString(1);//get data package id

      }

      pStmt.close();

      query = "SELECT rev from xml_documents where docid = ?";

      pStmt=dbConn.prepareStatement(query);

      //bind the value to query

      pStmt.setString(1, packageIdWithoutVersion);

      //execute the query

      pStmt.execute();

      rs=pStmt.getResultSet();

      //process the result

      if (rs.next()) //There are some records for the id in docId fields

      {

        rev=rs.getString(1);//get data package id

      }

      pStmt.close();

      accessNumber = packageIdWithoutVersion+"."+rev;

      MetaCatUtil.debugMessage("DataPackageId: "+accessNumber, 20);

    }//try

    catch (SQLException e)

    {

      MetaCatUtil.debugMessage("Error in isDataPackageId: "

                            +e.getMessage(), 30);

    }

    finally

    {

      try

      {

        pStmt.close();

      }//try

      catch (SQLException ee)

      {

        MetaCatUtil.debugMessage("Error in isDataPackageId: "

                                                        + ee.getMessage(), 30);

      }//catch

      finally

      {

        DBConnectionPool.returnDBConnection(dbConn, serialNumber);

      }//finally

    }//finally

    return accessNumber;

  }//isDataPackageId()

  public static void main(String[] agus)

  {

    if(agus.length == 0)

    {

      System.out.println("you should specify a docid!");

      return;

    }

    String docID = agus[0];

    try

    {

      DBConnectionPool pool = DBConnectionPool.getInstance();

      AccessRulesFromDocument xmlDocument = new AccessRulesFromDocument(docID);

      Vector rules = xmlDocument.getAccessRuleVector();

      Vector docid = xmlDocument.getACLObjects();

      AccessRulesFromDB db = new AccessRulesFromDB(docID);

      Vector rulesFromDB = db.getAccessRuleVector();

      Vector docidFromDB = db.getDocidAccessRuleApplied();

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

      {

        System.out.println("rule: "+(String)rulesFromDB.elementAt(i));

        if (!rules.contains(rulesFromDB.elementAt(i)))

        {

          System.out.println("find a new rule!!!");

        }

      }

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

      {

        System.out.println("docid: "+(String)docidFromDB.elementAt(i));

        if (!docid.contains(docidFromDB.elementAt(i)))

        {

          System.out.println("find a new triple");

        }

      }

    }

    catch(Exception e)

    {

      System.out.println("exception is: "+e.getMessage());

    }

  }

}//cleanupAccessTable