XmlReader interface, which
+ * reads and parses an XML formatted WebRowSet object.
+ * This implementation uses an org.xml.sax.Parser 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 WebRowSet object, getting its input from
+ * the given java.io.Reader object. The parser will send
+ * notifications of parse events to the rowset's
+ * XmlReaderDocHandler, which will build the rowset as
+ * an XML document.
+ *
+ * This method is called internally by the method
+ * WebRowSet.readXml.
+ *
+ * If a parsing error occurs, the exception thrown will include
+ * information for locating the error in the original XML document.
+ *
+ * @param caller the WebRowSet object to be parsed, whose
+ * xmlReader field must contain a reference to
+ * this XmlReader object
+ * @param reader the java.io.Reader object from which
+ * the parser will get its input
+ * @exception SQLException if a database access error occurs or
+ * this WebRowSetXmlReader 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 WebRowSet object, getting its input from
+ * the given java.io.InputStream object. The parser will send
+ * notifications of parse events to the rowset's
+ * XmlReaderDocHandler, which will build the rowset as
+ * an XML document.
+ *
+ * Using streams is a much faster way than using java.io.Reader
+ *
+ * This method is called internally by the method
+ * WebRowSet.readXml.
+ *
+ * If a parsing error occurs, the exception thrown will include
+ * information for locating the error in the original XML document.
+ *
+ * @param caller the WebRowSet object to be parsed, whose
+ * xmlReader field must contain a reference to
+ * this XmlReader object
+ * @param iStream the java.io.InputStream object from which
+ * the parser will get its input
+ * @throws SQLException if a database access error occurs or
+ * this WebRowSetXmlReader 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;
+}