src/java.sql.rowset/share/classes/com/sun/rowset/internal/WebRowSetXmlReader.java
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/java.sql.rowset/share/classes/com/sun/rowset/internal/WebRowSetXmlReader.java Tue Sep 12 19:03:39 2017 +0200
@@ -0,0 +1,237 @@
+/*
+ * Copyright (c) 2003, 2010, Oracle and/or its affiliates. All rights reserved.
+ * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
+ *
+ * This code is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU General Public License version 2 only, as
+ * published by the Free Software Foundation. Oracle designates this
+ * particular file as subject to the "Classpath" exception as provided
+ * by Oracle in the LICENSE file that accompanied this code.
+ *
+ * This code is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
+ * version 2 for more details (a copy is included in the LICENSE file that
+ * accompanied this code).
+ *
+ * You should have received a copy of the GNU General Public License version
+ * 2 along with this work; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
+ * or visit www.oracle.com if you need additional information or have any
+ * questions.
+ */
+
+package com.sun.rowset.internal;
+
+import java.sql.*;
+import javax.sql.*;
+import java.io.*;
+
+import org.xml.sax.*;
+import org.xml.sax.helpers.*;
+import javax.xml.parsers.*;
+
+import com.sun.rowset.*;
+import java.text.MessageFormat;
+import javax.sql.rowset.*;
+import javax.sql.rowset.spi.*;
+
+/**
+ * An implementation of the <code>XmlReader</code> interface, which
+ * reads and parses an XML formatted <code>WebRowSet</code> object.
+ * This implementation uses an <code>org.xml.sax.Parser</code> object
+ * as its parser.
+ */
+public class WebRowSetXmlReader implements XmlReader, Serializable {
+
+
+ private JdbcRowSetResourceBundle resBundle;
+
+ public WebRowSetXmlReader(){
+ try {
+ resBundle = JdbcRowSetResourceBundle.getJdbcRowSetResourceBundle();
+ } catch(IOException ioe) {
+ throw new RuntimeException(ioe);
+ }
+ }
+
+ /**
+ * Parses the given <code>WebRowSet</code> object, getting its input from
+ * the given <code>java.io.Reader</code> object. The parser will send
+ * notifications of parse events to the rowset's
+ * <code>XmlReaderDocHandler</code>, which will build the rowset as
+ * an XML document.
+ * <P>
+ * This method is called internally by the method
+ * <code>WebRowSet.readXml</code>.
+ * <P>
+ * If a parsing error occurs, the exception thrown will include
+ * information for locating the error in the original XML document.
+ *
+ * @param caller the <code>WebRowSet</code> object to be parsed, whose
+ * <code>xmlReader</code> field must contain a reference to
+ * this <code>XmlReader</code> object
+ * @param reader the <code>java.io.Reader</code> object from which
+ * the parser will get its input
+ * @exception SQLException if a database access error occurs or
+ * this <code>WebRowSetXmlReader</code> object is not the
+ * reader for the given rowset
+ * @see XmlReaderContentHandler
+ */
+ public void readXML(WebRowSet caller, java.io.Reader reader) throws SQLException {
+ try {
+ // Crimson Parser(as in J2SE 1.4.1 is NOT able to handle
+ // Reader(s)(FileReader).
+ //
+ // But getting the file as a Stream works fine. So we are going to take
+ // the reader but send it as a InputStream to the parser. Note that this
+ // functionality needs to work against any parser
+ // Crimson(J2SE 1.4.x) / Xerces(J2SE 1.5.x).
+ InputSource is = new InputSource(reader);
+ DefaultHandler dh = new XmlErrorHandler();
+ XmlReaderContentHandler hndr = new XmlReaderContentHandler((RowSet)caller);
+ SAXParserFactory factory = SAXParserFactory.newInstance();
+ factory.setNamespaceAware(true);
+ factory.setValidating(true);
+ SAXParser parser = factory.newSAXParser() ;
+
+ parser.setProperty(
+ "http://java.sun.com/xml/jaxp/properties/schemaLanguage", "http://www.w3.org/2001/XMLSchema");
+
+ XMLReader reader1 = parser.getXMLReader() ;
+ reader1.setEntityResolver(new XmlResolver());
+ reader1.setContentHandler(hndr);
+
+ reader1.setErrorHandler(dh);
+
+ reader1.parse(is);
+
+ } catch (SAXParseException err) {
+ System.out.println (MessageFormat.format(resBundle.handleGetObject("wrsxmlreader.parseerr").toString(), new Object[]{ err.getMessage (), err.getLineNumber(), err.getSystemId()}));
+ err.printStackTrace();
+ throw new SQLException(err.getMessage());
+
+ } catch (SAXException e) {
+ Exception x = e;
+ if (e.getException () != null)
+ x = e.getException();
+ x.printStackTrace ();
+ throw new SQLException(x.getMessage());
+
+ }
+
+ // Will be here if trying to write beyond the RowSet limits
+
+ catch (ArrayIndexOutOfBoundsException aie) {
+ throw new SQLException(resBundle.handleGetObject("wrsxmlreader.invalidcp").toString());
+ }
+ catch (Throwable e) {
+ throw new SQLException(MessageFormat.format(resBundle.handleGetObject("wrsxmlreader.readxml").toString() , e.getMessage()));
+ }
+
+ }
+
+
+ /**
+ * Parses the given <code>WebRowSet</code> object, getting its input from
+ * the given <code>java.io.InputStream</code> object. The parser will send
+ * notifications of parse events to the rowset's
+ * <code>XmlReaderDocHandler</code>, which will build the rowset as
+ * an XML document.
+ * <P>
+ * Using streams is a much faster way than using <code>java.io.Reader</code>
+ * <P>
+ * This method is called internally by the method
+ * <code>WebRowSet.readXml</code>.
+ * <P>
+ * If a parsing error occurs, the exception thrown will include
+ * information for locating the error in the original XML document.
+ *
+ * @param caller the <code>WebRowSet</code> object to be parsed, whose
+ * <code>xmlReader</code> field must contain a reference to
+ * this <code>XmlReader</code> object
+ * @param iStream the <code>java.io.InputStream</code> object from which
+ * the parser will get its input
+ * @throws SQLException if a database access error occurs or
+ * this <code>WebRowSetXmlReader</code> object is not the
+ * reader for the given rowset
+ * @see XmlReaderContentHandler
+ */
+ public void readXML(WebRowSet caller, java.io.InputStream iStream) throws SQLException {
+ try {
+ InputSource is = new InputSource(iStream);
+ DefaultHandler dh = new XmlErrorHandler();
+
+ XmlReaderContentHandler hndr = new XmlReaderContentHandler((RowSet)caller);
+ SAXParserFactory factory = SAXParserFactory.newInstance();
+ factory.setNamespaceAware(true);
+ factory.setValidating(true);
+
+ SAXParser parser = factory.newSAXParser() ;
+
+ parser.setProperty("http://java.sun.com/xml/jaxp/properties/schemaLanguage",
+ "http://www.w3.org/2001/XMLSchema");
+
+ XMLReader reader1 = parser.getXMLReader() ;
+ reader1.setEntityResolver(new XmlResolver());
+ reader1.setContentHandler(hndr);
+
+ reader1.setErrorHandler(dh);
+
+ reader1.parse(is);
+
+ } catch (SAXParseException err) {
+ System.out.println (MessageFormat.format(resBundle.handleGetObject("wrsxmlreader.parseerr").toString(), new Object[]{err.getLineNumber(), err.getSystemId() }));
+ System.out.println(" " + err.getMessage ());
+ err.printStackTrace();
+ throw new SQLException(err.getMessage());
+
+ } catch (SAXException e) {
+ Exception x = e;
+ if (e.getException () != null)
+ x = e.getException();
+ x.printStackTrace ();
+ throw new SQLException(x.getMessage());
+
+ }
+
+ // Will be here if trying to write beyond the RowSet limits
+
+ catch (ArrayIndexOutOfBoundsException aie) {
+ throw new SQLException(resBundle.handleGetObject("wrsxmlreader.invalidcp").toString());
+ }
+
+ catch (Throwable e) {
+ throw new SQLException(MessageFormat.format(resBundle.handleGetObject("wrsxmlreader.readxml").toString() , e.getMessage()));
+ }
+ }
+
+ /**
+ * For code coverage purposes only right now
+ *
+ */
+
+ public void readData(RowSetInternal caller) {
+ }
+
+ /**
+ * This method re populates the resBundle
+ * during the deserialization process
+ *
+ */
+ private void readObject(ObjectInputStream ois) throws IOException, ClassNotFoundException {
+ // Default state initialization happens here
+ ois.defaultReadObject();
+ // Initialization of transient Res Bundle happens here .
+ try {
+ resBundle = JdbcRowSetResourceBundle.getJdbcRowSetResourceBundle();
+ } catch(IOException ioe) {
+ throw new RuntimeException(ioe);
+ }
+
+ }
+
+ static final long serialVersionUID = -9127058392819008014L;
+}