weblogic.jdbc.wrapper

Class JTSLoggableResourceTable

java.lang.Object

weblogic.jdbc.wrapper.JTSLoggableResourceTable

All Implemented Interfaces:

weblogic.timers.NakedTimerListener, weblogic.timers.TimerListener

final class JTSLoggableResourceTable
extends java.lang.Object
implements weblogic.timers.NakedTimerListener

This package class encapsulates an LLR DB table. It contains SQL for various operations, maintains the set of completed transactions ready for delete, and periodically executes SQL to delete old transaction records.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	JTSLoggableResourceTable.CompletedXARecord A package class that represents a completed transaction waiting for delete.
private static class	JTSLoggableResourceTable.CompletedXARecordSet An inner class that represents a set of completed transactions waiting for delete.
(package private) static class	JTSLoggableResourceTable.SQLRuntimeException

Field Summary

Fields

Modifier and Type	Field and Description
private JTSLoggableResourceTable.CompletedXARecordSet	completedXids
private java.lang.String	createSQL
private static java.lang.String	DATA_COL_NAME
private int	dataColumnLength
private int	dbmsType
private java.lang.String	ddlName
private static int	DELETE_DELAY_MILLIS
private java.lang.String	deleteSQL
private java.lang.String	dmlName
private java.lang.String	domain
private java.lang.String	getSQL
private java.lang.String	insertSQL
private boolean	isADMDDL
private boolean	isDeleteBatchSupported
private static int	MAX_BATCH_SIZE
private static int	MAX_PIGGY_BACKING_BATCH_SIZE
private static java.lang.String	OWNER_ROW
private static int	PIGGY_BACKING_THRESHOLD
private weblogic.timers.Timer	pingTimer
private static java.lang.String	POOL_COL_NAME
private java.lang.String	poolName
private java.lang.String	recoverSQL
private java.lang.String	server
private java.lang.String	sizeSQL
private static java.lang.String	TABLE_PREFIX
private java.lang.String	tableRef
private static java.lang.String	TEST_ROW
private static java.lang.String	TEST_ROW2
private static int	TIMER_INTERVAL_MILLIS
private static int	TIMER_TIMEOUT_MILLS
private weblogic.timers.TimerManager	timerManager
private static java.lang.String	VERSION_ROW
private static java.lang.String	VERSION_VALUE
private static java.lang.String	XID_COL_NAME

Constructor Summary

Constructors

Constructor and Description
JTSLoggableResourceTable(java.sql.Connection conn, java.lang.String poolName)
JTSLoggableResourceTable(java.sql.Connection conn, java.lang.String poolName, java.lang.String migratedServerName)

Method Summary

Modifier and Type	Method and Description
(package private) void	addCompleted(JTSLoggableResourceTable.CompletedXARecord first)
(package private) void	addCompleted(javax.transaction.xa.Xid xid)
private void	createTable(java.sql.Connection conn)
private void	delete(java.sql.Connection conn, JTSLoggableResourceTable.CompletedXARecord first, int batchSize)
private boolean	deleteCompletedOlderThanOrMoreThan(long delayMillis, int max, int timeoutMills)
private void	deleteRow(java.sql.Connection conn, java.lang.String xidStr)
private void	deleteRowsInBatch(java.sql.Connection conn, java.lang.String xidStr, java.lang.String xidStr2)
(package private) JTSLoggableResourceTable.CompletedXARecord	deleteYoungestCompleted(java.sql.Connection conn)
private void	detectAndDeleteRowsInBatch(java.sql.Connection conn, java.lang.String xidStr, java.lang.String xidStr2)
private void	detectDataColumnlength(java.sql.Connection conn, java.lang.String xidStr)
private boolean	existsForADMDDL(java.sql.Connection conn)
(package private) void	findOrCreateTable(java.sql.Connection conn) This method verifies the table.
private java.sql.DatabaseMetaData	getMetaData(java.sql.Connection conn)
(package private) java.lang.String	getRow(java.sql.Connection conn, java.lang.String xidStr)
(package private) int	getRowCount() returns number of rows in the table table
(package private) int	getRowCount(java.sql.Connection conn)
private void	init(java.sql.Connection conn, java.lang.String serverName)
(package private) void	insertRow(java.sql.Connection conn, java.lang.String xidStr, java.lang.String poolStr, java.lang.String recStr)
private java.sql.SQLException	newVerifyException(java.lang.String row, java.lang.String msg, java.lang.Throwable cause)
(package private) java.util.HashMap	recover(java.sql.Connection conn) Return all xid/record pairs for this table's pool.
(package private) int	setMaxDeleteIntervalMillis(int millis) Set the max age of committed tx records before lazy deletes occur.
void	timerExpired(weblogic.timers.Timer timer) This method is invoked by a TimerManager when a timer expires.
java.lang.String	toString()
private void	trace(javax.transaction.xa.Xid xid, java.lang.String s)
private void	trace(javax.transaction.xa.Xid xid, java.lang.String s, java.lang.Exception e)

Methods inherited from class java.lang.Object

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

Field Detail

TABLE_PREFIX

private static final java.lang.String TABLE_PREFIX

See Also:

Constant Field Values

XID_COL_NAME

private static final java.lang.String XID_COL_NAME

See Also:

Constant Field Values

POOL_COL_NAME

private static final java.lang.String POOL_COL_NAME

See Also:

Constant Field Values

DATA_COL_NAME

private static final java.lang.String DATA_COL_NAME

See Also:

Constant Field Values

VERSION_ROW

private static final java.lang.String VERSION_ROW

See Also:

Constant Field Values

VERSION_VALUE

private static final java.lang.String VERSION_VALUE

See Also:

Constant Field Values

OWNER_ROW

private static final java.lang.String OWNER_ROW

See Also:

Constant Field Values

TEST_ROW

private static final java.lang.String TEST_ROW

See Also:

Constant Field Values

TEST_ROW2

private static final java.lang.String TEST_ROW2

See Also:

Constant Field Values

DELETE_DELAY_MILLIS

private static int DELETE_DELAY_MILLIS

TIMER_INTERVAL_MILLIS

private static final int TIMER_INTERVAL_MILLIS

See Also:

Constant Field Values

MAX_BATCH_SIZE

private static final int MAX_BATCH_SIZE

See Also:

Constant Field Values

PIGGY_BACKING_THRESHOLD

private static final int PIGGY_BACKING_THRESHOLD

See Also:

Constant Field Values

MAX_PIGGY_BACKING_BATCH_SIZE

private static final int MAX_PIGGY_BACKING_BATCH_SIZE

See Also:

Constant Field Values

TIMER_TIMEOUT_MILLS

private static final int TIMER_TIMEOUT_MILLS

See Also:

Constant Field Values

isDeleteBatchSupported

private boolean isDeleteBatchSupported

poolName

private java.lang.String poolName

tableRef

private java.lang.String tableRef

dmlName

private java.lang.String dmlName

ddlName

private java.lang.String ddlName

domain

private java.lang.String domain

server

private java.lang.String server

createSQL

private java.lang.String createSQL

insertSQL

private java.lang.String insertSQL

deleteSQL

private java.lang.String deleteSQL

recoverSQL

private java.lang.String recoverSQL

sizeSQL

private java.lang.String sizeSQL

getSQL

private java.lang.String getSQL

dataColumnLength

private int dataColumnLength

dbmsType

private int dbmsType

completedXids

private JTSLoggableResourceTable.CompletedXARecordSet completedXids

pingTimer

private weblogic.timers.Timer pingTimer

timerManager

private weblogic.timers.TimerManager timerManager

isADMDDL

private boolean isADMDDL

Constructor Detail

JTSLoggableResourceTable

JTSLoggableResourceTable(java.sql.Connection conn,
                         java.lang.String poolName,
                         java.lang.String migratedServerName)
                  throws java.sql.SQLException

Throws:

java.sql.SQLException

JTSLoggableResourceTable

JTSLoggableResourceTable(java.sql.Connection conn,
                         java.lang.String poolName)
                  throws java.sql.SQLException

Throws:

java.sql.SQLException

Method Detail

init

private void init(java.sql.Connection conn,
                  java.lang.String serverName)
           throws java.sql.SQLException

Throws:

java.sql.SQLException

getMetaData

private java.sql.DatabaseMetaData getMetaData(java.sql.Connection conn)
                                       throws java.sql.SQLException,
                                              JTSLoggableResourceTable.SQLRuntimeException

Throws:

java.sql.SQLException

JTSLoggableResourceTable.SQLRuntimeException

createTable

private void createTable(java.sql.Connection conn)
                  throws java.sql.SQLException

Throws:

java.sql.SQLException

newVerifyException

private java.sql.SQLException newVerifyException(java.lang.String row,
                                                 java.lang.String msg,
                                                 java.lang.Throwable cause)
                                          throws java.sql.SQLException

Throws:

java.sql.SQLException

findOrCreateTable

void findOrCreateTable(java.sql.Connection conn)
                throws java.sql.SQLException

This method verifies the table. First it creates the table if it can not find it, then it tests an insert, delete, and get for a row on the table, then it checks to make sure that this server and this domain matches the server and domain record stored in the table, and finally it checks to make sure that the version field in the table is less than or equal to the version of this class.

Throws:

java.sql.SQLException

existsForADMDDL

private boolean existsForADMDDL(java.sql.Connection conn)
                         throws java.sql.SQLException

Throws:

java.sql.SQLException

getRowCount

int getRowCount(java.sql.Connection conn)
         throws java.sql.SQLException

Throws:

java.sql.SQLException

getRowCount

int getRowCount()
         throws java.sql.SQLException

returns number of rows in the table table

Throws:

java.sql.SQLException

setMaxDeleteIntervalMillis

int setMaxDeleteIntervalMillis(int millis)

Set the max age of committed tx records before lazy deletes occur. A value of 0 disables such deletes. Returns the current value.

detectDataColumnlength

private void detectDataColumnlength(java.sql.Connection conn,
                                    java.lang.String xidStr)
                             throws java.sql.SQLException

Throws:

java.sql.SQLException

getRow

java.lang.String getRow(java.sql.Connection conn,
                        java.lang.String xidStr)
                 throws java.sql.SQLException

Throws:

java.sql.SQLException

insertRow

void insertRow(java.sql.Connection conn,
               java.lang.String xidStr,
               java.lang.String poolStr,
               java.lang.String recStr)
        throws java.sql.SQLException

Throws:

java.sql.SQLException

deleteRow

private void deleteRow(java.sql.Connection conn,
                       java.lang.String xidStr)
                throws java.sql.SQLException

Throws:

java.sql.SQLException

deleteRowsInBatch

private void deleteRowsInBatch(java.sql.Connection conn,
                               java.lang.String xidStr,
                               java.lang.String xidStr2)
                        throws java.sql.SQLException

Throws:

java.sql.SQLException

detectAndDeleteRowsInBatch

private void detectAndDeleteRowsInBatch(java.sql.Connection conn,
                                        java.lang.String xidStr,
                                        java.lang.String xidStr2)
                                 throws java.sql.SQLException

Throws:

java.sql.SQLException

addCompleted

void addCompleted(javax.transaction.xa.Xid xid)

addCompleted

void addCompleted(JTSLoggableResourceTable.CompletedXARecord first)

recover

java.util.HashMap recover(java.sql.Connection conn)
                   throws java.sql.SQLException

Return all xid/record pairs for this table's pool.

Throws:

java.sql.SQLException

timerExpired

public void timerExpired(weblogic.timers.Timer timer)

Description copied from interface: weblogic.timers.TimerListener

This method is invoked by a TimerManager when a timer expires.

Specified by:

timerExpired in interface weblogic.timers.TimerListener

Parameters:

timer - The timer that expired and caused the listener to be invoked.

delete

private void delete(java.sql.Connection conn,
                    JTSLoggableResourceTable.CompletedXARecord first,
                    int batchSize)
             throws java.sql.SQLException

Throws:

java.sql.SQLException

deleteCompletedOlderThanOrMoreThan

private boolean deleteCompletedOlderThanOrMoreThan(long delayMillis,
                                                   int max,
                                                   int timeoutMills)

deleteYoungestCompleted

JTSLoggableResourceTable.CompletedXARecord deleteYoungestCompleted(java.sql.Connection conn)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

trace

private void trace(javax.transaction.xa.Xid xid,
                   java.lang.String s)

trace

private void trace(javax.transaction.xa.Xid xid,
                   java.lang.String s,
                   java.lang.Exception e)