0

これは Java API を使用した Scala コードであることに注意してください。ドキュメントと例を読んだ後、ストリーミング接続から XML ドキュメントを取得する次のソリューションを思いつくことができました。

  val connection = getConnection(URL, USER, PASSWORD)
  val inputStream = connection.getInputStream()
  
  val factory = XMLInputFactory.newInstance()
  val parser = factory.createFilteredReader(factory.createXMLStreamReader(inputStream), new XMLDocFilter())

  while(parser.hasNext){
    // what to do?
  }

パーサーを反復処理する必要があることを理解しています。しかし、実際のドキュメントを抽出するにはどうすればよいでしょうか? 必要なのはドキュメント文字列だけなので、それをオフライン処理に渡すことができます。

ありがとう！

編集

私はフォローしてきました：http://www.java-tips.org/java-ee-tips/enterprise-java-beans/introducing-the-sun-java-streaming-xml-p.html

私は次のようなことを考えていました：

while(parser.hasNext) {
  println(parser.next)
}

しかし問題は、上記がブール値を返すことです。それをドキュメントにする方法はありますか？

4

1 に答える 1

1

「peak()」メソッドを使用します。私のJavaコードを参照してください。たぶん、scalaコードを変更するのは簡単です 頑張ってください

import java.io.File;
import java.io.FileInputStream;
import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;

import javax.xml.bind.JAXBException;
import javax.xml.parsers.ParserConfigurationException;
import javax.xml.stream.XMLEventReader;
import javax.xml.stream.XMLInputFactory;
import javax.xml.stream.XMLStreamException;
import javax.xml.stream.events.EndElement;
import javax.xml.stream.events.StartElement;
import javax.xml.stream.events.XMLEvent;
import javax.xml.transform.TransformerException;
import javax.xml.xpath.XPathExpressionException;

import org.xml.sax.SAXException;

public class DomParserMain {
    final static String ROOT_NODE_NAME = "data";
    final static String FILE_PATH =  "/Users/file.xml";
    public static void main(String[] args) throws ParserConfigurationException, SAXException, IOException, JAXBException, XMLStreamException, XPathExpressionException, TransformerException {
        XMLInputFactory xif = XMLInputFactory.newInstance();
        XMLEventReader  xmlr = null;

        xmlr = xif.createXMLEventReader((new FileInputStream(new File(FILE_PATH))));

        boolean inline = false;
        StringBuffer sb = new StringBuffer(1024 * 66);
        while(xmlr.hasNext()){
            XMLEvent event = xmlr.nextEvent();

            if (event.isStartElement() ){
                StartElement element = (StartElement) event;
                if( ROOT_NODE_NAME.equals( element.getName().toString().trim() ) ) {
                    inline = true;
                }
            }

            if(inline) {
                sb.append( xmlr.peek()  );
            }

            if (event.isEndElement() ){
                EndElement element = (EndElement)event ;
                if( ROOT_NODE_NAME.equals( element.getName().toString().trim() ))  {
                    inline = false;
                    System.out.println("=====");
                    System.out.println(sb.toString());
                    System.out.println("=====");
                    sb.setLength(0);
                }
            }
        } 
    }
}
于 2013-07-11T08:07:40.147 に答える