Metacat

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.SystemUtil;

import edu.ucsb.nceas.utilities.FileUtil;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

    {

        try {

            //this.conn = conn;

            // Look up the document information

            getDocumentInfo(docid, rev);

            serialNumber = conn.getCheckOutSerialNumber();

            conn.setAutoCommit(false);

            String action = null;

            action = checkRevInXMLDocuments(docIdWithoutRev, userSpecifyRev);

            logMetacat.warn("after check rev, the action is "+action);

            if (action.equals("UPDATE"))

            serialNumber = conn.getCheckOutSerialNumber();

            conn.setAutoCommit(false);

            String action = null;

            if (tableName.equals(DOCUMENTTABLE))

            {

                action = checkRevInXMLDocuments(docIdWithoutRev, userSpecifyRev);

            throws Exception

    {

        boolean flag = true;

        if (serverCode == 1) {

            flag = true;

                    .getServerNameForServerCode(serverCode);

            MetacatReplication.replLog("attempting to lock " + accnum);

            URL u = new URL("https://" + server + "?server="

                    + "&action=getlock&updaterev=" + rev + "&docid=" + docid);

            //System.out.println("sending message: " + u.toString());

            String serverResStr = MetacatReplication.getURLContent(u);

                    // if it is inline data first to get the inline data

                    // internal id

                    String fileName = currentNode.getNodeData();

                            .getDocIdWithoutRevFromInlineDataID(fileName);

                    // check if user has read permision for this inline data

                    boolean readInlinedata = false;

                      currentName, docid, doctype, parentId));

                  }

                }

                    leafData.trim().length() != 0 ){

                	logMetacat.debug("paths found for indexing: " + currentName);

                	pathsFoundForIndexing.put(currentName, new PathIndexEntry(

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

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

                    doctype, parentId));

                    leafData.trim().length() != 0 ){

                	logMetacat.debug("paths found for indexing: " + currentName);

                	pathsFoundForIndexing.put(path, new PathIndexEntry(

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

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

                    docid, doctype, parentId));

                   leafData.trim().length() != 0 ){

                	logMetacat.debug("paths found for indexing: " + currentName);

                	pathsFoundForIndexing.put(fullPath, new PathIndexEntry(

     */

    private void deleteNodeIndex(DBConnection conn) throws SQLException

    {

    	double start = System.currentTimeMillis()/1000;

        String familyId = docid;

        String sql = "DELETE FROM xml_index WHERE docid = ?";

                if (!server.equals("localhost")) {

                    this.docHomeServer = server;

                } else {

                            .getLocalReplicationServerName();

                }

                logMetacat.info("server: " + docHomeServer);

                try

                {

                	logMetacat.debug("Node data in read process before normalize=== "+nodedata);

                	logMetacat.debug("Node data in read process after normalize==== "+nodedata);

                } catch (java.lang.StringIndexOutOfBoundsException SIO){

                	logMetacat.warn("StringIndexOutOfBoundsException in normalize() while reading the document");

            }

            //DocumentIdentifier id = new DocumentIdentifier(accnum);

            String updaterev = (new Integer(revision)).toString();

            String server = MetacatReplication

                    .getServerNameForServerCode(serverCode);

            MetacatReplication.replLog("attempting to lock " + accnum);

            URL u = new URL("https://" + server + "?server="

                    + "&action=getlock&updaterev=" + updaterev + "&docid="

                    + docid);

            //System.out.println("sending message: " + u.toString());

        String catalogId = null;

        logMetacat.info("user in replication" + user);

        // Docid without revision

        logMetacat.warn("The docid without rev is " + docid);

        // Revision specified by user (int)

        logMetacat.warn("The user specifyRev: " + userSpecifyRev);

        // Revision for this docid in current database

        int revInDataBase = DBUtil.getLatestRevisionInDocumentTable(docid);

        try {

            String packagedoctype = PropertyService.getProperty("xml.packagedoctype");

            Vector<String> packagedoctypes = new Vector<String>();

            if (documenttype != null &&

                    packagedoctypes.contains(documenttype)) {

                dbconn = DBConnectionPool.getDBConnection(

                String aclidWithRev = RelationHandler.getAccessFileIDWithRevision(docIdWithoutRev);

                if (aclidWithRev != null)

                {

                  // if there are access file, write ACL for that package

                  if (aclid != null) {

            }

            // if it is an access file

            else if (documenttype != null

                            PropertyService.getProperty("xml.accessdoctype")).contains(

                            documenttype)) {

                dbconn = DBConnectionPool.getDBConnection(

        int serialNumber = -1;

        try {

            //get rid of revision number

            dbConnection = DBConnectionPool.getDBConnection(

                    "DocumentImpl.getDocTypeFromDBForCurrentDoc");

            serialNumber = dbConnection.getCheckOutSerialNumber();

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

            // IN IT

            //AccessionNumber ac = new AccessionNumber(accnum, "DELETE");

            //String rev = ac.getRev();

            // Check if the document exists.

            throws SQLException

    {

        //get rid of revNum part

        PreparedStatement pStmt = null;

        int serverLocation = 1;

        DBConnection conn = null;

        int serialNumber = -1;

        //we should consider about local host too

            serverLocation = 1;

            return serverLocation;

        }

            // If the server is not in the table, and server is not local host,

            // insert it

            if (!hasRow

                            .getLocalReplicationServerName())) {

                // Set auto commit false

                dbConn.setAutoCommit(false);

            dbconn = DBConnectionPool.getDBConnection(

                    "DeletedDocumentImpl.registerDeletedDataFile");

            serialNumber = dbconn.getCheckOutSerialNumber();

                    .getDocIdFromAccessionNumber(accnum);

            writeDocumentToRevisionTable(dbconn, docIdWithoutRev, 

                    rev, doctype, docname, user,

                    null, serverCode, -1, createDate, updateDate);