/*

 * Copyright 2003-2006 Sun Microsystems, Inc.  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.  Sun designates this

 * particular file as subject to the "Classpath" exception as provided

 * by Sun 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 Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,

 * CA 95054 USA or visit www.sun.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 {

    /**

     * 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

     */

    private JdbcRowSetResourceBundle resBundle;

    public WebRowSetXmlReader(){

        try {

           resBundle = JdbcRowSetResourceBundle.getJdbcRowSetResourceBundle();

        } catch(IOException ioe) {

            throw new RuntimeException(ioe);

        }

    }

    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) {

    }

}