MQSeries.net :: View topic

assubct · Posted: Fri Sep 12, 2008 4:14 am Post subject:

Hi all,
Broker 6.1 provides a new feature to interact with DataBases using JDBC from Java compute Nodes, have someone successfully used this feature?
I've configured a JDBC provider using the mqsicreateconfigurableservice command to connect to an Oracle DB end used the sample JAVA code from infocenter to use it from infocenter but I'm still getting error on getJDBCType4Connection method. I know that the JDBC configurable service I created is working because I was able to use it with DataBaseRetrieve node. Below is the JAVA code I used in JAVA compute node.

import com.ibm.broker.javacompute.MbJavaComputeNode;
import com.ibm.broker.plugin.*;
import java.sql.*;

public class testeJdbc_JavaCompute extends MbJavaComputeNode {

public void evaluate(MbMessageAssembly contact admin) throws MbException {
MbOutputTerminal out = getOutputTerminal("out");
MbMessage inMessage = contact admin.getMessage();

// create new message
MbMessage outMessage = new MbMessage(inMessage);
MbMessageAssembly outAssembly = new MbMessageAssembly(contact admin,outMessage);

try {
// Obtain a java.sql.Connection using a JDBC Type4 datasource - in this example for a
// JDBC broker configurable service called "Oracle"

Connection conn = getJDBCType4Connection("Oracle",JDBC_TransactionType.MB_TRANSACTION_AUTO);

// Example of using the Connection to create a java.sql.Statement
Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
ResultSet srs0 = stmt.executeQuery("SELECT * from openris.mestre_nfsd_merc");

// Perform other database updates

} catch (Exception sqx ){
sqx.printStackTrace();

} finally {
// clear the outMessage
outMessage.clearMessage();
}

}
}

I appreciate any help on this.
Regards,