Metacat

      { //start the replication server

        int rate;

        if(params.containsKey("rate"))

          rate = new Integer(

                 new String(((String[])params.get("rate"))[0])).intValue();

        else

          rate = 1000;

        out.println("New rate is: " + rate + " seconds.");

        replicationDaemon.cancel();

        replicationDaemon = new Timer(true);

                       ((String[])params.get("date"))[0] +

                       " from external metacat");

    response.setContentType("text/xml");

    StringBuffer sql = new StringBuffer();

    String updateStr = ((String[])params.get("date"))[0];

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

    //pseudo algorithm:

    update = formatter.parse(updateStr, pos);

    //update = new java.util.Date(update.getTime() - 10000);

    String dateString = formatter.format(update);

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

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

      pstmt.execute();

      ResultSet rs = pstmt.getResultSet();

      boolean tablehasrows = rs.next();

      returnXML.append("<server>").append(util.getOption("server"));

      returnXML.append(util.getOption("replicationpath"));

      returnXML.append("</server><updates>");

      {

        String docid = rs.getString(1);

        String dateUpdated = rs.getString(2);

        { //check that this document is from this server.

          //servers only replicate their own documents!

          returnXML.append("<updatedDocument><docid>").append(docid);

      }

      returnXML.append("</updates></replication>");

      conn.close();

      out.print(returnXML.toString());

    }

    catch(Exception e)

   private String   user = null;

   private Thread   xmlIndex;

   private boolean endDocument = false;

   private static final int MAXDATACHARS = 4000;

   private static final int MAXTITLELEN = 1000;

       stackCreated = true;

     }

   }

   /** Construct an instance of the handler class 

    *

       rootNode.writeNodename(docname);

       try {

         currentDocument = new DocumentImpl(conn, rootNode.getNodeID(), 

       } catch (Exception ane) {

         throw (new SAXException("Error with " + action, ane));

       }

   *

   */

  public DocumentImpl(Connection conn, long rootnodeid, String docname, 

                      String doctype, String docid, String action, String user)

                      throws SQLException, Exception

  {

      throw new McdbException("Error getting node data: " + docid);

    }

  }

 /** creates SQL code and inserts new document into DB connection */

               throws SQLException, Exception {

    try {

      PreparedStatement pstmt = null;

        //this.docid = ac.generate(docid, "INSERT");

        pstmt = conn.prepareStatement(

            "INSERT INTO xml_documents " +

        // Bind the values to the query

        pstmt.setString(1, this.docid);

        pstmt.setLong(2, rootnodeid);

        pstmt.setString(4, doctype);

        pstmt.setString(5, user);

        pstmt.setString(6, user);

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

        // Save the old document entry in a backup table

        pstmt = conn.prepareStatement(

            "UPDATE xml_documents " +

            "SET rootnodeid = ?, docname = ?, doctype = ?, " +

        // Bind the values to the query

        pstmt.setLong(1, rootnodeid);

        pstmt.setString(2, docname);

        pstmt.setString(3, doctype);

        pstmt.setString(4, user);

      } else {

        System.err.println("Action not supported: " + action);

      }

                  action, docid, user, group);

  }

  /**

   * Write an XML file to the database, given a Reader

   *

   * @param docid the docid to use for the INSERT OR UPDATE

   */

  public static String write( Connection conn, Reader xml, String action, 

                throws Exception {

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

    }

    try {

        conn.setAutoCommit(false);

        parser.parse(new InputSource(xml));

        conn.commit();

   * Set up the parser handlers for writing the document to the database

   */

  private static XMLReader initializeParser(Connection conn,

                           throws Exception {

    XMLReader parser = null;

    //

    // Set up the SAX document handlers for parsing

    //

    try {

      EntityResolver dbresolver = new DBEntityResolver(conn, 

                                      (DBSAXHandler)chandler);

      DTDHandler dtdhandler     = new DBDTDHandler(conn);

        //send the server a date and it will send back any docid that has 

        //been modified after that date

        u = new URL("http://" + server + "?action=update&date=" + update);

        istream = new InputStreamReader(u.openStream());

        while((istreamInt = istream.read()) != -1)

        {

          istreamChar = (char)istreamInt;

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

                                  "?action=getdocument&docid="+ docid);

          InputStreamReader getDocIstream = new InputStreamReader(

          //below before the DocumentImpl.write() call.

          serverResponse = new StringBuffer();

          while((istreamInt = getDocIstream.read()) != -1)

          //System.out.println(serverResponse.toString());

          //System.out.println("<<<<<<end document>>>>>");

                                               new StringReader(serverResponse.toString())

                                               /*getDocIstream*/, 

                                               action, 

        }

      }

      //update the last_update field for each server to the current date/time      

      SimpleDateFormat formatter = new SimpleDateFormat ("yy-MM-dd HH:mm:ss");

      java.util.Date newDate = new java.util.Date(System.currentTimeMillis());

      pstmt.executeUpdate();

      //conn.commit();

      System.out.println("last_checked updated: " + dateString);

    }

    catch(Exception e)

    {

      boolean tableHasRows = rs.next();

      while(tableHasRows)

      {

        tableHasRows = rs.next();

      }

    }