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 Request

buffer, netAgent_, passwordIncluded_, passwordLength_, passwordStart_

Constructor Summary

Constructors

Constructor	Description
NetConnectionRequest(NetAgent netAgent, int bufferSize)

Method Summary

Modifier and Type	Method	Description
private void	buildACCRDB(String rdbnam, boolean readOnly, byte[] crrtkn, byte[] prddta, Typdef typdef)
private void	buildACCSEC(int secmec, String rdbnam, byte[] sectkn)
private void	buildCRRTKN(byte[] crrtkn)
private void	buildDummyEXCSAT()
private void	buildEXCSAT(String externalName, int targetAgent, int targetSqlam, int targetRdb, int targetSecmgr, int targetCmntcpip, int targetCmnappc, int targetXamgr, int targetSyncptmgr, int targetRsyncmgr, int targetUnicodemgr)
private void	buildEXTNAM(String extnam)
private void	buildMGRLVLLS(int agent, int sqlam, int rdb, int secmgr, int xamgr, int syncptmgr, int rsyncmgr, int unicodemgr)
private void	buildPASSWORD(String password)
private void	buildPRDDTA(byte[] prddta)
private void	buildPRDID()
private void	buildRDBACCCL()
private void	buildRDBALWUPD(boolean readOnly)
private void	buildRDBCMM()
private void	buildRDBNAM(String rdbnam, boolean dontSendOnConversionError)	Relational 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.
private void	buildRDBRLLBCK()
private void	buildSECCHK(int secmec, String rdbnam, String user, String password, byte[] sectkn, byte[] sectkn2)
private void	buildSECMEC(int secmec)
private void	buildSECTKN(byte[] sectkn)
private void	buildSRVCLSNM()
private void	buildSRVNAM(String srvnam)
private void	buildSRVRLSLV()
(package private) void	buildSYNCCTLCommit(int xaFlags, Xid xid)
(package private) void	buildSYNCCTLMigrate()
(package private) void	buildSYNCCTLRollback(int xaFlags)
private void	buildTYPDEFNAM(String typdefnam)
private void	buildTYPDEFOVR(boolean sendCcsidSbc, int ccsidSbc, boolean sendCcsidDbc, int ccsidDbc, boolean sendCcsidMbc, int ccsidMbc)
private void	buildUSRID(String usrid)
(package private) void	writeAccessDatabase(String rdbnam, boolean readOnly, byte[] correlationToken, byte[] productData, Typdef typdef)
(package private) void	writeAccessSecurity(int securityMechanism, String databaseName, byte[] publicKey)
void	writeCommitSubstitute(NetConnection connection)
(package private) void	writeExchangeServerAttributes(String externalName, int targetAgent, int targetSqlam, int targetRdb, int targetSecmgr, int targetCmntcpip, int targetCmnappc, int targetXamgr, int targetSyncptmgr, int targetRsyncmgr, int targetUnicodemgr)
void	writeForget(int codepoint, int value)
void	writeLocalCommit(NetConnection connection)
void	writeLocalRollback(NetConnection connection)
void	writeLocalXACommit(NetConnection conn)
void	writeLocalXARollback(NetConnection conn)
void	writeLocalXAStart(NetConnection connection)
(package private) void	writeNullXID(int codepoint)
void	writeReleaseConversation(int codepoint, int value)
(package private) void	writeSecurityCheck(int securityMechanism, String databaseName, String userid, String password, byte[] encryptedUserid, byte[] encryptedPassword)
void	writeSYNCType(int codepoint, int syncType)
protected void	writeXaCommit(NetConnection conn, Xid xid)
void	writeXaEndUnitOfWork(NetConnection conn)
(package private) void	writeXAFlags(int codepoint, int xaFlags)
protected void	writeXaForget(NetConnection conn, Xid xid)
protected void	writeXaPrepare(NetConnection conn)
protected void	writeXaRecover(NetConnection conn, int flag)
protected void	writeXaRollback(NetConnection conn, Xid xid)
void	writeXaStartUnitOfWork(NetConnection conn)
(package private) void	writeXATimeout(int codepoint, long xaTimeout)
(package private) void	writeXID(int codepoint, Xid xid)

Methods inherited from class 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

Methods inherited from class Object

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

Constructor Details

NetConnectionRequest

NetConnectionRequest(NetAgent netAgent,
 int bufferSize)

Method Details

writeExchangeServerAttributes

void writeExchangeServerAttributes(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,
 String databaseName,
 byte[] publicKey)
                  throws SqlException

Throws:

SqlException

writeSecurityCheck

void writeSecurityCheck(int securityMechanism,
 String databaseName,
 String userid,
 String password,
 byte[] encryptedUserid,
 byte[] encryptedPassword)
                 throws SqlException

Throws:

SqlException

writeAccessDatabase

void writeAccessDatabase(String rdbnam,
 boolean readOnly,
 byte[] correlationToken,
 byte[] productData,
 Typdef typdef)
                  throws SqlException

Throws:

SqlException

writeCommitSubstitute

public void writeCommitSubstitute(NetConnection connection)
                           throws SqlException

Specified by:

writeCommitSubstitute in interface ConnectionRequestInterface

Throws:

SqlException

writeLocalCommit

public void writeLocalCommit(NetConnection connection)
                      throws SqlException

Specified by:

writeLocalCommit in interface ConnectionRequestInterface

Throws:

SqlException

writeLocalRollback

public void writeLocalRollback(NetConnection connection)
                        throws SqlException

Specified by:

writeLocalRollback in interface ConnectionRequestInterface

Throws:

SqlException

writeLocalXAStart

public void writeLocalXAStart(NetConnection connection)
                       throws SqlException

Specified by:

writeLocalXAStart in interface ConnectionRequestInterface

Throws:

SqlException

writeLocalXACommit

public void writeLocalXACommit(NetConnection conn)
                        throws SqlException

Specified by:

writeLocalXACommit in interface ConnectionRequestInterface

Throws:

SqlException

writeLocalXARollback

public void writeLocalXARollback(NetConnection conn)
                          throws SqlException

Specified by:

writeLocalXARollback in interface ConnectionRequestInterface

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,
 Xid xid)
                      throws SqlException

Throws:

SqlException

writeXaRollback

protected void writeXaRollback(NetConnection conn,
 Xid xid)
                        throws SqlException

Throws:

SqlException

writeXaRecover

protected void writeXaRecover(NetConnection conn,
 int flag)
                       throws SqlException

Throws:

SqlException

writeXaForget

protected void writeXaForget(NetConnection conn,
 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,
 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(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,
 String rdbnam,
 byte[] sectkn)
                  throws SqlException

Throws:

SqlException

buildSECCHK

private void buildSECCHK(int secmec,
 String rdbnam,
 String user,
 String password,
 byte[] sectkn,
 byte[] sectkn2)
                  throws SqlException

Throws:

SqlException

buildACCRDB

private void buildACCRDB(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,
 Xid xid)
                 throws SqlException

Throws:

SqlException

buildSYNCCTLRollback

void buildSYNCCTLRollback(int xaFlags)
                   throws SqlException

Throws:

SqlException

buildEXTNAM

private void buildEXTNAM(String extnam)
                  throws SqlException

Throws:

SqlException

buildSRVNAM

private void buildSRVNAM(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(String rdbnam,
 boolean dontSendOnConversionError)
                  throws SqlException

Relational 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(String usrid)
                 throws SqlException

Throws:

SqlException

buildPASSWORD

private void buildPASSWORD(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(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