Metacat

import java.io.Reader;

import java.io.StringReader;

import java.util.Enumeration;

import java.util.Stack;

import java.util.Vector;

import edu.ucsb.nceas.metacat.util.MetaCatUtil;

import org.apache.log4j.Logger;

    private String accNumberSeparator = null;

    private boolean percentageSearch = false;

    private String userName = null;

import javax.servlet.*;

import javax.servlet.http.*;

import edu.ucsb.nceas.metacat.service.PropertyService;

import edu.ucsb.nceas.metacat.service.SessionService;

import edu.ucsb.nceas.metacat.util.LDAPUtil;

import edu.ucsb.nceas.metacat.util.MetaCatUtil;

import edu.ucsb.nceas.metacat.util.SessionData;

import edu.ucsb.nceas.metacat.util.SystemUtil;

import edu.ucsb.nceas.utilities.GeneralPropertyException;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

public class MetacatReplication extends HttpServlet implements Runnable

{

  private long timeInterval;

  private Date firstTime;

  private boolean timedReplicationIsOn = false;

  Timer replicationDaemon;

  private Vector fileLocks = new Vector();

  private Thread lockThread = null;

  public static final String FORCEREPLICATEDELETE = "forcereplicatedelete";

  private static final String TIMEREPLICATION = "replication.timedreplication";

  private static final String TIMEREPLICATIONINTERVAl = "replication.timedreplicationinterval";

        pstmt = dbConn.prepareStatement("INSERT INTO xml_replication " +

                  "(server, last_checked, replicate, datareplicate, hub) " +

                                      "VALUES ('" + server + "', "+

                                      + ", '" +

                                      replicate +"', '" +dataReplicate+"', '"

                                      + hub +"')");

      // Get correct docid that reside on this server according the requesting

      // server's replicate and data replicate value in xml_replication table

      //docsql.append("select docid, rev, doctype from xml_documents where (docid not in (select a.docid from xml_documents a, xml_revisions b where a.docid=b.docid and a.rev<=b.rev)) ");

      revisionSql.append("select docid, rev, doctype from xml_revisions ");

      // If the localhost is not a hub to the remote server, only replicate

import java.util.Vector;

import java.util.Iterator;

import edu.ucsb.nceas.metacat.service.PropertyService;

import edu.ucsb.nceas.metacat.util.MetaCatUtil;

	    		}

	    		String xmlDocumentsCheck = 

	    					"xml_index", "a.docid = b.docid", nonJoinCriteria);

	    		PreparedStatement xmlDocCheck = dbConn.prepareStatement(xmlDocumentsCheck);

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Hashtable;

import java.util.HashMap;

import java.util.Iterator;

import java.util.TreeSet;

import java.util.Vector;

import edu.ucsb.nceas.metacat.service.PropertyService;

import edu.ucsb.nceas.metacat.spatial.SpatialHarvester;

import edu.ucsb.nceas.metacat.util.LDAPUtil;

import org.xml.sax.EntityResolver;

import org.xml.sax.ErrorHandler;

import org.xml.sax.InputSource;

import org.xml.sax.XMLReader;

import org.xml.sax.helpers.XMLReaderFactory;

    static final int ALL = 1;

    static final int WRITE = 2;

    static final int READ = 4;

    protected DBConnection connection = null;

    //protected String updatedVersion = null;

    protected String docname = null;

      PreparedStatement pstmt = null;

      int revision = (new Integer(rev)).intValue();

      if (createDate == null)

      {

          createDate = sqlDateString;

      }

      else

      {

      }

      if (updateDate == null)

      }

      else

      {

      }

      try

      {

        } else {

            out = new PrintWriter(pw);

        }

        // Here add code to handle subtree access control

        /*

         * PermissionController control = new PermissionController(docid);

                // Any other types of nodes are not handled.

                // Probably should throw an exception here to indicate this

            }

            out.flush();

        }

        String nodeprefix = null;

        String nodedata = null;

        float nodedatanumerical = -1;

        String table = "xml_nodes";

        //System.out.println("in getNodeREcorelist !!!!!!!!!!!for root node id "+rootnodeid);

        try {

            String catalogid, int serverCode, String createDate, String updateDate) throws SQLException, Exception

    {

        //System.out.println("!!!!!!!!1write document to db  " +docid +"."+rev);

        if (createDate == null)

        {

            createDate = sysdate;

        }

        else

        {

        }

        if (updateDate == null)

        {

        }

        else

        {

        }

        DocumentImpl thisdoc = null;

    private static void archiveDocAndNodesRevison(DBConnection dbconn, String docid, 

                                     String user, long rootNodeId) throws Exception

    {

        //DBConnection conn = null;

        //int serialNumber = -1;

        PreparedStatement pstmt = null;

    /** Save a document entry in the xml_revisions table */

    private static void archiveDocRevision(String docid, String user, DBConnection conn) throws Exception

    {

        PreparedStatement pstmt = null;

        // create a record in xml_revisions table

                        .prepareStatement("INSERT INTO xml_replication "

                                + "(server, last_checked, replicate, datareplicate, hub) "

                                + "VALUES ('" + server + "', "

                                + ", '" + replicate + "', '" + dataReplicate

                                + "','" + hub + "')");

            if (createDate == null)

            {

            }

            else

            {

            }

            logMetacat.info("the create date is "+createDate);

            if (updateDate == null)

            {

            }

            else

            {

            }

            logMetacat.info("the update date is "+updateDate);

            PreparedStatement pstmt = null;

package edu.ucsb.nceas.metacat;

import edu.ucsb.nceas.metacat.service.PropertyService;

import edu.ucsb.nceas.metacat.util.MetaCatUtil;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

  int serverCheckCode = 1;

  ReplicationServerList serverList = null;

  //PrintWriter out;

  private static Logger logMetacat = Logger.getLogger(ReplicationHandler.class);

  private static int DOCINSERTNUMBER = 1;

  private static int DOCERRORNUMBER  = 1;

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

         sql.append("server like '").append(server).append("'");*/

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

         sql.append(" where server like '").append(server).append("'");

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

package edu.ucsb.nceas.metacat;

import java.sql.*;

import java.util.Hashtable;

import java.util.Enumeration;

import org.apache.log4j.Logger;

import org.xml.sax.SAXException;

/**

 * A Class that represents an XML node and its contents and

  private DBConnection	connection;

  private DBSAXNode	parentNode;

  private Logger logMetacat = Logger.getLogger(DBSAXNode.class);

  /**

      pstmt.close();

      // get the generated unique id afterward

      //should incease connection usage!!!!!!

      pstmt.close();

      // get the generated unique id afterward

      //should incease connection usage!!!!!!

    } catch (SQLException e) {

import java.sql.ResultSet;

import java.sql.SQLException;

import edu.ucsb.nceas.metacat.service.PropertyService;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

/**

 */

public class AccessionNumber  {

  private String sitecode = null;

  private String sep = null;

  private String docid = null;

import java.io.IOException;

import java.io.PrintWriter;

import java.net.MalformedURLException;

import java.util.Hashtable;

import java.util.Stack;

import java.util.Vector;

import org.apache.log4j.Logger;

    private static char separator = '.';

    static {

        try {

        	separator = PropertyService.getProperty("document.accNumSeparator").charAt(0);

        } catch (PropertyNotFoundException pnfe) {

        	logMetacat.error("Could not retrieve account number separator. " 

        			+ "Separator set to '.' : " + pnfe.getMessage());

        }

    }

    /**

     * Utility method to parse the query part of a URL into parameters. This

     * method assumes the format of the query par tof the url is an ampersand

package edu.ucsb.nceas.metacat;

import java.util.Vector;

import java.sql.*;

public class ReplicationServerList

{

  private static Vector serverList = null; //Vector to store server list

  private static Logger logMetacat = Logger.getLogger(ReplicationServer.class);

  /**

        pStmt = dbConn.prepareStatement("INSERT INTO xml_replication " +

                      "(server, last_checked, replicate, datareplicate, hub) "+

                       "VALUES ('" + givenServerName + "', "+

                       replicate +"', '"+dataReplicate+"','"+ hub + "')");

        pStmt.execute();

import org.xml.sax.helpers.XMLReaderFactory;

import org.xml.sax.helpers.DefaultHandler;

import edu.ucsb.nceas.metacat.service.PropertyService;

import edu.ucsb.nceas.metacat.util.MetaCatUtil;

import edu.ucsb.nceas.metacat.util.SystemUtil;

{

  private DBConnection connection;

  private String parserName;