src/share/jaxws_classes/com/sun/xml/internal/fastinfoset/stax/events/StAXEventReader.java

Thu, 12 Oct 2017 19:44:07 +0800

author
aoqi
date
Thu, 12 Oct 2017 19:44:07 +0800
changeset 760
e530533619ec
parent 0
373ffda63c9a
permissions
-rw-r--r--

merge

aoqi@0 1 /*
aoqi@0 2 * Copyright (c) 2004, 2011, Oracle and/or its affiliates. All rights reserved.
aoqi@0 3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
aoqi@0 4 *
aoqi@0 5 * This code is free software; you can redistribute it and/or modify it
aoqi@0 6 * under the terms of the GNU General Public License version 2 only, as
aoqi@0 7 * published by the Free Software Foundation. Oracle designates this
aoqi@0 8 * particular file as subject to the "Classpath" exception as provided
aoqi@0 9 * by Oracle in the LICENSE file that accompanied this code.
aoqi@0 10 *
aoqi@0 11 * This code is distributed in the hope that it will be useful, but WITHOUT
aoqi@0 12 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
aoqi@0 13 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
aoqi@0 14 * version 2 for more details (a copy is included in the LICENSE file that
aoqi@0 15 * accompanied this code).
aoqi@0 16 *
aoqi@0 17 * You should have received a copy of the GNU General Public License version
aoqi@0 18 * 2 along with this work; if not, write to the Free Software Foundation,
aoqi@0 19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
aoqi@0 20 *
aoqi@0 21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
aoqi@0 22 * or visit www.oracle.com if you need additional information or have any
aoqi@0 23 * questions.
aoqi@0 24 *
aoqi@0 25 * THIS FILE WAS MODIFIED BY SUN MICROSYSTEMS, INC.
aoqi@0 26 */
aoqi@0 27
aoqi@0 28 package com.sun.xml.internal.fastinfoset.stax.events;
aoqi@0 29
aoqi@0 30 import com.sun.xml.internal.fastinfoset.stax.*;
aoqi@0 31 import java.util.NoSuchElementException;
aoqi@0 32 import javax.xml.stream.XMLInputFactory;
aoqi@0 33 import javax.xml.stream.XMLStreamException;
aoqi@0 34 import javax.xml.stream.XMLStreamReader;
aoqi@0 35 import javax.xml.stream.events.XMLEvent;
aoqi@0 36 import javax.xml.stream.util.XMLEventAllocator;
aoqi@0 37 import com.sun.xml.internal.fastinfoset.CommonResourceBundle;
aoqi@0 38
aoqi@0 39
aoqi@0 40
aoqi@0 41 public class StAXEventReader implements javax.xml.stream.XMLEventReader{
aoqi@0 42 protected XMLStreamReader _streamReader ;
aoqi@0 43 protected XMLEventAllocator _eventAllocator;
aoqi@0 44 private XMLEvent _currentEvent; //the current event
aoqi@0 45 private XMLEvent[] events = new XMLEvent[3];
aoqi@0 46 private int size = 3;
aoqi@0 47 private int currentIndex = 0;
aoqi@0 48 private boolean hasEvent = false; //true when current event exists, false initially & at end
aoqi@0 49
aoqi@0 50 //only constructor will do because we delegate everything to underlying XMLStreamReader
aoqi@0 51 public StAXEventReader(XMLStreamReader reader) throws XMLStreamException {
aoqi@0 52 _streamReader = reader ;
aoqi@0 53 _eventAllocator = (XMLEventAllocator)reader.getProperty(XMLInputFactory.ALLOCATOR);
aoqi@0 54 if(_eventAllocator == null){
aoqi@0 55 _eventAllocator = new StAXEventAllocatorBase();
aoqi@0 56 }
aoqi@0 57 //initialize
aoqi@0 58 if (_streamReader.hasNext())
aoqi@0 59 {
aoqi@0 60 _streamReader.next();
aoqi@0 61 _currentEvent =_eventAllocator.allocate(_streamReader);
aoqi@0 62 events[0] = _currentEvent;
aoqi@0 63 hasEvent = true;
aoqi@0 64 } else {
aoqi@0 65 throw new XMLStreamException(CommonResourceBundle.getInstance().getString("message.noElement"));
aoqi@0 66 }
aoqi@0 67 }
aoqi@0 68
aoqi@0 69 public boolean hasNext() {
aoqi@0 70 return hasEvent;
aoqi@0 71 }
aoqi@0 72
aoqi@0 73 public XMLEvent nextEvent() throws XMLStreamException {
aoqi@0 74 XMLEvent event = null;
aoqi@0 75 XMLEvent nextEvent = null;
aoqi@0 76 if (hasEvent)
aoqi@0 77 {
aoqi@0 78 event = events[currentIndex];
aoqi@0 79 events[currentIndex] = null;
aoqi@0 80 if (_streamReader.hasNext())
aoqi@0 81 {
aoqi@0 82 //advance and read the next
aoqi@0 83 _streamReader.next();
aoqi@0 84 nextEvent = _eventAllocator.allocate(_streamReader);
aoqi@0 85 if (++currentIndex==size)
aoqi@0 86 currentIndex = 0;
aoqi@0 87 events[currentIndex] = nextEvent;
aoqi@0 88 hasEvent = true;
aoqi@0 89 } else {
aoqi@0 90 _currentEvent = null;
aoqi@0 91 hasEvent = false;
aoqi@0 92 }
aoqi@0 93 return event;
aoqi@0 94 }
aoqi@0 95 else{
aoqi@0 96 throw new NoSuchElementException();
aoqi@0 97 }
aoqi@0 98 }
aoqi@0 99
aoqi@0 100 public void remove(){
aoqi@0 101 //stream reader is read-only.
aoqi@0 102 throw new java.lang.UnsupportedOperationException();
aoqi@0 103 }
aoqi@0 104
aoqi@0 105
aoqi@0 106 public void close() throws XMLStreamException {
aoqi@0 107 _streamReader.close();
aoqi@0 108 }
aoqi@0 109
aoqi@0 110 /** Reads the content of a text-only element. Precondition:
aoqi@0 111 * the current event is START_ELEMENT. Postcondition:
aoqi@0 112 * The current event is the corresponding END_ELEMENT.
aoqi@0 113 * @throws XMLStreamException if the current event is not a START_ELEMENT
aoqi@0 114 * or if a non text element is encountered
aoqi@0 115 */
aoqi@0 116 public String getElementText() throws XMLStreamException {
aoqi@0 117 if(!hasEvent) {
aoqi@0 118 throw new NoSuchElementException();
aoqi@0 119 }
aoqi@0 120
aoqi@0 121 if(!_currentEvent.isStartElement()) {
aoqi@0 122 StAXDocumentParser parser = (StAXDocumentParser)_streamReader;
aoqi@0 123 return parser.getElementText(true);
aoqi@0 124 } else {
aoqi@0 125 return _streamReader.getElementText();
aoqi@0 126 }
aoqi@0 127 }
aoqi@0 128
aoqi@0 129 /** Get the value of a feature/property from the underlying implementation
aoqi@0 130 * @param name The name of the property
aoqi@0 131 * @return The value of the property
aoqi@0 132 * @throws IllegalArgumentException if the property is not supported
aoqi@0 133 */
aoqi@0 134 public Object getProperty(java.lang.String name) throws java.lang.IllegalArgumentException {
aoqi@0 135 return _streamReader.getProperty(name) ;
aoqi@0 136 }
aoqi@0 137
aoqi@0 138 /** Skips any insignificant space events until a START_ELEMENT or
aoqi@0 139 * END_ELEMENT is reached. If anything other than space characters are
aoqi@0 140 * encountered, an exception is thrown. This method should
aoqi@0 141 * be used when processing element-only content because
aoqi@0 142 * the parser is not able to recognize ignorable whitespace if
aoqi@0 143 * the DTD is missing or not interpreted.
aoqi@0 144 * @throws XMLStreamException if anything other than space characters are encountered
aoqi@0 145 */
aoqi@0 146 public XMLEvent nextTag() throws XMLStreamException {
aoqi@0 147 if(!hasEvent) {
aoqi@0 148 throw new NoSuchElementException();
aoqi@0 149 }
aoqi@0 150 StAXDocumentParser parser = (StAXDocumentParser)_streamReader;
aoqi@0 151 parser.nextTag(true);
aoqi@0 152 return _eventAllocator.allocate(_streamReader);
aoqi@0 153 }
aoqi@0 154
aoqi@0 155 //XMLEventReader extends Iterator;
aoqi@0 156 public Object next() {
aoqi@0 157 try{
aoqi@0 158 return nextEvent();
aoqi@0 159 }catch(XMLStreamException streamException){
aoqi@0 160 return null;
aoqi@0 161 }
aoqi@0 162 }
aoqi@0 163
aoqi@0 164 public XMLEvent peek() throws XMLStreamException{
aoqi@0 165 if (!hasEvent)
aoqi@0 166 throw new XMLStreamException(CommonResourceBundle.getInstance().getString("message.noElement"));
aoqi@0 167 _currentEvent = events[currentIndex];
aoqi@0 168 return _currentEvent;
aoqi@0 169 }
aoqi@0 170
aoqi@0 171 public void setAllocator(XMLEventAllocator allocator) {
aoqi@0 172 if (allocator == null)
aoqi@0 173 throw new IllegalArgumentException(CommonResourceBundle.getInstance().getString("message.nullXMLEventAllocator"));
aoqi@0 174
aoqi@0 175 _eventAllocator = allocator;
aoqi@0 176 }
aoqi@0 177
aoqi@0 178
aoqi@0 179 }

mercurial