Package org.apache.derby.client.net
Class NetConnectionRequest
- java.lang.Object
-
- org.apache.derby.client.net.Request
-
- org.apache.derby.client.net.NetConnectionRequest
-
- All Implemented Interfaces:
ConnectionRequestInterface
- Direct Known Subclasses:
NetPackageRequest
class NetConnectionRequest extends Request implements ConnectionRequestInterface
-
-
Field Summary
-
Fields inherited from class org.apache.derby.client.net.Request
buffer, netAgent_, passwordIncluded_, passwordLength_, passwordStart_
-
-
Constructor Summary
Constructors Constructor Description NetConnectionRequest(NetAgent netAgent, int bufferSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private voidbuildACCRDB(java.lang.String rdbnam, boolean readOnly, byte[] crrtkn, byte[] prddta, Typdef typdef)private voidbuildACCSEC(int secmec, java.lang.String rdbnam, byte[] sectkn)private voidbuildCRRTKN(byte[] crrtkn)private voidbuildDummyEXCSAT()private voidbuildEXCSAT(java.lang.String externalName, int targetAgent, int targetSqlam, int targetRdb, int targetSecmgr, int targetCmntcpip, int targetCmnappc, int targetXamgr, int targetSyncptmgr, int targetRsyncmgr, int targetUnicodemgr)private voidbuildEXTNAM(java.lang.String extnam)private voidbuildMGRLVLLS(int agent, int sqlam, int rdb, int secmgr, int xamgr, int syncptmgr, int rsyncmgr, int unicodemgr)private voidbuildPASSWORD(java.lang.String password)private voidbuildPRDDTA(byte[] prddta)private voidbuildPRDID()private voidbuildRDBACCCL()private voidbuildRDBALWUPD(boolean readOnly)private voidbuildRDBCMM()private voidbuildRDBNAM(java.lang.String rdbnam, boolean dontSendOnConversionError)Relational Database Name specifies the name of a relational database of the server.private voidbuildRDBRLLBCK()private voidbuildSECCHK(int secmec, java.lang.String rdbnam, java.lang.String user, java.lang.String password, byte[] sectkn, byte[] sectkn2)private voidbuildSECMEC(int secmec)private voidbuildSECTKN(byte[] sectkn)private voidbuildSRVCLSNM()private voidbuildSRVNAM(java.lang.String srvnam)private voidbuildSRVRLSLV()(package private) voidbuildSYNCCTLCommit(int xaFlags, javax.transaction.xa.Xid xid)(package private) voidbuildSYNCCTLMigrate()(package private) voidbuildSYNCCTLRollback(int xaFlags)private voidbuildTYPDEFNAM(java.lang.String typdefnam)private voidbuildTYPDEFOVR(boolean sendCcsidSbc, int ccsidSbc, boolean sendCcsidDbc, int ccsidDbc, boolean sendCcsidMbc, int ccsidMbc)private voidbuildUSRID(java.lang.String usrid)(package private) voidwriteAccessDatabase(java.lang.String rdbnam, boolean readOnly, byte[] correlationToken, byte[] productData, Typdef typdef)(package private) voidwriteAccessSecurity(int securityMechanism, java.lang.String databaseName, byte[] publicKey)voidwriteCommitSubstitute(NetConnection connection)(package private) voidwriteExchangeServerAttributes(java.lang.String externalName, int targetAgent, int targetSqlam, int targetRdb, int targetSecmgr, int targetCmntcpip, int targetCmnappc, int targetXamgr, int targetSyncptmgr, int targetRsyncmgr, int targetUnicodemgr)voidwriteForget(int codepoint, int value)voidwriteLocalCommit(NetConnection connection)voidwriteLocalRollback(NetConnection connection)voidwriteLocalXACommit(NetConnection conn)voidwriteLocalXARollback(NetConnection conn)voidwriteLocalXAStart(NetConnection connection)(package private) voidwriteNullXID(int codepoint)voidwriteReleaseConversation(int codepoint, int value)(package private) voidwriteSecurityCheck(int securityMechanism, java.lang.String databaseName, java.lang.String userid, java.lang.String password, byte[] encryptedUserid, byte[] encryptedPassword)voidwriteSYNCType(int codepoint, int syncType)protected voidwriteXaCommit(NetConnection conn, javax.transaction.xa.Xid xid)voidwriteXaEndUnitOfWork(NetConnection conn)(package private) voidwriteXAFlags(int codepoint, int xaFlags)protected voidwriteXaForget(NetConnection conn, javax.transaction.xa.Xid xid)protected voidwriteXaPrepare(NetConnection conn)protected voidwriteXaRecover(NetConnection conn, int flag)protected voidwriteXaRollback(NetConnection conn, javax.transaction.xa.Xid xid)voidwriteXaStartUnitOfWork(NetConnection conn)(package private) voidwriteXATimeout(int codepoint, long xaTimeout)(package private) voidwriteXID(int codepoint, javax.transaction.xa.Xid xid)-
Methods inherited from class org.apache.derby.client.net.Request
buildTripletHeader, createCommand, createCommandData, createEncryptedCommandData, flush, initialize, markForCachingPKGNAMCSN, markLengthBytes, popMarkForCachingPKGNAMCSN, setCorrelationID, setDssLengthLocation, updateLengthBytes, write1Byte, write2Bytes, write4Bytes, writeBigDecimal, writeBoolean, writeBytes, writeBytes, writeCodePoint4Bytes, writeDate, writeDouble, writeFloat, writeInt, writeIntFdocaData, writeLDBytes, writeLengthCodePoint, writeLidAndLengths, writeLong, writeLong6Bytes, writeLongFdocaData, writeScalar1Byte, writeScalar2Bytes, writeScalar4Bytes, writeScalar8Bytes, writeScalarBytes, writeScalarBytes, writeScalarPaddedBytes, writeScalarStream, writeScalarStream, writeScalarStream, writeScalarStream, writeScalarString, writeScalarString, writeShort, writeShortFdocaData, writeSingleorMixedCcsidLDString, writeTime, writeTimestamp, writeUDT
-
-
-
-
Constructor Detail
-
NetConnectionRequest
NetConnectionRequest(NetAgent netAgent, int bufferSize)
-
-
Method Detail
-
writeExchangeServerAttributes
void writeExchangeServerAttributes(java.lang.String externalName, int targetAgent, int targetSqlam, int targetRdb, int targetSecmgr, int targetCmntcpip, int targetCmnappc, int targetXamgr, int targetSyncptmgr, int targetRsyncmgr, int targetUnicodemgr) throws SqlException- Throws:
SqlException
-
writeAccessSecurity
void writeAccessSecurity(int securityMechanism, java.lang.String databaseName, byte[] publicKey) throws SqlException- Throws:
SqlException
-
writeSecurityCheck
void writeSecurityCheck(int securityMechanism, java.lang.String databaseName, java.lang.String userid, java.lang.String password, byte[] encryptedUserid, byte[] encryptedPassword) throws SqlException- Throws:
SqlException
-
writeAccessDatabase
void writeAccessDatabase(java.lang.String rdbnam, boolean readOnly, byte[] correlationToken, byte[] productData, Typdef typdef) throws SqlException- Throws:
SqlException
-
writeCommitSubstitute
public void writeCommitSubstitute(NetConnection connection) throws SqlException
- Specified by:
writeCommitSubstitutein interfaceConnectionRequestInterface- Throws:
SqlException
-
writeLocalCommit
public void writeLocalCommit(NetConnection connection) throws SqlException
- Specified by:
writeLocalCommitin interfaceConnectionRequestInterface- Throws:
SqlException
-
writeLocalRollback
public void writeLocalRollback(NetConnection connection) throws SqlException
- Specified by:
writeLocalRollbackin interfaceConnectionRequestInterface- Throws:
SqlException
-
writeLocalXAStart
public void writeLocalXAStart(NetConnection connection) throws SqlException
- Specified by:
writeLocalXAStartin interfaceConnectionRequestInterface- Throws:
SqlException
-
writeLocalXACommit
public void writeLocalXACommit(NetConnection conn) throws SqlException
- Specified by:
writeLocalXACommitin interfaceConnectionRequestInterface- Throws:
SqlException
-
writeLocalXARollback
public void writeLocalXARollback(NetConnection conn) throws SqlException
- Specified by:
writeLocalXARollbackin interfaceConnectionRequestInterface- Throws:
SqlException
-
writeXaStartUnitOfWork
public void writeXaStartUnitOfWork(NetConnection conn) throws SqlException
- Throws:
SqlException
-
writeXaEndUnitOfWork
public void writeXaEndUnitOfWork(NetConnection conn) throws SqlException
- Throws:
SqlException
-
writeXaPrepare
protected void writeXaPrepare(NetConnection conn) throws SqlException
- Throws:
SqlException
-
writeXaCommit
protected void writeXaCommit(NetConnection conn, javax.transaction.xa.Xid xid) throws SqlException
- Throws:
SqlException
-
writeXaRollback
protected void writeXaRollback(NetConnection conn, javax.transaction.xa.Xid xid) throws SqlException
- Throws:
SqlException
-
writeXaRecover
protected void writeXaRecover(NetConnection conn, int flag) throws SqlException
- Throws:
SqlException
-
writeXaForget
protected void writeXaForget(NetConnection conn, javax.transaction.xa.Xid xid) throws SqlException
- Throws:
SqlException
-
writeSYNCType
public void writeSYNCType(int codepoint, int syncType)
-
writeForget
public void writeForget(int codepoint, int value)
-
writeReleaseConversation
public void writeReleaseConversation(int codepoint, int value)
-
writeNullXID
void writeNullXID(int codepoint)
-
writeXID
void writeXID(int codepoint, javax.transaction.xa.Xid xid) throws SqlException- Throws:
SqlException
-
writeXAFlags
void writeXAFlags(int codepoint, int xaFlags)
-
writeXATimeout
void writeXATimeout(int codepoint, long xaTimeout)
-
buildRDBCMM
private void buildRDBCMM() throws SqlException- Throws:
SqlException
-
buildRDBRLLBCK
private void buildRDBRLLBCK() throws SqlException- Throws:
SqlException
-
buildEXCSAT
private void buildEXCSAT(java.lang.String externalName, int targetAgent, int targetSqlam, int targetRdb, int targetSecmgr, int targetCmntcpip, int targetCmnappc, int targetXamgr, int targetSyncptmgr, int targetRsyncmgr, int targetUnicodemgr) throws SqlException- Throws:
SqlException
-
buildDummyEXCSAT
private void buildDummyEXCSAT() throws SqlException- Throws:
SqlException
-
buildACCSEC
private void buildACCSEC(int secmec, java.lang.String rdbnam, byte[] sectkn) throws SqlException- Throws:
SqlException
-
buildSECCHK
private void buildSECCHK(int secmec, java.lang.String rdbnam, java.lang.String user, java.lang.String password, byte[] sectkn, byte[] sectkn2) throws SqlException- Throws:
SqlException
-
buildACCRDB
private void buildACCRDB(java.lang.String rdbnam, boolean readOnly, byte[] crrtkn, byte[] prddta, Typdef typdef) throws SqlException- Throws:
SqlException
-
buildSYNCCTLMigrate
void buildSYNCCTLMigrate() throws SqlException- Throws:
SqlException
-
buildSYNCCTLCommit
void buildSYNCCTLCommit(int xaFlags, javax.transaction.xa.Xid xid) throws SqlException- Throws:
SqlException
-
buildSYNCCTLRollback
void buildSYNCCTLRollback(int xaFlags) throws SqlException- Throws:
SqlException
-
buildEXTNAM
private void buildEXTNAM(java.lang.String extnam) throws SqlException- Throws:
SqlException
-
buildSRVNAM
private void buildSRVNAM(java.lang.String srvnam) throws SqlException- Throws:
SqlException
-
buildSRVRLSLV
private void buildSRVRLSLV() throws SqlException- Throws:
SqlException
-
buildSRVCLSNM
private void buildSRVCLSNM() throws SqlException- Throws:
SqlException
-
buildSECMEC
private void buildSECMEC(int secmec) throws SqlException- Throws:
SqlException
-
buildRDBNAM
private void buildRDBNAM(java.lang.String rdbnam, boolean dontSendOnConversionError) throws SqlExceptionRelational Database Name specifies the name of a relational database of the server. if length of RDB name <= 18 characters, there is not change to the format of the RDB name. The length of the RDBNAM remains fixed at 18 which includes any right bland padding if necessary. if length of the RDB name is > 18 characters, the length of the RDB name is identical to the length of the RDB name. No right blank padding is required.- Parameters:
rdbnam- name of the database.dontSendOnConversionError- omit sending the RDBNAM if there is an exception converting to EBCDIC. This will be used by ACCSEC to defer sending the RDBNAM to SECCHK if it can't be converted.- Throws:
SqlException
-
buildSECTKN
private void buildSECTKN(byte[] sectkn) throws SqlException- Throws:
SqlException
-
buildUSRID
private void buildUSRID(java.lang.String usrid) throws SqlException- Throws:
SqlException
-
buildPASSWORD
private void buildPASSWORD(java.lang.String password) throws SqlException- Throws:
SqlException
-
buildRDBACCCL
private void buildRDBACCCL() throws SqlException- Throws:
SqlException
-
buildPRDID
private void buildPRDID() throws SqlException- Throws:
SqlException
-
buildPRDDTA
private void buildPRDDTA(byte[] prddta) throws SqlException- Throws:
SqlException
-
buildTYPDEFNAM
private void buildTYPDEFNAM(java.lang.String typdefnam) throws SqlException- Throws:
SqlException
-
buildTYPDEFOVR
private void buildTYPDEFOVR(boolean sendCcsidSbc, int ccsidSbc, boolean sendCcsidDbc, int ccsidDbc, boolean sendCcsidMbc, int ccsidMbc) throws SqlException- Throws:
SqlException
-
buildMGRLVLLS
private void buildMGRLVLLS(int agent, int sqlam, int rdb, int secmgr, int xamgr, int syncptmgr, int rsyncmgr, int unicodemgr) throws SqlException- Throws:
SqlException
-
buildCRRTKN
private void buildCRRTKN(byte[] crrtkn) throws SqlException- Throws:
SqlException
-
buildRDBALWUPD
private void buildRDBALWUPD(boolean readOnly) throws SqlException- Throws:
SqlException
-
-