org.hsqldb

Class ClientConnection

java.lang.Object

org.hsqldb.ClientConnection

All Implemented Interfaces:

SessionInterface

Direct Known Subclasses:

ClientConnectionHTTP

public class ClientConnection
extends java.lang.Object
implements SessionInterface

Base remote session proxy implementation. Uses instances of Result to transmit and recieve data. This implementation utilises the updated HSQL protocol.

Since:

1.7.2

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	NETWORK_COMPATIBILITY_VERSION Specifies the Compatibility version required for both Servers and network JDBC Clients built with this baseline.
static int	NETWORK_COMPATIBILITY_VERSION_INT

Fields inherited from interface org.hsqldb.SessionInterface

INFO_AUTOCOMMIT, INFO_BOOLEAN, INFO_CATALOG, INFO_CONNECTION_READONLY, INFO_ID, INFO_INTEGER, INFO_ISOLATION, INFO_LIMIT, INFO_VARCHAR, lobStreamBlockSize, TX_READ_COMMITTED, TX_READ_UNCOMMITTED, TX_REPEATABLE_READ, TX_SERIALIZABLE

Constructor Summary

Constructors

Constructor and Description
ClientConnection(java.lang.String host, int port, java.lang.String path, java.lang.String database, boolean isTLS, boolean isTLSWrapper, java.lang.String user, java.lang.String password, int timeZoneSeconds) Establishes a connection to the server.

Method Summary

Modifier and Type	Method and Description
void	addWarning(HsqlException warning)
void	allocateResultLob(ResultLob resultLob, java.io.InputStream dataInput) Does nothing here
void	close()
void	closeNavigator(long navigatorId)
void	commit(boolean chain)
BlobDataID	createBlob(long length)
ClobDataID	createClob(long length)
Result	execute(Result r)
java.lang.Object	getAttribute(int id)
java.util.Calendar	getCalendar()
java.util.Calendar	getCalendarGMT()
HsqlProperties	getClientProperties()
TimestampData	getCurrentDate()
java.lang.String	getDatabaseUniqueName()
long	getId()
java.lang.String	getInternalConnectionURL() Never called on this class
int	getIsolation()
JDBCConnection	getJDBCConnection()
long	getLobId()
RowSetNavigatorClient	getRows(long navigatorId, int offset, int size)
Scanner	getScanner()
Session	getSession()
java.text.SimpleDateFormat	getSimpleDateFormatGMT()
int	getStreamBlockSize()
int	getZoneSeconds()
boolean	isAutoCommit()
boolean	isClosed()
boolean	isReadOnlyDefault()
void	prepareCommit()
void	releaseSavepoint(java.lang.String name)
void	resetSession() Used by pooled connections to reset the server-side session to a new one.
void	rollback(boolean chain)
void	rollbackToSavepoint(java.lang.String name)
void	savepoint(java.lang.String name)
void	setAttribute(int id, java.lang.Object value)
void	setAutoCommit(boolean mode)
void	setIsolationDefault(int level)
void	setJDBCConnection(JDBCConnection connection)
void	setReadOnlyDefault(boolean mode)
void	startPhasedTransaction()
static java.lang.String	toNetCompVersionString(int i) Converts specified encoded integer to a Network Compatibility Version String.

Methods inherited from class java.lang.Object

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

Field Detail

NETWORK_COMPATIBILITY_VERSION

public static final java.lang.String NETWORK_COMPATIBILITY_VERSION

Specifies the Compatibility version required for both Servers and network JDBC Clients built with this baseline. Must remain public for Server to have visibility to it. Update this value only when the current version of HSQLDB does not have inter-compatibility with Server and network JDBC Driver of the previous HSQLDB version. Must specify all 4 version segments (any segment may be the value 0, however). The string elements at (position p from right counted from 0) are multiplied by 100 to power p and added up, then negated, to form the integer representation of version string.

See Also:

Constant Field Values

NETWORK_COMPATIBILITY_VERSION_INT

public static final int NETWORK_COMPATIBILITY_VERSION_INT

See Also:

Constant Field Values

Constructor Detail

ClientConnection

public ClientConnection(java.lang.String host,
                        int port,
                        java.lang.String path,
                        java.lang.String database,
                        boolean isTLS,
                        boolean isTLSWrapper,
                        java.lang.String user,
                        java.lang.String password,
                        int timeZoneSeconds)

Establishes a connection to the server.

Method Detail

execute

public Result execute(Result r)

Specified by:

execute in interface SessionInterface

getRows

public RowSetNavigatorClient getRows(long navigatorId,
                                     int offset,
                                     int size)

Specified by:

getRows in interface SessionInterface

closeNavigator

public void closeNavigator(long navigatorId)

Specified by:

closeNavigator in interface SessionInterface

close

public void close()

Specified by:

close in interface SessionInterface

getAttribute

public java.lang.Object getAttribute(int id)

Specified by:

getAttribute in interface SessionInterface

setAttribute

public void setAttribute(int id,
                         java.lang.Object value)

Specified by:

setAttribute in interface SessionInterface

isReadOnlyDefault

public boolean isReadOnlyDefault()

Specified by:

isReadOnlyDefault in interface SessionInterface

setReadOnlyDefault

public void setReadOnlyDefault(boolean mode)

Specified by:

setReadOnlyDefault in interface SessionInterface

isAutoCommit

public boolean isAutoCommit()

Specified by:

isAutoCommit in interface SessionInterface

setAutoCommit

public void setAutoCommit(boolean mode)

Specified by:

setAutoCommit in interface SessionInterface

setIsolationDefault

public void setIsolationDefault(int level)

Specified by:

setIsolationDefault in interface SessionInterface

getIsolation

public int getIsolation()

Specified by:

getIsolation in interface SessionInterface

isClosed

public boolean isClosed()

Specified by:

isClosed in interface SessionInterface

getSession

public Session getSession()

startPhasedTransaction

public void startPhasedTransaction()

Specified by:

startPhasedTransaction in interface SessionInterface

prepareCommit

public void prepareCommit()

Specified by:

prepareCommit in interface SessionInterface

commit

public void commit(boolean chain)

Specified by:

commit in interface SessionInterface

rollback

public void rollback(boolean chain)

Specified by:

rollback in interface SessionInterface

rollbackToSavepoint

public void rollbackToSavepoint(java.lang.String name)

Specified by:

rollbackToSavepoint in interface SessionInterface

savepoint

public void savepoint(java.lang.String name)

Specified by:

savepoint in interface SessionInterface

releaseSavepoint

public void releaseSavepoint(java.lang.String name)

Specified by:

releaseSavepoint in interface SessionInterface

addWarning

public void addWarning(HsqlException warning)

Specified by:

addWarning in interface SessionInterface

getId

public long getId()

Specified by:

getId in interface SessionInterface

resetSession

public void resetSession()

Used by pooled connections to reset the server-side session to a new one. In case of failure, the connection is closed. When the Connection.close() method is called, a pooled connection calls this method instead of HSQLClientConnection.close(). It can then reuse the HSQLClientConnection object with no further initialisation.

Specified by:

resetSession in interface SessionInterface

getInternalConnectionURL

public java.lang.String getInternalConnectionURL()

Never called on this class

Specified by:

getInternalConnectionURL in interface SessionInterface

getLobId

public long getLobId()

createBlob

public BlobDataID createBlob(long length)

Specified by:

createBlob in interface SessionInterface

createClob

public ClobDataID createClob(long length)

Specified by:

createClob in interface SessionInterface

allocateResultLob

public void allocateResultLob(ResultLob resultLob,
                              java.io.InputStream dataInput)

Does nothing here

Specified by:

allocateResultLob in interface SessionInterface

getScanner

public Scanner getScanner()

Specified by:

getScanner in interface SessionInterface

getCalendar

public java.util.Calendar getCalendar()

Specified by:

getCalendar in interface SessionInterface

getCalendarGMT

public java.util.Calendar getCalendarGMT()

Specified by:

getCalendarGMT in interface SessionInterface

getSimpleDateFormatGMT

public java.text.SimpleDateFormat getSimpleDateFormatGMT()

Specified by:

getSimpleDateFormatGMT in interface SessionInterface

getCurrentDate

public TimestampData getCurrentDate()

Specified by:

getCurrentDate in interface SessionInterface

getZoneSeconds

public int getZoneSeconds()

Specified by:

getZoneSeconds in interface SessionInterface

getStreamBlockSize

public int getStreamBlockSize()

Specified by:

getStreamBlockSize in interface SessionInterface

getClientProperties

public HsqlProperties getClientProperties()

Specified by:

getClientProperties in interface SessionInterface

getJDBCConnection

public JDBCConnection getJDBCConnection()

Specified by:

getJDBCConnection in interface SessionInterface

setJDBCConnection

public void setJDBCConnection(JDBCConnection connection)

Specified by:

setJDBCConnection in interface SessionInterface

getDatabaseUniqueName

public java.lang.String getDatabaseUniqueName()

Specified by:

getDatabaseUniqueName in interface SessionInterface

toNetCompVersionString

public static java.lang.String toNetCompVersionString(int i)

Converts specified encoded integer to a Network Compatibility Version String. The tranmitted integer is negative to distinguish it from 7 bit ASCII characters.