Metacat

  //private static 

  //ReplicationServerList serverList = new ReplicationServerList();

      // local server has newer version, then notify the remote server

      else if ( userSpecifyRev < revInDataBase && revInDataBase > 0)

      {

        throw new Exception("Local server: "+MetaCatUtil.getOption("server")+

                 " has newer revision of doc: "+docIdWithoutRev+"."

                  +revInDataBase+". Please notify it.");

      }

      // Set auto commit fasle

      dbconn.setAutoCommit(false);

      // Commit the insert

      dbconn.commit();

      // Set DBConnection auto commit true

      dbconn.setAutoCommit(true);

   * data file input Stream into file system.. It is only used in replication

   * @param docHomeServer, the home server of the docid

   * @param notificationServer, the server to notify force replication info to 

   *                            local metacat

 public static void writeDataFileInReplication(InputStream input, 

                 String filePath, String docname, String doctype, String accnum, 

                   String user, String docHomeServer, String notificationServer)

    int serverCode=-2;

    // If server is not int the xml replication talbe, insert it into 

    // xml_replication table

    //serverList.addToServerListIfItIsNot(docHomeServer);

    insertServerIntoReplicationTable(docHomeServer);

    // Get server code again

    serverCode = getServerCode(docHomeServer);

    //register data file into xml_documents table

    registerDocumentInReplication(docname, doctype, accnum, user, serverCode);

    //write inputstream into file system.

    File dataDirectory = new File(filePath);

    File newFile = new File(dataDirectory, accnum); 

    // create a buffered byte output stream

    // that uses a default-sized output buffer

    FileOutputStream fos = new FileOutputStream(newFile);

    BufferedOutputStream outPut = new BufferedOutputStream(fos);

    BufferedInputStream bis = null;

    bis = new BufferedInputStream(input);

    byte[] buf = new byte[4 * 1024]; // 4K buffer

    int b = bis.read(buf);

    while (b != -1) 

    {

    }

    bis.close();

	  outPut.close();

	  fos.close();

    // Force replicate data file

    ForceReplicationHandler forceReplication = new ForceReplicationHandler

                                    (accnum, false, notificationServer);

      String server=MetacatReplication.getServerNameForServerCode(serverCode);

      // Get miss docid and rev, throw to McdDocNotFoundException

      String missDocId = MetaCatUtil.getDocIdFromString(docid.toString());

      String missRevision = 

                  MetaCatUtil.getRevisionStringFromString(docid.toString());

      throw new McdbDocNotFoundException("the requested docid '" + 

                docid.toString() + "' does not exist", missDocId, missRevision);

                                        AccessionNumberException, Exception

  private void getDocumentInfo(DocumentIdentifier docid) throws McdbException

                                                          , Exception

    // catch a McdbDocNotFoundException throw it

    catch (McdbDocNotFoundException notFound)

      throw notFound;

    catch(Exception e)

      MetaCatUtil.debugMessage("error in DocumentImpl.getDocumentInfo: " + 

                          e.getMessage(), 30);

      throw e;

      throw new McdbDocNotFoundException("Document not found: " + docid,

                                 docid.getIdentifier(), docid.getRev());

        DocumentImpl thisdoc = new DocumentImpl(docid, false);

      String server=MetacatReplication.getServerNameForServerCode(serverCode);

        // Force replication the docid

        ForceReplicationHandler frh = new ForceReplicationHandler

                                                          (accnum, true, null);

        return(accnum);

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

    // Start the thread to replicate this new document out to the other servers

    // true mean it is xml document

    // null is because no metacat notify the force replication.

    ForceReplicationHandler frh = new ForceReplicationHandler

                                                  (accnum, action, true, null);

   * @param notifyServer, the server which notify local server the force 

   *                       replication command

     String[] groups,String homeServer, boolean validate, String notifyServer)

    // Docid without revision

    String docid=MetaCatUtil.getDocIdFromString(accnum);

    // Revision specified by user (int)

    int userSpecifyRev=MetaCatUtil.getVersionFromString(accnum);

    // Revision for this docid in current database

    int revInDataBase=getLatestRevisionNumber(docid);

    // String to store the revision

    String rev = null;

    //revIndataBase=-1, there is no record in xml_documents table

    //the document is a new one for local server, inert it into table

    //user specified rev should be great than 0

    if (revInDataBase==-1 && userSpecifyRev>0 )

        // rev equals user specified

        rev=(new Integer(userSpecifyRev)).toString();

        // action should be INSERT

        action = "INSERT";

    //rev is greater the last revsion number and revInDataBase isn't -1

    // it is a updated  file

    else if (userSpecifyRev>revInDataBase && revInDataBase>0)

       // rev equals user specified

       rev=(new Integer(userSpecifyRev)).toString();

       // action should be update

       action = "UPDATE";

    // local server has newer version, then notify the remote server

    else if ( userSpecifyRev < revInDataBase && revInDataBase > 0)

    {

      throw new Exception("Local server: "+MetaCatUtil.getOption("server")+

                " has newer revision of doc: "+docid+"."+revInDataBase

                 +". Please notify it.");

    }

    //other situation

    else

    {

        throw new Exception("The docid"+docid+"'s revision number couldn't be "

                    +userSpecifyRev);

    }

    // Variable to store homeserver code

    int serverCode=-2;

     // If server is not int the xml replication talbe, insert it into

    // xml_replication table

    //serverList.addToServerListIfItIsNot(homeServer);

    insertServerIntoReplicationTable(homeServer);

    // Get server code again

    serverCode = getServerCode(homeServer);

    MetaCatUtil.debugMessage("Document "+docid+"."+rev+" "+action+ " into local"

                               +" metacat with servercode: "+ serverCode, 10);

    // insert into xml_nodes and xml_index table

    //Force replication to other server

    ForceReplicationHandler forceReplication = new ForceReplicationHandler

                                  (accnum, action, true, notifyServer);

  private static synchronized void 

                                insertServerIntoReplicationTable(String server)

    // Initial value for the server

    int replicate = 0;

    int dataReplicate = 0;

    int hub = 0;

       // Get DBConnection

      // Compare the server to dabase

      pStmt = dbConn.prepareStatement

      ("SELECT serverid FROM xml_replication WHERE server='" + server +"'");

      pStmt.execute();

      ResultSet rs = pStmt.getResultSet();

      boolean hasRow = rs.next();

      // Close preparedstatement and result set

      pStmt.close();

      rs.close();

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

      // insert it

      if ( !hasRow 

         && !server.equals(MetaCatUtil.getLocalReplicationServerName()))

      {

        // Set auto commit false

        dbConn.setAutoCommit(false);

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

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

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

                       "'01/01/00', 'MM/DD/YY'), '" +

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

        dbConn.commit();

        // Increase usage number

        dbConn.increaseUsageCount(1);

      }

        // Set auto commit true

        dbConn.setAutoCommit(true);