MQSeries.net :: View topic - JRE Version for QueueManager's getJDBCConnection for 2PC

murali_bestha · Posted: Mon Mar 08, 2004 7:20 pm Post subject:

Hi,

We have the following environment:

DB : Oracle9i on Solaris
Websphere MQ : on Windows 2K
JRE : 1.3.1_10
JDBC Driver : classes12.jar from Oracle

In a standalone java application, we are trying to update a DB and put a message to a queue. This needs to be done under a transaction for a 2 phase commit.

In MqBaseJavaTest.java

<CODE>
PreparedStatement pStmnt = null;
MQQueue queue = null;
//Create a connection to the queue manager
java.util.Hashtable properties = new Hashtable();
properties.put(MQC.THREAD_AFFINITY, new Boolean(true));
qMgr =new MQQueueManager(strQMgrName, properties);
OracleXADataSource ds = new OracleXADataSource();
ds.setUser("scott");
ds.setPassword("tiger");
ds.setURL("jdbc:oracle:thin:@192.111.11.111:1521:test");
conn = qMgr.getJDBCConnection( (javax.sql.XADataSource)ds );

qMgr.begin();
pStmnt = conn.prepareStatement("update atm set cash = " + iValue + " where id='" + strUserId + "'");
int iUpdateCount = pStmnt.executeUpdate();
if( iUpdateCount <= 0 )
{
qMgr.backout;
throw new Exception("No records are updated for " + strUserId );
}
// Set up the options on the queue we wish to open...
int openOption = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT | MQC.MQOO_INQUIRE;
// Now specify the queue that we wish to open, and the open options...
queue = qMgr.accessQueue("BANKQUEUE2",openOption,strQMgrName,strQMgrName,"");
// Define a simple MQSeries message, and write some text in UTF format..
MQMessage putMessage = new MQMessage();
putMessage.priority = 5;
putMessage.characterSet = 943;
putMessage.writeUTF("Hello World!");
MQPutMessageOptions mqpmo = new MQPutMessageOptions();
mqpmo.options = MQC.MQPMO_SYNCPOINT;
queue.put(putMessage, mqpmo);
qMgr.commit();
iValue++;
</CODE>

When we try to run this class. the following exception is occurring:

java.lang.ArrayIndexOutOfBoundsException
at oracle.security.o3logon.C1.r(C1)
at oracle.security.o3logon.C1.l(C1)
at oracle.security.o3logon.C0.c(C0)
at oracle.security.o3logon.O3LoginClientHelper.getEPasswd(O3LoginClientH
elper)
at oracle.jdbc.ttc7.O3log.<init>(O3log.java:291)
at oracle.jdbc.ttc7.TTC7Protocol.logon(TTC7Protocol.java:257)
at oracle.jdbc.driver.OracleConnection.<init>(OracleConnection.java:287)

at oracle.jdbc.driver.OracleDriver.getConnectionInstance(OracleDriver.ja
va:442)
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:321)
at java.sql.DriverManager.getConnection(DriverManager.java:512)
at java.sql.DriverManager.getConnection(DriverManager.java:172)
at oracle.jdbc.pool.OracleDataSource.getConnection(OracleDataSource.java
:116)
at oracle.jdbc.pool.OracleConnectionPoolDataSource.getPhysicalConnection
(OracleConnectionPoolDataSource.java:107)
at oracle.jdbc.xa.client.OracleXADataSource.getXAConnection(OracleXAData
Source.java:211)
at oracle.jdbc.xa.client.OracleXADataSource.getXAConnection(OracleXAData
Source.java:84)
at com.ibm.mq.XAtoJTA.helpGetConnection(XAtoJTA.java:395)
at com.ibm.mq.MQQueueManager.getJDBCConnection(MQQueueManager.java:242)
at com.ibm.mq.MQQueueManager.getJDBCConnection(MQQueueManager.java:199)
at MqBaseJavaTest.doProcess(MqBaseJavaTest.java:8

at MqBaseJavaTest.main(MqBaseJavaTest.java:202)

Looks like the transactions in MQ cannot be done in Java 1.3.1. Do we need to use Java 1.4 version?

Please let us know asap as this is very urgent for us.

Thanks and Regards
Murali