Metacat

import java.text.*;

import javax.servlet.*;

import javax.servlet.http.*;

import org.xml.sax.*;

public class MetacatReplication extends HttpServlet implements Runnable

                               HttpServletResponse response) 

                               throws ServletException, IOException 

  {

    PrintWriter out = response.getWriter();

    Hashtable params = new Hashtable();

    Enumeration paramlist = request.getParameterNames();

      }

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

      {

      }

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

      { //request an update list from the server

    }

  }

  /**

   * Grants or denies a lock to a requesting host.

   * The servlet parameters of interrest are:

  private void handleGetLockRequest(PrintWriter out, Hashtable params,

                                    HttpServletResponse response)

  {

    java.util.Date remoteDate = new java.util.Date();

    java.util.Date localDate = new java.util.Date();

    try

                              String group, int serverCode )

                throws Exception 

  {

    MetaCatUtil util = new MetaCatUtil();

        // Determine if the docid is OK for INSERT or UPDATE

    AccessionNumber ac = new AccessionNumber(conn);

      update = update.replace(' ', '+');

      URL u = new URL("http://" + server + "?action=getlock&updatedate=" + 

                      update + "&docid=" + docid);

      String serverResStr = MetacatReplication.getURLContent(u);

      String openingtag = serverResStr.substring(0, serverResStr.indexOf(">")+1);

      {//the lock was granted go ahead with the insert

        try 

        {

          conn.setAutoCommit(false);

          parser.parse(new InputSource(xml));

          conn.commit();

              stmt.execute("DELETE FROM xml_access WHERE docid='"+newdocid +"'");

              stmt.close();

            }

            conn.commit();

          } 

          conn.setAutoCommit(true);

        URL comeAndGetIt = new URL("http://" + server + 

                                   "?action=forcereplicate&server=" + 

                                   util.getOption("server") + 

        String message = MetacatReplication.getURLContent(comeAndGetIt);

        if ( (docid != null) && !(newdocid.equals(docid)) ) 

                            "merge your changes and try again.");

      }

    }

    if ( action.equals("UPDATE") ) {

      // check for 'write' permission for 'user' to update this document

            URL docinfoUrl = new URL("http://" + docServer + 

                                     "?action=getdocumentinfo&docid=" +

                                     docid);

            Hashtable docinfoHash = dih.getDocInfo();

            String newDocid = DocumentImpl.write(conn, 

                               new StringReader(srvrResponseStr),

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

        URL dateurl = new URL("http://" + server + "?action=gettime");

        String datexml = MetacatReplication.getURLContent(dateurl);

        String datestr = datexml.substring(11, datexml.indexOf('<', 11));

        StringBuffer sql = new StringBuffer();

        sql.append("update xml_replication set last_checked = to_date('");

        sql.append(datestr).append("', 'YY-MM-DD HH24:MI:SS') where ");

  }

  /**

   * Method to query xml_replication and build a hashtable of each server

   * and it's last update time.

   * @param conn a connection to the database

    }

    return sl;

  }

}