Metacat

        				throw new SAXException("Odd number of elements found when parsing schema location: " + 	

        						attributeValue + ". There should be an even number of uri/files in location.");

        			}

        			XMLSchema xmlSchema = 

        			schemaList.add(xmlSchema);

        		}

            }

    public static String write(DBConnection conn, String xmlString, String pub,

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

            throws Exception

    {

        //this method will be called in handleUpdateOrInsert method

        // get server location for this doc

        int serverLocation = getServerLocationNumber(docid);

        return write(conn, xmlString, pub, dtd, action, docid, user, groups,

    }

    /**

    public static String write(DBConnection conn, String xmlString, String pub,

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

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

    {

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

                    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

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

            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

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

            String[] groups, String homeServer, String notifyServer,

            String ruleBase, boolean needValidation, String tableName, 

    {

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

    	StringReader xmlReader = new StringReader(xmlString);

            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 {

                // From DB to find the register external schema location

                String externalSchemaLocation = null;

//                SchemaLocationResolver resolver = new SchemaLocationResolver();

                // Set external schemalocation.

                if (externalSchemaLocation != null

                        && !(externalSchemaLocation.trim()).equals("")) {

                    parser.setProperty(EXTERNALSCHEMALOCATIONPROPERTY,

                            externalSchemaLocation);

                }

                logMetacat.debug("DocumentImpl.initalizeParser - 2.0.0 parser configured");

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

                parser.setFeature(SCHEMAVALIDATIONFEATURE, true);

                // From DB to find the register external schema location

                String externalSchemaLocation = null;

                // Set external schemalocation.

                if (externalSchemaLocation != null

                        && !(externalSchemaLocation.trim()).equals("")) {

                    parser.setProperty(EXTERNALSCHEMALOCATIONPROPERTY,

                            externalSchemaLocation);

                }

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

            } else {

                    }

                    // From DB to find the register external schema location

                    String externalSchemaLocation = null;

                    // Set external schemalocation.

                    if (externalSchemaLocation != null

                            && !(externalSchemaLocation.trim()).equals("")) {

                        parser.setProperty(EXTERNALSCHEMALOCATIONPROPERTY,

                                externalSchemaLocation);

                    }

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

	}//Constructor

	public String write(DBConnection conn, String xml, String pub, Reader dtd,

		return DocumentImpl.write(conn, xml, pub, dtd, action, docid, user, groups,

	}

	public String writeReplication(DBConnection conn, String xml, byte[]xmlBytes, String pub, Reader dtd,

			String action, String accnum, String user, String[] groups,

			throws Exception {

		//we don't need to check validation in replication

		// so rule base is null and need validation is false (first false)

		// and timed replication is false (last false)

		return DocumentImpl.writeReplication(conn, xml, xmlBytes, pub, dtd, action, accnum, user,

				groups, homeServer, notifyServer, ruleBase, false,

		// last false means is not timed replication

	}

	public String writeReplication(DBConnection conn, String xml, byte[]xmlBytes, String pub, Reader dtd,

			String action, String accnum, String user, String[] groups,

			String homeServer, String notifyServer, String tableName,

			throws Exception {

		//we don't need to check validation in replication

		// so rule base is null and need validation is false

		return DocumentImpl.writeReplication(conn, xml, xmlBytes, pub, dtd, action, accnum, user,

				groups, homeServer, notifyServer, ruleBase, false, tableName,

	}

}

		// if we get here, metacat is configured.  If we have not completed the 

		// second half of the initialization, do so now.  This allows us to initially

		// configure metacat without a restart.

		if (!_fullyInitialized) {

			initSecondHalf(request.getSession().getServletContext());

		}

                }

				PrintWriter out = response.getWriter();

				if ((userName != null) && !userName.equals("public")) {

					handler.handleInsertOrUpdateAction(request.getRemoteAddr(), request.getHeader("User-Agent"), response, out, params, userName,

				} else {

					response.setContentType("text/xml");

					out.println("<?xml version=\"1.0\"?>");

     */

    public String handleInsertOrUpdateAction(String ipAddress, String userAgent,

            HttpServletResponse response, PrintWriter out, Hashtable<String, String[]> params,

        Logger logMetacat = Logger.getLogger(MetacatHandler.class);

        DBConnection dbConn = null;

        int serialNumber = -1;

              } else {*/

              newdocid = documentWrapper.write(dbConn, doctext[0], pub, dtd,

              EventLog.getInstance().log(ipAddress, userAgent, user, accNumber, action[0]);

                params.put("doctext", doctextArr);

                boolean writeAccessRules = true;

                //call the insert routine

                handleInsertOrUpdateAction(request.getRemoteAddr(), request.getHeader("User-Agent"), response, out, 

              }

              catch(Exception e)

              {

    } 

  }

  {

     try

     {

       logMetacat.error("erorr in Schemalocation.main: " + 

                                e.getMessage());

     }

  /**

   * Gets the downloadNewSchema's value.

      	//String objectAsXML = "";

        try {

	        //objectAsXML = IOUtils.toString(object, "UTF-8");

	        //localId = im.getLocalId(pid.getValue());

        } catch (IOException e) {

          " is science metadata: " + e.getMessage());*/

    } catch (NotFound e) {

          sysmeta.getIdentifier().getValue() + 

          " is science metadata: " + e.getMessage());

   * 

   */

  public String insertOrUpdateDocument(InputStream xml, String encoding,  Identifier pid, 

    throws ServiceFailure, IOException {

  	logMetacat.debug("Starting to insert xml document...");

    // do the insert or update action

    handler = new MetacatHandler(new Timer());

    String result = handler.handleInsertOrUpdateAction(request.getRemoteAddr(), request.getHeader("User-Agent"), null, 

    if(result.indexOf("<error>") != -1) {

    	String detailCode = "";

                //String objectAsXML = "";

                try {

                    //objectAsXML = IOUtils.toString(object, "UTF-8");

                    // register the newPid and the generated localId

                    if (newPid != null) {

      {

        parserBase = DocumentImpl.EML210;

      }

      // Write the document into local host

      DocumentImplWrapper wrapper = new DocumentImplWrapper(parserBase, false, false);

      String newDocid = wrapper.writeReplication(dbConn,

                              docHomeServer,

                              remoteserver, tableName, true,// true is for time replication 

                              createdDate,

      if(sysMeta != null) {

			// submit for indexing. When the doc writing process fails, the index process will fail as well. But this failure

				parserBase = DocumentImpl.EML210;

			}

			logReplication.warn("ReplicationService.handleForceReplicateRequest - The parserBase is: " + parserBase);

			// Get DBConnection from pool

			dbConn = DBConnectionPool

					.getDBConnection("MetacatReplication.handleForceReplicateRequest");

			try {

				wrapper.writeReplication(dbConn, xmldoc, xmlBytes, null, null,

						dbaction, docid, null, null, homeServer, server, createdDate,

			} finally {

				if(sysMeta != null) {

					// submit for indexing. When the doc writing process fails, the index process will fail as well. But this failure

	private String fileName = null;

	private String localFileUri = null;

	private String localFileDir = null;

	/**

	 * Constructor - the schema file name will be extracted from the external

	 * file uri. The local file uri and local file dir will be constructed using

	 * @param externalFileUri

	 *            the external uri where the schema is located

	 */

		setFileNamespace(fileNamespace);

		setExternalFileUri(externalFileUri);

	}

	/**

	 * @param namespace

	 *            the file's name space

	 */

		setFileNamespace(fileNamespace);

	/**

	 * Set the file name. The local file uri and local file dir will also get

	public String getLocalFileDir() {

		return localFileDir;

	}

}

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.Vector;

import java.util.regex.Matcher;

import java.util.regex.Pattern;

    private static Vector<String> nameSpaceList = new Vector<String>();

    // a convenience string that holds all name spaces and locations in a space

	/**

	 * private constructor since this is a singleton

	 */

	/**

	 * Gets the name space and location string. This is a convenience method.

	 * The string will have space delimited namespaces and locations that are

	 * 

	 * @return a string that holds space delimited registered namespaces and

	 *         locations.

	 */

	}

	/**

	 * Gets a list of name spaces. This is a convenience method. The list will 

	 * have all namespaces that are held in the registered schema list.

	 * 

		registeredSchemaList = new Vector<XMLSchema>();

		// get the system id from the xml_catalog table for all schemas.

				+ "entry_type ='" + DocumentImpl.SCHEMA + "'";

		try {

			// check out DBConnection

			while (resultSet.next()) {

				String fileNamespace = resultSet.getString(1);

				String fileLocation = resultSet.getString(2);

				if(fileLocation.startsWith("http://") || fileLocation.startsWith("https://"))

				{

				    //System.out.println("processing an http schemal location");

	 * in the registered schema list.

	 */

	private static void createRegisteredNameSpaceAndLocationString() {

		for (XMLSchema xmlSchema : registeredSchemaList) {

		}

	}

										+ targetLine

										+ ". There should be an even number of uri/files in location.");

					}

					XMLSchema xmlSchema = new XMLSchema(parsedUri.get(j), parsedUri

					schemaList.add(xmlSchema);

				}

				i = matcher.end();

             DBConnection dbconn = null;

             StringReader dtd = null;

             int serialNumber = -1;

             try

             {

            	 dbconn = DBConnectionPool

                 .getDBConnection("EMLVersionsTransformer.handleSingleEML200Document");

                  serialNumber = dbconn.getCheckOutSerialNumber();

                  documentWrapper.write(dbconn, eml210Content, pub, dtd,

                  logMetacat.warn("Doc "+docidWithRev+" was transformed to eml210 with new id "+newId);

                  transformLog("Doc "+docidWithRev+" was transformed to eml210 with new id "+newId);

             }