org.objectweb.cjdbc.common.stream
Class CJDBCInputStream

java.lang.Object
  org.objectweb.cjdbc.common.stream.CJDBCInputStream

public class CJDBCInputStream

extends java.lang.Object

DataInputStream wrapper used between the controller and the driver.

Author:

Nicolas Modrzyk , Emmanuel Cecchet , Marc Herbert

Field Summary

private long	dateCreated
private java.io.DataInputStream	input
private java.net.Socket	socket

Constructor Summary

CJDBCInputStream(java.io.InputStream in)
Creates a new CJDBCInputStream from the given input stream.

CJDBCInputStream(java.net.Socket socket)
Useful constructor for statistics on sockets ..

Method Summary

int	available()
void	close()
long	getDateCreated()
java.net.Socket	getSocket()
boolean	readBoolean()
double	readDouble()
double	readFloat()
void	readFully(byte[] b)
int	readInt()
long	readLong()
java.lang.String	readUTF()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

input

private java.io.DataInputStream input

socket

private java.net.Socket socket

dateCreated

private long dateCreated

Constructor Detail

CJDBCInputStream

public CJDBCInputStream(java.io.InputStream in)

Creates a new CJDBCInputStream from the given input stream.

Parameters:

in - inputstream to wrap

CJDBCInputStream

public CJDBCInputStream(java.net.Socket socket)
                 throws java.io.IOException,
                        java.io.StreamCorruptedException

Useful constructor for statistics on sockets ..

Parameters:

socket - socket for this stream

Throws:

java.io.IOException - if an error occurs

java.io.StreamCorruptedException - if an error occurs

Method Detail

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException - if an error occurs

See Also:

FilterInputStream.close()

readBoolean

public boolean readBoolean()
                    throws java.io.IOException

Returns:

a boolean value

Throws:

java.io.IOException - if an error occurs

See Also:

DataInputStream.readBoolean()

readInt

public int readInt()
            throws java.io.IOException

Returns:

an int value

Throws:

java.io.IOException - if an error occurs

See Also:

DataInputStream.readInt()

readLong

public long readLong()
              throws java.io.IOException

Returns:

a long value

Throws:

java.io.IOException - if an error occurs

See Also:

DataInputStream.readLong()

readFloat

public double readFloat()
                 throws java.io.IOException

Returns:

a floatvalue

Throws:

java.io.IOException - if an error occurs

See Also:

DataInputStream.readFloat()

readDouble

public double readDouble()
                  throws java.io.IOException

Returns:

a doublevalue

Throws:

java.io.IOException - if an error occurs

See Also:

DataInputStream.readDouble()

readFully

public void readFully(byte[] b)
               throws java.io.IOException

Parameters:

b - the byte array to fill up

Throws:

java.io.IOException - if an error occurs

See Also:

DataInputStream.readFully(byte[])

readUTF

public java.lang.String readUTF()
                         throws java.io.IOException

Returns:

a String in UTF format

Throws:

java.io.IOException - if an error occurs

See Also:

DataInputStream.readUTF(), CJDBCOutputStream.writeUTF(String)

available

public int available()
              throws java.io.IOException

Returns:

the number of available bytes.

Throws:

java.io.IOException - if an error occurs

See Also:

FilterInputStream.available()

getSocket

public java.net.Socket getSocket()

Returns:

Returns the socket.

getDateCreated

public long getDateCreated()

Returns:

Returns the dateCreated.