Metacat

import org.xml.sax.SAXException;

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

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

/**

				// initialize namespace hash for in line data

				inlineDataNameSpace = new Hashtable<String, String>();

				// initialize file writer

				String seperator = ".";

				try {

					seperator = PropertyService.getProperty("document.accNumSeparator");

						&& (processAdditionalAccess || processOtherAccess || processTopLevelAccess)) {

					// stored the pull out nodes into storedNode stack

					NodeRecord nodeElement = new NodeRecord(-2, -2, -2, "TEXT", null,

					storedAccessNodeStack.push(nodeElement);

				}

					&& (processAdditionalAccess || processOtherAccess || processTopLevelAccess)) {

				// stored the pull out nodes into storedNode stack

				NodeRecord nodeElement = new NodeRecord(-2, -2, -2, "ELEMENT", localName,

				storedAccessNodeStack.push(nodeElement);

				for (int i = 0; i < atts.getLength(); i++) {

					String attributeName = atts.getQName(i);

					String attributeValue = atts.getValue(i);

					NodeRecord nodeAttribute = new NodeRecord(-2, -2, -2, "ATTRIBUTE",

					storedAccessNodeStack.push(nodeAttribute);

				}

						data = (textBuffer.toString()).trim();

						handleOnlineUrlDataFile(data);

						/*

						 * .getProperty("httpserver")) != -1 || data

						 * .getDocIdWithRevFromOnlineURL(data); // add to vector

						 * onlineDataFileIdVector.add(dataId); }//if

						 */

						&& (processAdditionalAccess || processOtherAccess || processTopLevelAccess)) {

					// stored the pull out nodes into storedNode stack

					NodeRecord nodeElement = new NodeRecord(-2, -2, -2, "TEXT", null,

					storedAccessNodeStack.push(nodeElement);

				}

						&& (processAdditionalAccess || processOtherAccess || processTopLevelAccess)) {

					// stored the pull out nodes into storedNode stack

					NodeRecord nodeElement = new NodeRecord(-2, -2, -2, "COMMENT", null,

					storedAccessNodeStack.push(nodeElement);

				}

						&& (processAdditionalAccess || processOtherAccess || processTopLevelAccess)) {

					// stored the pull out nodes into storedNode stack

					NodeRecord nodeElement = new NodeRecord(-2, -2, -2, "TEXT", null,

					storedAccessNodeStack.push(nodeElement);

				}

							Stack<NodeRecord> newStack = accessObj

									.getStoredTmpNodeStack();

							// revise order

							// go throught the vector of

							// unChangeableAccessSubtreevector

							// and find the one whose id is as same as

			throw new SAXException("The access object is null");

		}

		// get rid of rev from dataId

		String permOrder = accessSection.getPermissionOrder();

		String sql = null;

		PreparedStatement pstmt = null;

		}

		// if the url is not in ecogrid protocol, null will be returned

		if (accessionNumber == null) {

			// the accession number is null if the url does not references a

			// local data file (url would start with "ecogrid://"

		} else {

			// handle ecogrid protocol

			// get rid of revision number to get the docid.

			currentDistributionSection

					.setDistributionType(DistributionSection.DATA_DISTRIBUTION);

package edu.ucsb.nceas.metacat;

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

import edu.ucsb.nceas.utilities.HttpMessage;

import javax.servlet.ServletOutputStream;

    // If replication doc home server is local host. throws a exception

    if (replicationDocHomeServer.

    {

      throw new Exception ("Couldn't find the docid: "

                                          +docIdWithoutRevision+"."+revision);

<%

	/**

 *  '$RCSfile$'

String addedParams = "";

String redirectURI = "";

    //if qformat has not been set, set its value to "DEFAULT_STYLE"

    if (qformat==null) {

      qformat = DEFAULT_STYLE;

<%@page contentType="text/html"%>

<%@page pageEncoding="UTF-8"%>

<%@ include file="../../common/common-settings.jsp"%>

<%@ include file="../../common/configure-check.jsp"%>

<%@ page errorPage="jsperrorpage.html"%>

<%

	 /**

	 *   '$RCSfile$'

%>

<%

%>

	<jsp:forward page="/metacat" />

<%

import java.util.Stack;

import java.util.Vector;

import org.apache.log4j.Logger;

import org.xml.sax.Attributes;

              queryTitle = textBuffer.toString().trim();

        } else if (leaving.getTagName().equals("value")) {

              currentValue = textBuffer.toString().trim();

        } else if (leaving.getTagName().equals("pathexpr")) {

              currentPathexpr = textBuffer.toString().trim();

        } else if (leaving.getTagName().equals("returndoctype")) {

        }

        String normalizedXML = textBuffer.toString().trim();

        logMetacat.debug("================before normailze "+normalizedXML);

        logMetacat.debug("================after normailze "+normalizedXML);

        xml.append(normalizedXML);

        xml.append("</");

        	{

        		elementVector.add(path);

        	}       	

                usePathIndex = false;              

            }

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

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

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

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

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

import edu.ucsb.nceas.utilities.FileUtil;

      logMetacat.info("Force replication action: "+dbaction);

      // sending back read request to remote server

      URL u = new URL("https://" + server + "?server="

                +"&action=read&docid=" + docid);

      String xmldoc = MetacatReplication.getURLContent(u);

      // get the document info from server

      URL docinfourl = new URL("https://" + server +

                               +"&action=getdocumentinfo&docid=" + docid);

      String docInfoStr = MetacatReplication.getURLContent(docinfourl);

    try

    {

      //docid was switch to two parts uinque code and rev

      if(params.containsKey("dbaction"))

      {

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

      logMetacat.info("Force replication action: "+dbaction);

      // get the document info from server

      URL docinfourl = new URL("https://" + server +

                               +"&action=getdocumentinfo&docid=" + docid);

      String docInfoStr = MetacatReplication.getURLContent(docinfourl);

        //Get data file and store it into local file system.

        // sending back readdata request to server

        URL url = new URL("https://" + server + "?server="

                +"&action=readdata&docid=" + docid);

        String datafilePath = PropertyService.getProperty("application.datafilepath");

      filepath = PropertyService.getProperty("application.datafilepath");

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

      URL u = new URL("https://" + server + "?server="

                +"&action=test");

      String test = MetacatReplication.getURLContent(u);

      //couldn't pass the test

      //in the key store, this is security issue

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

      URL u = new URL("https://" + server + "?server="

                +"&action=test");

      String test = MetacatReplication.getURLContent(u);

      //couldn't pass the test

      //try to open a https stream to test if the request server's public key

      //in the key store, this is security issue

      URL u = new URL("https://" + server + "?server="

                +"&action=test");

      String test = MetacatReplication.getURLContent(u);

      //couldn't pass the test

      // Append local server's name and replication servlet to doclist

      doclist.append("<?xml version=\"1.0\"?><replication>");

      //doclist.append(util.getProperty("replicationpath"));

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

        while(tablehasrows)

        {

          String recordDoctype = rs.getString(3);

                                     PropertyService.getProperty("xml.packagedoctype"));

          //if this is a package file, put it at the end

          //because if a package file is read before all of the files it

          String recordDoctype = rs.getString(3);

          if(!recordDoctype.equals("BIN"))

          { //don't replicate data files

                                     PropertyService.getProperty("xml.packagedoctype"));

            if(recordDoctype != null && !packagedoctypes.contains(recordDoctype))

            {   //if this is a package file, put it at the end

    Hashtable<String,String> sl = new Hashtable<String,String>();

    DBConnection dbConn = null;

    int serialNumber = -1;

    PreparedStatement pstmt=null;

    int serverLocation;

    try

    int serialNumber = -1;

    PreparedStatement pstmt = null;

    int serverCode = 1;

    try

    {

import org.apache.log4j.Logger;

import org.xml.sax.SAXException;

/**

 * A Class that represents an XML Subtree

           nodename = rs.getString(5);

           nodeprefix = rs.getString(6);

           nodedata = rs.getString(7);

           // add the data to the node record list hashtable

           NodeRecord currentRecord = new NodeRecord(nodeid,parentnodeid,nodeindex,

                                      nodetype, nodename, nodeprefix, nodedata);

import java.lang.Comparable;

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

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

import org.apache.log4j.Logger;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

/**

 * document IDs.

 */

}

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

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

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

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

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

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

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

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

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

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

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

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

    public static final String NONAMESPACELOCATION = ":noNamespaceSchemaLocation";

    public static final String EML2KEYWORD = ":eml";

    public static final String XMLFORMAT = "xml";

    private static final String FALSE = "false";

    private static final String TRUE  = "true";

            super.init(config);

            ServletContext context = config.getServletContext();

            // Initialize the properties file

            String LOG_CONFIG_NAME = dirPath + "/log4j.properties";

            PropertyConfigurator.configureAndWatch(LOG_CONFIG_NAME);

    		// Check to see if the user has requested to bypass configuration 

            // (dev option) and check see if metacat has been configured.

    		// If both are false then stop the initialization

            	return;

            }  

        		"Service problem while intializing MetaCat Servlet: " + se.getMessage();

            logMetacat.error(errorMessage);

            throw new ServletException(errorMessage);

        } 

    }

	public void initSecondHalf(ServletContext context) throws ServletException {

		Logger logMetacat = Logger.getLogger(MetaCatServlet.class);

			// initialize DBConnection pool

			DBConnectionPool connPool = DBConnectionPool.getInstance();

			logMetacat.debug("DBConnection pool initialized: " + connPool.toString());

			// check if eml201 document were corrected or not. if not, correct

			// eml201 documents.

					+ gpe.getMessage();

			logMetacat.error(errorMessage);

			throw new ServletException(errorMessage);

	}

    /**

        Logger logMetacat = Logger.getLogger(MetaCatServlet.class);

        try {

        }

        catch (PropertyNotFoundException pnfe) {

            logMetacat.error("Could not find index paths.  Setting " 

        }

            logMetacat.debug("Indexing paths specified in metacat.properties....");

            PreparedStatement pstmt1 = null;

            ResultSet rs = null;

                logMetacat.debug("Checking if '"

                        + "' is indexed.... ");

                try {

                    pstmt = conn.prepareStatement(

                            "SELECT * FROM xml_path_index " + "WHERE path = ?");

                            .elementAt(i));

                    pstmt.execute();

                        logMetacat.debug(

                                "Inserting following path in xml_path_index: "

                                .elementAt(i));

                            pstmt = conn.prepareStatement("SELECT DISTINCT n.docid, "

                                    + "n.nodedata, n.nodedatanumerical, n.parentnodeid"

                                    + " FROM xml_nodes n, xml_index i WHERE"

                                    + " i.path = ? and n.nodeid=i.nodeid and"

                                    + " n.nodetype LIKE 'ATTRIBUTE' order by n.parentnodeid");

                        }

                                pathsForIndexing.elementAt(i));

                        pstmt.execute();

                        rs = pstmt.getResultSet();

                        int count = 0;

                        logMetacat.debug(

                                "Executed the select statement for: "

                                .elementAt(i));

                        try {

                                            + " VALUES (?, ?, ?, ?, ?)");

                                    pstmt1.setString(1, docid);

                                            pathsForIndexing.elementAt(i));

                                    pstmt1.setString(3, nodedata);

                                    pstmt1.setFloat(4, nodedatanumerical);

                        logMetacat.info("Indexed " + count

                                + " records from xml_nodes for '"

                                + "'");

                    } else {

		// Each time metacat is called, check to see if metacat has been 

		// configured. If not then forward to the administration servlet

			RequestUtil.forwardRequest(request, response, "/admin?action=configure");

			return;

		}

		// if we get here, metacat is configured.  If we have not completed the 

		// configure metacat without a restart.

		if (!fullyInitialized) {

			initSecondHalf(request.getSession().getServletContext());

		}

					 * out.println(" Ref: " + u.getRef()); String pquery =

					 * u.getQuery(); out.println(" Query: " + pquery);

					 * out.println(" Params: "); if (pquery != null) { Hashtable

					 * (Enumeration en = qparams.keys(); en .hasMoreElements();) {

					 * String pname = (String) en.nextElement(); String pvalue =

					 * (String) qparams.get(pname); out.println(" " + pname + ": " +

					// TODO MCD this interface is for testing.  It should go through a 

					// ServiceService class and only work for an admin user.  Move to the

					// MetacatAdminServlet

					return;

				}else {

					PrintWriter out = response.getWriter();

			String errorString = "Utility error: " + ue.getMessage();

			logMetacat.error(errorString);

			throw new ServletException(errorString);

		}

	}

        Logger logMetacat = Logger.getLogger(MetaCatServlet.class);

        logMetacat.warn("Total search time for action 'squery': "

                + (outPutTime - startTime));

                "-------------------------------------------------------------------------------Total search time for "

                + (outPutTime - startTime));

    }

    /**

        Logger logMetacat = Logger.getLogger(MetaCatServlet.class);

        logMetacat.warn("Total search time for action 'query': "

                + (outPutTime - startTime));

                "-------------------------------------------------------------------------------Total search time is "

                + (outPutTime - startTime));

        //handleSQuery(out, params, response,user, groups, sessionid);

    }

                throw new Exception("You didn't specify requested inlinedataid"); }

            // check for permission

                    .getDocIdWithoutRevFromInlineDataID(inlineDataId);

            PermissionController controller = new PermissionController(docId);

            // check top level read permission

                    Hashtable<String,String> unReadableInlineDataList =

                            PermissionController.getUnReadableInlineDataIdList(docId,

                            user, groups, false);

                    if (unReadableInlineDataList.containsValue(inlineDataIdWithoutRev)) {

                        throw new Exception("User " + user

                                + " doesn't have permission " + " to read inlinedata "

        }

    }

    /**

     * Handle the "read" request of metadata/data files from Metacat or any

     * files from Internet; transformed metadata XML document into HTML

                try {

                    URL murl = new URL(docs[i]);

                            murl.getQuery());

                    // case docid="http://.../?docid=aaa"

                    // or docid="metacat://.../?docid=bbb"

                    // Delete from spatial cache if runningSpatialOption

                    if ( PropertyService.getProperty("spatial.runSpatialOption").equals("true") ) {

                        SpatialHarvester sh = new SpatialHarvester();

                        sh.destroy();

                    }

                    String fileTempLocation;

                    // the filePart will be clobbered on the next loop, save to disk

                    fileList.put(name, fileTempLocation);

                    fileList.put("filename", fileName);

                    fileList.put("name", fileTempLocation);

                    // copy file to desired output location

                    try 

                    {

                    } 

                    catch (IOException ioe) 

                    {

                            if ( fileExists == false ) {

                                // copy file to desired output location

                                try {

                                } catch (IOException ioe) {

                                    logMetacat.error("IO Exception copying file: " +

                                            ioe.getMessage());

        Vector<String> packageSet = null;

        try {

        	packageSet = 

        } catch (PropertyNotFoundException pnfe) {

        	logMetacat.error("Could not find package doctype set.  Setting to null: " 

        			+ pnfe.getMessage());

        int serialNumber = -1;

        // get rid of revision if access number has

        try {

            //check out DBConnection

            conn = DBConnectionPool

import org.ecoinformatics.eml.EMLParser;

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

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

/**

 * This class will figure out which content type it is for a given data file.

   */

  public ContentTypeProvider(String docIdWithRevision)

  {

    //get relative doclist for data file and package type

    Vector docLists = null;

    docLists = getRelativeDocIdList(dataFileId);

          if (URLData.indexOf(DBSAXHandler.ECOGRID) != -1 )

          {

            // Get docid from url

                               getAccessionNumberFromEcogridIdentifier(URLData);

            // Get rid of revision

            logMetacat.info("docid from url element in xml is: " +

                                     docId);

            //if this docid equals target one, we find it

      }//while

      // set up data package type

                                     contains(packType))

      {

        //this is beta4 or beta6 version

        logMetacat.warn("This is beta package");

        packageType = BETA;

      }

               (PropertyService.getProperty("xml.eml2_0_0namespace"))).contains(packType))

      {

        // this eml 2 document

        logMetacat.warn("This is EML2.0.0 package");

        packageType = EML2;

      }

               (PropertyService.getProperty("xml.eml2_0_1namespace"))).contains(packType))

      {

        // this eml 2 document

        String packType = rs.getString(1);

        String targetId  = rs.getString(2);

        // find physical document

                                     contains(packType))

       {

         // assign physical document and jump out the while loop

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

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

import org.apache.log4j.Logger;

	    		dbConn = DBConnectionPool.getDBConnection("IndexingThread");

	    		serialNumber = dbConn.getCheckOutSerialNumber();

	            String nonJoinCriteria = "b.docid is NULL";

	    		boolean first = true;

import org.apache.log4j.Logger;

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

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

public class PermissionController

   public PermissionController(String myDocid) throws McdbException

   {

     // Get rid of rev number

     //hasSubTreeAccessControl = checkSubTreeAccessControl();

   }

     }

     else

     {

     }

   }

	 */

	private boolean isAccessDocument(String docId) throws SQLException {

		// detele the rev number if docid contains it

		PreparedStatement pStmt = null;

		DBConnection conn = null;

		int serialNumber = -1;

			// if it is an access document

			if (doctype != null

							.getProperty("xml.accessdoctype")).contains(doctype)))) {

				return true;

            {

                logMetacat.info("Put subtree id " + subTreeId +

                                         " and " + "inline data file name " +

                                         getInlineDataIdWithoutRev(fileId) +

                                         " into " + "un" + permission +

                                         " hash");

                                      getInlineDataIdWithoutRev(fileId));

            }

        }

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

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

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

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

import edu.ucsb.nceas.utilities.FileUtil;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

    {

        try {

            //this.conn = conn;

            // Look up the document information

            getDocumentInfo(docid, rev);

            serialNumber = conn.getCheckOutSerialNumber();

            conn.setAutoCommit(false);

            String action = null;

            action = checkRevInXMLDocuments(docIdWithoutRev, userSpecifyRev);

            logMetacat.warn("after check rev, the action is "+action);

            if (action.equals("UPDATE"))

            serialNumber = conn.getCheckOutSerialNumber();

            conn.setAutoCommit(false);

            String action = null;

            if (tableName.equals(DOCUMENTTABLE))

            {

                action = checkRevInXMLDocuments(docIdWithoutRev, userSpecifyRev);

            throws Exception

    {

        boolean flag = true;

        if (serverCode == 1) {

            flag = true;

                    .getServerNameForServerCode(serverCode);

            MetacatReplication.replLog("attempting to lock " + accnum);

            URL u = new URL("https://" + server + "?server="

                    + "&action=getlock&updaterev=" + rev + "&docid=" + docid);

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

            String serverResStr = MetacatReplication.getURLContent(u);

                    // if it is inline data first to get the inline data

                    // internal id

                    String fileName = currentNode.getNodeData();

                            .getDocIdWithoutRevFromInlineDataID(fileName);

                    // check if user has read permision for this inline data

                    boolean readInlinedata = false;

                      currentName, docid, doctype, parentId));

                  }

                }

                    leafData.trim().length() != 0 ){

                	logMetacat.debug("paths found for indexing: " + currentName);

                	pathsFoundForIndexing.put(currentName, new PathIndexEntry(

                logMetacat.debug("B: " + path +"\n");

                pathList.put(path, new PathIndexEntry(leafNodeId, path, docid,

                    doctype, parentId));

                    leafData.trim().length() != 0 ){

                	logMetacat.debug("paths found for indexing: " + currentName);

                	pathsFoundForIndexing.put(path, new PathIndexEntry(

                logMetacat.debug("C: " + fullPath +"\n");

                pathList.put(fullPath, new PathIndexEntry(leafNodeId, fullPath,

                    docid, doctype, parentId));

                   leafData.trim().length() != 0 ){

                	logMetacat.debug("paths found for indexing: " + currentName);

                	pathsFoundForIndexing.put(fullPath, new PathIndexEntry(

     */

    private void deleteNodeIndex(DBConnection conn) throws SQLException

    {

    	double start = System.currentTimeMillis()/1000;

        String familyId = docid;

        String sql = "DELETE FROM xml_index WHERE docid = ?";

                if (!server.equals("localhost")) {

                    this.docHomeServer = server;

                } else {

                            .getLocalReplicationServerName();

                }

                logMetacat.info("server: " + docHomeServer);

                try

                {

                	logMetacat.debug("Node data in read process before normalize=== "+nodedata);

                	logMetacat.debug("Node data in read process after normalize==== "+nodedata);

                } catch (java.lang.StringIndexOutOfBoundsException SIO){

                	logMetacat.warn("StringIndexOutOfBoundsException in normalize() while reading the document");

            }

            //DocumentIdentifier id = new DocumentIdentifier(accnum);

            String updaterev = (new Integer(revision)).toString();

            String server = MetacatReplication

                    .getServerNameForServerCode(serverCode);

            MetacatReplication.replLog("attempting to lock " + accnum);

            URL u = new URL("https://" + server + "?server="

                    + "&action=getlock&updaterev=" + updaterev + "&docid="

                    + docid);

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

        String catalogId = null;

        logMetacat.info("user in replication" + user);

        // Docid without revision

        logMetacat.warn("The docid without rev is " + docid);

        // Revision specified by user (int)

        logMetacat.warn("The user specifyRev: " + userSpecifyRev);

        // Revision for this docid in current database

        int revInDataBase = DBUtil.getLatestRevisionInDocumentTable(docid);

        try {

            String packagedoctype = PropertyService.getProperty("xml.packagedoctype");

            Vector<String> packagedoctypes = new Vector<String>();

            if (documenttype != null &&

                    packagedoctypes.contains(documenttype)) {

                dbconn = DBConnectionPool.getDBConnection(

                String aclidWithRev = RelationHandler.getAccessFileIDWithRevision(docIdWithoutRev);

                if (aclidWithRev != null)

                {

                  // if there are access file, write ACL for that package

                  if (aclid != null) {

            }

            // if it is an access file

            else if (documenttype != null

                            PropertyService.getProperty("xml.accessdoctype")).contains(

                            documenttype)) {

                dbconn = DBConnectionPool.getDBConnection(

        int serialNumber = -1;

        try {

            //get rid of revision number

            dbConnection = DBConnectionPool.getDBConnection(

                    "DocumentImpl.getDocTypeFromDBForCurrentDoc");

            serialNumber = dbConnection.getCheckOutSerialNumber();

            // NEW - WHEN CLIENT ALWAYS PROVIDE ACCESSION NUMBER INCLUDING REV

            // IN IT

            //AccessionNumber ac = new AccessionNumber(accnum, "DELETE");

            //String rev = ac.getRev();

            // Check if the document exists.

            throws SQLException

    {

        //get rid of revNum part

        PreparedStatement pStmt = null;

        int serverLocation = 1;

        DBConnection conn = null;

        int serialNumber = -1;

        //we should consider about local host too

            serverLocation = 1;

            return serverLocation;

        }

            // If the server is not in the table, and server is not local host,

            // insert it

            if (!hasRow

                            .getLocalReplicationServerName())) {

                // Set auto commit false

                dbConn.setAutoCommit(false);

            dbconn = DBConnectionPool.getDBConnection(

                    "DeletedDocumentImpl.registerDeletedDataFile");

            serialNumber = dbconn.getCheckOutSerialNumber();

                    .getDocIdFromAccessionNumber(accnum);

            writeDocumentToRevisionTable(dbconn, docIdWithoutRev, 

                    rev, doctype, docname, user,

                    null, serverCode, -1, createDate, updateDate); 

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

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

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

import java.sql.*;

  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;

        try

        {

          u = new URL("https://" + server + "?server="

          logMetacat.info("Sending infomation " +u.toString());

          result = MetacatReplication.getURLContent(u);

        }

      serialNumber=dbConn.getCheckOutSerialNumber();

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

      String readDocURLString = "https://" + remoteserver + "?server="+

      URL u = new URL(readDocURLString);

      // Get docid content

      DocInfoHandler dih = new DocInfoHandler();

      XMLReader docinfoParser = initParser(dih);

      String docInfoURLStr = "https://" + remoteserver +

                       "&action=getdocumentinfo&docid="+accNumber;