Metacat

    }

  }

  /**

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

   *

   * @param xml the xml stream to be loaded into the database

   * @param pub flag for public "read" access on xml document

   * @param dtd the dtd to be uploaded on server's file system

   * @param user the user that owns the document

   * @param group the group to which user belongs

   * @param serverCode the serverid from xml_replication on which this document

   */

  public static String write( Connection conn,Reader xml,String pub,Reader dtd,

                              String group, int serverCode, boolean override,

                              boolean validate)

                throws Exception

  {

    AccessionNumber ac = new AccessionNumber(conn);

    MetaCatUtil.debugMessage("action: " + action + " servercode: " + 

                             serverCode + " override: " + override);

      //merge the differences manually.

      int istreamInt; 

      char istreamChar;

      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 

        {

                                      server);

                                              user, group, pub, serverCode, dtd);

          conn.setAutoCommit(false);

          parser.parse(new InputSource(xml)); 

        //to come get a copy from here.

        ForceReplicationHandler frh = new ForceReplicationHandler(docid);

      }

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

      {//the file is currently locked by another user

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

       //again.

        //System.out.println("file locked");

                                   server + " reason: file already locked");

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

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

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

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

        //System.out.println("outdated file");

                                    server + " reason: local file outdated");

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

                            " version.  Please checkout the newest document, " +

      if ( !hasPermission(conn, user, group, docid) ) {

        throw new Exception("User " + user + 

      }          

    }

    try 

    { 

                                          user, group, pub, serverCode, dtd);

      conn.setAutoCommit(false);

      parser.parse(new InputSource(xml));

    //force replicate out the new document to each server in our server list.

    if(serverCode == 1)

    { //start the thread to replicate this new document out to the other servers

    }

  }

  /**

   *

   * @param docid the ID of the document to be deleted from the database

   */

                                 String user, String group )

    AccessionNumber ac = new AccessionNumber(conn);

    // check for 'write' permission for 'user' to delete this document

    if ( !hasPermission(conn, user, group, docid) ) {

      throw new Exception("User " + user + 

    }

    conn.setAutoCommit(false);

    //if the deleted document is a package document its relations should 

    //no longer be active if it has been deleted from the system.

  }

  /** 

   * Construct an AccessionNumber 

   */

  public AccessionNumber () 

    MetaCatUtil util = new MetaCatUtil();

    this.sitecode = util.getOption("sitecode");

   *

   * @param conn the db connection to read from and write Accession# to

   */

    MetaCatUtil util = new MetaCatUtil();

    this.sitecode = util.getOption("sitecode");

    this.sep = util.getOption("accNumSeparator");

    this.conn = conn;

  }

  /**

   * Generate an Accession Number of form <sidecode>.<createdate>

   */

                throws AccessionNumberException, SQLException 

  {

    try {

      // INSERT

      if ( action.equals("INSERT")) {

          String sitecode = getSitecode();

          String uniqueid = getUniqueID();

          return sitecode + sep + uniqueid;

        } else {

        }

      // UPDATE or DELETE

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

        // Accession# is not provided; throw an exception to prevent the action

          throw new AccessionNumberException("Accession number is required.");

        // Accession# is not current (not in xml_documents); throw an exception

          throw new AccessionNumberException

        // Accession# is current (present in xml_documents); return it

        } else {

        }

      }

    } catch (SQLException e) {

      throw new SQLException

    }    

    // never comes here

    return hasAccNumber;

  }    

  private boolean accNumberIsCurrent(String accNumber) throws SQLException {

    boolean hasCurrentAccNumber = false;

    return hasCurrentAccNumber;

  }    

}

  public DocumentIdentifier(String docid) throws AccessionNumberException

  {

    this.docid = docid;

    {

      throw new AccessionNumberException("Accession number cannot end with " + 

                "a seperator.");

    }

    {

      throw new AccessionNumberException("Accession number cannot begin with " + 

                "a seperator.");

   */

  private void parseDocid()

  {

    int firstIndex = docid.indexOf(separator);

    int lastIndex = docid.lastIndexOf(separator);

    if(firstIndex != lastIndex)