Apache Derby Client JDBC Driver 10.17.1.0 · org.apache.derby.client.net.NetAgent

Modifier and Type	Field and Description
private int	clientSSLMode_
pack-priv ConnectionReply	connectionReply_
pack-priv ConnectionRequestInterface	connectionRequest_
private CcsidManager	currentCcsidManager_
private EbcdicCcsidManager	ebcdicCcsidManager_
pack-priv SqlException	exceptionConvertingRdbnam
pack-priv SqlException	exceptionOpeningSocket_
pack-priv NetConnection	netConnection_
pack-priv NetConnectionReply	netConnectionReply_
pack-priv NetConnectionRequest	netConnectionRequest_
private NetPackageReply	netPackageReply_
private NetPackageRequest	netPackageRequest_
private NetResultSetReply	netResultSetReply_
private NetResultSetRequest	netResultSetRequest_
private NetStatementReply	netStatementReply_
private NetStatementRequest	netStatementRequest_
pack-priv Typdef	originalTargetTypdef_
pack-priv int	orignalTargetSqlam_
private ConnectionReply	packageReply_
pack-priv int	port_
private InputStream	rawSocketInputStream_
private OutputStream	rawSocketOutputStream_
private Reply	reply_
private Request	request_
pack-priv ResultSetReply	resultSetReply_
pack-priv ResultSetRequestInterface	resultSetRequest_
pack-priv String	server_
pack-priv Socket	socket_
pack-priv StatementReply	statementReply_
pack-priv StatementRequestInterface	statementRequest_
private int	svrcod_
pack-priv int	targetSqlam_
pack-priv Typdef	targetTypdef_
pack-priv Typdef	typdef_
private Utf8CcsidManager	utf8CcsidManager_
private boolean	writeChainIsDirty_ Flag which indicates that a writeChain has been started and data sent to the server.

Access	Constructor and Description
public	NetAgent(NetConnection netConnection, LogWriter logWriter)
pack-priv	NetAgent(NetConnection netConnection, LogWriter netLogWriter, int loginTimeout, String server, int port, int clientSSLMode)

Method Summary

Modifier and Type	Method and Description
protected void	beginReadChain(ClientStatement statement) Overrides org.apache.derby.client.am.Agent.beginReadChain.
protected void	beginReadChainOutsideUOW() Overrides org.apache.derby.client.am.Agent.beginReadChainOutsideUOW.
public void	beginWriteChain(ClientStatement statement) Overrides org.apache.derby.client.am.Agent.beginWriteChain.
public void	beginWriteChainOutsideUOW() Implements abstract org.apache.derby.client.am.Agent.beginWriteChainOutsideUOW.
public void	checkForChainBreakingException_() Implements abstract org.apache.derby.client.am.Agent.checkForChainBreakingException_.
pack-priv void	clearSvrcod()
public void	close_() Implements abstract org.apache.derby.client.am.Agent.close_.
protected void	endWriteChain() Implements abstract org.apache.derby.client.am.Agent.endWriteChain.
public void	flush_() Implements abstract org.apache.derby.client.am.Agent.flush_.
public CcsidManager	getCurrentCcsidManager()
public InputStream	getInputStream()
public OutputStream	getOutputStream()
private int	getSvrcod()
protected int	Returns: The timeout value in seconds. A value of 0 corresponds to that no timeout is specified on the socket. getTimeout() Returns the current timeout value that is set on the socket.
protected void	markChainBreakingException_() Implements abstract org.apache.derby.client.am.Agent.markChainBreakingException_.
pack-priv void	markWriteChainAsDirty() Marks the agent's write chain as dirty.
private void	readDeferredResetConnection()
protected void	resetAgent_(LogWriter netLogWriter, int loginTimeout, String server, int port) Implements abstract org.apache.derby.client.am.Agent.resetAgent_.
private void	sendRequest()
pack-priv void	setInputStream(InputStream inputStream)
pack-priv void	setOutputStream(OutputStream outputStream)
pack-priv void	setSvrcod(int svrcod)
protected void	setTimeout(int The timeout value in seconds. A value of 0 corresponds to infinite timeout. timeout) Specifies the maximum blocking time that should be used when sending and receiving messages.
pack-priv void	switchToEbcdicMgr() Switches the current CCSID manager to EBCDIC
pack-priv void	switchToUtf8CcsidMgr() Switches the current CCSID manager to UTF-8
pack-priv void	throwCommunicationsFailure(Throwable cause)
private void	verifyWriteChainIsClean()
private void	writeDeferredResetConnection()

Inherited from org.apache.derby.client.am.Agent:: accumulateChainBreakingReadExceptionAndThrow accumulateReadException checkForExceptions close endReadChain flow flowOutsideUOW getLogWriter loggingEnabled setBatchedExceptionLabelIndex setLogWriter

Field Detail

clientSSLMode_	back to summary
private int clientSSLMode_

connectionReply_	back to summary
pack-priv ConnectionReply connectionReply_

connectionRequest_	back to summary
pack-priv ConnectionRequestInterface connectionRequest_

currentCcsidManager_	back to summary
private CcsidManager currentCcsidManager_

ebcdicCcsidManager_	back to summary
private EbcdicCcsidManager ebcdicCcsidManager_

exceptionConvertingRdbnam	back to summary
pack-priv SqlException exceptionConvertingRdbnam

exceptionOpeningSocket_	back to summary
pack-priv SqlException exceptionOpeningSocket_

netConnection_	back to summary
pack-priv NetConnection netConnection_

netConnectionReply_	back to summary
pack-priv NetConnectionReply netConnectionReply_

netConnectionRequest_	back to summary
pack-priv NetConnectionRequest netConnectionRequest_

netPackageReply_	back to summary
private NetPackageReply netPackageReply_

netPackageRequest_	back to summary
private NetPackageRequest netPackageRequest_

netResultSetReply_	back to summary
private NetResultSetReply netResultSetReply_

netResultSetRequest_	back to summary
private NetResultSetRequest netResultSetRequest_

netStatementReply_	back to summary
private NetStatementReply netStatementReply_

netStatementRequest_	back to summary
private NetStatementRequest netStatementRequest_

originalTargetTypdef_	back to summary
pack-priv Typdef originalTargetTypdef_

orignalTargetSqlam_	back to summary
pack-priv int orignalTargetSqlam_

packageReply_	back to summary
private ConnectionReply packageReply_

port_	back to summary
pack-priv int port_

rawSocketInputStream_	back to summary
private InputStream rawSocketInputStream_

rawSocketOutputStream_	back to summary
private OutputStream rawSocketOutputStream_

reply_	back to summary
private Reply reply_

request_	back to summary
private Request request_

resultSetReply_	back to summary
pack-priv ResultSetReply resultSetReply_

resultSetRequest_	back to summary
pack-priv ResultSetRequestInterface resultSetRequest_

server_	back to summary
pack-priv String server_

socket_	back to summary
pack-priv Socket socket_

statementReply_	back to summary
pack-priv StatementReply statementReply_

statementRequest_	back to summary
pack-priv StatementRequestInterface statementRequest_

svrcod_	back to summary
private int svrcod_

targetSqlam_	back to summary
pack-priv int targetSqlam_

targetTypdef_	back to summary
pack-priv Typdef targetTypdef_

typdef_	back to summary
pack-priv Typdef typdef_

utf8CcsidManager_	back to summary
private Utf8CcsidManager utf8CcsidManager_

writeChainIsDirty_	back to summary
private boolean writeChainIsDirty_ Flag which indicates that a writeChain has been started and data sent to the server. If true, starting a new write chain will throw a DisconnectException. It is cleared when the write chain is ended.

Constructor Detail

NetAgent	back to summary
public NetAgent(NetConnection netConnection, LogWriter logWriter) throws SqlException

NetAgent	back to summary
pack-priv NetAgent(NetConnection netConnection, LogWriter netLogWriter, int loginTimeout, String server, int port, int clientSSLMode) throws SqlException

Method Detail

beginReadChain	back to summary
protected void beginReadChain(ClientStatement statement) throws SqlException Overrides org.apache.derby.client.am.Agent.beginReadChain.

beginReadChainOutsideUOW	back to summary
protected void beginReadChainOutsideUOW() throws SqlException Overrides org.apache.derby.client.am.Agent.beginReadChainOutsideUOW.

beginWriteChain	back to summary
public void beginWriteChain(ClientStatement statement) throws SqlException Overrides org.apache.derby.client.am.Agent.beginWriteChain.

beginWriteChainOutsideUOW	back to summary
public void beginWriteChainOutsideUOW() throws SqlException Implements abstract org.apache.derby.client.am.Agent.beginWriteChainOutsideUOW.

checkForChainBreakingException_	back to summary
public void checkForChainBreakingException_() throws SqlException Implements abstract org.apache.derby.client.am.Agent.checkForChainBreakingException_.

clearSvrcod	back to summary
pack-priv void clearSvrcod()

close_	back to summary
public void close_() throws SqlException Implements abstract org.apache.derby.client.am.Agent.close_.

endWriteChain	back to summary
protected void endWriteChain() Implements abstract org.apache.derby.client.am.Agent.endWriteChain.

flush_	back to summary
public void flush_() throws DisconnectException Implements abstract org.apache.derby.client.am.Agent.flush_.

getCurrentCcsidManager	back to summary
public CcsidManager getCurrentCcsidManager()

getInputStream	back to summary
public InputStream getInputStream()

getOutputStream	back to summary
public OutputStream getOutputStream()

getSvrcod	back to summary
private int getSvrcod()

getTimeout

back to summary

protected int getTimeout()

Returns the current timeout value that is set on the socket. Note that the support for timeout on sockets is dependent on the OS implementation. For the same reason we ignore any exceptions thrown by the call to the socket layer.

Returns:int: The timeout value in seconds. A value of 0 corresponds to that no timeout is specified on the socket.

markChainBreakingException_	back to summary
protected void markChainBreakingException_() Implements abstract org.apache.derby.client.am.Agent.markChainBreakingException_.

markWriteChainAsDirty

back to summary

pack-priv void markWriteChainAsDirty()

Marks the agent's write chain as dirty. A write chain is dirty when data from it has been sent to the server. A dirty write chain cannot be reset and reused for another request until the remaining data has been sent to the server and the write chain properly ended. Resetting a dirty chain will cause the new request to be appended to the unfinished request already at the server, which will likely lead to cryptic syntax errors.

readDeferredResetConnection	back to summary
private void readDeferredResetConnection() throws SqlException

resetAgent_	back to summary
protected void resetAgent_(LogWriter netLogWriter, int loginTimeout, String server, int port) throws SqlException Implements abstract org.apache.derby.client.am.Agent.resetAgent_.

sendRequest	back to summary
private void sendRequest() throws DisconnectException

setInputStream	back to summary
pack-priv void setInputStream(InputStream inputStream)

setOutputStream	back to summary
pack-priv void setOutputStream(OutputStream outputStream)

setSvrcod	back to summary
pack-priv void setSvrcod(int svrcod)

setTimeout

back to summary

protected void setTimeout(int timeout)

Specifies the maximum blocking time that should be used when sending and receiving messages. The timeout is implemented by using the the underlying socket implementation's timeout support. Note that the support for timeout on sockets is dependent on the OS implementation. For the same reason we ignore any exceptions thrown by the call to the socket layer.

Parameters

timeout:int: The timeout value in seconds. A value of 0 corresponds to infinite timeout.

switchToEbcdicMgr	back to summary
pack-priv void switchToEbcdicMgr() Switches the current CCSID manager to EBCDIC

switchToUtf8CcsidMgr	back to summary
pack-priv void switchToUtf8CcsidMgr() Switches the current CCSID manager to UTF-8

throwCommunicationsFailure	back to summary
pack-priv void throwCommunicationsFailure(Throwable cause) throws DisconnectException

verifyWriteChainIsClean	back to summary
private void verifyWriteChainIsClean() throws DisconnectException

writeDeferredResetConnection	back to summary
private void writeDeferredResetConnection() throws SqlException

public Class NetAgent

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail