Metacat

<table border="0" cellpadding="4" cellspacing="0" width="100%" 

       class="tablepanel">

  <tr class="tablehead">

  </tr>

  <tr>

    <td rowspan="2" width="50%">

  private static final String FIRSTTIME  = "replication.firsttimedreplication";

  private static final int    TIMEINTERVALLIMIT = 7200000;

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

  /**

   * Initialize the servlet by creating appropriate database connections

      Hashtable<String,String> docinfoHash = dih.getDocInfo();

      // Get user owner of this docid

      // Get home server of this docid

      String homeServer=(String)docinfoHash.get("home_server");

      String createdDate = (String)docinfoHash.get("date_created");

      MetacatReplication.replLog("document " + docid + " added to DB with " +

                                 "action " + dbaction);

    }//try

    catch(Exception e)

    {

    MetacatReplication.replLog("force replication delete docid " + docid);

    logMetacat.info("Force replication delete request from: "+ server);

    logMetacat.info("Force replication delete docid: "+docid);

    MetacatReplication.replLog("document " + docid + " was successfully deleted ");

    logMetacat.info("document " + docid + " was successfully deleted ");

  }

  catch(Exception e)

      XMLReader docinfoParser = ReplicationHandler.initParser(dih);

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

      Hashtable<String,String> docinfoHash = dih.getDocInfo();

      String docName = (String)docinfoHash.get("docname");

        //false means non-timed replication

        MetacatReplication.replLog("datafile " + docid + " added to DB with " +

                "action " + dbaction);

     }

    }

			if (FileUtil.getFileStatus(documentPath) == FileUtil.DOES_NOT_EXIST

					|| FileUtil.getFileSize(documentPath) == 0) {

				FileWriter fileWriter = new FileWriter(documentPath);

			}

			// read the file from disk and sent it to PrintWriter

			// PrintWriter out = new PrintWriter(streamOut);

			// response.setContentType("text/xml");

			// out.print(di.toString(null, null, true));

import java.sql.*;

import java.util.Enumeration;

import java.util.Hashtable;

import java.util.Vector;

import org.apache.log4j.Logger;

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

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

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

   private String docId = null;

   private boolean hasSubTreeAccessControl = false; // flag if has a subtree

                                                    // access for this docid

   private long TOPLEVELSTARTNODEID = 0; //if start node is 0, means it is top

                                         //level document

    {

      return true;

    }

    //create a userpackage including user, public and group member

    userPackage=createUsersPackage(user, groups);

  {

    boolean flag = true;

    // Get unaccessble subtree for this user

                                                           myPermission);

    while (en.hasMoreElements())

    {

      SubTree tree = (SubTree)en.nextElement();

   * @param groups  the groups which the use is in

   * @param myPermission  permission type to check for

   */

                                       String myPermission) throws McdbException

  {

    String [] principals=null;

    int permission =AccessControlList.intValue(myPermission);

   * is a subtree of subtree a. And user doesn't have read permission for both

   * so we only use subtree a is enough.

   */

  {

    boolean   needDelete = false;

    // check the parameters

    if (unAccessSubTree == null || unAccessSubTree.isEmpty())

      // look every subtree start point and stop point, to see if it is embedded

      // in another one. If embedded, they are equavelent and we can use bigger

      // one to replace smaller one

      while (en.hasMoreElements())

      {

        SubTree tree    = (SubTree)en.nextElement();

        long    startId = tree.getStartNodeId();

        long    endId   = tree.getEndNodeId();

        while (enu.hasMoreElements())

        {

          SubTree subTree = (SubTree)enu.nextElement();

          long   subTreeStartId = subTree.getStartNodeId();

          long   subTreeEndId   = subTree.getEndNodeId();

          //compare and if the first subtree is a subtree of the second

                  throws SQLException, Exception

  {

	Vector<AccessControlForSingleFile> accessControl = new Vector<AccessControlForSingleFile>();

    PreparedStatement pStmt = null;

    DBConnection conn = null;

    int serialNumber = -1;

   PreparedStatement pStmt = null;

   int permissionValue=permission;

   int permissionValueInTable;

   DBConnection conn = null;

   int serialNumber = -1;

   boolean topLever = false;

                               boolean withRevision)

                             throws SQLException,McdbException, Exception

   {

      Enumeration<String> en = allIdList.keys();

      while (en.hasMoreElements())

      {

    * about the inline data. The key is subtree id and data is a inline internal

    * file name

    */

   {

     String sql = "SELECT subtreeid, docid FROM xml_access WHERE " +

                   "accessfileid = ? AND subtreeid  IS NOT NULL";

     PreparedStatement pStmt=null;

import edu.ucsb.nceas.utilities.FileUtil;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

import edu.ucsb.nceas.utilities.StringUtil;

import org.apache.log4j.Logger;

import org.xml.sax.ContentHandler;

    private static void writeToFileSystem(String xml, String accNumber) throws McdbException {

		// write the document to disk

		String documentDir = null;

		String documentPath = null;

			}

			if (accNumber != null

			}			

		} catch (PropertyNotFoundException pnfe) {

			throw new McdbException("Could not write file: " + documentPath + " : "

					+ pnfe.getMessage());

			throw new McdbException("Could not write file: " + documentPath + " : "

		}

	}	

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

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

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

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

import java.sql.*;

import java.util.*;

import java.util.Date;

import java.io.*;

import java.net.*;

import java.text.*;

import org.apache.log4j.Logger;

import org.xml.sax.AttributeList;

import org.xml.sax.ContentHandler;

import org.xml.sax.ErrorHandler;

import org.xml.sax.InputSource;

import org.xml.sax.XMLReader;

import org.xml.sax.helpers.XMLReaderFactory;

import org.xml.sax.helpers.DefaultHandler;

                                        // ReplicationServer got from

                                        // Server list

    String server = null; // Variable to store server name

    URL u;

          REVINSERTNUMBER++;

      }

      String ip = getIpFromURL(u);

    }//try

            REVINSERTNUMBER++;

        }

        String ip = getIpFromURL(u);

      }//if

      else

         MetacatReplication.replLog("Doc " + docId + " deleted");

         URL u = new URL("https://"+notifyServer);

         String ip = getIpFromURL(u);

      }

    }//try

					continue;

				}

				continue;

			}

	private static Hashtable<String, SessionData> sessionHash = null;

	private static final String PUBLIC_SESSION_ID = "0";

	/**

	 * private constructor since this is a singleton

	private SessionService() throws ServiceException {

		sessionHash = new Hashtable<String, SessionData>();

		logMetacat.debug("Registering public session id: " + PUBLIC_SESSION_ID);

	}

	/**

	}

	/**

	 * Keep a session active by updating its last accessed time. 

	 * 

	 * @param sessionId

          }

          else

          {

          }

        }//try

        catch(Exception e)