All ServerConnection objects are listed in a Set in server and removed by this class when closed.

When the database or server is shutdown, the signalClose() method is called for all current ServerConnection instances. This will call the private close() method. If the ServerConnection thread itself has caused the shutdown it returns the result of the operation to the client. (fredt@users)

ODBC support added for version 2.0.0 by Blaine Simpson.

ODBC support updated for version 2.5.x. (fredt@users)

Nested and Inner Type Summary

Modifier and Type	Class and Description
private static class	ServerConnection.ClientFailure
pack-priv class	ServerConnection.HsqlInResultProcessor
pack-priv class	ServerConnection.OdbcInResultProcessor

Field Summary

Modifier and Type	Field and Description
pack-priv static final int	BUFFER_SIZE
private CleanExit	cleanExit
public static long	CLIENT_DATA_POLLING_PERIOD Don't want this too high, or users may give up before seeing the banner.
private DataInputStream	dataInput
private DataOutputStream	dataOutput
pack-priv int	dbID
pack-priv int	dbIndex
pack-priv static final int	HSQL_STREAM_PROTOCOL
pack-priv boolean	keepAlive
pack-priv final byte[]	mainBuffer
private static AtomicLong	mCurrentThread
private long	mThread
pack-priv static final int	ODBC_STREAM_PROTOCOL
pack-priv int	odbcCommMode
private OdbcPacketOutputStream	outPacket
pack-priv InResultProcessor	processor
pack-priv RowInputBinary	rowIn
pack-priv RowOutputInterface	rowOut
pack-priv Thread	runnerThread
private Server	server
private volatile Session	session
private Map<String, StatementPortal>	sessionOdbcPortalMap
private Map<String, OdbcPreparedStatement>	sessionOdbcPsMap
private Socket	socket
private int	streamProtocol
protected static String	TEXTBANNER_PART1
protected static String	TEXTBANNER_PART2
pack-priv static final int	UNDEFINED_STREAM_PROTOCOL
private String	user

Constructor Summary

Access	Constructor and Description
pack-priv	ServerConnection(Socket the network socket on which Server communication takes place socket, Server the Server instance to which the object represents a connection server) Creates a new ServerConnection to the specified Server on the specified socket.

Method Summary

Modifier and Type	Method and Description
private Result	cancelStatement(Result resultIn)
private void	close() Closes this connection.
pack-priv String	Returns: the thread name to be used when this object is the Runnable object of a Thread. getConnectionThreadName() Retrieves the thread name to be used when this object is the Runnable object of a Thread.
public int	Returns: int read as first thing off of stream handshake() The only known case where a connection attempt will get stuck is if client connects with hsqls to a https server; or hsql to a http server.
private void	init() Initializes this connection.
private void	odbcConnect(int firstInt)
private void	odbcExecDirect(String inStatement)
private static String	readNullTermdUTF(int Required length reqLength, InputStream istream) Read String directly from dataInput.
private void	receiveOdbcPacket(char inC)
private void	receiveResult(int resultMode)
public void	run() Implements java.lang.Runnable.run. Initializes this connection and runs the request handling loop until closed.
private Result	setDatabase(Result resultIn)
pack-priv void	signalClose() Signals this object to close, including exiting the thread running the request handling loop

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

BUFFER_SIZE	back to summary
pack-priv static final int BUFFER_SIZE

cleanExit	back to summary
private CleanExit cleanExit

CLIENT_DATA_POLLING_PERIOD	back to summary
public static long CLIENT_DATA_POLLING_PERIOD Don't want this too high, or users may give up before seeing the banner. Can't be too low or we could close a valid but slow client connection.

dataInput	back to summary
private DataInputStream dataInput

dataOutput	back to summary
private DataOutputStream dataOutput

dbID	back to summary
pack-priv int dbID

dbIndex	back to summary
pack-priv int dbIndex

HSQL_STREAM_PROTOCOL	back to summary
pack-priv static final int HSQL_STREAM_PROTOCOL

keepAlive	back to summary
pack-priv boolean keepAlive

mainBuffer	back to summary
pack-priv final byte[] mainBuffer

mCurrentThread	back to summary
private static AtomicLong mCurrentThread

mThread	back to summary
private long mThread

ODBC_STREAM_PROTOCOL	back to summary
pack-priv static final int ODBC_STREAM_PROTOCOL

odbcCommMode	back to summary
pack-priv int odbcCommMode

outPacket	back to summary
private OdbcPacketOutputStream outPacket

processor	back to summary
pack-priv InResultProcessor processor

rowIn	back to summary
pack-priv RowInputBinary rowIn

rowOut	back to summary
pack-priv RowOutputInterface rowOut

runnerThread	back to summary
pack-priv Thread runnerThread

server	back to summary
private Server server

session	back to summary
private volatile Session session

sessionOdbcPortalMap	back to summary
private Map<String, StatementPortal> sessionOdbcPortalMap

sessionOdbcPsMap	back to summary
private Map<String, OdbcPreparedStatement> sessionOdbcPsMap

socket	back to summary
private Socket socket

streamProtocol	back to summary
private int streamProtocol

TEXTBANNER_PART1	back to summary
protected static String TEXTBANNER_PART1

TEXTBANNER_PART2	back to summary
protected static String TEXTBANNER_PART2

UNDEFINED_STREAM_PROTOCOL	back to summary
pack-priv static final int UNDEFINED_STREAM_PROTOCOL

user	back to summary
private String user

Constructor Detail

ServerConnection	back to summary
pack-priv ServerConnection(Socket socket, Server server) Creates a new ServerConnection to the specified Server on the specified socket. Parameters socket:Socket the network socket on which Server communication takes place server:Server the Server instance to which the object represents a connection

ServerConnection

back to summary

pack-priv ServerConnection(Socket socket, Server server)

Creates a new ServerConnection to the specified Server on the specified socket.

Parameters

socket:Socket: the network socket on which Server communication takes place
server:Server: the Server instance to which the object represents a connection

Method Detail

cancelStatement	back to summary
private Result cancelStatement(Result resultIn)

close	back to summary
private void close() Closes this connection.

getConnectionThreadName	back to summary
pack-priv String getConnectionThreadName() Retrieves the thread name to be used when this object is the Runnable object of a Thread. Returns:String the thread name to be used when this object is the Runnable object of a Thread.

getConnectionThreadName

back to summary

pack-priv String getConnectionThreadName()

Retrieves the thread name to be used when this object is the Runnable object of a Thread.

Returns:String: the thread name to be used when this object is the Runnable object of a Thread.

handshake	back to summary
public int handshake() throws IOException The only known case where a connection attempt will get stuck is if client connects with hsqls to a https server; or hsql to a http server. All other client X server combinations are handled gracefully. If returns (a.o.t. throws), then state variable streamProtocol will be set. Returns:int int read as first thing off of stream

handshake

back to summary

public int handshake() throws IOException

The only known case where a connection attempt will get stuck is if client connects with hsqls to a https server; or hsql to a http server. All other client X server combinations are handled gracefully.

If returns (a.o.t. throws), then state variable streamProtocol will be set.

Returns:int: int read as first thing off of stream

init	back to summary
private void init() Initializes this connection. Will return (not throw) if fail to initialize the connection.

init

back to summary

private void init()

Initializes this connection.

Will return (not throw) if fail to initialize the connection.

odbcConnect	back to summary
private void odbcConnect(int firstInt) throws IOException

odbcExecDirect	back to summary
private void odbcExecDirect(String inStatement) throws RecoverableOdbcFailure, IOException

readNullTermdUTF	back to summary
private static String readNullTermdUTF(int reqLength, InputStream istream) throws IOException Read String directly from dataInput. Parameters reqLength:int Required length

readNullTermdUTF

back to summary

private static String readNullTermdUTF(int reqLength, InputStream istream) throws IOException

Read String directly from dataInput.

Parameters

reqLength:int: Required length

receiveOdbcPacket	back to summary
private void receiveOdbcPacket(char inC) throws IOException, CleanExit

receiveResult	back to summary
private void receiveResult(int resultMode) throws CleanExit, IOException

run	back to summary
public void run() Implements java.lang.Runnable.run. Initializes this connection and runs the request handling loop until closed.

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Initializes this connection and runs the request handling loop until closed.

setDatabase	back to summary
private Result setDatabase(Result resultIn)

signalClose	back to summary
pack-priv void signalClose() Signals this object to close, including exiting the thread running the request handling loop

org.hsqldb.server back to summary

private Class ServerConnection.ClientFailure

Class Inheritance

extends Exception

java.lang.Object
java.lang.Throwable
java.lang.Exception
org.hsqldb.server.ServerConnection.ClientFailure

Field Summary

Modifier and Type	Field and Description
private String	clientMessage

Constructor Summary

Access	Constructor and Description
public	ClientFailure(String ourMessage, String clientMessage)

Method Summary

Modifier and Type	Method and Description
public String	getClientMessage()

Field Detail

clientMessage	back to summary
private String clientMessage

Constructor Detail

ClientFailure	back to summary
public ClientFailure(String ourMessage, String clientMessage)

Method Detail

getClientMessage	back to summary
public String getClientMessage()

org.hsqldb.server back to summary

pack-priv Class ServerConnection.HsqlInResultProcessor

Class Inheritance

extends Object
implements InResultProcessor

java.lang.Object
org.hsqldb.server.ServerConnection.HsqlInResultProcessor

All Implemented Interfaces

org.hsqldb.server.InResultProcessor

Constructor Summary

Access	Constructor and Description
pack-priv	HsqlInResultProcessor()

Method Summary

Modifier and Type	Method and Description
public void	receiveConnection(int type) Implements org.hsqldb.server.InResultProcessor.receiveConnection.
public void	receiveResult(int type) Implements org.hsqldb.server.InResultProcessor.receiveResult.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

HsqlInResultProcessor	back to summary
pack-priv HsqlInResultProcessor()

Method Detail

receiveConnection	back to summary
public void receiveConnection(int type) throws CleanExit, IOException Implements org.hsqldb.server.InResultProcessor.receiveConnection.

receiveResult	back to summary
public void receiveResult(int type) throws CleanExit, IOException Implements org.hsqldb.server.InResultProcessor.receiveResult.

org.hsqldb.server back to summary

pack-priv Class ServerConnection.OdbcInResultProcessor

Class Inheritance

extends Object
implements InResultProcessor

java.lang.Object
org.hsqldb.server.ServerConnection.OdbcInResultProcessor

All Implemented Interfaces

org.hsqldb.server.InResultProcessor

Constructor Summary

Access	Constructor and Description
pack-priv	OdbcInResultProcessor()

Method Summary

Modifier and Type	Method and Description
public void	receiveConnection(int type) Implements org.hsqldb.server.InResultProcessor.receiveConnection.
public void	receiveResult(int type) Implements org.hsqldb.server.InResultProcessor.receiveResult.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

OdbcInResultProcessor	back to summary
pack-priv OdbcInResultProcessor()

Method Detail

receiveConnection	back to summary
public void receiveConnection(int type) throws IOException Implements org.hsqldb.server.InResultProcessor.receiveConnection.

receiveResult	back to summary
public void receiveResult(int type) throws CleanExit, IOException Implements org.hsqldb.server.InResultProcessor.receiveResult.