Metacat

/**

 *  '$RCSfile$'

 *    Purpose: A class that handles xml messages  passed by  the replication handler

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

 *             National Center for Ecological Analysis and Synthesis

 *    Authors: Chad Berkley

 *    Release: @release@

 *

 *   '$Author$'

 *     '$Date$'

 * '$Revision$'

 */

package edu.ucsb.nceas.metacat;

import java.sql.*;

import java.util.Stack;

import java.util.Vector;

import java.util.Enumeration;

import java.util.EmptyStackException;

import org.xml.sax.Attributes;

import org.xml.sax.SAXException;

import org.xml.sax.SAXParseException;

import org.xml.sax.ext.DeclHandler;

import org.xml.sax.ext.LexicalHandler;

import org.xml.sax.helpers.DefaultHandler;

/**

 */

public class ReplMessageHandler extends DefaultHandler

{

  private Vector updates = new Vector();

  private Vector indivUpdate = new Vector();

  private Vector deletes = new Vector();

  private boolean delete = false;

  public ReplMessageHandler()

  {

  }

  /**

   * This method starts a new vector for each updatedDocument tag.

   */

  public void startElement(String uri, String localName, String qName,

                           Attributes attributes) throws SAXException

  {

    currentTag = localName;

    if(localName.equals("updatedDocument"))

    {

      indivUpdate = new Vector();

    {

      indivDelete = new Vector();

      delete = true;

    }

  /**

   * This method write the indivUpdate to updates when it finds the end of

   */

  public void endElement(String uri, String localName, String qName)

              throws SAXException

  {

    if(localName.equals("updatedDocument"))

    {

      updates.add(new Vector(indivUpdate));

    {

      deletes.add(new Vector(indivDelete));

      delete = false;

    }

  /**

   * Take the data out of the docid and date_updated fields

   */

  public void characters(char[] ch, int start, int length) throws SAXException

  {

      indivUpdate.add(new String(ch, start, length));

    }

    }

    {

      indivUpdate.add(new String(ch, start, length));

      indivUpdate.add(server);

    }

    else if(currentTag.equals("rev") && delete)

    {

      indivDelete.add(new String(ch, start, length));

      indivDelete.add(server);

    }

    {

    {

      indivDelete.add(new String(ch, start, length));

      indivDelete.add(server);

    }

    {

      server = new String(ch, start, length);

    }

    return updates;

  }

  {

    return deletes;

  }