java.io.Closeable
, java.lang.AutoCloseable
class EXTDTAInputStream
extends java.io.InputStream
Modifier and Type | Field | Description |
---|---|---|
private java.sql.Blob |
_blob |
|
private java.sql.Clob |
_clob |
|
private java.io.InputStream |
binaryInputStream |
|
(package private) int |
columnNumber |
Column index starting with 1
|
(package private) int |
ndrdaType |
DRDA Type of column/parameter
|
(package private) EngineResultSet |
rs |
ResultSet that contains the stream
|
Modifier | Constructor | Description |
---|---|---|
private |
EXTDTAInputStream(java.sql.Blob blob,
int ndrdaType) |
|
private |
EXTDTAInputStream(java.sql.Clob clob,
int ndrdaType) |
|
private |
EXTDTAInputStream(java.sql.ResultSet rs,
int columnNumber,
int ndrdaType) |
Modifier and Type | Method | Description |
---|---|---|
int |
available() |
|
private static void |
badDRDAType(int drdaType) |
|
void |
close() |
|
boolean |
equals(java.lang.Object arg0) |
|
protected void |
finalize() |
|
private java.io.InputStream |
getBinaryStream() |
|
private java.io.Reader |
getCharacterStream() |
|
static EXTDTAInputStream |
getEXTDTAStream(java.sql.CallableStatement cs,
int column,
int drdaType) |
Create a new EXTDTAInputStream from a CallableStatement.
|
static EXTDTAInputStream |
getEXTDTAStream(java.sql.ResultSet rs,
int column,
int drdaType) |
Create a new EXTDTAInputStream.
|
int |
hashCode() |
|
void |
initInputStream() |
This method takes information of ResultSet and
initializes the binaryInputStream variable of this object with not empty stream
by calling getBinaryStream or getCharacterStream() as appropriate.
|
protected boolean |
isEmptyStream() |
|
boolean |
isNull() |
Is the value null?
|
private long |
length() |
|
void |
mark(int arg0) |
|
boolean |
markSupported() |
|
int |
read() |
Requires
initInputStream() be called before we can read from the stream |
int |
read(byte[] arg0) |
|
int |
read(byte[] arg0,
int arg1,
int arg2) |
|
void |
reset() |
|
long |
skip(long arg0) |
private java.io.InputStream binaryInputStream
int ndrdaType
EngineResultSet rs
int columnNumber
private java.sql.Clob _clob
private java.sql.Blob _blob
private EXTDTAInputStream(java.sql.ResultSet rs, int columnNumber, int ndrdaType)
private EXTDTAInputStream(java.sql.Clob clob, int ndrdaType)
private EXTDTAInputStream(java.sql.Blob blob, int ndrdaType)
public static EXTDTAInputStream getEXTDTAStream(java.sql.ResultSet rs, int column, int drdaType)
initInputStream()
rs
- result set from which to retrieve the lobcolumn
- column numberdrdaType
- FD:OCA type of object one of
DRDAConstants.DRDA_TYPE_NLOBBYTES
DRDAConstants.DRDA_TYPE_LOBBYTES
DRDAConstants.DRDA_TYPE_NLOBCMIXED
DRDAConstants.DRDA_TYPE_LOBCMIXEDjava.sql.SQLException
DDMWriter.writeScalarStream(boolean, int, org.apache.derby.impl.drda.EXTDTAInputStream, boolean)
,
initInputStream()
public static EXTDTAInputStream getEXTDTAStream(java.sql.CallableStatement cs, int column, int drdaType) throws java.sql.SQLException
cs
- CallableStatement from which to retrieve the lobcolumn
- column numberdrdaType
- FD:OCA type of object one of
DRDAConstants.DRDA_TYPE_NLOBBYTES
DRDAConstants.DRDA_TYPE_LOBBYTES
DRDAConstants.DRDA_TYPE_NLOBCMIXED
DRDAConstants.DRDA_TYPE_LOBCMIXEDjava.sql.SQLException
public int read() throws java.io.IOException
initInputStream()
be called before we can read from the streamread
in class java.io.InputStream
java.io.IOException
InputStream.read()
public int available() throws java.io.IOException
available
in class java.io.InputStream
java.io.IOException
InputStream.available()
public void close() throws java.io.IOException
close
in interface java.lang.AutoCloseable
close
in interface java.io.Closeable
close
in class java.io.InputStream
java.io.IOException
InputStream.close()
public boolean equals(java.lang.Object arg0)
equals
in class java.lang.Object
Object.equals(java.lang.Object)
public int hashCode()
hashCode
in class java.lang.Object
Object.hashCode()
public void mark(int arg0)
mark
in class java.io.InputStream
InputStream.mark(int)
public boolean markSupported()
markSupported
in class java.io.InputStream
InputStream.markSupported()
public int read(byte[] arg0) throws java.io.IOException
read
in class java.io.InputStream
java.io.IOException
InputStream.read(byte[])
public int read(byte[] arg0, int arg1, int arg2) throws java.io.IOException
read
in class java.io.InputStream
java.io.IOException
InputStream.read(byte[], int, int)
public void reset() throws java.io.IOException
reset
in class java.io.InputStream
java.io.IOException
InputStream.reset()
public long skip(long arg0) throws java.io.IOException
skip
in class java.io.InputStream
java.io.IOException
InputStream.skip(long)
protected boolean isEmptyStream() throws java.sql.SQLException
java.sql.SQLException
private long length() throws java.sql.SQLException
java.sql.SQLException
public void initInputStream() throws java.sql.SQLException
java.sql.SQLException
private java.io.InputStream getBinaryStream() throws java.sql.SQLException
java.sql.SQLException
private java.io.Reader getCharacterStream() throws java.sql.SQLException
java.sql.SQLException
private static void badDRDAType(int drdaType)
protected void finalize() throws java.lang.Throwable
finalize
in class java.lang.Object
java.lang.Throwable
public boolean isNull() throws java.sql.SQLException
java.sql.SQLException
Apache Derby V10.14 Internals - Copyright © 2004,2018 The Apache Software Foundation. All Rights Reserved.