org.apache.derby.impl.drda
Class XADatabase

java.lang.Object
  org.apache.derby.impl.drda.Database
      org.apache.derby.impl.drda.XADatabase

class XADatabase

extends Database

Field Summary

protected int	accessCount
(package private) java.lang.String	attrString
protected int	byteOrder
protected int	ccsidDBC
protected java.lang.String	ccsidDBCEncoding
protected int	ccsidMBC
protected java.lang.String	ccsidMBCEncoding
protected int	ccsidSBC
protected java.lang.String	ccsidSBCEncoding
protected byte[]	crrtkn
protected java.lang.String	dbName
protected java.lang.String	decryptedPassword
protected java.lang.String	decryptedUserId
(package private) DRDAStatement	defaultStatement
(package private) boolean	forXA
protected java.lang.String	password
protected byte[]	publicKeyIn
protected byte[]	publicKeyOut
protected boolean	rdbAllowUpdates
protected boolean	RDBUPDRM_sent
protected int	securityMechanism
protected boolean	sendTRGDFTRT
protected java.lang.String	shortDbName
(package private) java.util.Hashtable	stmtTable
protected java.lang.String	typDefNam
protected java.lang.String	userId
private javax.sql.XAConnection	xaConnection
private EmbeddedXADataSource	xaDataSource
private javax.transaction.xa.XAResource	xaResource

Constructor Summary

protected

XADatabase(java.lang.String dbName)

Method Summary

(package private) java.lang.String	appendAttrString(java.util.Properties p)
protected java.lang.String	buildRuntimeInfo(java.lang.String indent, LocalizedResource localLangUtil)
protected void	close() Close the connection and clean up the statement table
protected void	commit()
protected java.sql.Connection	getConnection() Get the connection
protected DRDAStatement	getCurrentStatement() Get current DRDA statement
protected DRDAStatement	getDefaultStatement() Get default statement for use in EXCIMM
protected DRDAStatement	getDefaultStatement(java.lang.String pkgnamcsn) Get default statement for use in EXCIMM with specified pkgnamcsn The pkgnamcsn has the encoded isolation level
protected DRDAStatement	getDRDAStatement(java.lang.String pkgnamcsn) Get DRDA statement based on pkgnamcsn
protected java.sql.PreparedStatement	getPreparedStatement(java.lang.String pkgnamcsn) Get prepared statement based on pkgnamcsn
protected int	getPrepareIsolation() get prepare isolation level for this connection.
protected java.sql.ResultSet	getResultSet(java.lang.String pkgnamcsn) Get result set
protected javax.transaction.xa.XAResource	getXAResource() get XA Resource for this connection
protected java.sql.Connection	makeConnection(java.util.Properties p) Make a new connection using the database name and set the connection in the database
protected DRDAStatement	newDRDAStatement(java.lang.String pkgnamcsn) Get a new DRDA statement and store it in the stmtTable if stortStmt is true If possible recycle an existing statement If we are asking for one with the same name it means it was already closed.
protected void	removeStatement(DRDAStatement stmt)
protected void	rollback()
protected void	setConnection(java.sql.Connection conn) Set connection and create the SQL statement for the default statement
protected void	setCurrentStatement(DRDAStatement stmt) Make statement the current statement
protected void	setDrdaID(java.lang.String drdaID) Set DRDA id for this connection
protected void	setPrepareIsolation(int level) Set the internal isolation level to use for preparing statements.
protected void	setResultSet(java.sql.ResultSet value) Set result set
protected void	setXAResource(javax.transaction.xa.XAResource resource) SetXAResource
protected void	storeStatement(DRDAStatement stmt) Store DRDA prepared statement

Methods inherited from class java.lang.Object

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

Field Detail

xaDataSource

private EmbeddedXADataSource xaDataSource

xaResource

private javax.transaction.xa.XAResource xaResource

xaConnection

private javax.sql.XAConnection xaConnection

dbName

protected java.lang.String dbName

shortDbName

protected java.lang.String shortDbName

attrString

java.lang.String attrString

securityMechanism

protected int securityMechanism

userId

protected java.lang.String userId

password

protected java.lang.String password

decryptedUserId

protected java.lang.String decryptedUserId

decryptedPassword

protected java.lang.String decryptedPassword

rdbAllowUpdates

protected boolean rdbAllowUpdates

accessCount

protected int accessCount

publicKeyIn

protected byte[] publicKeyIn

publicKeyOut

protected byte[] publicKeyOut

crrtkn

protected byte[] crrtkn

typDefNam

protected java.lang.String typDefNam

byteOrder

protected int byteOrder

ccsidSBC

protected int ccsidSBC

ccsidDBC

protected int ccsidDBC

ccsidMBC

protected int ccsidMBC

ccsidSBCEncoding

protected java.lang.String ccsidSBCEncoding

ccsidDBCEncoding

protected java.lang.String ccsidDBCEncoding

ccsidMBCEncoding

protected java.lang.String ccsidMBCEncoding

RDBUPDRM_sent

protected boolean RDBUPDRM_sent

sendTRGDFTRT

protected boolean sendTRGDFTRT

defaultStatement

DRDAStatement defaultStatement

stmtTable

java.util.Hashtable stmtTable

forXA

boolean forXA

Constructor Detail

XADatabase

protected XADatabase(java.lang.String dbName)

Method Detail

makeConnection

protected java.sql.Connection makeConnection(java.util.Properties p)
                                      throws java.sql.SQLException

Make a new connection using the database name and set the connection in the database

Overrides:

makeConnection in class Database

Parameters:

p - Properties for connection attributes to pass to connect

Returns:

new local connection

Throws:

java.sql.SQLException

setXAResource

protected void setXAResource(javax.transaction.xa.XAResource resource)

SetXAResource

Parameters:

resource - XAResource for this connection

setDrdaID

protected void setDrdaID(java.lang.String drdaID)

Set DRDA id for this connection

Overrides:

setDrdaID in class Database

Parameters:

drdaID -

setPrepareIsolation

protected void setPrepareIsolation(int level)
                            throws java.sql.SQLException

Set the internal isolation level to use for preparing statements. Subsequent prepares will use this isoalation level

Overrides:

setPrepareIsolation in class Database

Parameters:

level - internal isolation level

Throws:

java.sql.SQLException

See Also:

BrokeredConnection.setPrepareIsolation(int)

getPrepareIsolation

protected int getPrepareIsolation()
                           throws java.sql.SQLException

get prepare isolation level for this connection.

Overrides:

getPrepareIsolation in class Database

Throws:

java.sql.SQLException

getXAResource

protected javax.transaction.xa.XAResource getXAResource()

get XA Resource for this connection

setConnection

protected void setConnection(java.sql.Connection conn)
                      throws java.sql.SQLException

Set connection and create the SQL statement for the default statement

Parameters:

conn - Connection

Throws:

java.sql.SQLException

getConnection

protected java.sql.Connection getConnection()

Get the connection

Returns:

connection

getCurrentStatement

protected DRDAStatement getCurrentStatement()

Get current DRDA statement

Returns:

DRDAStatement

Throws:

java.sql.SQLException

getDefaultStatement

protected DRDAStatement getDefaultStatement()

Get default statement for use in EXCIMM

Returns:

DRDAStatement

getDefaultStatement

protected DRDAStatement getDefaultStatement(java.lang.String pkgnamcsn)

Get default statement for use in EXCIMM with specified pkgnamcsn The pkgnamcsn has the encoded isolation level

Parameters:

pkgnamcsn - package/ section # for statement

Returns:

DRDAStatement

getPreparedStatement

protected java.sql.PreparedStatement getPreparedStatement(java.lang.String pkgnamcsn)
                                                   throws java.sql.SQLException

Get prepared statement based on pkgnamcsn

Parameters:

pkgnamcsn - - key to access statement

Returns:

prepared statement

Throws:

java.sql.SQLException

newDRDAStatement

protected DRDAStatement newDRDAStatement(java.lang.String pkgnamcsn)
                                  throws java.sql.SQLException

Get a new DRDA statement and store it in the stmtTable if stortStmt is true If possible recycle an existing statement If we are asking for one with the same name it means it was already closed.

Parameters:

pkgnamcsn - Package name and section

Returns:

DRDAStatement

Throws:

java.sql.SQLException

getDRDAStatement

protected DRDAStatement getDRDAStatement(java.lang.String pkgnamcsn)
                                  throws java.sql.SQLException

Get DRDA statement based on pkgnamcsn

Parameters:

pkgnamcsn - - key to access statement

Returns:

DRDAStatement

Throws:

java.sql.SQLException

appendAttrString

java.lang.String appendAttrString(java.util.Properties p)

getResultSet

protected java.sql.ResultSet getResultSet(java.lang.String pkgnamcsn)
                                   throws java.sql.SQLException

Get result set

Parameters:

pkgnamcsn - - key to access prepared statement

Returns:

result set

Throws:

java.sql.SQLException

setResultSet

protected void setResultSet(java.sql.ResultSet value)
                     throws java.sql.SQLException

Set result set

Parameters:

value -

Throws:

java.sql.SQLException

storeStatement

protected void storeStatement(DRDAStatement stmt)
                       throws java.sql.SQLException

Store DRDA prepared statement

Parameters:

stmt - DRDA prepared statement

Throws:

java.sql.SQLException

removeStatement

protected void removeStatement(DRDAStatement stmt)
                        throws java.sql.SQLException

Throws:

java.sql.SQLException

setCurrentStatement

protected void setCurrentStatement(DRDAStatement stmt)

Make statement the current statement

Parameters:

stmt -

commit

protected void commit()
               throws java.sql.SQLException

Throws:

java.sql.SQLException

rollback

protected void rollback()
                 throws java.sql.SQLException

Throws:

java.sql.SQLException

close

protected void close()
              throws java.sql.SQLException

Close the connection and clean up the statement table

Throws:

java.sql.SQLException - on conn.close() error to be handled in DRDAConnThread.

buildRuntimeInfo

protected java.lang.String buildRuntimeInfo(java.lang.String indent,
                                            LocalizedResource localLangUtil)