Metacat

#

user=@user@

password=@password@

dbDriver=oracle.jdbc.driver.OracleDriver

initialConnections=5

incrementConnections=5

servletpath=@servlet-path@

htmlpath=@html-path@

packagedoctype=-//NCEAS//package1.0//EN

authclass=edu.ucsb.nceas.metacat.AuthLdap

ldapurl=ldap://ldap.nceas.ucsb.edu:389/

ldapbase=o=NCEAS,c=US

deltaT=60

replicationpath=@replication-path@

        replicationDaemon.cancel();

        out.println("Replication Handler Stopped");

        System.out.println("Replication Handler Stopped");

      }

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

      { //start the replication server

        replicationDaemon = new Timer(true);

        replicationDaemon.scheduleAtFixedRate(new ReplicationHandler(out), 0, 

                                              rate * 1000);

        out.println("Replication Handler Started");

        System.out.println("Replication Handler Started");

      }

      }

      //System.out.println("action in forcereplicate is: " + dbaction);

      //System.out.println("serverCode in forcereplicate is: " + serverCode);

      int serverCheckCode = MetacatReplication.getServerCode(server);

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

      Connection conn = util.openDBConnection();

      DocumentImpl.write(conn, new StringReader(xmldoc), null, dbaction, docid, 

                         user, group, serverCode, override);

      conn.close();

    }

    catch(Exception e)

  private void handleGetLockRequest(PrintWriter out, Hashtable params,

                                    HttpServletResponse response)

  {

    try

    {

      Connection conn = util.openDBConnection();

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

      String remoteRev = ((String[])params.get("updaterev"))[0];

      DocumentImpl requestDoc = new DocumentImpl(conn, docid);

      int localRevInt = requestDoc.getRev();

      int remoteRevInt = Integer.parseInt(remoteRev);

          lockThread = new Thread(this);

          lockThread.setPriority(Thread.MIN_PRIORITY);

          lockThread.start();

        }

        else

        { //deny the lock

          out.println("<filelocked><docid>" + docid + "</docid></filelocked>");

        }

      }

      else

      {//deny the lock.

        out.println("<outdatedfile><docid>" + docid + "</docid></filelocked>");

      }

      conn.close();

    }

    try

    {

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

      Connection conn = util.openDBConnection();

      DocumentImpl di = new DocumentImpl(conn, docid);

      response.setContentType("text/xml");

      out.print(di.toString());

      conn.close();

    }

    catch(Exception e)

    {

  private void handleUpdateRequest(PrintWriter out, Hashtable params, 

                                    HttpServletResponse response)

  {

    try

    {

      StringBuffer docsql = new StringBuffer();

      StringBuffer doclist = new StringBuffer();

      conn.close();

      response.setContentType("text/xml");

      out.println(doclist.toString());

    }

    catch(Exception e)

    {

    return serverResponse.toString();

  }

}

                              String group, int serverCode, boolean override)

                              throws Exception 

  {

    MetaCatUtil util = new MetaCatUtil();

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

    AccessionNumber ac = new AccessionNumber(conn);

    String newdocid = ac.generate(docid, action);

    if((serverCode != 1 && action.equals("UPDATE")) && !override)

    { //if this document being written is not a resident of this server then

      DocumentImpl newdoc = new DocumentImpl(conn, docid);

      int updaterev = newdoc.getRev();

      String server = MetacatReplication.getServer(serverCode);

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

                      updaterev + "&docid=" + docid);

      System.out.println("sending message: " + u.toString());

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

        try 

        {

          XMLReader parser = initializeParser(conn,action,newdocid,user,

                                              serverCode);

          conn.setAutoCommit(false);

      {//the file is currently locked by another user

       //notify our user to wait a few minutes, check out a new copy and try

       //again.

        throw new Exception("The file specified is already locked by another " +

                            "user.  Please wait 30 seconds, checkout the " +

                            "newer document, merge your changes and try " +

      else if(openingtag.equals("<outdatedfile>"))

      {//our file is outdated.  notify our user to check out a new copy of the

       //file and merge his version with the new version.

        throw new Exception("The file you are trying to update is an outdated" +

                            " version.  Please checkout the newest document, " +

                            "merge your changes and try again.");

      {

        //System.out.println("get responses");

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

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

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

        String result = MetacatReplication.getURLContent(u);

        responses.add(result);

      }

          { //if the document needs to be updated or inserted, this is executed

            u = new URL("http://" + docServer + "?action=read&docid=" +

                          docid);

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

            String newxmldoc = MetacatReplication.getURLContent(u);

            DocInfoHandler dih = new DocInfoHandler();

            docinfoParser.parse(new InputSource(new StringReader(docInfoStr)));

            Hashtable docinfoHash = dih.getDocInfo();

            int serverCode = MetacatReplication.getServerCode(docServer);

            String newDocid = DocumentImpl.write(conn, 

                              new StringReader(newxmldoc),

                              null,

                              (String)docinfoHash.get("user_owner"), 

                              serverCode, 

                              true);

          }

        }

          if(!alreadyDeleted(docid, conn))

          {

            DocumentImpl.delete(conn, docid, null, null);

          }

        }

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

          pstmt.executeUpdate();

          //conn.commit();

        }

      }

    }

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

        if(dbactionFlag)

        {

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

                                 "?action=forcereplicate&server=" + 

                                 util.getOption("server") + 

        }

        else

        {

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

                                 "?action=forcereplicate&server=" + 

                                 util.getOption("server") +