org.h2.value

Class Transfer

java.lang.Object

org.h2.value.Transfer

public class Transfer
extends Object

The transfer class is used to send and receive Value objects. It is used on both the client side, and on the server side.

Constructor Summary

Constructors

Constructor and Description
Transfer(SessionInterface session) Create a new transfer object for the specified session.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close the transfer object and the socket.
void	flush() Write pending changes.
Socket	getSocket() Get the socket.
void	init() Initialize the transfer object.
boolean	isClosed()
Transfer	openNewConnection() Open a new new connection to the same address and port as this one.
boolean	readBoolean() Read a boolean.
byte[]	readBytes() Read a byte array.
int	readInt() Read an int.
long	readLong() Read a long.
String	readString() Read a string.
Value	readValue() Read a value.
void	setSession(SessionInterface session) Set the session.
void	setSocket(Socket s) Set the socket this object uses.
void	setSSL(boolean ssl) Enable or disable SSL.
void	setVersion(int version)
Transfer	writeBoolean(boolean x) Write a boolean.
Transfer	writeBytes(byte[] data) Write a byte array.
Transfer	writeInt(int x) Write an int.
Transfer	writeLong(long x) Write a long.
Transfer	writeString(String s) Write a string.
void	writeValue(Value v) Write a value.

Methods inherited from class java.lang.Object

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

Constructor Detail

Transfer

public Transfer(SessionInterface session)

Create a new transfer object for the specified session.

Parameters:

session - the session

Method Detail

setSocket

public void setSocket(Socket s)

Set the socket this object uses.

Parameters:

s - the socket

init

public void init()
          throws IOException

Initialize the transfer object. This method will try to open an input and output stream.

Throws:

IOException

flush

public void flush()
           throws IOException

Write pending changes.

Throws:

IOException

writeBoolean

public Transfer writeBoolean(boolean x)
                      throws IOException

Write a boolean.

Parameters:

x - the value

Returns:

itself

Throws:

IOException

readBoolean

public boolean readBoolean()
                    throws IOException

Read a boolean.

Returns:

the value

Throws:

IOException

writeInt

public Transfer writeInt(int x)
                  throws IOException

Write an int.

Parameters:

x - the value

Returns:

itself

Throws:

IOException

readInt

public int readInt()
            throws IOException

Read an int.

Returns:

the value

Throws:

IOException

writeLong

public Transfer writeLong(long x)
                   throws IOException

Write a long.

Parameters:

x - the value

Returns:

itself

Throws:

IOException

readLong

public long readLong()
              throws IOException

Read a long.

Returns:

the value

Throws:

IOException

writeString

public Transfer writeString(String s)
                     throws IOException

Write a string. The maximum string length is Integer.MAX_VALUE.

Parameters:

s - the value

Returns:

itself

Throws:

IOException

readString

public String readString()
                  throws IOException

Read a string.

Returns:

the value

Throws:

IOException

writeBytes

public Transfer writeBytes(byte[] data)
                    throws IOException

Write a byte array.

Parameters:

data - the value

Returns:

itself

Throws:

IOException

readBytes

public byte[] readBytes()
                 throws IOException

Read a byte array.

Returns:

the value

Throws:

IOException

close

public void close()

Close the transfer object and the socket.

writeValue

public void writeValue(Value v)
                throws IOException

Write a value.

Parameters:

v - the value

Throws:

IOException

readValue

public Value readValue()
                throws IOException

Read a value.

Returns:

the value

Throws:

IOException

getSocket

public Socket getSocket()

Get the socket.

Returns:

the socket

setSession

public void setSession(SessionInterface session)

Set the session.

Parameters:

session - the session

setSSL

public void setSSL(boolean ssl)

Enable or disable SSL.

Parameters:

ssl - the new value

openNewConnection

public Transfer openNewConnection()
                           throws IOException

Open a new new connection to the same address and port as this one.

Returns:

the new transfer object

Throws:

IOException

setVersion

public void setVersion(int version)

isClosed

public boolean isClosed()