org.apache.derby.impl.drda
Class XADatabase

java.lang.Object
  extended byorg.apache.derby.impl.drda.Database
      extended byorg.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)

Built on Tue 2006-10-10 19:23:47+0200, from revision exported

Apache Derby V10.1 Engine Documentation - Copyright © 1997,2005 The Apache Software Foundation or its licensors, as applicable.