/src/edu/ucsb/nceas/metacat/RelationHandler.java - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 819

Added by bojilova over 22 years ago

- when the Access file goes first before the Package file (eml-dataset-2.0)
relations are not available in xml_relation, thus updated the code
to check and run ACL also after the Package file is saved.
- cut out the rev# from subject and object in xml_relation as needed by ACL
- put missing pstmt.close in RelationHandler.

        * @param docid the ID of the XML document to index.
        */
       public RelationHandler(String docid, Connection conn)
                   throws McdbException, SQLException, AccessionNumberException
+      {
         this.conn = conn;
         this.docid = docid;
-...
       /**
        * insert the relations specified in the triples into xml_relation table
        */
       public void putRelations() {
       private void putRelations()
                   throws McdbException, SQLException, AccessionNumberException
+      {
         String packagetype = null;
         String subject = null;
         String subDoctype = null;
         String relationship = null;
         String object = null;
         String objDoctype = null;
         PreparedStatement pstmt = null; // to get the relations from xml_nodes
         PreparedStatement tstmt = null; // to insert each relation into xml_relation
         MetaCatUtil.debugMessage("Running relation handler!");
         // deletes all of the relations with a docid of @docid.
         //pseudo-code algorithm
         //for each new relation r in xml_nodes
         //  put r into xml_relation
         //  compare r to each relation already in xml_relation
         //  if r isrelatedto a row in xml_relation
         //    add a new row to xml_relation that represents this new relation
         try {
         /*
          * PSEUDO-CODE ALGORITHM:
          * deletes all of the relations with a docid of @docid.
          * for each new relation r in xml_nodes
          *   put r into xml_relation
          */
           DocumentImpl xmldoc = new DocumentImpl(conn,docid,false);
           //DocumentImpl xmldoc = new DocumentImpl(conn);
           //xmldoc.getDocumentInfo(docid);
           String packagetype = xmldoc.getDoctype();
         //DocumentImpl xmldoc = new DocumentImpl(conn,docid,false);
         packagetype = (new DocumentImpl(conn,docid,false)).getDoctype();
           // first delete the relations for this package document if any
           deleteRelations(docid);
           // put the new relations
           PreparedStatement pstmt = conn.prepareStatement(
                                     QuerySpecification.printPackageSQL(docid));
           pstmt.execute();
           //get the new relations out of xml_nodes
           ResultSet rs = pstmt.getResultSet();
           boolean hasmorerows = rs.next();
           while(hasmorerows) {
             String subject = rs.getString(1);
             String relationship = rs.getString(2);
             String object = rs.getString(3);
         // first delete the relations for this package document if any
         deleteRelations(docid);
             String subjectDoctype = null;
             String paramDocid = null;
             URL subjectMurl = null;
         // to put the new relations get them out of xml_nodes
         pstmt = conn.prepareStatement(QuerySpecification.printPackageSQL(docid));
         pstmt.execute();
         ResultSet rs = pstmt.getResultSet();
         boolean hasmorerows = rs.next();
         if (hasmorerows) {
           tstmt = conn.prepareStatement("INSERT INTO xml_relation (" +
                                         "docid,packagetype,subject,subdoctype," +
                                         "relationship, object, objdoctype) " +
                                         "VALUES (?, ?, ?, ?, ?, ?, ?)");
+        }
         while(hasmorerows) {
           subject = rs.getString(1);
           relationship = rs.getString(2);
           object = rs.getString(3);
             //get the current relations information
             String subDocid = null;
             String objDocid = null;
             String subDoctype = null;
             String objDoctype = null;
           // cut out the revision number for subject and object
           subject = (new DocumentIdentifier(subject)).getIdentifier();
           object = (new DocumentIdentifier(object)).getIdentifier();
           //subDoctype and objDoctype are N/A
           subDoctype = null;
           objDoctype = null;
           //put the new relation into xml_relation
           tstmt.setString(1, docid);
           tstmt.setString(2, packagetype);
           tstmt.setString(3, subject);
           tstmt.setString(4, subDoctype);
           tstmt.setString(5, relationship);
           tstmt.setString(6, object);
           tstmt.setString(7, objDoctype);
           tstmt.execute();
             try {
               URL subMurl = new URL(subject);
               if(subMurl.getQuery() != null) {
                 Hashtable subMurlParams = util.parseQuery(subMurl.getQuery());
                 subDocid = (String)subMurlParams.get("docid");
                 if(subMurl.getProtocol().equals("metacat")) {
                   DocumentImpl subDoc = new DocumentImpl(conn, subDocid);
                   subDoctype = subDoc.getDoctype();
+                }
               } else {
                 subDocid = subject;
+              }
             } catch(MalformedURLException murle) {
               //assume this is just a docid not a url
               subDocid = subject;
+            }
             try {
               URL objMurl = new URL(object);
               if(objMurl.getQuery() != null) {
                 Hashtable objMurlParams = util.parseQuery(objMurl.getQuery());
                 objDocid = (String)objMurlParams.get("docid");
                 if(objMurl.getProtocol().equals("metacat")) {
                   DocumentImpl objDoc = new DocumentImpl(conn, objDocid);
                   objDoctype = objDoc.getDoctype();
+                }
               } else {
                 objDocid = object;
+              }
             } catch(MalformedURLException murle) {
               //assume this is just a docid
               objDocid = object;
+            }
             //now that the comparisons are done, the new relation can be put
             //into xml_relation
             StringBuffer insertStmt = new StringBuffer();
             insertStmt.append("insert into xml_relation (docid, packagetype, ");
             insertStmt.append("subject, subdoctype, ");
             insertStmt.append("relationship, object, objdoctype) values ('");
             insertStmt.append(docid).append("', '");
             insertStmt.append(packagetype).append("', '");
             insertStmt.append(subject).append("', '");
             insertStmt.append(subDoctype).append("', '");
             insertStmt.append(relationship).append("', '");
             insertStmt.append(object).append("', '");
             insertStmt.append(objDoctype).append("')");
             pstmt = conn.prepareStatement(insertStmt.toString());
             pstmt.execute();
             hasmorerows = rs.next();
+          }
           hasmorerows = rs.next();
+        }
           pstmt.close();
           conn.commit();
         } catch(Exception e) {
           MetaCatUtil.debugMessage("Error in RelationHandler.run(): " +
                                    e.getMessage());
           System.out.println("Error in RelationHandler.run(): " +
                                    e.getMessage());
           try {
             conn.rollback();
           } catch (SQLException sqle) {
             System.out.println("Error in RelationHandler.run(): " +
                                sqle.getMessage());
+          }
         if ( tstmt != null ) {
           tstmt.close();
+        }
         pstmt.close();
         conn.commit();
+      }
       /**
        * Deletes all of the relations with a docid of 'docid'.
        * @param docid the docid to delete.
        * @param docid the docid of the package which relations to delete.
        */
       public void deleteRelations(String docid) throws SQLException
+      {
         try {
           PreparedStatement pstmt = conn.prepareStatement("delete from " +
                                  "xml_relation where docid like '" + docid + "'");
           PreparedStatement pstmt = conn.prepareStatement(
                                     "DELETE FROM xml_relation " +
                                     "WHERE docid = '" + docid + "'");
           pstmt.execute();
           pstmt.close();
         } catch(SQLException e) {
-...
           throw e;
+        }
+      }
       /**
        * Get the access file id for a package
        * @param docid the document identifier of the package
        * @return the document identifier of the access file for that package
        */
       public String getAccessFileID(String docid) throws SQLException
+      {
         String aclid = null;
         PreparedStatement pstmt =
           conn.prepareStatement("SELECT docid FROM xml_documents " +
                                 "WHERE docid in " +
                                 "(SELECT subject FROM xml_relation " +
                                 "WHERE docid = ?) " +
                                 "AND doctype = ?");
         pstmt.setString(1, docid);
         pstmt.setString(2, MetaCatUtil.getOption("accessdoctype"));
         pstmt.execute();
         ResultSet rs = pstmt.getResultSet();
         boolean hasRow = rs.next();
         if (hasRow) {
           aclid = rs.getString(1);
+        }
         pstmt.close();
         return aclid;
+      }
+    }

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 819

Added by bojilova over 22 years ago