| /* |
| * 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 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. |
| */ |
| @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(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. |
| */ |
| @SuppressWarnings("unchecked") |
| 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. |
| */ |
| @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(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(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(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. |
| */ |
| @SuppressWarnings("unchecked") |
| 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. |
| */ |
| @SuppressWarnings("unchecked") |
| 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. |
| */ |
| @SuppressWarnings("unchecked") |
| 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. |
| */ |
| @SuppressWarnings("unchecked") |
| 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. |
| */ |
| @SuppressWarnings("unchecked") |
| public void writeURL(java.net.URL url) throws SQLException { |
| if (url == null) { |
| attribs.add(url); |
| return; |
| } |
| attribs.add(new SerialDatalink(url)); |
| |
| } |
| |
| |
| /** |
| * Writes the next attribute to the stream as a <code>String</code> |
| * in the Java programming language. The driver converts this to a |
| * SQL <code>NCHAR</code> or |
| * <code>NVARCHAR</code> or <code>LONGNVARCHAR</code> value |
| * (depending on the argument's |
| * size relative to the driver's limits on <code>NVARCHAR</code> values) |
| * when it sends it to the stream. |
| * |
| * @param x the value to pass to the database |
| * @exception SQLException if a database access error occurs |
| * @since 1.6 |
| */ |
| @SuppressWarnings("unchecked") |
| public void writeNString(String x) throws SQLException { |
| throw new UnsupportedOperationException("Operation not supported"); |
| } |
| |
| /** |
| * Writes an SQL <code>NCLOB</code> value to the stream. |
| * |
| * @param x a <code>NClob</code> object representing data of an SQL |
| * <code>NCLOB</code> value |
| * |
| * @exception SQLException if a database access error occurs |
| * @since 1.6 |
| */ |
| @SuppressWarnings("unchecked") |
| public void writeNClob(NClob x) throws SQLException { |
| throw new UnsupportedOperationException("Operation not supported"); |
| } |
| |
| |
| /** |
| * Writes an SQL <code>ROWID</code> value to the stream. |
| * |
| * @param x a <code>RowId</code> object representing data of an SQL |
| * <code>ROWID</code> value |
| * |
| * @exception SQLException if a database access error occurs |
| * @since 1.6 |
| */ |
| @SuppressWarnings("unchecked") |
| public void writeRowId(RowId x) throws SQLException { |
| throw new UnsupportedOperationException("Operation not supported"); |
| } |
| |
| |
| /** |
| * Writes an SQL <code>XML</code> value to the stream. |
| * |
| * @param x a <code>SQLXML</code> object representing data of an SQL |
| * <code>XML</code> value |
| * |
| * @exception SQLException if a database access error occurs |
| * @since 1.6 |
| */ |
| @SuppressWarnings("unchecked") |
| public void writeSQLXML(SQLXML x) throws SQLException { |
| throw new UnsupportedOperationException("Operation not supported"); |
| } |
| |
| } |