MQSeries.net :: View topic - error when connectin to an AS400 DB from a Java compute node

sandhyarajcoomar · Posted: Wed Mar 27, 2013 2:34 am Post subject:

Hello..I'm trying to connect to an AS400 db From a Java compute nodebut getting errors.Can u plz advise.

My testing scenario is :

1. My broker flow is triggered every 9secs to run a select and delete row in AS400 DB
2. Connect to AS400 DB using JDBC_TransactionType.MB_TRANSACTION_AUTO.

try {
//get connection to the AS400 server

if (conn == null)

try { conn = getJDBCType4Connection("AS400db",JDBC_TransactionType.MB_TRANSACTION_AUTO);

strSelectStoredProcName = (String)getUserDefinedAttribute("SelectStoredProcName");

result = new CoreSelectCustomerDetails().retrievePPWICustomerDetails(conn, strSelectStoredProcName);

} catch (SQLException e) {
//store any error code and description in the environment tree.
mbElement.createElementAsFirstChild(MbElement.TYPE_NAME_VALUE, "ErrorCode", ErrorCodes.C0001.toString());
mbElement.createElementAsFirstChild(MbElement.TYPE_NAME_VALUE, "ErrorDesc",ErrorCodes.C0001.getErrorDescription());
catchTerminal.propagate(assembly);

3. Get rows from ResultSet once and get right results - OK

4. Delete all rows from the table using rs.DeleterOW, meaning that the ResultSet should return nothing next time.

5.Try fetching again (now it should return 0 rows) .BUT it returns the exact same rows as in step 3, even though the database table is empty.

6. If I restart the broker flow it works fine again.

Now if I change the code as follows :

try {
//get connection to the AS400 server

if (conn == null)
{
conn = getJDBCType4Connection("AS400db",JDBC_TransactionType.MB_TRANSACTION_AUTO);
}

try {
strSelectStoredProcName = (String)getUserDefinedAttribute("SelectStoredProcName");
result = new CoreSelectCustomerDetails().retrievePPWICustomerDetails(conn, strSelectStoredProcName);

} catch (SQLException e) {
//store any error code and description in the environment tree.
ErrorCodes.C0001.toString());
mbElement.createElementAsFirstChild(MbElement.TYPE_NAME_VALUE, "ErrorDesc", ErrorCodes.C0001.getErrorDescription());
catchTerminal.propagate(assembly);

I get an error : java.sql.sqlexception the connection does not exist