Metacat

import edu.ucsb.nceas.metacat.database.DBConnection;

import edu.ucsb.nceas.metacat.database.DBConnectionPool;

import edu.ucsb.nceas.metacat.database.DatabaseService;

import edu.ucsb.nceas.metacat.dataone.hazelcast.HazelcastService;

import edu.ucsb.nceas.metacat.index.MetacatSolrIndex;

import edu.ucsb.nceas.metacat.properties.PropertyService;

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

    	StringReader xmlReader = new StringReader(xmlString);

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

                + conn.getUsageCount());

        AccessionNumber ac = new AccessionNumber(accnum, action);

                	// detect encoding

                    XmlStreamReader xsr = new XmlStreamReader(new ByteArrayInputStream(xmlString.getBytes()));

			        String encoding = xsr.getEncoding();

                    /*

                     * XMLReader parser = initializeParser(conn, action, docid,

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

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

                    parser = initializeParser(conn, action, docid, xmlReader, updaterev,

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

                    	// false means it is not a revision doc

                                   //null, null are createdate and updatedate

                                   //null will use current time as create date time

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

                    addDocidToIndexingQueue(docid, rev);

               } catch (Exception e) {

                   e.printStackTrace();

            	   logMetacat.error("DocumentImpl.write - Problem with parsing: " + e.getMessage());

            // detect encoding

        	XmlStreamReader xsr = new XmlStreamReader(new ByteArrayInputStream(xmlString.getBytes()));

	        String encoding = xsr.getEncoding();

            parser = initializeParser(conn, action, docid, xmlReader, rev, user, groups,

                    // null and null are createtime and updatetime

                    // null will create current time

                    //false means it is not a revision doc

        	writeToFileSystem(xmlString, accnum, encoding);

            addDocidToIndexingQueue(docid, rev);

        } catch (Exception e) {

        	logMetacat.error("DocumentImpl.write - Problem with parsing: " + e.getMessage());

            e.printStackTrace();

	        // no need to write the EML-contained access rules for replication

	        boolean writeAccessRules = false;

            parser = initializeParser(conn, action, docid, xmlReader, rev, user, groups,

                    pub, serverCode, dtd, ruleBase, needValidation, 

            conn.setAutoCommit(false);

            parser.parse(new InputSource(xmlReader));

            String action, String docid, Reader xml, String rev, String user,

            String[] groups, String pub, int serverCode, Reader dtd,

            String ruleBase, boolean needValidation, boolean isRevision,

    {

        XMLReader parser = null;

        try {

            } else if (ruleBase != null && ruleBase.equals(EML210)) {

                logMetacat.info("DocumentImpl.initalizeParser - Using eml 2.1.0 parser");

                chandler = new Eml210SAXHandler(dbconn, action, docid, rev,

                chandler.setIsRevisionDoc(isRevision);

                chandler.setEncoding(encoding);

                parser.setContentHandler((ContentHandler) chandler);

	DistributionSection currentDistributionSection = null;

	Vector<DistributionSection> allDistributionSections = new Vector<DistributionSection>();

	// This variable keeps a counter of each distribution element. This index

	// will be used to name the inline data file that gets written to disk, and to

	 */

	public Eml210SAXHandler(DBConnection conn, String action, String docid,

			String revision, String user, String[] groups, String pub, int serverCode,

		super(conn, action, docid, revision, user, groups, pub, serverCode, createDate,

				updateDate, writeAccessRules);

		// Get the unchangeable subtrees (user doesn't have write permission)

		try {

				pstmt.setString(7, subSectionId);

				logMetacat.debug("SubSectionId in accesstable: " + subSectionId);

			}

			Vector<AccessRule> accessRules = accessSection.getAccessRules();

		// for D1, refresh the entries

		HazelcastService.getInstance().refreshSystemMetadataEntry(guid);

		HazelcastService.getInstance().refreshSystemMetadataEntry(referencedGuid);

	}// writeGivenAccessRuleIntoDB