/ - Diff - Metacat - Ecoinformatics Redmine

           { //stop the replication server
             replicationDaemon.cancel();
             out.println("Replication Handler Stopped");
             System.out.println("Replication Handler Stopped");
+          }
           else if(((String[])params.get("action"))[0].equals("start"))
           { //start the replication server
-...
         sql.append("to_date('").append(dateString).append("','YY-MM-DD HH24:MI:SS')");
         //System.out.println("sql: " + sql.toString());
         //get any recently deleted documents
         StringBuffer delsql = new StringBuffer();
         delsql.append("select docid, date_created, server_location from ");
         delsql.append("xml_revisions where docid not in (select docid from ");
         delsql.append("xml_documents) and date_created > to_date('");
         delsql.append(dateString).append("','YY-MM-DD HH24:MI:SS')");
         try
+        {
           Connection conn = util.openDBConnection();
-...
+            }
             tablehasrows = rs.next();
+          }
           pstmt = conn.prepareStatement(delsql.toString());
           pstmt.execute();
           rs = pstmt.getResultSet();
           tablehasrows = rs.next();
           while(tablehasrows)
           { //handle the deleted documents
             String docid = rs.getString(1);
             String dateUpdated = rs.getString(2);
             int serverCode = rs.getInt(3);
             if(serverCode == 1)
+            {
               returnXML.append("<deletedDocument><docid>").append(docid);
               returnXML.append("</docid><date_updated>").append(dateUpdated);
               returnXML.append("</date_updated></deletedDocument>");
+            }
             tablehasrows = rs.next();
+          }
           returnXML.append("</updates></replication>");
           conn.close();
           //System.out.println(returnXML.toString());

src/edu/ucsb/nceas/metacat/ReplMessageHandler.java
34	34	{
35	35	private Vector updates = new Vector();
36	36	private Vector indivUpdate = new Vector();
	37	private Vector indivDelete = new Vector();
	38	private Vector deletes = new Vector();
37	39	private String server;
	40	private boolean update = false;
	41	private boolean delete = false;
38	42	String currentTag = new String();
39	43
40	44	public ReplMessageHandler()
...	...
51	55	if(localName.equals("updatedDocument"))
52	56	{
53	57	indivUpdate = new Vector();
	58	update = true;
54	59	}
	60	else if(localName.equals("deletedDocument"))
	61	{
	62	indivDelete = new Vector();
	63	delete = true;
	64	}
55	65	}
56	66
57	67	/**
...	...
63	73	if(localName.equals("updatedDocument"))
64	74	{
65	75	updates.add(new Vector(indivUpdate));
	76	update = false;
66	77	}
	78	else if(localName.equals("deletedDocument"))
	79	{
	80	deletes.add(new Vector(indivDelete));
	81	delete = false;
	82	}
67	83	}
68	84
69	85	/**
...	...
71	87	*/
72	88	public void characters(char[] ch, int start, int length) throws SAXException
73	89	{
74		if(currentTag.equals("docid"))
	90	if(currentTag.equals("docid") && update)
75	91	{
76	92	indivUpdate.add(new String(ch, start, length));
77	93	}
78		if(currentTag.equals("date_updated"))
	94	else if(currentTag.equals("docid") && delete)
79	95	{
	96	indivDelete.add(new String(ch, start, length));
	97	}
	98
	99	if(currentTag.equals("date_updated") && update)
	100	{
80	101	indivUpdate.add(new String(ch, start, length));
81	102	indivUpdate.add(server);
82	103	}
	104	else if(currentTag.equals("date_updated") && delete)
	105	{
	106	indivDelete.add(new String(ch, start, length));
	107	indivDelete.add(server);
	108	}
	109
83	110	if(currentTag.equals("server"))
84	111	{
85	112	server = new String(ch, start, length);
86	113	}
87	114	}
88	115
89		public Vector getResultVect()
	116	public Vector getUpdatesVect()
90	117	{
91	118	return updates;
92	119	}
93	120
	121	public Vector getDeletesVect()
	122	{
	123	return deletes;
	124	}
	125
94	126	}

             parser.parse(new InputSource(
                          new StringReader(
                          (String)(responses.elementAt(i)))));
             Vector v = new Vector(message.getResultVect());
             Vector v = new Vector(message.getUpdatesVect());
             Vector d = new Vector(message.getDeletesVect());
             for(int j=0; j<v.size(); j++)
             { //go through each update vector and update or insert
               //a new document
-...
                 System.out.println("newDocid: " + newDocid + " " + action + "ED");
+              }
+            }
             for(int k=0; k<d.size(); k++)
+            {
               Vector w = new Vector((Vector)d.elementAt(k));
               String docid = (String)w.elementAt(0);
               DocumentImpl.delete(conn, docid, null, null);
+            }
+          }
           //update the last_update field for each server to the current date/time

Project

General

Profile

Metacat

Revision 554

Added by berkley about 24 years ago