Metacat

import java.sql.Timestamp;

import java.text.DateFormat;

import java.text.ParseException;

import java.util.Date;

import java.util.Hashtable;

import java.util.TimerTask;

import java.util.Vector;

import org.apache.log4j.Logger;

import org.dataone.service.types.v1.SystemMetadata;

import edu.ucsb.nceas.metacat.client.InsufficientKarmaException;

import edu.ucsb.nceas.metacat.database.DBConnection;

import edu.ucsb.nceas.metacat.database.DBConnectionPool;

import edu.ucsb.nceas.metacat.dataone.hazelcast.HazelcastService;

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

import edu.ucsb.nceas.metacat.shared.HandlerException;

                                        // Server list

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

//    String update;

    URL u;

    long replicationStartTime = System.currentTimeMillis();

    long timeToGetServerList = 0;

        replServer = serverList.serverAt(i);

        // Get server name from ReplicationServer object

        server = replServer.getServerName().trim();

        logReplication.info("ReplicationHandler.update - full update started to: " + server);

        // Send command to that server to get updated docid information

        try

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

          +MetacatUtil.getLocalReplicationServerName()+"&action=update");

          logReplication.info("ReplicationHandler.update - Sending infomation " +u.toString());

        }

        catch (Exception e)

        {

        //logReplication.info("ReplicationHandler.update - docid: "+server+" "+result);

        //check if result have error or not, if has skip it.

          logMetacat.error("ReplicationHandler.update - " + ReplicationService.METACAT_REPL_ERROR_MSG);

          logReplication.error( "ReplicationHandler.update - Failed to get updated doc list "+

                       "for server " + server + " because "+result);

        try

        {

        }

        catch(Exception e)

        {

	public static final String REPLICATION_LOG_FILE_NAME = "metacatreplication.log";

	public static String METACAT_REPL_ERROR_MSG = null;

	private static Logger logReplication = Logger.getLogger("ReplicationLogging");

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

			// Store the sql command

			StringBuffer docsql = new StringBuffer();

			StringBuffer revisionSql = new StringBuffer();

			// Store the deleted docid list

			StringBuffer delsql = new StringBuffer();

			// Store the data set file

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

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

					.append(MetacatUtil.getLocalReplicationServerName());

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

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

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

						//If this is not data file

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

							//for non-data file document

						}//if

						else {

							//for data file document, in datafile attributes

							//we put "datafile" value there

						}//else

					}//if packagedoctpes

					else { //the package files are saved to be put into the xml later.

								&& !packagedoctypes.contains(recordDoctype)) { //if this is a package file, put it at the end

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

							//refers to are loaded then there is an error

						} else { //the package files are saved to be put into the xml later.

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

							v.add(rs.getString(1));

			rs = pstmt.getResultSet();

			tablehasrows = rs.next();

			while (tablehasrows) { //handle the deleted documents

				//note that rev is always empty for deleted docs

				tablehasrows = rs.next();

			}

			//now we can put the package files into the xml results

			for (int i = 0; i < packageFiles.size(); i++) {

				Vector<String> v = packageFiles.elementAt(i);

			}

			// add revision doc list  

					replicateData));

			pstmt.close();

			//conn.close();

		} catch (Exception e) {

			logMetacat.error("ReplicationService.handleUpdateRequest - " + ReplicationService.METACAT_REPL_ERROR_MSG);