/*

 * Copyright (c) 2003, 2013, 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 javax.sql.rowset.serial;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.sql.*;

import java.util.Map;

import java.util.Vector;

/**

 * The output stream for writing the attributes of a

 * custom-mapped user-defined type (UDT) back to the database.

 * The driver uses this interface internally, and its

 * methods are never directly invoked by an application programmer.

 * <p>

 * When an application calls the

 * method <code>PreparedStatement.setObject</code>, the driver

 * checks to see whether the value to be written is a UDT with

 * a custom mapping.  If it is, there will be an entry in a

 * type map containing the <code>Class</code> object for the

 * class that implements <code>SQLData</code> for this UDT.

 * If the value to be written is an instance of <code>SQLData</code>,

 * the driver will create an instance of <code>SQLOutputImpl</code>

 * and pass it to the method <code>SQLData.writeSQL</code>.

 * The method <code>writeSQL</code> in turn calls the

 * appropriate <code>SQLOutputImpl.writeXXX</code> methods

 * to write data from the <code>SQLData</code> object to

 * the <code>SQLOutputImpl</code> output stream as the

 * representation of an SQL user-defined type.

 */

public class SQLOutputImpl implements SQLOutput {

    /**

     * A reference to an existing vector that

     * contains the attributes of a <code>Struct</code> object.

     */

    @SuppressWarnings("rawtypes")

    private Vector attribs;

    /**

     * The type map the driver supplies to a newly created

     * <code>SQLOutputImpl</code> object.  This type map

     * indicates the <code>SQLData</code> class whose

     * <code>writeSQL</code> method will be called.  This

     * method will in turn call the appropriate

     * <code>SQLOutputImpl</code> writer methods.

     */

    @SuppressWarnings("rawtypes")

    private Map map;

    /**

     * Creates a new <code>SQLOutputImpl</code> object

     * initialized with the given vector of attributes and

     * type map.  The driver will use the type map to determine

     * which <code>SQLData.writeSQL</code> method to invoke.

     * This method will then call the appropriate

     * <code>SQLOutputImpl</code> writer methods in order and

     * thereby write the attributes to the new output stream.

     *

     * @param attributes a <code>Vector</code> object containing the attributes of

     *        the UDT to be mapped to one or more objects in the Java

     *        programming language

     *

     * @param map a <code>java.util.Map</code> object containing zero or

     *        more entries, with each entry consisting of 1) a <code>String</code>

     *        giving the fully qualified name of a UDT and 2) the

     *        <code>Class</code> object for the <code>SQLData</code> implementation

     *        that defines how the UDT is to be mapped

     * @throws SQLException if the <code>attributes</code> or the <code>map</code>

     *        is a <code>null</code> value

     */

    public SQLOutputImpl(Vector<?> attributes, Map<String,?> map)

        throws SQLException

    {

        if ((attributes == null) || (map == null)) {

            throw new SQLException("Cannot instantiate a SQLOutputImpl " +

            "instance with null parameters");

        }

        this.attribs = attributes;

        this.map = map;

    }

    //================================================================

    // Methods for writing attributes to the stream of SQL data.

    // These methods correspond to the column-accessor methods of

    // java.sql.ResultSet.

    //================================================================

    /**

     * Writes a <code>String</code> in the Java programming language

     * to this <code>SQLOutputImpl</code> object. The driver converts

     * it to an SQL <code>CHAR</code>, <code>VARCHAR</code>, or

     * <code>LONGVARCHAR</code> before returning it to the database.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeString(String x) throws SQLException {

        //System.out.println("Adding :"+x);

        attribs.add(x);

    }

    /**

     * Writes a <code>boolean</code> in the Java programming language

     * to this <code>SQLOutputImpl</code> object. The driver converts

     * it to an SQL <code>BIT</code> before returning it to the database.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeBoolean(boolean x) throws SQLException {

        attribs.add(Boolean.valueOf(x));

    }

    /**

     * Writes a <code>byte</code> in the Java programming language

     * to this <code>SQLOutputImpl</code> object. The driver converts

     * it to an SQL <code>BIT</code> before returning it to the database.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeByte(byte x) throws SQLException {

        attribs.add(Byte.valueOf(x));

    }

    /**

     * Writes a <code>short</code> in the Java programming language

     * to this <code>SQLOutputImpl</code> object. The driver converts

     * it to an SQL <code>SMALLINT</code> before returning it to the database.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeShort(short x) throws SQLException {

        attribs.add(Short.valueOf(x));

    }

    /**

     * Writes an <code>int</code> in the Java programming language

     * to this <code>SQLOutputImpl</code> object. The driver converts

     * it to an SQL <code>INTEGER</code> before returning it to the database.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeInt(int x) throws SQLException {

        attribs.add(Integer.valueOf(x));

    }

    /**

     * Writes a <code>long</code> in the Java programming language

     * to this <code>SQLOutputImpl</code> object. The driver converts

     * it to an SQL <code>BIGINT</code> before returning it to the database.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeLong(long x) throws SQLException {

        attribs.add(Long.valueOf(x));

    }

    /**

     * Writes a <code>float</code> in the Java programming language

     * to this <code>SQLOutputImpl</code> object. The driver converts

     * it to an SQL <code>REAL</code> before returning it to the database.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeFloat(float x) throws SQLException {

        attribs.add(Float.valueOf(x));

    }

    /**

     * Writes a <code>double</code> in the Java programming language

     * to this <code>SQLOutputImpl</code> object. The driver converts

     * it to an SQL <code>DOUBLE</code> before returning it to the database.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeDouble(double x) throws SQLException{

        attribs.add(Double.valueOf(x));

    }

    /**

     * Writes a <code>java.math.BigDecimal</code> object in the Java programming

     * language to this <code>SQLOutputImpl</code> object. The driver converts

     * it to an SQL <code>NUMERIC</code> before returning it to the database.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeBigDecimal(java.math.BigDecimal x) throws SQLException{

        attribs.add(x);

    }

    /**

     * Writes an array of <code>bytes</code> in the Java programming language

     * to this <code>SQLOutputImpl</code> object. The driver converts

     * it to an SQL <code>VARBINARY</code> or <code>LONGVARBINARY</code>

     * before returning it to the database.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeBytes(byte[] x) throws SQLException {

        attribs.add(x);

    }

    /**

     * Writes a <code>java.sql.Date</code> object in the Java programming

     * language to this <code>SQLOutputImpl</code> object. The driver converts

     * it to an SQL <code>DATE</code> before returning it to the database.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeDate(java.sql.Date x) throws SQLException {

        attribs.add(x);

    }

    /**

     * Writes a <code>java.sql.Time</code> object in the Java programming

     * language to this <code>SQLOutputImpl</code> object. The driver converts

     * it to an SQL <code>TIME</code> before returning it to the database.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeTime(java.sql.Time x) throws SQLException {

        attribs.add(x);

    }

    /**

     * Writes a <code>java.sql.Timestamp</code> object in the Java programming

     * language to this <code>SQLOutputImpl</code> object. The driver converts

     * it to an SQL <code>TIMESTAMP</code> before returning it to the database.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeTimestamp(java.sql.Timestamp x) throws SQLException {

        attribs.add(x);

    }

    /**

     * Writes a stream of Unicode characters to this

     * <code>SQLOutputImpl</code> object. The driver will do any necessary

     * conversion from Unicode to the database <code>CHAR</code> format.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeCharacterStream(java.io.Reader x) throws SQLException {

         BufferedReader bufReader = new BufferedReader(x);

         try {

             int i;

             while( (i = bufReader.read()) != -1 ) {

                char ch = (char)i;

                StringBuffer strBuf = new StringBuffer();

                strBuf.append(ch);

                String str = new String(strBuf);

                String strLine = bufReader.readLine();

                writeString(str.concat(strLine));

             }

         } catch(IOException ioe) {

         }

    }

    /**

     * Writes a stream of ASCII characters to this

     * <code>SQLOutputImpl</code> object. The driver will do any necessary

     * conversion from ASCII to the database <code>CHAR</code> format.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeAsciiStream(java.io.InputStream x) throws SQLException {

         BufferedReader bufReader = new BufferedReader(new InputStreamReader(x));

         try {

               int i;

               while( (i=bufReader.read()) != -1 ) {

                char ch = (char)i;

                StringBuffer strBuf = new StringBuffer();

                strBuf.append(ch);

                String str = new String(strBuf);

                String strLine = bufReader.readLine();

                writeString(str.concat(strLine));

            }

          }catch(IOException ioe) {

            throw new SQLException(ioe.getMessage());

        }

    }

    /**

     * Writes a stream of uninterpreted bytes to this <code>SQLOutputImpl</code>

     * object.

     *

     * @param x the value to pass to the database

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeBinaryStream(java.io.InputStream x) throws SQLException {

         BufferedReader bufReader = new BufferedReader(new InputStreamReader(x));

         try {

               int i;

             while( (i=bufReader.read()) != -1 ) {

                char ch = (char)i;

                StringBuffer strBuf = new StringBuffer();

                strBuf.append(ch);

                String str = new String(strBuf);

                String strLine = bufReader.readLine();

                writeString(str.concat(strLine));

             }

        } catch(IOException ioe) {

            throw new SQLException(ioe.getMessage());

        }

    }

    //================================================================

    // Methods for writing items of SQL user-defined types to the stream.

    // These methods pass objects to the database as values of SQL

    // Structured Types, Distinct Types, Constructed Types, and Locator

    // Types.  They decompose the Java object(s) and write leaf data

    // items using the methods above.

    //================================================================

    /**

     * Writes to the stream the data contained in the given

     * <code>SQLData</code> object.

     * When the <code>SQLData</code> object is <code>null</code>, this

     * method writes an SQL <code>NULL</code> to the stream.

     * Otherwise, it calls the <code>SQLData.writeSQL</code>

     * method of the given object, which

     * writes the object's attributes to the stream.

     * <P>

     * The implementation of the method <code>SQLData.writeSQ</code>

     * calls the appropriate <code>SQLOutputImpl.writeXXX</code> method(s)

     * for writing each of the object's attributes in order.

     * The attributes must be read from an <code>SQLInput</code>

     * input stream and written to an <code>SQLOutputImpl</code>

     * output stream in the same order in which they were

     * listed in the SQL definition of the user-defined type.

     *

     * @param x the object representing data of an SQL structured or

     *          distinct type

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeObject(SQLData x) throws SQLException {

        /*

         * Except for the types that are passed as objects

         * this seems to be the only way for an object to

         * get a null value for a field in a structure.

         *

         * Note: this means that the class defining SQLData

         * will need to track if a field is SQL null for itself

         */

        if (x == null) {

            attribs.add(null);

        } else {

            /*

             * We have to write out a SerialStruct that contains

             * the name of this class otherwise we don't know

             * what to re-instantiate during readSQL()

             */

            attribs.add(new SerialStruct(x, map));

        }

    }

    /**

     * Writes a <code>Ref</code> object in the Java programming language

     * to this <code>SQLOutputImpl</code> object.  The driver converts

     * it to a serializable <code>SerialRef</code> SQL <code>REF</code> value

     * before returning it to the database.

     *

     * @param x an object representing an SQL <code>REF</code> value

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeRef(Ref x) throws SQLException {

        if (x == null) {

            attribs.add(null);

        } else {

            attribs.add(new SerialRef(x));

        }

    }

    /**

     * Writes a <code>Blob</code> object in the Java programming language

     * to this <code>SQLOutputImpl</code> object.  The driver converts

     * it to a serializable <code>SerialBlob</code> SQL <code>BLOB</code> value

     * before returning it to the database.

     *

     * @param x an object representing an SQL <code>BLOB</code> value

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeBlob(Blob x) throws SQLException {

        if (x == null) {

            attribs.add(null);

        } else {

            attribs.add(new SerialBlob(x));

        }

    }

    /**

     * Writes a <code>Clob</code> object in the Java programming language

     * to this <code>SQLOutputImpl</code> object.  The driver converts

     * it to a serializable <code>SerialClob</code> SQL <code>CLOB</code> value

     * before returning it to the database.

     *

     * @param x an object representing an SQL <code>CLOB</code> value

     * @throws SQLException if the <code>SQLOutputImpl</code> object is in

     *        use by a <code>SQLData</code> object attempting to write the attribute

     *        values of a UDT to the database.

     */

    @SuppressWarnings("unchecked")

    public void writeClob(Clob x) throws SQLException {

        if (x == null) {

            attribs.add(null);

        } else {

            attribs.add(new SerialClob(x));

        }

    }

    /**

     * Writes a <code>Struct</code> object in the Java