D-Net

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

public class MongoBulkWritesManager {

	private static final Log log = LogFactory.getLog(MongoBulkWritesManager.class);

		}

		log.debug("found props: " + recordProperties);

			final DBObject obj = buildDBObject(record, recordProperties, indexRecordField);

			if (log.isDebugEnabled()) {

				log.debug("Saving object" + obj);

			}

			if (((validBulkOperationList.size() % bulkSize) == 0) && !validBulkOperationList.isEmpty()) {

				validCollection.bulkWrite(validBulkOperationList, writeOptions);

				validBulkOperationList.clear();

	}

	private void discardRecord(final String record) {

		if (((discardedBulkOperationList.size() % bulkSize) == 0) && !discardedBulkOperationList.isEmpty()) {

			discardedCollection.bulkWrite(discardedBulkOperationList, writeOptions);

	private DBObject buildDBObject(final String record, final Map<String, String> recordProperties, final Map<String, List<String>> indexFieldProperties) {

		final DBObject obj = new BasicDBObject();

		if (indexFieldProperties != null)

			obj.putAll(indexFieldProperties);

		return obj;

import org.apache.commons.logging.LogFactory;

import org.xml.sax.InputSource;

/**

 * Terrible implementation of a record parser.

 * 

	@Override

	public Map<String, String> parseRecord(String record) {

		Map<String, String> props = new HashMap<String, String>();

		try {

//			DocumentBuilder builder = DocumentBuilderFactory.newInstance().newDocumentBuilder();

//			Document doc = builder.parse(new InputSource(new StringReader(record)));

			InputSource doc = new InputSource(new StringReader(record));

			props.put("originalId", xpath.evaluate("//*[local-name()='efgEntity']/*/*[local-name()='identifier']", doc));

//			String date = xpath.evaluate("//*[local-name()='dateOfCollection'][1]", doc);

import javax.xml.stream.XMLStreamException;

import javax.xml.stream.XMLStreamReader;

/**

 * This method outperforms SimpleRecordParser by a vast amount, especially since we are just getting stuff in the

 * header.

			XMLStreamReader parser = factory.createXMLStreamReader(new ByteArrayInputStream(record.getBytes()));

			HashMap<String, String> res = new HashMap<String, String>();

			Stack<String> elementStack = new Stack<String>();

			elementStack.push("/");

					final String localName = parser.getLocalName();

					elementStack.push(localName);

						parser.next();

					} else if ("identifier".equals(localName) && "efgEntity".equals(grandParent(elementStack))) {

						if (!res.containsKey("originalId")) {

//						log.info("ZZZZZZ: found identifier not at right depth " + elementStack + " grand parent " + grandParent(elementStack));

					}

						return res;

				}

			}