/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 1324

Added by Jing Tao over 21 years ago

Add code to update tripes in data set file.

        *                      into the data set doc
        */
       private static final String TRIPLESTAG = "//triple";
       private static final String IDENTIFIER = "//identifier";
       private static final String RELATIONSHIP = "provides access control rules for";
       public static final String DELIMITER = "!";
       public static void addNewTripleIntoDataset(String accessionNumber,
                                                  Vector newTripleVector)
+      {
         String docidWithoutVersion = null;
         int rev = 0;
         // check parameter
         if (newTripleVector.size()==0 || accessionNumber == null ||
             accessionNumber.equals(""))
+        {
           return;
+        }
         DocumentImpl doc = null;
         try
+        {
           docidWithoutVersion = MetaCatUtil.getDocIdFromString(accessionNumber);
           rev = MetaCatUtil.getVersionFromString(accessionNumber);
           doc = new DocumentImpl(accessionNumber);
+        }
         catch (Exception e)
-...
           newTripleForDataSet.addTriple(triple);
+        }
         xmlDoc = addTriplesToTriplesString(newTripleForDataSet, xmlDoc, TRIPLESTAG);
         System.out.println("add triple xml file: "+xmlDoc);
         // Update accessNumber
         Vector oldAccessNumberVector = new Vector();
         Vector newAccessNumberVector = new Vector();
         oldAccessNumberVector.addElement(accessionNumber);
         //increase rev number
         rev++;
         accessionNumber = docidWithoutVersion + "." + rev;
         newAccessNumberVector.addElement(accessionNumber);
         xmlDoc = incRevInTriples(xmlDoc, oldAccessNumberVector,
                                  newAccessNumberVector, TRIPLESTAG);
         System.out.println("add triple xml file: "+xmlDoc);
         System.out.println("increate rev xml file: "+xmlDoc);
+      }
         /**
-...
        * searches for any triples already in the string and appends the new
        * ones after the existing ones.
        * @param triples the collection of triples to add
        * @param dataPackageString the xml document of data set
        * @param triplesTag the trip tag in xml docment
        */
       private static String addTriplesToTriplesString(TripleCollection triples,
-...
         return docString;
+      }
       private static String incRevInTriples(String xml, Vector oldid,
                                             Vector newid, String triplePath)
+      {
         System.out.println("oldid: " + oldid.toString() + " newid: " + newid.toString());
         Document doc = null;
         DOMParser parser = new DOMParser();
         InputSource in;
         StringReader sr;
          try
         { //parse the wizard created file with existing triples
           sr = new StringReader(xml);
           in = new InputSource(sr);
+        }
         catch(Exception fnf)
+        {
           fnf.printStackTrace();
           return null;
+        }
         try
+        {
           parser.parse(in);
           sr.close();
+        }
         catch(Exception e1)
+        {
           System.err.println(e1.toString());
+        }
         doc = parser.getDocument();
         NodeList tripleList = null;
         try
+        {
           //find where the triples go in the file
           tripleList = XPathAPI.selectNodeList(doc, triplePath);
+        }
         catch(Exception se)
+        {
           System.err.println("incRevInTriples() : parse threw: " +
                              se.toString());
+        }
         for(int i=0; i<tripleList.getLength(); i++)
+        {
           Node triple = tripleList.item(i);
           NodeList children = triple.getChildNodes();
           String sub = null;
           String rel = null;
           String obj = null;
           if(children.getLength() > 2)
+          {
             for(int j=0; j<children.getLength(); j++)
+            {
               Node childNode = children.item(j);
               String nodename = childNode.getNodeName().trim().toUpperCase();
               if(nodename.equals("SUBJECT") || nodename.equals("OBJECT"))
+              {
                 String nodeval;
                 try
+                {
                   nodeval = childNode.getFirstChild().getNodeValue().trim();
+                }
                 catch(NullPointerException npe)
+                {
                   continue;
+                }
                 if(oldid.contains(nodeval.trim()))
+                {
                   String newidS = "";
                   for(int k=0; k<newid.size(); k++)
+                  {
                     newidS = (String)newid.elementAt(k);
                     if(nodeval.trim().equals(oldid.elementAt(k)))
+                    {
                       break;
+                    }
+                  }
                   System.out.println("replacing: " + nodeval + " with " + newidS);
                   childNode.getFirstChild().setNodeValue(newidS);
+                }
+              }
+            }
+          }
+        }
         //increase the identifier
         NodeList identiferList = null;
         try
+        {
           //find where the triples go in the file
           identiferList = XPathAPI.selectNodeList(doc, IDENTIFIER);
+        }
         catch(Exception se)
+        {
           System.err.println("incRevInTriples() : parse threw: " +
                              se.toString());
+        }
         for(int i=0; i<identiferList.getLength(); i++)
+        {
           Node identifierNode = identiferList.item(i);
           String nodeName = identifierNode.getNodeName().trim().toUpperCase();
           if (nodeName.equals("IDENTIFIER"))
+          {
             String nodeValue = null;
             try
+            {
                nodeValue = identifierNode.getFirstChild().getNodeValue().trim();
+            }
             catch(NullPointerException npe)
+            {
               continue;
+            }
             if(oldid.contains(nodeValue.trim()))
+            {
                String newidS = "";
                 for(int k=0; k<newid.size(); k++)
+                {
                    newidS = (String)newid.elementAt(k);
                    if(nodeValue.trim().equals(oldid.elementAt(k)))
+                   {
                       break;
+                   }
+                }
                 System.out.println("replacing: " + nodeValue + " with " + newidS);
                 identifierNode.getFirstChild().setNodeValue(newidS);
+             }
+          }
+        }
         return PackageUtil.printDoctype(doc) +
                PackageUtil.print(doc.getDocumentElement());
+      }
       /*
        *Give a docid to find a package accesssionNumber for it.
        */
        private static String getDataPackageId(String docId)
        private static String getDataPackageAccessionNumber(String docId)
+      {
         String accessNumber = null;
         String packageIdWithoutVersion = null;
-...
             packageIdWithoutVersion=rs.getString(1);//get data package id
+          }
           pStmt.close();
           query = "SELECT rev from xml_documents where docid = ?";
           pStmt=dbConn.prepareStatement(query);
           //bind the value to query
           pStmt.setString(1, packageIdWithoutVersion);
           //execute the query
           pStmt.execute();
           rs=pStmt.getResultSet();
           //process the result
           if (rs.next()) //There are some records for the id in docId fields
+          {
             rev=rs.getString(1);//get data package id
+          }
           pStmt.close();
           rev = getRevNumber(packageIdWithoutVersion);
           accessNumber = packageIdWithoutVersion+"."+rev;
           MetaCatUtil.debugMessage("DataPackageId: "+accessNumber, 20);
         }//try
-...
         return accessNumber;
       }//isDataPackageId()
       /**
        * Get a dev number from a given docid(without dev)
        */
       public static String getRevNumber(String docId)
+      {
         DBConnection dbConn = null;
         int serialNumber = -1;
         String query = "SELECT rev from xml_documents where docid = ?";
         PreparedStatement pStmt = null;
         ResultSet rs = null;
         String rev = null;
         try
+        {
           dbConn=DBConnectionPool.
                       getDBConnection("DBQuery.getDataPackageId");
           serialNumber=dbConn.getCheckOutSerialNumber();
           pStmt=dbConn.prepareStatement(query);
           //bind the value to query
           pStmt.setString(1, docId);
           //execute the query
           pStmt.execute();
           rs=pStmt.getResultSet();
           //process the result
           if (rs.next()) //There are some records for the id in docId fields
+          {
             rev=rs.getString(1);//get data package id
+          }
           pStmt.close();
+        }
         catch (SQLException e)
+        {
           System.out.println("the error in getRevNumber: "+e.getMessage());
+        }
         finally
+        {
           try
+          {
             pStmt.close();
+          }
           catch (SQLException ee)
+          {
             System.out.println("the error in getRevNumber2: "+ee.getMessage());
+          }
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
             return rev;
+          }
+        }
+      }
       /**
        * Delete a access control rule which is not in access xml document
        */
       public static void deleteAccessRule(String aclDocid, String accessRule)
+      {
         String principal  = null;
         String allowType  = null;
         String permission = null;
         String allowOrder = null;
         String [] parseAccessRuleArray = null;
          DBConnection dbConn = null;
         int serialNumber = -1;
         String query = "delete from xml_access where accessfileid = ? " +
                        "and principal_name = ? and permission_type = ? "+
                        "and permission = ? and permission_order = ?";
         PreparedStatement pStmt = null;
         String rev = null;
         // parse the access rule
         parseAccessRuleArray = parseAccessRule(accessRule);
         if ( parseAccessRuleArray == null)
+        {
           System.out.println("couldn't parse docid: "+aclDocid);
           return;
+        }
         else
+        {
           principal  = parseAccessRuleArray[0];
           System.out.println("principal: "+principal);
           allowType  = parseAccessRuleArray[1];
           System.out.println("allowType: "+allowType);
           permission = parseAccessRuleArray[2];
           System.out.println("permission: "+permission);
           allowOrder = parseAccessRuleArray[3];
           System.out.println("allowOrder: "+allowOrder);
+        }
         /*try
+        {
           dbConn=DBConnectionPool.
                       getDBConnection("DBQuery.getDataPackageId");
           serialNumber=dbConn.getCheckOutSerialNumber();
           //pStmt=dbConn.prepareStatement(query);
           //bind the value to query
           //pStmt.setString(1, docId);
           //execute the query
           //pStmt.execute();
           //pStmt.close();
+        }
         catch (SQLException e)
+        {
           System.out.println("the error in getRevNumber: "+e.getMessage());
+        }
         finally
+        {
           try
+          {
             //pStmt.close();
+          }
           catch (SQLException ee)
+          {
             System.out.println("the error in getRevNumber2: "+ee.getMessage());
+          }
           finally
+          {
             DBConnectionPool.returnDBConnection(dbConn, serialNumber);
+          }
         }*/
+      }
       /*
        * parse the string and get a array cotains principle name(index 0),
        * allow type (index1), permission (index2), and allow order(index, 4)
        */
       private static String[] parseAccessRule(String accessRule)
+      {
         String principal  = null;
         String allowType  = null;
         String permission = null;
         String allowOrder = null;
         String [] result  = new String[4];
         int count = 0;
         int index = 0;
         char delimiter = DELIMITER.charAt(0);
         if (accessRule== null)
+        {
           return result;
+        }
         for (int i=0; i<accessRule.length(); i++)
+        {
           char charInString = accessRule.charAt(i);
           // find a symbol !
           if (charInString == delimiter)
+          {
             count ++;
+          }
           else
+          {
             continue;
+          }
           switch (count)
+          {
             case 1:
+            {
               // get principal
               principal = accessRule.substring(0, i);
               // remeber the index
               index = i;
               break;
+            }
             case 2:
+            {
               allowType = accessRule.substring(index+1, i);
               index = i;
               break;
+            }
             case 3:
+            {
               permission = accessRule.substring(index+1, i);
               index = i;
               allowOrder = accessRule.substring(index+1, accessRule.length());
               break;
+            }
           }//switch
         }//for
         // if the string exactly has 3 !, add it to array
         if ( count == 3)
+        {
           result[0] = principal;
           result[1] = allowType;
           result[2] = permission;
           result[3] = allowOrder;
         }//if
         return result;
+      }
       public static void main(String[] agus)
+      {
         if(agus.length == 0)
-...
           return;
+        }
         String docID = agus[0];
         Vector newTripleVector = new Vector();
         try
+        {
           DBConnectionPool pool = DBConnectionPool.getInstance();
           String packagAccessionNumber=getDataPackageAccessionNumber(docID);
           AccessRulesFromDocument xmlDocument = new AccessRulesFromDocument(docID);
           Vector rules = xmlDocument.getAccessRuleVector();
           Vector docid = xmlDocument.getACLObjects();
-...
             if (!rules.contains(rulesFromDB.elementAt(i)))
+            {
               System.out.println("find a new rule!!!");
               deleteAccessRule(docID, (String)rulesFromDB.elementAt(i));
+            }
+          }
           for (int i = 0; i<docidFromDB.size(); i++)
+          {
             System.out.println("docid: "+(String)docidFromDB.elementAt(i));
             if (!docid.contains(docidFromDB.elementAt(i)))
             String objectId = (String)docidFromDB.elementAt(i);
             System.out.println("docid: "+objectId);
             if (!docid.contains(objectId))
+            {
               String revs = getRevNumber(objectId);
               objectId = objectId+"."+revs;
               revs = getRevNumber(docID);
               docID = docID+"."+revs;
               Triple newTriple = new Triple(docID, RELATIONSHIP, objectId);
               newTripleVector.add(newTriple);
               System.out.println("find a new triple");
+            }
+          }
           // add new triple vector to xml
           addNewTripleIntoDataset(packagAccessionNumber, newTripleVector);
+        }
         catch(Exception e)
+        {

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 1324

Added by Jing Tao over 21 years ago