| java.lang.Object
 java.lang.Thread
org.apache.derby.impl.drda.DRDAConnThread
| Method Summary | |
| protected void | agentError(String msg)
| | protected String | buildRuntimeInfo(String indent, LocalizedResource localLangUtil)
| | protected void | close()
| | protected void | codePointNotSupported(int codePoint)
| | protected int | getCorrelationID()
| | protected byte[] | getCrrtkn()
| | protected Database | getDatabase()
| | protected String | getDbName()
| | protected InputStream | getInputStream()
| | protected OutputStream | getOutputStream()
| | protected DDMReader | getReader()
| | protected NetworkServerControlImpl | getServer()
| | protected Session | getSession()
| | protected DDMWriter | getWriter()
| | protected void | invalidCodePoint(int codePoint)
| | protected void | markCommunicationsFailure(String arg1, String arg2, String arg3, String arg4)
| | protected void | missingCodePoint(int codePoint)
| | protected void | parseSQLATTR(DRDAStatement stmt)
Parse SQLATTR - Cursor attributes on prepare
This is an encoded string. | | protected static void | println2Log(String dbname, String drdaID, String msg)
| | public void | run()
| | protected void | setLogConnections(boolean value)
| | protected void | setTimeSlice(long value)
| | public static void | showmem()
| | protected void | throwSyntaxrm(int errcd, int cpArg)
| | protected void | trace(String value)
| | void | writeEXTDTA(DRDAStatement stmt)
| | protected void | writeFdocaVal(int index, Object val, int drdaType, int precision, int scale, boolean valNull, DRDAStatement stmt)
| | protected void | writeRDBNAM(String rdbnam)
|
| DRDAConnThread | | DRDAConnThread(Session session, NetworkServerControlImpl server, long timeSlice, boolean logConnections)(Code) | | Create a new Thread for processing session requests
Parameters:
session - Session requesting processing
Parameters:
server - Server starting thread
Parameters:
timeSlice - timeSlice for thread
Parameters:
logConnections - |
| close | | protected void close()(Code) | | Close DRDA connection thread
|
| getCorrelationID | | protected int getCorrelationID()(Code) | | Get correlation id
correlation id |
| getCrrtkn | | protected byte[] getCrrtkn()(Code) | | Get correlation token
crrtkn |
| getDatabase | | protected Database getDatabase()(Code) | | Get Database we are working on
database |
| getDbName | | protected String getDbName()(Code) | | Get database name
database name |
| getInputStream | | protected InputStream getInputStream()(Code) | | Get input stream
input stream |
| getOutputStream | | protected OutputStream getOutputStream()(Code) | | Get output stream
output stream |
| getReader | | protected DDMReader getReader()(Code) | | get DDMReader
DDMReader for this thread |
| getSession | | protected Session getSession()(Code) | | Get session we are working on
session |
| getWriter | | protected DDMWriter getWriter()(Code) | | get DDMWriter
DDMWriter for this thread |
| markCommunicationsFailure | | protected void markCommunicationsFailure(String arg1, String arg2, String arg3, String arg4) throws DRDAProtocolException(Code) | | Indicate a communications failure
Parameters:
arg1 - - info about the communications failure
Parameters:
arg2 - - info about the communications failure
Parameters:
arg3 - - info about the communications failure
Parameters:
arg4 - - info about the communications failure
exception:
DRDAProtocolException - disconnect exception always thrown |
| parseSQLATTR | | protected void parseSQLATTR(DRDAStatement stmt) throws DRDAProtocolException(Code) | | Parse SQLATTR - Cursor attributes on prepare
This is an encoded string. Can have combination of following, eg INSENSITIVE SCROLL WITH HOLD
Possible strings are
SENSITIVE DYNAMIC SCROLL [FOR UPDATE]
SENSITIVE STATIC SCROLL [FOR UPDATE]
INSENSITIVE SCROLL
FOR UPDATE
WITH HOLD
Parameters:
stmt - DRDAStatement
exception:
DRDAProtocolException - |
| println2Log | | protected static void println2Log(String dbname, String drdaID, String msg)(Code) | | Print a line to the DB2j log
Parameters:
dbname - database name
Parameters:
drdaID - DRDA identifier
Parameters:
msg - message |
| run | | public void run()(Code) | | Main routine for thread, loops until the thread is closed
Gets a session, does work for the session
|
| setLogConnections | | protected void setLogConnections(boolean value)(Code) | | Set logging of connections
Parameters:
value - value to set for logging connections |
| setTimeSlice | | protected void setTimeSlice(long value)(Code) | | Set time slice value
Parameters:
value - new value for time slice |
| showmem | | public static void showmem()(Code) | | Show runtime memory
|
| trace | | protected void trace(String value)(Code) | | Send string to console
Parameters:
value - - value to print on console |
| writeFdocaVal | | protected void writeFdocaVal(int index, Object val, int drdaType, int precision, int scale, boolean valNull, DRDAStatement stmt) throws DRDAProtocolException, SQLException(Code) | | Write Fdoca Value to client
Parameters:
index - Index of column being returned
Parameters:
val - Value to write to client
Parameters:
drdaType - FD:OCA DRDA Type from FdocaConstants
Parameters:
precision - Precision
Parameters:
stmt - Statement being processed
exception:
DRDAProtocolException -
exception:
SQLException -
See Also: FdocaConstants |
|
|