|
||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||
java.lang.Objectorg.h2.engine.SessionRemote
public class SessionRemote
The client side part of a session when using the server mode. This object communicates with a Session on the server side.
| Field Summary | |
|---|---|
static int |
CHANGE_ID
|
static int |
COMMAND_CLOSE
|
static int |
COMMAND_COMMIT
|
static int |
COMMAND_EXECUTE_QUERY
|
static int |
COMMAND_EXECUTE_UPDATE
|
static int |
COMMAND_GET_META_DATA
|
static int |
LOB_READ
|
static int |
RESULT_CLOSE
|
static int |
RESULT_FETCH_ROWS
|
static int |
RESULT_RESET
|
static int |
SESSION_CANCEL_STATEMENT
|
static int |
SESSION_CHECK_KEY
|
static int |
SESSION_CLOSE
|
static int |
SESSION_PREPARE
|
static int |
SESSION_PREPARE_READ_PARAMS
|
static int |
SESSION_SET_AUTOCOMMIT
|
static int |
SESSION_SET_ID
|
static int |
SESSION_UNDO_LOG_POS
|
protected java.util.ArrayList<java.lang.String> |
sessionState
|
protected boolean |
sessionStateChanged
|
static int |
STATUS_CLOSED
|
static int |
STATUS_ERROR
|
static int |
STATUS_OK
|
static int |
STATUS_OK_STATE_CHANGED
|
| Constructor Summary | |
|---|---|
SessionRemote(ConnectionInfo ci)
|
|
| Method Summary | |
|---|---|
void |
afterWriting()
Called after writing has ended. |
void |
autoCommitIfCluster()
Calls COMMIT if the session is in cluster mode. |
void |
cancel()
Cancel the current or next command (called when closing a connection). |
void |
cancelStatement(int id)
Cancel the statement with the given id. |
void |
checkClosed()
Check if this session is closed and throws an exception if so. |
void |
checkPowerOff()
Check if the simulated power failure occurred. |
void |
checkWritingAllowed()
Check if writing is allowed. |
void |
close()
Roll back pending transactions and close the session. |
SessionInterface |
connectEmbeddedOrServer(boolean openNew)
Open a new (remote or embedded) session. |
void |
done(Transfer transfer)
Called to flush the output after data has been sent to the server and just before receiving data. |
boolean |
getAutoCommit()
Check if this session is in auto-commit mode. |
int |
getCurrentId()
|
java.lang.String |
getDatabasePath()
Get the database path. |
DataHandler |
getDataHandler()
Get the data handler object. |
int |
getLastReconnect()
|
java.lang.String |
getLobCompressionAlgorithm(int type)
Get the compression algorithm used for large objects. |
java.sql.Connection |
getLobConnection()
Get a database connection to be used for LOB access. |
SmallLRUCache<java.lang.String,java.lang.String[]> |
getLobFileListCache()
Get the lob file list cache if it is used. |
LobStorage |
getLobStorage()
Get the lob storage mechanism to use. |
java.lang.Object |
getLobSyncObject()
Get the synchronization object for lob operations. |
int |
getMaxLengthInplaceLob()
Get the maximum length of a in-place large object |
int |
getNextId()
|
int |
getPowerOffCount()
Get the number of disk operations before power failure is simulated. |
TempFileDeleter |
getTempFileDeleter()
Get the temp file deleter mechanism. |
Trace |
getTrace()
Get the trace object |
int |
getUndoLogPos()
Get the undo log position. |
boolean |
isClosed()
Check if close was called. |
boolean |
isClustered()
Returns true if the connection was opened in cluster mode. |
boolean |
isReconnectNeeded(boolean write)
Check if the database changed and therefore reconnecting is required. |
FileStore |
openFile(java.lang.String name,
java.lang.String mode,
boolean mustExist)
Open a file at the given location. |
CommandInterface |
prepareCommand(java.lang.String sql,
int fetchSize)
Parse a command and prepare it for execution. |
int |
readLob(long lobId,
long offset,
byte[] buff,
int off,
int length)
Read from a lob. |
void |
readSessionState()
Read the session state if necessary. |
SessionInterface |
reconnect(boolean write)
Close the connection and open a new connection. |
protected void |
recreateSessionState()
Re-create the session state using the stored sessionState list. |
void |
removeServer(java.io.IOException e,
int i,
int count)
Remove a server from the list of cluster nodes and disables the cluster mode. |
void |
setAutoCommit(boolean autoCommit)
Set the auto-commit mode. |
void |
setAutoCommitFromServer(boolean autoCommit)
|
void |
setPowerOffCount(int count)
Set the number of disk operations before power failure is simulated. |
void |
traceOperation(java.lang.String operation,
int id)
Write the operation to the trace system if debug trace is enabled. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
public static final int SESSION_PREPARE
public static final int SESSION_CLOSE
public static final int COMMAND_EXECUTE_QUERY
public static final int COMMAND_EXECUTE_UPDATE
public static final int COMMAND_CLOSE
public static final int RESULT_FETCH_ROWS
public static final int RESULT_RESET
public static final int RESULT_CLOSE
public static final int COMMAND_COMMIT
public static final int CHANGE_ID
public static final int COMMAND_GET_META_DATA
public static final int SESSION_PREPARE_READ_PARAMS
public static final int SESSION_SET_ID
public static final int SESSION_CANCEL_STATEMENT
public static final int SESSION_CHECK_KEY
public static final int SESSION_SET_AUTOCOMMIT
public static final int SESSION_UNDO_LOG_POS
public static final int LOB_READ
public static final int STATUS_ERROR
public static final int STATUS_OK
public static final int STATUS_CLOSED
public static final int STATUS_OK_STATE_CHANGED
protected java.util.ArrayList<java.lang.String> sessionState
protected boolean sessionStateChanged
| Constructor Detail |
|---|
public SessionRemote(ConnectionInfo ci)
| Method Detail |
|---|
public int getUndoLogPos()
SessionInterface
getUndoLogPos in interface SessionInterfacepublic void cancel()
SessionInterface
cancel in interface SessionInterfacepublic void cancelStatement(int id)
id - the statement idpublic boolean getAutoCommit()
SessionInterface
getAutoCommit in interface SessionInterfacepublic void setAutoCommit(boolean autoCommit)
SessionInterface
setAutoCommit in interface SessionInterfaceautoCommit - the new valuepublic void setAutoCommitFromServer(boolean autoCommit)
public void autoCommitIfCluster()
public int getPowerOffCount()
SessionInterface
getPowerOffCount in interface SessionInterfacepublic void setPowerOffCount(int count)
SessionInterface
setPowerOffCount in interface SessionInterfacecount - the number of operationspublic SessionInterface connectEmbeddedOrServer(boolean openNew)
openNew - whether to open a new session in any case
public void removeServer(java.io.IOException e,
int i,
int count)
e - the exception (used for debugging)i - the index of the server to removecount - the retry count index
public CommandInterface prepareCommand(java.lang.String sql,
int fetchSize)
SessionInterface
prepareCommand in interface SessionInterfacesql - the SQL statementfetchSize - the number of rows to fetch in one step
public void checkClosed()
DbException - if the session is closedpublic void close()
SessionInterface
close in interface java.io.Closeableclose in interface SessionInterfacepublic Trace getTrace()
SessionInterface
getTrace in interface SessionInterfacepublic int getNextId()
public int getCurrentId()
public void done(Transfer transfer)
throws java.io.IOException
transfer - the transfer object
DbException - if the server sent an exception
java.io.IOException - if there is a communication problem between client
and serverpublic boolean isClustered()
public boolean isClosed()
SessionInterface
isClosed in interface SessionInterface
public void traceOperation(java.lang.String operation,
int id)
operation - the operation performedid - the id of the operationpublic void checkPowerOff()
DataHandler
checkPowerOff in interface DataHandlerpublic void checkWritingAllowed()
DataHandler
checkWritingAllowed in interface DataHandlerpublic java.lang.String getDatabasePath()
DataHandler
getDatabasePath in interface DataHandlerpublic java.lang.String getLobCompressionAlgorithm(int type)
DataHandler
getLobCompressionAlgorithm in interface DataHandlertype - the data type (CLOB or BLOB)
public int getMaxLengthInplaceLob()
DataHandler
getMaxLengthInplaceLob in interface DataHandler
public FileStore openFile(java.lang.String name,
java.lang.String mode,
boolean mustExist)
DataHandler
openFile in interface DataHandlername - the file namemode - the modemustExist - whether the file must already exist
public DataHandler getDataHandler()
SessionInterface
getDataHandler in interface SessionInterfacepublic java.lang.Object getLobSyncObject()
DataHandler
getLobSyncObject in interface DataHandlerpublic SmallLRUCache<java.lang.String,java.lang.String[]> getLobFileListCache()
DataHandler
getLobFileListCache in interface DataHandlerpublic int getLastReconnect()
public TempFileDeleter getTempFileDeleter()
DataHandler
getTempFileDeleter in interface DataHandlerpublic boolean isReconnectNeeded(boolean write)
SessionInterface
isReconnectNeeded in interface SessionInterfacewrite - if the next operation may be writing
public SessionInterface reconnect(boolean write)
SessionInterface
reconnect in interface SessionInterfacewrite - if the next operation may be writing
public void afterWriting()
SessionInterface
afterWriting in interface SessionInterfacepublic LobStorage getLobStorage()
DataHandler
getLobStorage in interface DataHandlerpublic java.sql.Connection getLobConnection()
DataHandler
getLobConnection in interface DataHandler
public int readLob(long lobId,
long offset,
byte[] buff,
int off,
int length)
DataHandler
readLob in interface DataHandlerlobId - the loboffset - the offset within the lobbuff - the target bufferoff - the offset within the target bufferlength - the number of bytes to read
protected void recreateSessionState()
public void readSessionState()
|
||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||