/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 6015

Added by ben leinfelder over 13 years ago

insert/update documents with null user and null group to circumvent access control restrictions then update the user_owner and user_updated values to reflect what exists on the originating server (pisco)

                                   null,  /* the dtd text */
                                   actions,
                                   accNumber,
                                   docinfoHash.get("user_updated"),
                                   //docinfoHash.get("user_owner"),
                                   null, //docinfoHash.get("user_owner"),
                                   null, /* null for groups[] */
                                   docHomeServer,
                                   remoteserver, tableName, true,// true is for time replication
                                   createdDate,
                                   updatedDate);
           //set the user information
           String user = (String) docinfoHash.get("user_owner");
           String updated = (String) docinfoHash.get("user_updated");
           ReplicationService.updateUserOwner(dbConn, accNumber, user, updated);
           //process extra access rules
           Vector<XMLAccessDAO> xmlAccessDAOList = dih.getAccessControlList();
           if (xmlAccessDAOList != null) {
-...
           String docInfoStr = ReplicationService.getURLContent(docinfoUrl);
           docinfoParser.parse(new InputSource(new StringReader(docInfoStr)));
           Hashtable<String, String> docinfoHash = dih.getDocInfo();
           // Get docid owner
           //String user = docinfoHash.get("user_owner");
           String user = docinfoHash.get("user_updated");
           // Get docid name (such as acl or dataset)
           String docName = docinfoHash.get("docname");
           // Get doc type (eml public id)
-...
             DocumentImpl.writeDataFileInReplication(input,
                                                     datafilePath,
                                                     docName,docType,
                                                     accNumber, user,
                                                     accNumber,
                                                     null,
                                                     docHomeServer,
                                                     remoteserver,
                                                     tableName,
-...
                                                     createdDate,
                                                     updatedDate);
             //set the user information
             String user = (String) docinfoHash.get("user_owner");
     		String updated = (String) docinfoHash.get("user_updated");
             ReplicationService.updateUserOwner(dbConn, accNumber, user, updated);
             //process extra access rules
             Vector<XMLAccessDAO> xmlAccessDAOList = dih.getAccessControlList();
             if (xmlAccessDAOList != null) {

     			//      Hashtable<String,Vector<AccessControlForSingleFile>> docinfoHash = dih.getDocInfo();
     			Hashtable<String, String> docinfoHash = dih.getDocInfo();
     			// Get user owner of this docid
     			String user = (String) docinfoHash.get("user_updated");
     			//String user = (String) docinfoHash.get("user_owner");
     			// Get home server of this docid
     			String homeServer = (String) docinfoHash.get("home_server");
     			String guid = (String) docinfoHash.get("guid");
-...
     //			Exception writeException = null;
     			try {
     				wrapper.writeReplication(dbConn, xmldoc, null, null,
     						dbaction, docid, user, null, homeServer, server, createdDate,
     						dbaction, docid, null, null, homeServer, server, createdDate,
     						updatedDate);
     			} finally {
     //				writeException = e;
-...
+    		        		}
+    		            }
+    		        }
     //				if (accessControlList != null) {
     //					for (int i = 0; i < accessControlList.size(); i++) {
     //						AccessControlForSingleFile acfsf = (AccessControlForSingleFile) accessControlList
     //								.get(i);
     //						if (!acfsf.accessControlExists()) {
     //							acfsf.insertPermissions();
     //							logReplication.info("ReplicationService.handleForceReplicateRequest - document " + docid
     //									+ " permissions added to DB");
     //						}
     //					}
     //				}
     		        // process the real owner and updater
     				String user = (String) docinfoHash.get("user_owner");
     				String updated = (String) docinfoHash.get("user_updated");
     		        updateUserOwner(dbConn, docid, user, updated);
     //				if (writeException != null) {
     //					throw writeException;
     //				}
     				logReplication.info("ReplicationService.handleForceReplicateRequest - document " + docid + " added to DB with "
     						+ "action " + dbaction);
-...
     			XMLReader docinfoParser = ReplicationHandler.initParser(dih);
     			docinfoParser.parse(new InputSource(new StringReader(docInfoStr)));
     			Hashtable<String, String> docinfoHash = dih.getDocInfo();
     			String user = (String) docinfoHash.get("user_updated");
     			//String user = (String) docinfoHash.get("user_owner");
     			String docName = (String) docinfoHash.get("docname");
     			String docType = (String) docinfoHash.get("doctype");
-...
     				//into file system
     				try {
     					DocumentImpl.writeDataFileInReplication(url.openStream(),
     							datafilePath, docName, docType, docid, user, docHomeServer,
     							datafilePath, docName, docType, docid, null, docHomeServer,
     							server, DocumentImpl.DOCUMENTTABLE, false, createdDate,
     							updatedDate);
     				} catch (Exception e) {
     					writeException = e;
+    				}
     				//process extra access rules
     //				Vector<AccessControlForSingleFile> accessControlList = dih
     //						.getAccessControlList();
     //				if (accessControlList != null) {
     //					for (int i = 0; i < accessControlList.size(); i++) {
     //						AccessControlForSingleFile acfsf = (AccessControlForSingleFile) accessControlList
     //								.get(i);
     //						if (!acfsf.accessControlExists()) {
     //							acfsf.insertPermissions();
     //							logReplication.info("ReplicationService.handleForceReplicateDataFileRequest - datafile " + docid
     //									+ " permissions added to DB");
     //						}
     //					}
     //				}
     				// process the real owner and updater
     				DBConnection dbConn = DBConnectionPool.getDBConnection("ReplicationService.handleForceDataFileRequest");
     		        int serialNumber = dbConn.getCheckOutSerialNumber();
     		        dbConn.setAutoCommit(false);
     				String user = (String) docinfoHash.get("user_owner");
     				String updated = (String) docinfoHash.get("user_updated");
     		        updateUserOwner(dbConn, docid, user, updated);
     		        DBConnectionPool.returnDBConnection(dbConn, serialNumber);
     		        Vector<XMLAccessDAO> accessControlList = dih.getAccessControlList();
     		        if (accessControlList != null) {
     		        	AccessControlForSingleFile acfsf = new AccessControlForSingleFile(docid);
-...
     	}//handlUpdateRequest
     	/**
+    	 *
     	 * @param dbConn connection for doing the update
     	 * @param docid the document id to update
     	 * @param owner the user_owner
     	 * @param updater the user_updated
     	 * @throws SQLException
     	 */
     	public static void updateUserOwner(DBConnection dbConn, String docid, String owner, String updater) throws SQLException {
     		String sql =
     			"UPDATE xml_documents " +
     			"SET user_owner = ?, " +
     			"user_updated = ? " +
     			"WHERE docid = ?;";
     		PreparedStatement pstmt = dbConn.prepareStatement(sql);
     		//usage count should increas 1
     		dbConn.increaseUsageCount(1);
     		docid = DocumentUtil.getSmartDocId(docid);
     		pstmt.setString(1, owner);
     		pstmt.setString(2, updater);
     		pstmt.setString(3, docid);
     		pstmt.execute();
     		pstmt.close();
     		dbConn.commit();
+    	}
     	/*
     	 * This method will get the xml string for document in xml_revision
     	 * The schema look like <!ELEMENT revisionDocument (docid, rev, datafile*)>

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 6015

Added by ben leinfelder over 13 years ago