Reading mutilple element types with StaxEventItemReader

[fabianosuet]

Dear Friends,

I need to read multiple types of elements from XML input and bind to objects. I believe that is possible using StaxEventItemReader, but i don't know how.

If it's not possible, please, tell me how can I do that using other ItemReader? Or if necessary, suggestions of custom XMLItemReader implementations.

Thanks from Brazil.

Fabiano

[arno]

You need to configure your StaxEventItemReader and provide it with an Spring OXM Unmarshaller. The latter will convert XML fragments into domain objects. This is explained here. Note you can use any marshalling library supported by Spring OXM (XStream, JAXB2, etc.).

[fabianosuet]

Thank you for reply!

I undestand you, but the configuration allows only one fragmentRootElementName. Because of that, i can't map other element type at the same reader.

I have some Spring Batch samples using StaxEventItemReader, but in everyone, the author didn't use multiple input type.

[mzehnder]

I had the same problem and came up with the following solution:

package x.y.z;

import java.util.List;

import javax.xml.namespace.QName;
import javax.xml.stream.XMLEventReader;
import javax.xml.stream.XMLStreamException;
import javax.xml.stream.events.StartElement;

import org.apache.commons.lang.Validate;
import org.springframework.batch.item.xml.StaxEventItemReader;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.dao.DataAccessResourceFailureException;

/**
 * An enhanced <code>StaxEventItemReader</code> to handle multiple node element
 * names that need to be extracted.
 * 
 * @author mazehnder
 */
public class MultiFragmentStaxEventItemReader<T> extends StaxEventItemReader<T>
    implements InitializingBean {

  private List<String> fragmentRootElementNames;
  
  public void setFragmentRootElementNames(List<String> fragmentRootElementNames) {
    if (fragmentRootElementNames == null || fragmentRootElementNames.isEmpty()) {
      throw new IllegalArgumentException("At least one root element name must be provided");
    }
    // to satisfy super class's afterPropertiesSet
    super.setFragmentRootElementName(fragmentRootElementNames.get(0));
    this.fragmentRootElementNames = fragmentRootElementNames;
  }
  
  @Override
  protected boolean moveCursorToNextFragment(XMLEventReader reader) {
    try {
      while (true) {
        while (reader.peek() != null && !reader.peek().isStartElement()) {
          reader.nextEvent();
        }
        if (reader.peek() == null) {
          return false;
        }
        QName startElementName = ((StartElement) reader.peek()).getName();
        String elementName = startElementName.getLocalPart();
        if (fragmentRootElementNames.contains(elementName)) {
          return true;
        } else {
          reader.nextEvent();
        }
      }
    } catch (XMLStreamException e) {
      throw new DataAccessResourceFailureException("Error while reading from event reader", e);
    }
  }
  
  @Override
  public void afterPropertiesSet() throws Exception {
    super.afterPropertiesSet();
    Validate.notNull(fragmentRootElementNames, "Property fragmentRootElementNames must not be null");
    Validate.notEmpty(fragmentRootElementNames, "Property fragmentRootElementNames must not be empty");
  }
}

[fabianosuet]

Okay! Thank you very much!

I'm going to implement some tests!!!

[thomasvst]

Pay attention that the implementation of MultiFragmentStaxEventItemReader does not support restart. jumpToItem is not overridden and the implementation provided by StaxEventItemReader is based on the first fragmentRootElementName.