Metacat

      else if(((String[])params.get("action"))[0].equals("getcatalog"))

      {

        handleGetCatalogRequest(out, params, response, true);

      }

      MetaCatUtil.debugMessage("action in forcereplicate is: " + dbaction);

      MetaCatUtil.debugMessage("serverCode in forcereplicate is: " + serverCode);

      MetaCatUtil.debugMessage("sending message: " + u.toString());

      MetaCatUtil.debugMessage("document: " + xmldoc);

      MetaCatUtil.debugMessage("sending message: " + docinfourl.toString());

      MetaCatUtil.debugMessage("docInfo: " + docInfoStr);

      MetaCatUtil.debugMessage("incoming get request for document: " + docid);

      MetaCatUtil.debugMessage("received update request");

      MetaCatUtil.debugMessage("doclist: " + doclist.toString());

   * Returns the xml_catalog table encoded in xml

   */

  public static String getCatalogXML()

  {

    return handleGetCatalogRequest(null, null, null, false);

  }

  /**

   * Sends the contents of the xml_catalog table encoded in xml

   * The xml format is:

   * <!ELEMENT xml_catalog (row*)>

   * <!ELEMENT row (entry_type, source_doctype, target_doctype, public_id,

   *                system_id)>

   * All of the sub elements of row are #PCDATA

   * If printFlag == false then do not print to out.

   */

  private static String handleGetCatalogRequest(PrintWriter out, 

                                                Hashtable params,

                                                HttpServletResponse response,

                                                boolean printFlag)

  {

    try

    {

      Connection conn = util.openDBConnection();

      PreparedStatement pstmt = conn.prepareStatement("select entry_type, " +

                              "source_doctype, target_doctype, public_id, " +

                              "system_id from xml_catalog");

      pstmt.execute();

      ResultSet rs = pstmt.getResultSet();

      boolean tablehasrows = rs.next();

      StringBuffer sb = new StringBuffer();

      sb.append("<?xml version=\"1.0\"?><xml_catalog>");

      while(tablehasrows)

      {

        sb.append("<row><entry_type>").append(rs.getString(1));

        sb.append("</entry_type><source_doctype>").append(rs.getString(2));

        sb.append("</source_doctype><target_doctype>").append(rs.getString(3));

        sb.append("</target_doctype><public_id>").append(rs.getString(4));

        sb.append("</public_id><system_id>").append(rs.getString(5));

        sb.append("</system_id></row>");

        tablehasrows = rs.next();

      }

      sb.append("</xml_catalog>");

      conn.close();

      if(printFlag)

      {

        response.setContentType("text/xml");

        out.println(sb.toString());

      }

      return sb.toString();

    }

    catch(Exception e)

    {

      System.out.println("error in handleGetCatalogRequest: " + e.getMessage());

      e.printStackTrace(System.out);

    }

    return null;

  }

  /**

      MetaCatUtil.debugMessage("thread started for docid: " + 

                               (String)fileLocks.elementAt(0));

      MetaCatUtil.debugMessage("thread for docid: " + 

                            (String)fileLocks.elementAt(fileLocks.size() - 1) + 

                            " exiting.");

    MetaCatUtil.debugMessage("action: " + action + " servercode: " + 

                             serverCode + " override: " + override);

      updateCatalog(serverList, conn);

      MetaCatUtil.debugMessage("init parser");

        MetaCatUtil.debugMessage("get responses");

        MetaCatUtil.debugMessage(u.toString());

        MetaCatUtil.debugMessage(result);

      MetaCatUtil.debugMessage("responses: " + responses.toString());

            MetaCatUtil.debugMessage("updating doc: " + docid + " action: "+ action);

            MetaCatUtil.debugMessage("Document " + docid + " deleted.");

          MetaCatUtil.debugMessage("last_checked updated to " + datestr + " on " +

                            server);

   * updates xml_catalog with entries from other servers.

   */

  private void updateCatalog(Hashtable serverList, Connection conn)

  {

    System.out.println("in updateCatalog");

    try

    {

      String server;

      Enumeration keys = serverList.keys();

      while(keys.hasMoreElements())

      { //go through each server

        server = (String)(keys.nextElement());

        System.out.println("server: " + server);

        URL u = new URL("http://" + server + "?action=getcatalog");

        String catxml = MetacatReplication.getURLContent(u);

        System.out.println("catxml: " + catxml);

        CatalogMessageHandler cmh = new CatalogMessageHandler();

        XMLReader catparser = initParser(cmh);

        catparser.parse(new InputSource(new StringReader(catxml)));

        //parse the returned catalog xml and put it into a vector

        Vector remoteCatalog = cmh.getCatalogVect();

        String localcatxml = MetacatReplication.getCatalogXML();

        System.out.println("localcatxml: " + localcatxml);

        cmh = new CatalogMessageHandler();

        catparser = initParser(cmh);

        catparser.parse(new InputSource(new StringReader(localcatxml)));

        Vector localCatalog = cmh.getCatalogVect();

        //now we have the catalog from the remote server and this local server

        //we now need to compare the two and merge the differences.

        //the comparison is base on the public_id fields which is the 4th

        //entry in each row vector.

        Vector publicId = new Vector();

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

        {

          Vector v = new Vector((Vector)localCatalog.elementAt(i));

          System.out.println("v1: " + v.toString());

          publicId.add(new String((String)v.elementAt(3)));

          System.out.println("adding " + (String)v.elementAt(3));

        }

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

        {

          Vector v = (Vector)remoteCatalog.elementAt(i);

          System.out.println("v2: " + v.toString());

          //System.out.println("i: " + i);

          //System.out.println("remoteCatalog.size(): " + remoteCatalog.size());

          System.out.println("publicID: " + publicId.toString());

          System.out.println("v.elementAt(3): " + (String)v.elementAt(3));

          if(!publicId.contains(v.elementAt(3)))

          { //so we don't have this public id in our local table so we need to

            //add it.

            System.out.println("in if");

            StringBuffer sql = new StringBuffer();

            sql.append("insert into xml_catalog (entry_type, source_doctype, ");

            sql.append("target_doctype, public_id, system_id) values (?,?,?,");

            sql.append("?,?)");

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

            PreparedStatement pstmt = conn.prepareStatement(sql.toString());

            pstmt.setString(1, (String)v.elementAt(0));

            pstmt.setString(2, (String)v.elementAt(1));

            pstmt.setString(3, (String)v.elementAt(2));

            pstmt.setString(4, (String)v.elementAt(3));

            pstmt.setString(5, (String)v.elementAt(4));

            pstmt.execute();

          }

        }

      }

    }

    catch(Exception e)

    {

      System.out.println("error in updateCatalog: " + e.getMessage());

      e.printStackTrace(System.out);

    }

  }

  /**

   * The table is (a docid in one of the tables is represented by the X):

        MetaCatUtil.debugMessage("sending message: " + comeAndGetIt.toString());

    MetaCatUtil.debugMessage("exiting ForceReplicationHandler Thread");