Author: veithen
Date: Sun Mar 15 17:35:09 2009
New Revision: 754700
URL: http://svn.apache.org/viewvc?rev=754700&view=rev
Log:
Merged the code in OMStAXWrapper and DOMStAXWrapper into a single base class.
Rationale: There is nothing implementation (LLOM/DOOM) specific in this code
and it doesn't make sense to maintain two separate copies of it (with over 1500
lines of code).
Note that the only remaining differences between these two classes were:
* Code handling OMSourcedElements (which don't exist in DOOM).
* Code related to WSCOMMONS-220 (StAX getProperty(String) support and keep
track of parser closure state).
* Code related to WSCOMMONS-280 (Control string interning of
OMStAXWrapper.getNamespaceURI()).
* Code related to WSCOMMONS-344 (OMStaXWrapper Does Not Support Optimized
OMText as an XOP:Include).
* Some additional null checks and logging.
All this should also be available to DOOM.
This change has been tested successfully with Axis2 trunk and Rampart trunk.
Added:
webservices/commons/trunk/modules/axiom/modules/axiom-api/src/main/java/org/apache/axiom/om/impl/OMStAXWrapper.java
(contents, props changed)
- copied, changed from r754659,
webservices/commons/trunk/modules/axiom/modules/axiom-impl/src/main/java/org/apache/axiom/om/impl/llom/OMStAXWrapper.java
Modified:
webservices/commons/trunk/modules/axiom/modules/axiom-dom/src/main/java/org/apache/axiom/om/impl/dom/DOMStAXWrapper.java
webservices/commons/trunk/modules/axiom/modules/axiom-impl/src/main/java/org/apache/axiom/om/impl/llom/OMStAXWrapper.java
Copied:
webservices/commons/trunk/modules/axiom/modules/axiom-api/src/main/java/org/apache/axiom/om/impl/OMStAXWrapper.java
(from r754659,
webservices/commons/trunk/modules/axiom/modules/axiom-impl/src/main/java/org/apache/axiom/om/impl/llom/OMStAXWrapper.java)
URL:
http://svn.apache.org/viewvc/webservices/commons/trunk/modules/axiom/modules/axiom-api/src/main/java/org/apache/axiom/om/impl/OMStAXWrapper.java?p2=webservices/commons/trunk/modules/axiom/modules/axiom-api/src/main/java/org/apache/axiom/om/impl/OMStAXWrapper.java&p1=webservices/commons/trunk/modules/axiom/modules/axiom-impl/src/main/java/org/apache/axiom/om/impl/llom/OMStAXWrapper.java&r1=754659&r2=754700&rev=754700&view=diff
==============================================================================
---
webservices/commons/trunk/modules/axiom/modules/axiom-impl/src/main/java/org/apache/axiom/om/impl/llom/OMStAXWrapper.java
(original)
+++
webservices/commons/trunk/modules/axiom/modules/axiom-api/src/main/java/org/apache/axiom/om/impl/OMStAXWrapper.java
Sun Mar 15 17:35:09 2009
@@ -17,7 +17,7 @@
* under the License.
*/
-package org.apache.axiom.om.impl.llom;
+package org.apache.axiom.om.impl;
import java.util.HashMap;
import java.util.Iterator;
Propchange:
webservices/commons/trunk/modules/axiom/modules/axiom-api/src/main/java/org/apache/axiom/om/impl/OMStAXWrapper.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
webservices/commons/trunk/modules/axiom/modules/axiom-api/src/main/java/org/apache/axiom/om/impl/OMStAXWrapper.java
------------------------------------------------------------------------------
svn:mergeinfo =
Modified:
webservices/commons/trunk/modules/axiom/modules/axiom-dom/src/main/java/org/apache/axiom/om/impl/dom/DOMStAXWrapper.java
URL:
http://svn.apache.org/viewvc/webservices/commons/trunk/modules/axiom/modules/axiom-dom/src/main/java/org/apache/axiom/om/impl/dom/DOMStAXWrapper.java?rev=754700&r1=754699&r2=754700&view=diff
==============================================================================
---
webservices/commons/trunk/modules/axiom/modules/axiom-dom/src/main/java/org/apache/axiom/om/impl/dom/DOMStAXWrapper.java
(original)
+++
webservices/commons/trunk/modules/axiom/modules/axiom-dom/src/main/java/org/apache/axiom/om/impl/dom/DOMStAXWrapper.java
Sun Mar 15 17:35:09 2009
@@ -19,139 +19,14 @@
package org.apache.axiom.om.impl.dom;
-import org.apache.axiom.om.OMAttachmentAccessor;
-import org.apache.axiom.om.OMAttribute;
-import org.apache.axiom.om.OMComment;
-import org.apache.axiom.om.OMConstants;
-import org.apache.axiom.om.OMContainer;
-import org.apache.axiom.om.OMDocument;
import org.apache.axiom.om.OMElement;
-import org.apache.axiom.om.OMException;
-import org.apache.axiom.om.OMNamespace;
-import org.apache.axiom.om.OMNode;
-import org.apache.axiom.om.OMText;
import org.apache.axiom.om.OMXMLParserWrapper;
-import org.apache.axiom.om.OMXMLStreamReader;
-import org.apache.axiom.om.impl.EmptyOMLocation;
-import org.apache.axiom.om.impl.OMNavigator;
-import org.apache.axiom.om.impl.builder.StAXBuilder;
-import org.apache.axiom.om.impl.exception.OMStreamingException;
-import org.apache.axiom.om.impl.util.NamespaceContextImpl;
-
-import javax.activation.DataHandler;
-import javax.xml.namespace.NamespaceContext;
-import javax.xml.namespace.QName;
-import javax.xml.stream.Location;
-import javax.xml.stream.XMLStreamConstants;
-import javax.xml.stream.XMLStreamException;
-import javax.xml.stream.XMLStreamReader;
-
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.LinkedHashMap;
-import java.util.Map;
-import java.util.Stack;
+import org.apache.axiom.om.impl.OMStAXWrapper;
/**
- * This is exactly the same as org.apache.axiom.om.impl.llom.OMStAXWrapper.
BUT this uses the
- * org.apache.axis2.om.impl.dom.DOMNavigator.
- * <p/>
- * Note - This class also implements the streaming constants interface to get
access to the StAX
- * constants.
+ * Empty subclass of {...@link OMStAXWrapper} to keep compatibility with
existing code.
*/
-public class DOMStAXWrapper implements OMXMLStreamReader, XMLStreamConstants {
- /** Field navigator */
- private OMNavigator navigator;
-
- /** Field builder */
- private OMXMLParserWrapper builder;
-
- /** Field parser */
- private XMLStreamReader parser;
-
- /** Field rootNode */
- private OMNode rootNode;
-
- /** Field isFirst */
- private boolean isFirst = true;
-
- // Navigable means the output should be taken from the navigator.
- // As soon as the navigator returns a null navigable will be reset
- // to false and the subsequent events will be taken from the builder
- // or the parser directly.
-
- /** Field NAVIGABLE */
- private static final short NAVIGABLE = 0;
- private static final short SWITCH_AT_NEXT = 1;
- private static final short COMPLETED = 2;
- private static final short SWITCHED = 3;
- private static final short DOCUMENT_COMPLETE = 4;
-
- /** Field state */
- private short state;
-
- /** Field currentEvent Default set to START_DOCUMENT */
- private int currentEvent = START_DOCUMENT;
-
- // SwitchingAllowed is set to false by default.
- // This means that unless the user explicitly states
- // that he wants things not to be cached, everything will
- // be cached.
-
- /** Field switchingAllowed */
- boolean switchingAllowed = false;
-
- /** Field elementStack */
- private Stack elementStack = new Stack();
-
- // keeps the next event. The parser actually keeps one step ahead to
- // detect the end of navigation. (at the end of the stream the navigator
- // returns a null
-
- /** Field nextNode */
- private OMNode nextNode = null;
-
- // holder for the current node. Needs this to generate events from the
- // current node
-
- /** Field currentNode */
- private OMNode currentNode = null;
-
- // needs this to refer to the last known node
-
- /** Field lastNode */
- private OMNode lastNode = null;
-
- /** Track depth to ensure we stop generating events when we are done with
the root node. */
- int depth = 0;
-
- private boolean needToThrowEndDocument = false;
-
- /**
- * If true then TEXT events are constructed for the MTOM attachment
- * If false, an <xop:Include href="cid:xxxxx"/> event is constructed and
- * the consumer must call getDataHandler(cid) to access the datahandler.
- */
- private boolean inlineMTOM = true;
-
- /**
- * Method setAllowSwitching.
- *
- * @param b
- */
- public void setAllowSwitching(boolean b) {
- this.switchingAllowed = b;
- }
-
- /**
- * Method isAllowSwitching.
- *
- * @return Returns boolean.
- */
- public boolean isAllowSwitching() {
- return switchingAllowed;
- }
-
+public class DOMStAXWrapper extends OMStAXWrapper {
/**
* When constructing the OMStaxWrapper, the creator must produce the
builder (an instance of the
* OMXMLparserWrapper of the input) and the Element Node to start parsing.
The wrapper will
@@ -162,7 +37,7 @@
* @param startNode
*/
public DOMStAXWrapper(OMXMLParserWrapper builder, OMElement startNode) {
- this(builder, startNode, false);
+ super(builder, startNode);
}
/**
@@ -174,1161 +49,6 @@
*/
public DOMStAXWrapper(OMXMLParserWrapper builder, OMElement startNode,
boolean cache) {
-
- // create a navigator
- this.navigator = new OMNavigator(startNode);
- this.builder = builder;
- this.rootNode = startNode;
- if (rootNode != null && rootNode.getParent() != null &&
- rootNode.getParent() instanceof OMDocument) {
- needToThrowEndDocument = true;
- }
-
- // initiate the next and current nodes
- // Note - navigator is written in such a way that it first
- // returns the starting node at the first call to it
- currentNode = navigator.next();
- updateNextNode();
- switchingAllowed = !cache;
- }
-
- /**
- * @return Returns String.
- * @see javax.xml.stream.XMLStreamReader#getPrefix()
- */
- public String getPrefix() {
- String returnStr = null;
- if (parser != null) {
- returnStr = parser.getPrefix();
- } else {
- if ((currentEvent == START_ELEMENT)
- || (currentEvent == END_ELEMENT)) {
- OMNamespace ns = ((OMElement) lastNode).getNamespace();
- returnStr = (ns == null) ? null : ns.getPrefix();
- }
- }
- return returnStr;
- }
-
- /**
- * @return Returns String.
- * @see javax.xml.stream.XMLStreamReader#getNamespaceURI()
- */
- public String getNamespaceURI() {
- String returnStr = null;
- if (parser != null) {
- returnStr = parser.getNamespaceURI();
- } else {
- if ((currentEvent == START_ELEMENT)
- || (currentEvent == END_ELEMENT)
- || (currentEvent == NAMESPACE)) {
- OMNamespace ns = ((OMElement) lastNode).getNamespace();
- returnStr = (ns == null) ? null : ns.getNamespaceURI();
- }
- }
- return (returnStr != null) ? returnStr.intern() : null;
- }
-
- /**
- * @return Returns boolean.
- * @see javax.xml.stream.XMLStreamReader#hasName()
- */
- public boolean hasName() {
- if (parser != null) {
- return parser.hasName();
- } else {
- return ((currentEvent == START_ELEMENT)
- || (currentEvent == END_ELEMENT));
- }
- }
-
- /**
- * @return Returns String.
- * @see javax.xml.stream.XMLStreamReader#getLocalName()
- */
- public String getLocalName() {
- String returnStr = null;
- if (parser != null) {
- returnStr = parser.getLocalName();
- } else {
- if ((currentEvent == START_ELEMENT)
- || (currentEvent == END_ELEMENT)
- || (currentEvent == ENTITY_REFERENCE)) {
- returnStr = ((OMElement) lastNode).getLocalName();
- }
- }
- return returnStr;
- }
-
- /**
- * @return Returns QName.
- * @see javax.xml.stream.XMLStreamReader#getName()
- */
- public QName getName() {
- QName returnName = null;
- if (parser != null) {
- returnName = parser.getName();
- } else {
- if ((currentEvent == START_ELEMENT)
- || (currentEvent == END_ELEMENT)) {
- returnName = getQName((OMElement) lastNode);
- }
- }
- return returnName;
- }
-
- /**
- * @return Returns boolean.
- * @see javax.xml.stream.XMLStreamReader#hasText()
- */
- public boolean hasText() {
- return ((currentEvent == CHARACTERS) || (currentEvent == DTD)
- || (currentEvent == CDATA)
- || (currentEvent == ENTITY_REFERENCE)
- || (currentEvent == COMMENT) || (currentEvent == SPACE));
- }
-
- /**
- * @return Returns int.
- * @see javax.xml.stream.XMLStreamReader#getTextLength()
- */
- public int getTextLength() {
- if (parser != null) {
- return parser.getTextLength();
- } else {
- String text = getTextFromNode();
- return text == null ? 0 : text.length();
- }
- }
-
- /**
- * @return Returns int.
- * @see javax.xml.stream.XMLStreamReader#getTextStart()
- */
- public int getTextStart() {
- if (parser != null) {
- return parser.getTextStart();
- } else {
- // getTextCharacters always returns a new char array and the start
- // index is therefore always 0
- return 0;
- }
- }
-
- /**
- * @param sourceStart
- * @param target
- * @param targetStart
- * @param length
- * @return Returns int.
- * @throws XMLStreamException
- * @see javax.xml.stream.XMLStreamReader#getTextCharacters(int, char[],
int, int)
- */
- public int getTextCharacters(int sourceStart, char[] target, int
targetStart, int length)
- throws XMLStreamException {
- if (parser != null) {
- try {
- return parser.getTextCharacters(sourceStart, target,
targetStart, length);
- } catch (XMLStreamException e) {
- throw new OMStreamingException(e);
- }
- } else {
- String text = getTextFromNode();
- if (text != null) {
- int copied = Math.min(length, text.length()-sourceStart);
- text.getChars(sourceStart, sourceStart + copied, target,
targetStart);
- return copied;
- } else {
- return 0;
- }
- }
- }
-
- /**
- * @return Returns char[].
- * @see javax.xml.stream.XMLStreamReader#getTextCharacters()
- */
- public char[] getTextCharacters() {
- if (parser != null) {
- return parser.getTextCharacters();
- } else {
- String text = getTextFromNode();
- return text == null ? null : text.toCharArray();
- }
- }
-
- /**
- * @return Returns String.
- * @see javax.xml.stream.XMLStreamReader#getText()
- */
- public String getText() {
- if (parser != null) {
- return parser.getText();
- } else {
- return getTextFromNode();
- }
- }
-
- private String getTextFromNode() {
- if (hasText()) {
- OMNode node = lastNode;
- if (node instanceof OMText) {
- return ((OMText)node).getText();
- } else if (node instanceof OMComment) {
- return ((OMComment)node).getValue();
- }
- }
- return null;
- }
-
- /**
- * @return Returns int.
- * @see javax.xml.stream.XMLStreamReader#getEventType()
- */
-
- // todo this should be improved
- public int getEventType() {
- return currentEvent;
- }
-
- /**
- * @param i
- * @return Returns String.
- * @see javax.xml.stream.XMLStreamReader#getNamespaceURI
- */
- public String getNamespaceURI(int i) {
- String returnString = null;
- if (parser != null) {
- returnString = parser.getNamespaceURI(i);
- } else {
- if (isStartElement() || isEndElement()
- || (currentEvent == NAMESPACE)) {
- OMNamespace ns = (OMNamespace) getItemFromIterator(
- ((OMElement) lastNode).getAllDeclaredNamespaces(), i);
- returnString = (ns == null) ? null : ns.getNamespaceURI();
- }
- }
- return returnString;
- }
-
- /**
- * @param i
- * @return Returns String.
- * @see javax.xml.stream.XMLStreamReader#getNamespacePrefix
- */
- public String getNamespacePrefix(int i) {
- String returnString = null;
- if (parser != null) {
- returnString = parser.getNamespacePrefix(i);
- } else {
- if (isStartElement() || isEndElement()
- || (currentEvent == NAMESPACE)) {
- OMNamespace ns = (OMNamespace) getItemFromIterator(
- ((OMElement) lastNode).getAllDeclaredNamespaces(), i);
- returnString = (ns == null) ? null : ns.getPrefix();
- }
- }
- return returnString;
- }
-
- /**
- * @return Returns int.
- * @see javax.xml.stream.XMLStreamReader#getNamespaceCount()
- */
- public int getNamespaceCount() {
- int returnCount = 0;
- if (parser != null) {
- returnCount = parser.getNamespaceCount();
- } else {
- if (isStartElement() || isEndElement()
- || (currentEvent == NAMESPACE)) {
- returnCount = getCount(((OMElement) lastNode)
- .getAllDeclaredNamespaces());
- }
- }
- return returnCount;
- }
-
- /**
- * @param i
- * @return Returns boolean.
- * @see javax.xml.stream.XMLStreamReader#isAttributeSpecified
- */
- public boolean isAttributeSpecified(int i) {
- boolean returnValue = false;
- if (parser != null) {
- returnValue = parser.isAttributeSpecified(i);
- } else {
- if (isStartElement() || (currentEvent == ATTRIBUTE)) {
-
- // theres nothing to be returned here
- } else {
- throw new IllegalStateException(
- "attribute type accessed in illegal event!");
- }
- }
- return returnValue;
- }
-
- /**
- * @param i
- * @return Returns String.
- * @see javax.xml.stream.XMLStreamReader#getAttributeValue
- */
- public String getAttributeValue(int i) {
- String returnString = null;
- if (parser != null) {
- returnString = parser.getAttributeValue(i);
- } else {
- if (isStartElement() || (currentEvent == ATTRIBUTE)) {
- OMAttribute attrib = getAttribute((OMElement) lastNode, i);
- if (attrib != null) {
- returnString = attrib.getAttributeValue();
- }
- } else {
- throw new IllegalStateException(
- "attribute type accessed in illegal event!");
- }
- }
- return returnString;
- }
-
- /**
- * @param i
- * @return Returns String.
- * @see javax.xml.stream.XMLStreamReader#getAttributeType
- */
- public String getAttributeType(int i) {
- String returnString = null;
- if (parser != null) {
- returnString = parser.getAttributeType(i);
- } else {
- if (isStartElement() || (currentEvent == ATTRIBUTE)) {
- OMAttribute attrib = getAttribute((OMElement) lastNode,
i);
- if (attrib != null) {
- returnString = attrib.getAttributeType();
- }
-
- } else {
- throw new IllegalStateException(
- "attribute type accessed in illegal event!");
- }
- }
- return returnString;
- }
-
- /**
- * @param i
- * @return Returns String.
- * @see javax.xml.stream.XMLStreamReader#getAttributePrefix
- */
- public String getAttributePrefix(int i) {
- String returnString = null;
- if (parser != null) {
- returnString = parser.getAttributePrefix(i);
- } else {
- if (isStartElement() || (currentEvent == ATTRIBUTE)) {
- OMAttribute attrib = getAttribute((OMElement) lastNode, i);
- if (attrib != null) {
- OMNamespace nameSpace = attrib.getNamespace();
- if (nameSpace != null) {
- returnString = nameSpace.getPrefix();
- }
- }
- } else {
- throw new IllegalStateException(
- "attribute prefix accessed in illegal event!");
- }
- }
- return returnString;
- }
-
- /**
- * @param i
- * @return Returns String.
- * @see javax.xml.stream.XMLStreamReader#getAttributeLocalName
- */
- public String getAttributeLocalName(int i) {
- String returnString = null;
- if (parser != null) {
- returnString = parser.getAttributeLocalName(i);
- } else {
- if (isStartElement() || (currentEvent == ATTRIBUTE)) {
- OMAttribute attrib = getAttribute((OMElement) lastNode, i);
- if (attrib != null) {
- returnString = attrib.getLocalName();
- }
- } else {
- throw new IllegalStateException(
- "attribute localName accessed in illegal event!");
- }
- }
- return returnString;
- }
-
- /**
- * @param i
- * @return Returns String.
- * @see javax.xml.stream.XMLStreamReader#getAttributeNamespace
- */
- public String getAttributeNamespace(int i) {
- String returnString = null;
- if (parser != null) {
- returnString = parser.getAttributeNamespace(i);
- } else {
- if (isStartElement() || (currentEvent == ATTRIBUTE)) {
- OMAttribute attrib = getAttribute((OMElement) lastNode, i);
- if (attrib != null) {
- OMNamespace nameSpace = attrib.getNamespace();
- if (nameSpace != null) {
- returnString = nameSpace.getNamespaceURI();
- }
- }
- } else {
- throw new IllegalStateException(
- "attribute nameSpace accessed in illegal event!");
- }
- }
- return returnString;
- }
-
- /**
- * @param i
- * @return Returns QName.
- * @see javax.xml.stream.XMLStreamReader#getAttributeName
- */
- public QName getAttributeName(int i) {
- QName returnQName = null;
- if (parser != null) {
- returnQName = parser.getAttributeName(i);
- } else {
- if (isStartElement() || (currentEvent == ATTRIBUTE)) {
- returnQName = getAttribute((OMElement) lastNode, i).getQName();
- } else {
- throw new IllegalStateException(
- "attribute count accessed in illegal event!");
- }
- }
- return returnQName;
- }
-
- /**
- * @return Returns int.
- * @see javax.xml.stream.XMLStreamReader#getAttributeCount
- */
- public int getAttributeCount() {
- int returnCount = 0;
- if (parser != null) {
- returnCount = parser.getAttributeCount();
- } else {
- if (isStartElement() || (currentEvent == ATTRIBUTE)) {
- OMElement elt = (OMElement) lastNode;
- returnCount = getCount(elt.getAllAttributes());
- } else {
- throw new IllegalStateException(
- "attribute count accessed in illegal event (" +
- currentEvent + ")!");
- }
- }
- return returnCount;
- }
-
- // todo
-
- /**
- * Method getAttributeValue.
- *
- * @param s
- * @param s1
- * @return Returns String.
- */
- public String getAttributeValue(String s, String s1) {
- String returnString = null;
- if (parser != null) {
- returnString = parser.getAttributeValue(s, s1);
- } else {
- if (isStartElement() || (currentEvent == ATTRIBUTE)) {
- QName qname = new QName(s, s1);
- OMAttribute attrib = ((OMElement)
lastNode).getAttribute(qname);
- if (attrib != null) {
- returnString = attrib.getAttributeValue();
- }
- } else {
- throw new IllegalStateException(
- "attribute type accessed in illegal event!");
- }
- }
- return returnString;
- }
-
- /**
- * Method isWhiteSpace.
- *
- * @return Returns boolean.
- */
- public boolean isWhiteSpace() {
- boolean b;
- if (parser != null) {
- b = parser.isWhiteSpace();
- } else {
- b = (currentEvent == SPACE);
- }
- return b;
- }
-
- /**
- * Method isCharacters.
- *
- * @return Returns boolean.
- */
- public boolean isCharacters() {
- boolean b;
- if (parser != null) {
- b = parser.isCharacters();
- } else {
- b = (currentEvent == CHARACTERS);
- }
- return b;
- }
-
- /**
- * Method isEndElement.
- *
- * @return Returns boolean.
- */
- public boolean isEndElement() {
- boolean b;
- if (parser != null) {
- b = parser.isEndElement();
- } else {
- b = (currentEvent == END_ELEMENT);
- }
- return b;
- }
-
- /**
- * @param i
- * @param s
- * @param s1
- * @throws XMLStreamException
- * @see javax.xml.stream.XMLStreamReader#require(int, String, String)
- */
- public void require(int i, String s, String s1) throws XMLStreamException {
- throw new XMLStreamException();
- }
-
- /**
- * Method isStartElement.
- *
- * @return Returns boolean.
- */
- public boolean isStartElement() {
- boolean b;
- if (parser != null) {
- b = parser.isStartElement();
- } else {
- b = (currentEvent == START_ELEMENT);
- }
- return b;
- }
-
- /**
- * Method getNamespaceURI.
- *
- * @param prefix
- * @return Returns String.
- */
- public String getNamespaceURI(String prefix) {
- String returnString = null;
- if (parser != null) {
- returnString = parser.getNamespaceURI(prefix);
- } else {
- if (isStartElement() || isEndElement()
- || (currentEvent == NAMESPACE)) {
-
- // Nothing to do here! How to get the namespacace references
- }
- }
- return returnString;
- }
-
- /**
- * Method close.
- *
- * @throws XMLStreamException
- */
- public void close() throws XMLStreamException {
-
- // this doesnot mean anything with respect to the OM
- if (parser != null) {
- parser.close();
- }
- }
-
- /**
- * Method hasNext.
- *
- * @return Returns boolean.
- * @throws XMLStreamException
- */
- public boolean hasNext() throws XMLStreamException {
- if (needToThrowEndDocument) {
- return !(state == DOCUMENT_COMPLETE);
- } else {
- return (state != COMPLETED && currentEvent != END_DOCUMENT);
- }
- }
-
- /**
- * Returns the next tag.
- *
- * @return Returns int.
- * @throws org.apache.axiom.om.impl.exception.OMStreamingException
- *
- * @throws XMLStreamException
- */
- public int nextTag() throws XMLStreamException {
- int eventType = next();
- while ((eventType == XMLStreamConstants.CHARACTERS && isWhiteSpace())
// skip whitespace
- || (eventType == XMLStreamConstants.CDATA && isWhiteSpace())
// skip whitespace
- || eventType == XMLStreamConstants.SPACE
- || eventType == XMLStreamConstants.PROCESSING_INSTRUCTION
- || eventType == XMLStreamConstants.COMMENT) {
- eventType = next();
- }
- if (eventType != XMLStreamConstants.START_ELEMENT &&
- eventType != XMLStreamConstants.END_ELEMENT) {
- throw new XMLStreamException("expected start or end tag",
getLocation());
- }
- return eventType;
- }
-
- /**
- * @return Returns String.
- * @throws XMLStreamException
- * @see javax.xml.stream.XMLStreamReader#getElementText()
- */
- public String getElementText() throws XMLStreamException {
- if (parser != null) {
- try {
- return parser.getElementText();
- } catch (XMLStreamException e) {
- throw new OMStreamingException(e);
- }
- } else {
- ///////////////////////////////////////////////////////
- //// Code block directly from the API documentation ///
- if (getEventType() != XMLStreamConstants.START_ELEMENT) {
- throw new XMLStreamException(
- "parser must be on START_ELEMENT to read next text",
getLocation());
- }
- int eventType = next();
- StringBuffer content = new StringBuffer();
- while (eventType != XMLStreamConstants.END_ELEMENT) {
- if (eventType == XMLStreamConstants.CHARACTERS
- || eventType == XMLStreamConstants.CDATA
- || eventType == XMLStreamConstants.SPACE
- || eventType == XMLStreamConstants.ENTITY_REFERENCE) {
- content.append(getText());
- } else if (eventType ==
XMLStreamConstants.PROCESSING_INSTRUCTION
- || eventType == XMLStreamConstants.COMMENT) {
- // skipping
- } else if (eventType == XMLStreamConstants.END_DOCUMENT) {
- throw new XMLStreamException(
- "unexpected end of document when reading element
text content");
- } else if (eventType == XMLStreamConstants.START_ELEMENT) {
- throw new XMLStreamException(
- "element text content may not contain
START_ELEMENT");
- } else {
- throw new XMLStreamException(
- "Unexpected event type " + eventType,
getLocation());
- }
- eventType = next();
- }
- return content.toString();
- ///////////////////////////////////////////////////////////////
- }
- }
-
- /**
- * Method next.
- *
- * @return Returns int.
- * @throws XMLStreamException
- */
- public int next() throws XMLStreamException {
- switch (state) {
- case DOCUMENT_COMPLETE:
- throw new XMLStreamException("End of the document reached");
- case COMPLETED:
- state = DOCUMENT_COMPLETE;
- currentEvent = END_DOCUMENT;
- break;
- case SWITCH_AT_NEXT:
- state = SWITCHED;
-
- // load the parser
- try {
- parser = (XMLStreamReader) builder.getParser();
- } catch (Exception e) {
- throw new XMLStreamException("problem accessing the
parser", e);
- }
-
- if ((currentEvent == START_DOCUMENT)
- && (currentEvent == parser.getEventType())) {
- currentEvent = parser.next();
- } else {
- currentEvent = parser.getEventType();
- }
- updateCompleteStatus();
- break;
- case NAVIGABLE:
- currentEvent = generateEvents(currentNode);
- updateCompleteStatus();
- updateLastNode();
- break;
- case SWITCHED:
- currentEvent = parser.next();
- updateCompleteStatus();
- break;
- default:
- throw new OMStreamingException("unsuppported state!");
- }
- return currentEvent;
- }
-
- /**
- * Method getProperty.
- *
- * @param s
- * @return Returns Object.
- * @throws IllegalArgumentException
- */
- public Object getProperty(String s) throws IllegalArgumentException {
- if (OMConstants.IS_DATA_HANDLERS_AWARE.equals(s)) {
- return Boolean.TRUE;
- }
- if (OMConstants.IS_BINARY.equals(s)) {
- if (lastNode instanceof OMText) {
- OMText text = (OMText) lastNode;
- return new Boolean(text.isBinary());
- }
- return Boolean.FALSE;
- } else if (OMConstants.DATA_HANDLER.equals(s)) {
- if (lastNode instanceof OMText) {
- OMText text = (OMText) lastNode;
- if (text.isBinary())
- return text.getDataHandler();
- }
- }
- // Per spec, throw IllegalArgumentException
- if (s == null) {
- throw new IllegalArgumentException();
- }
- if (parser != null) {
- return parser.getProperty(s);
- }
- // Delegate to the builder's parser.
- if (builder != null && builder instanceof StAXBuilder) {
- StAXBuilder staxBuilder = (StAXBuilder) builder;
- if (!staxBuilder.isClosed()) {
- // If the parser was closed by something other
- // than the builder, an IllegalStateException is
- // thrown. For now, return null as this is unexpected
- // by the caller.
- try {
- return ((StAXBuilder) builder).getReaderProperty(s);
- } catch (IllegalStateException ise) {
- return null;
- }
- }
- }
- return null;
- }
-
- /**
- * This is a very important method. It keeps the navigator one step ahead
and pushes it one
- * event ahead. If the nextNode is null then navigable is set to false. At
the same time the
- * parser and builder are set up for the upcoming event generation.
- *
- * @throws XMLStreamException
- */
- private void updateLastNode() throws XMLStreamException {
- lastNode = currentNode;
- currentNode = nextNode;
- try {
- updateNextNode();
- } catch (Exception e) {
- throw new XMLStreamException(e);
- }
- }
-
- /** Method updateNextNode. */
- private void updateNextNode() {
- if (navigator.isNavigable()) {
- nextNode = navigator.next();
- } else {
- if (!switchingAllowed) {
- if (navigator.isCompleted()) {
- nextNode = null;
-
- } else {
- builder.next();
- navigator.step();
- nextNode = navigator.next();
- }
- } else {
-
- // reset caching (the default is ON so it was not needed in the
- // earlier case!
- builder.setCache(false);
- state = SWITCH_AT_NEXT;
- }
- }
- }
-
- /** Method updateCompleteStatus. */
- private void updateCompleteStatus() {
- if (state == NAVIGABLE) {
- if (rootNode == currentNode) {
- if (isFirst) {
- isFirst = false;
- } else {
- state = COMPLETED;
- }
- }
- } else {
- if (state == SWITCHED) {
- //this is a potential place for bugs
- //we have to test if the root node of this parser
- //has the same name for this test
- if (currentEvent == START_ELEMENT &&
-
(parser.getLocalName().equals(((OMElement)rootNode).getLocalName()))) {
- ++depth;
- } else if (currentEvent == END_ELEMENT &&
-
(parser.getLocalName().equals(((OMElement)rootNode).getLocalName())) ) {
- --depth;
- if (depth < 0) {
- state = COMPLETED;
- }
- }
- }
- state = (currentEvent == END_DOCUMENT) ? DOCUMENT_COMPLETE : state;
- }
- }
-
- /**
- * Method getNamespaceContext.
- *
- * @return Returns NamespaceContext.
- */
- public NamespaceContext getNamespaceContext() {
- if (state==SWITCHED){
- return parser.getNamespaceContext();
- }
- return new NamespaceContextImpl(getAllNamespaces(lastNode));
- }
-
- /**
- * Method getEncoding.
- *
- * @return Returns String.
- */
- public String getEncoding() {
- return null;
- }
-
- /**
- * Method getLocation.
- *
- * @return Returns Location.
- */
- public Location getLocation() {
- return new EmptyOMLocation();
- }
-
- /**
- * Method getVersion.
- *
- * @return Returns String.
- */
- public String getVersion() {
- return "1.0"; // todo put the constant
- }
-
- /**
- * Method isStandalone.
- *
- * @return Returns boolean.
- */
- public boolean isStandalone() {
- return true;
- }
-
- /**
- * Method standaloneSet.
- *
- * @return Returns boolean.
- */
- public boolean standaloneSet() {
- return false;
- }
-
- /**
- * Method getCharacterEncodingScheme.
- *
- * @return Returns String.
- */
- public String getCharacterEncodingScheme() {
- return "utf-8";
- }
-
- /**
- * Method getPITarget.
- *
- * @return Returns String.
- */
- public String getPITarget() {
- throw new UnsupportedOperationException();
- }
-
- /**
- * Method getPIData.
- *
- * @return Returns String.
- */
- public String getPIData() {
- throw new UnsupportedOperationException();
- }
-
- /*
- *
- * ################################################################
- * Generator methods for the OMNodes returned by the navigator
- * ################################################################
- *
- */
-
- /**
- * Method generateEvents.
- *
- * @param node
- * @return Returns int.
- */
- private int generateEvents(OMNode node) {
- int returnEvent;
- int nodeType = node.getType();
- switch (nodeType) {
- case OMNode.ELEMENT_NODE:
- OMElement element = (OMElement) node;
- returnEvent = generateElementEvents(element);
- break;
- case OMNode.TEXT_NODE:
- case OMNode.SPACE_NODE:
- returnEvent = generateTextEvents();
- break;
- case OMNode.COMMENT_NODE:
- returnEvent = generateCommentEvents();
- break;
- case OMNode.CDATA_SECTION_NODE:
- returnEvent = generateCdataEvents();
- break;
- default :
- throw new OMStreamingException("Encountered node with unknown
node type "
- + nodeType);
- }
- return returnEvent;
- }
-
- /**
- * Method generateElementEvents.
- *
- * @param elt
- * @return Returns int.
- */
- private int generateElementEvents(OMElement elt) {
- int returnValue = START_ELEMENT;
- if (!elementStack.isEmpty() && elementStack.peek().equals(elt)) {
- returnValue = END_ELEMENT;
- elementStack.pop();
- } else {
- elementStack.push(elt);
- }
- return returnValue;
- }
-
- /**
- * Method generateTextEvents.
- *
- * @return Returns int.
- * @noinspection SameReturnValue
- */
- private int generateTextEvents() {
- return CHARACTERS;
- }
-
- /**
- * Method generateCommentEvents.
- *
- * @return Returns int.
- * @noinspection SameReturnValue
- */
- private int generateCommentEvents() {
- return COMMENT;
- }
-
- /**
- * Method generateCdataEvents.
- *
- * @return Returns int.
- */
- private int generateCdataEvents() {
- return CDATA;
- }
-
- /*
- * ####################################################################
- * Other helper methods
- * ####################################################################
- */
-
- /**
- * helper method getCount.
- *
- * @param it
- * @return Returns int.
- */
- private int getCount(Iterator it) {
- int count = 0;
- if (it != null) {
- while (it.hasNext()) {
- it.next();
- count++;
- }
- }
- return count;
- }
-
- /**
- * Helper method getItemFromIterator.
- *
- * @param it
- * @param index
- * @return Returns Object.
- */
- private Object getItemFromIterator(Iterator it, int index) {
- int count = 0;
- Object returnObject = null;
- boolean found = false;
- if (it != null) {
- while (it.hasNext()) {
- returnObject = it.next();
- if (index == count++) {
- found = true;
- break;
- }
- }
- }
- if (found) {
- return returnObject;
- } else {
- return null;
- }
- }
-
- /**
- * Helper method getQName.
- *
- * @param element
- * @return Returns QName.
- */
- private QName getQName(OMElement element) {
- QName returnName;
- OMNamespace ns = element.getNamespace();
- String localPart = element.getLocalName();
- if (ns != null) {
- String prefix = ns.getPrefix();
- String uri = ns.getNamespaceURI();
- if ((prefix == null) || prefix.equals("")) {
- returnName = new QName(uri, localPart);
- } else {
- returnName = new QName(uri, localPart, prefix);
- }
- } else {
- returnName = new QName(localPart);
- }
- return returnName;
- }
-
- /**
- * @param elt
- * @param index
- * @return Returns OMAttribute.
- */
- private OMAttribute getAttribute(OMElement elt, int index) {
- OMAttribute returnAttrib = null;
- if (elt != null) {
- returnAttrib = (OMAttribute) getItemFromIterator(
- elt.getAllAttributes(), index);
- }
- return returnAttrib;
- }
-
- public void setParser(XMLStreamReader parser) {
- this.parser = parser;
- }
-
- private Map getAllNamespaces(OMNode contextNode) {
- if (!(contextNode instanceof OMContainer &&
- contextNode instanceof OMElement)) {
- return new HashMap();
- }
- Map nsMap = new LinkedHashMap();
- for (OMContainer context = (OMContainer) contextNode;
- context != null && !(context instanceof OMDocument);
- context = ((OMElement) context).getParent()) {
- OMElement element = (OMElement) context;
- Iterator i = element.getAllDeclaredNamespaces();
- while (i != null && i.hasNext()) {
- addNamespaceToMap((OMNamespace) i.next(), nsMap);
- }
- if (element.getNamespace() != null) {
- addNamespaceToMap(element.getNamespace(), nsMap);
- }
- for (Iterator iter = element.getAllAttributes();
- iter != null && iter.hasNext();) {
- OMAttribute attr = (OMAttribute) iter.next();
- if (attr.getNamespace() != null) {
- addNamespaceToMap(attr.getNamespace(), nsMap);
- }
- }
- }
- return nsMap;
- }
-
- private void addNamespaceToMap(OMNamespace ns, Map map) {
- if (map.get(ns.getPrefix()) == null) {
- map.put(ns.getPrefix(), ns.getNamespaceURI());
- }
- }
-
- public DataHandler getDataHandler(String blobcid) {
- DataHandler dh = null;
- if (builder != null &&
- builder instanceof OMAttachmentAccessor) {
- dh = ((OMAttachmentAccessor) builder).getDataHandler(blobcid);
- }
- return dh;
- }
-
- public boolean isInlineMTOM() {
- return inlineMTOM;
-
- }
-
- public void setInlineMTOM(boolean value) {
- if (value == true) {
- throw new OMException("setInlineMTOM(true) is not supported");
- }
+ super(builder, startNode, cache);
}
}
