Example: Test a connection using testConnection(ConfigID): WAS v5.1

Example: Test a connection using testConnection(ConfigID)

You can pass the configuration ID of a configured data source, rather than the properties of the data source. This program uses JMX to connect to a running server and invoke the testConnection method on the DataSourceCfgHelper MBean.
/**
 * Description
 * Resource adapter test program to make sure that the MBean interfaces work.
 * Following interfaces are tested
 * 
 *  ---  testConnection()
 * 
 * 
 * We need following to run
 * C:\src>java -Djava.ext.dirs=C:\WebSphere\AppServer\lib;C:\WebSphere\AppServer\java\jre\lib\ext testDSGUI
 * must include jre for log.jar and mail.jar, else get cass not found exception
 * 
 * 
 */

import java.util.Iterator;
import java.util.Locale;
import java.util.Properties;
import java.util.Set;

import javax.management.InstanceNotFoundException;
import javax.management.MBeanException;
import javax.management.MalformedObjectNameException;
import javax.management.ObjectName;
import javax.management.RuntimeMBeanException;
import javax.management.RuntimeOperationsException;

import com.ibm.websphere.management.AdminClient;
import com.ibm.websphere.management.AdminClientFactory;
import com.ibm.ws.rsadapter.exceptions.DataStoreAdapterException;

public class testDSGUI {

//Use port 8880 for base installation or port 8879 for ND installation
String port = "8880";
// String port = "8879";
String host = "localhost";
final static boolean verbose = true;

// eg a configuration ID for 5.0 DataSource declared at the node level for base
private static final String resURI = "cells/cat/nodes/cat:resources.xml#DataSource_1";

// eg a 4.0 DataSource declared at the node level for base
//    private static final String resURI = "cells/cat/nodes/cat:resources.xml#WAS40DataSource_1";

// eg Cloudscape DataSource declared at the server level for base
//private static final String resURI = "cells/cat/nodes/cat/servers/server/resources.xml#DataSource_6";

// eg node level DataSource for ND
//private static final String resURI = "cells/catNetwork/nodes/cat:resources.xml#DataSource_1";

// eg server level DataSource for ND
//private static final String resURI = "cells/catNetwork/nodes/cat/servers/server:resources.xml#DataSource_4";

// eg cell level DataSource for ND
//private static final String resURI = "cells/catNetwork:resources.xml#DataSource_1";

 public static void main(String[] args) {
  testDSGUI cds = new testDSGUI();
  cds.run(args);
 }

/**
 * This method tests the ResourceMbean.
 * 
 * @param args
 * @exception Exception
 */
 public void run(String[] args) {

  try {

    System.out.println("Connecting to the appserver.......");

        /*************************************************************************/
        /**    Initialize the AdminClient                                        */
        /*************************************************************************/    
    Properties adminProps = new Properties();
    adminProps.setProperty(AdminClient.CONNECTOR_TYPE, AdminClient.CONNECTOR_TYPE_SOAP);
    adminProps.setProperty(AdminClient.CONNECTOR_HOST, host);
    adminProps.setProperty(AdminClient.CONNECTOR_PORT, port);
    AdminClient adminClient = null;
    try {
        adminClient = AdminClientFactory.createAdminClient(adminProps);
    } catch  com.ibm.websphere.management.exception.ConnectorException(ce) {
          System.out.println("NLS: Cannot make a connection to the appserver\n");
        ce.printStackTrace();
        System.exit(1);
    }

       /*************************************************************************/
       /**    Locate the Mbean                                                  */
       /*************************************************************************/
    ObjectName handle = null;
    try {
                // Send in a locator string 
                // eg for a Baseinstallation this is enough
                ObjectName queryName = new ObjectName("WebSphere:type=DataSourceCfgHelper,*");

                // for ND you need to specify which node/process you would like to test from
                // eg run in the server
        //ObjectName queryName = new     OjectName("WebSphere:cell=catNetwork,node=cat,process=server,type=DataSourceCfgHelper,*");
                // eg run in the node agent
        //ObjectName queryName = new ObjectName("WebSphere:cell=catNetwork,node=cat,process=nodeagent,type=DataSourceCfgHelper,*");
        // eg run in the Deployment Manager
        //ObjectName queryName = new ObjectName("WebSphere:cell=catNetwork,node=catManager,process=dmgr,type=DataSourceCfgHelper,*");
        Set s = adminClient.queryNames(queryName, null);
        Iterator iter = s.iterator();
        while (iter.hasNext()) {
                       // use the first MBean that is found
             handle = (ObjectName) iter.next();
            System.out.println("Found this ->" + handle);
        }
        if  handle(== null) {
            System.out.println("NLS: Did not find this MBean>>" + queryName);
            System.exit(1);
        }
    } catch  MalformedObjectNameException(mone) {
        System.out.println("Check the program variable queryName" + mone);
    } catch  com.ibm.websphere.management.exception.ConnectorException(ce) {
        System.out.println("Cannot connect to the appserver" + ce);
    }

         /*************************************************************************/
         /**           Build parameters to pass to Mbean                          */
         /*************************************************************************/
    String[] signature = { "java.lang.String" };
    Object[] params = { resURI };
    Object result = null;

       /*****************************************************************************/
       /** For the following to work  give all permission to the database   */
       /** jar/zip files else you will see this exception:                          */
       /** DSRA8040W: Failed to connect to the DataSource.  Encountered              */
       /** java.lang.ExceptionInInitializerError:                                   */
       /** Chained java.security.AccessControlException:                            */
       /** access denied  java.util.PropertyPermission(ibm.db2.instance.path read). */
       /**                                                                          */
       /** e.g.                                                                     */
       /** Put this in server.policy                                                */
       /**                                                                          */ 
       /**    grant codeBase "file:D:/sqllib/java/db2java.zip" {                   */
       /**        permission java.security.AllPermission;                       */
       /**    };                                                                   */
       /**                                                                          */
    /*****************************************************************************/

    if (verbose) {
        System.out.println("\nTesting connection to the database using " + handle);
    }

    try {
               /*************************************************************************/
               /**  Start to test the connection to the database                        */
               /*************************************************************************/
        result = adminClient.invoke(handle, "testConnection", params, signature);
    } catch  MBeanException(mbe) {
        // ****** all user exceptions come in here
        if (verbose) {
            Exception ex = mbe.getTargetException(); // this is the real exception from the Mbean
            System.out.println("\nNLS:Mbean Exception was received contains " + ex);
            ex.printStackTrace();
            System.exit(1);
        }
    } catch  InstanceNotFoundException(infe) {
        System.out.println("Cannot find " + infe);
    } catch  RuntimeMBeanException(rme) {
        Exception ex = rme.getTargetException();
        ex.printStackTrace(System.out);
        throw ex;
    } catch  Exception(ex) {
        System.out.println("\nUnexpected Exception occurred: " + ex);
        ex.printStackTrace();
    }

         /*************************************************************************/
         /**  Process the result.  The result will be the number of warnings      */
         /**  issued.  A result of 0 indicates a successful connection with       */
         /**  no warnings.                                                        */
         /*************************************************************************/

    //A result of 0 indicates a successful connection with no warnings.
    System.out.println("Result= " + result);

  } catch  RuntimeOperationsException(roe) {
    Exception ex = roe.getTargetException();
    ex.printStackTrace(System.out);
  } catch  Exception(ex) {
    System.out.println("General exception occurred");
    ex.printStackTrace(System.out);
  }
 }
}
Example: Test a connection using testConnection(ConfigID)

See Also
