Metacat

import edu.ucsb.nceas.metacat.replication.ReplicationService;

import edu.ucsb.nceas.metacat.service.XMLSchema;

import edu.ucsb.nceas.metacat.service.XMLSchemaService;

import edu.ucsb.nceas.metacat.spatial.SpatialHarvester;

import edu.ucsb.nceas.metacat.util.AuthUtil;

import edu.ucsb.nceas.metacat.util.DocumentUtil;

import edu.ucsb.nceas.metacat.util.SystemUtil;

import edu.ucsb.nceas.utilities.FileUtil;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

import edu.ucsb.nceas.utilities.UtilException;

import org.apache.log4j.Logger;

    protected long rootnodeid;

    private ElementNode rootNode = null;

    private TreeSet<NodeRecord> nodeRecordList = null;

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

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

            //this.conn = conn;

            this.docid = DocumentUtil.getDocIdFromAccessionNumber(accNum);

            this.rev   = DocumentUtil.getRevisionFromAccessionNumber(accNum);

            // Look up the document information

            getDocumentInfo(docid, rev);

        this.doctype = docType;

        this.docid = docId;

        this.rev = (new Integer(newRevision)).intValue();

        //this.updatedVersion = newRevision;

        writeDocumentToDB(action, user, pub, catalogId, serverCode, createDate, updateDate);

    }

	 * @param accNumber

	 *            the document id which is used to name the output file

	 */

		// write the document to disk

//		FileWriter fileWriter = null;

                      currentName, docid, doctype, parentId));

                  }

                }

				}

            }

            // process relative xpaths

                logMetacat.debug("B: " + path +"\n");

                pathList.put(path, new PathIndexEntry(leafNodeId, path, docid,

                    doctype, parentId));

				}

            }

            // process absolute xpaths

                logMetacat.debug("C: " + fullPath +"\n");

                pathList.put(fullPath, new PathIndexEntry(leafNodeId, fullPath,

                    docid, doctype, parentId));

				}

            }

        } 

        double afterDeleteIndex = System.currentTimeMillis()/1000;

        logMetacat.debug("DocumentImpl.deleteNodeIndex - The delete index time is "+(afterDeleteIndex - start));

        // Delete all the entries in xml_queryresult

        logMetacat.debug("DocumentImpl.deleteNodeIndex - Deleted " + rows + " rows from xml_queryresult " +

                "for document " + docid);

        double afterDeleteQueryResult = System.currentTimeMillis()/1000;

     * false); }

     */

            Reader dtd, String action, String docid, String user,

            String[] groups, String ruleBase, boolean needValidation)

            throws Exception

        //in MetacatServlet class and now is wrapper into documentImple

        // get server location for this doc

        int serverLocation = getServerLocationNumber(docid);

                serverLocation, false, ruleBase, needValidation);

    }

     *            and version checked.

     */

            Reader dtd, String action, String accnum, String user,

            String[] groups, int serverCode, boolean override, String ruleBase,

            boolean needValidation) throws Exception

        // NEW - WHEN CLIENT ALWAYS PROVIDE ACCESSION NUMBER INCLUDING REV IN IT

    	// Get the xml as a string so we can write to file later

        logMetacat.debug("DocumentImpl.write - conn usage count before writting: "

                + conn.getUsageCount());

                     * updaterev, validate, user, groups, pub, serverCode, dtd);

                     */

                    logMetacat.debug("DocumentImpl.write - initializing parser");

                            user, groups, pub, serverCode, dtd, ruleBase,

                            needValidation, false, null, null);// false means it is not a revision doc

                                   //null, null are createdate and updatedate

                                   //null will use current time as create date time

                    conn.setAutoCommit(false);

                    logMetacat.debug("DocumentImpl.write - parsing xml");

                    conn.commit();

                    conn.setAutoCommit(true);

                    //write the file to disk

                    logMetacat.debug("DocumentImpl.write - Writing xml to file system");

                    // write to xml_node complete. start the indexing thread.

                    addDocidToIndexingQueue(docid, rev);

        }

        XMLReader parser = null;

        try {

                    pub, serverCode, dtd, ruleBase, needValidation, false, null, null);

                    // null and null are createtime and updatetime

                    // null will create current time

                    //false means it is not a revision doc

            conn.setAutoCommit(false);

            conn.commit();

            conn.setAutoCommit(true);

            //write the file to disk

            addDocidToIndexingQueue(docid, rev);

        } catch (Exception e) {

        // result next time

        if (action.equals("UPDATE")) {

          try {

          } catch (Exception e){

              logMetacat.error("DocumentImpl.write - Error in deleting enteries from "

                                       + "xml_queryresult where docid is "

     *            the server which notify local server the force replication

     *            command

     */

            String pub, Reader dtd, String action, String accnum, String user,

            String[] groups, String homeServer, String notifyServer,

            String ruleBase, boolean needValidation, String tableName, 

            boolean timedReplication, String createDate, String updateDate) throws Exception

    {

    	// Get the xml as a string so we can write to file later

        long rootId;

        String docType = null;

            {

                isRevision = true;

            }

                    pub, serverCode, dtd, ruleBase, needValidation, 

                    isRevision, createDate, updateDate);

            conn.setAutoCommit(false);

            conn.commit();

            conn.setAutoCommit(true);

            // Write the file to disk

            // write to xml_node complete. start the indexing thread.

            // this only for xml_documents

            double afterDeleteXmlAccess2 = System.currentTimeMillis()/1000;

            logMetacat.info("DocumentImpl.delete - The deleting xml_access base on docid time is "+(afterDeleteXmlAccess2 - afterDeleteXmlAccess1 ));

            // Delete enteries from xml_queryresult

            double afterDeleteQueryResult = System.currentTimeMillis()/1000;

            logMetacat.info("DocumentImpl.delete - The deleting xml_queryresult time is "+(afterDeleteQueryResult - afterDeleteXmlAccess2));

            // Delete it from relation table