- /*
- * @(#)SQLOutputImpl.java 1.5 04/05/05
- *
- * Copyright 2004 Sun Microsystems, Inc. All rights reserved.
- * SUN PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.
- */
-
- package javax.sql.rowset.serial;
-
- import java.sql.*;
- import javax.sql.*;
- import java.io.*;
- import java.lang.String;
- import java.math.*;
- 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.
- */
- 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.
- */
- 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.
- */
- 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.
- */
- public void writeBoolean(boolean x) throws SQLException {
- attribs.add(new Boolean(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.
- */
- public void writeByte(byte x) throws SQLException {
- attribs.add(new Byte(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.
- */
- public void writeShort(short x) throws SQLException {
- attribs.add(new Short(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.
- */
- public void writeInt(int x) throws SQLException {
- attribs.add(new Integer(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.
- */
- public void writeLong(long x) throws SQLException {
- attribs.add(new Long(x));
- }
-
- /**
- * Writes a <code>float</code> in the Java programming language
- * to this <code><code>SQLOutputImpl</code></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.
- */
- public void writeFloat(float x) throws SQLException {
- attribs.add(new Float(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.
- */
- public void writeDouble(double x) throws SQLException{
- attribs.add(new Double(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.
- */
- 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.
- */
- 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.
- */
- 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.
- */
- 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.
- */
- 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.
- */
- 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.
- */
- 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.
- */
- 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.
- */
- 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(x);
- return;
- }
-
- /*
- * 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((SQLData)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.
- */
- public void writeRef(Ref x) throws SQLException {
- if (x == null) {
- attribs.add(x);
- return;
- }
- 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.
- */
- public void writeBlob(Blob x) throws SQLException {
- if (x == null) {
- attribs.add(x);
- return;
- }
- 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.
- */
- public void writeClob(Clob x) throws SQLException {
- if (x == null) {
- attribs.add(x);
- return;
- }
- attribs.add(new SerialClob(x));
- }
-
- /**
- * Writes a <code>Struct</code> object in the Java
- * programming language to this <code>SQLOutputImpl</code>
- * object. The driver converts this value to an SQL structured type
- * before returning it to the database.
- * <P>
- * This method should be used when an SQL structured type has been
- * mapped to a <code>Struct</code> object in the Java programming
- * language (the standard mapping). The method
- * <code>writeObject</code> should be used if an SQL structured type
- * has been custom mapped to a class in the Java programming language.
- *
- * @param x an object representing the attributes of an SQL structured 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.
- */
- public void writeStruct(Struct x) throws SQLException {
- SerialStruct s = new SerialStruct(x,map);;
- attribs.add(s);
- }
-
- /**
- * Writes an <code>Array</code> object in the Java
- * programming language to this <code>SQLOutputImpl</code>
- * object. The driver converts this value to a serializable
- * <code>SerialArray</code> SQL <code>ARRAY</code>
- * value before returning it to the database.
- *
- * @param x an object representing an SQL <code>ARRAY</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.
- */
- public void writeArray(Array x) throws SQLException {
- if (x == null) {
- attribs.add(x);
- return;
- }
- attribs.add(new SerialArray(x, map));
- }
-
- /**
- * Writes an <code>java.sql.Type.DATALINK</code> object in the Java
- * programming language to this <code>SQLOutputImpl</code> object. The
- * driver converts this value to a serializable <code>SerialDatalink</code>
- * SQL <code>DATALINK</code> value before return it to the database.
- *
- * @param url an object representing a SQL <code>DATALINK</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.
- */
- public void writeURL(java.net.URL url) throws SQLException {
- if (url == null) {
- attribs.add(url);
- return;
- }
- attribs.add(new SerialDatalink(url));
-
- }
- }
-
-
-
-
-