Example: Test a connection to a data source

This resource adapter test program ensures that the MBean interfaces work. The following interfaces are tested...

• getPropertiesForDataSource()

• reload()

• testConnectionToDataSource()

You need the following to run: set the classpath to classpath=%classpath%; was_home\lib\wsexception.jar; was_home\lib\wasjmx.jar; was_home/lib/j2ee.jar; was_home\lib\admin.jar; was_home\lib\jmxc.jar; was_home\lib\utils.jar. Replace the variable was_home with the directory where you installed WAS.

//
// "This program may be used, executed, copied, modified and distributed without royalty for the 
// purpose of developing, using, marketing, or distributing."
//
// Product 5630-A36,  (C) COPYRIGHT International Business Machines Corp., 2001, 2002
// All Rights Reserved * Licensed Materials - Property of IBM
//

import java.util.*;
import javax.sql.DataSource;
import javax.transaction.*;
import javax.management.*;

import com.ibm.websphere.management.*;
import com.ibm.websphere.management.configservice.*;
import com.ibm.ws.exception.WsException;
import com.ibm.websphere.rsadapter.DSPropertyEntry;

/**
 * Resource adapter test program to make sure that the MBean interfaces work.
 * Following interfaces are tested
 * 
 *  -getPropertiesForDataSource()
 *  -reload()
 *  -testConnectionToDataSource()
 * 
 * 
 * We need following to run
 * set classpath=%classpath%;D:\WebSphere\AppServer\lib\wsexception.jar;D:\WebSphere\AppServer\lib\wasjmx.jar;D:\$WAS_HOME\lib\wasx.jar
 * 
 
 */
public class testDS {


   String port = "8880";
   String host = "localhost";
   final static boolean verbose = true;



   /**
    * Main method.
    * 
    * @param args   DataBase classpath, DataSource name
    */
   public static void main(String[] args) {
      testDS cds = new testDS();

      try {
         cds.run(args);
      } catch (com.ibm.ws.exception.WsException ex) {
         System.out.println("Caught this " + ex   );
         ex.printStackTrace();
         //ex.getCause().printStackTrace();
      } catch  Exception(ex) {
         System.out.println("Caught this " + ex );
         ex.printStackTrace();
      }
   }


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

      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("Cannot make a connection to the appserver\n"+ce);
            System.exit(1);
         }


         // First get the  Mbean
         ObjectName handle = null;
         try {
            ObjectName queryName = new ObjectName("WebSphere:type=DataSourceCfgHelper,*");
            Set s = adminClient.queryNames(queryName, null);
            Iterator iter = s.iterator();
            if (iter.hasNext()) handle = (ObjectName)iter.next();
         } 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);
         }

         //System.out.println("Connected to the appserver" + handle);

         // now call a method on the Mbean to do the desired operation.
         String dsClassName = "COM.ibm.db2.jdbc.DB2XADataSource";
         String providerLibPath = "D:/SQLLIB/java/db2java.zip";
         String[] signature = { "java.lang.String", "java.lang.String"};
         Object[] params = { dsClassName, providerLibPath};
         Object result = null;

         if (verbose) {
            System.out.println("Calling getPropertiesForDataSource() for " + dsClassName + "\n");
         }
         try {
            // get the properties
            result = adminClient.invoke(handle, "getPropertiesForDataSource", params, signature);
         } catch  MBeanException(mbe) {
            if (verbose) {
               System.out.println("\tMbean Exception " + dsClassName);
            }
         } catch  InstanceNotFoundException(infe) {
            System.out.println("Cannot find " + dsClassName);
         } catch  Exception(ex) {
            System.out.println("Exception occurred calling getPropertiesForDataSource() for " + dsClassName + ex);
         }

         // Pretty print what we found
         Iterator propIterator = ((List)result).iterator();
         System.out.println(format("Name",21)+ "|" + format("Default Value",34) + "|" + format("Type",17) +"|Reqd");
         String line = "_______________________________________________________________________________";
         System.out.println(line);
         while (propIterator.hasNext()) {
            DSPropertyEntry dspe = (DSPropertyEntry)propIterator.next();
            System.out.print(format(dspe.getPropertyName(),21)+"|"+ format(dspe.getDefaultValue(),34) + "|");
            System.out.println(format(dspe.getPropertyType(),17) +"|"+ ((dspe.isRequired())? " Y" : " N"));
         }
         System.out.println(line);


         //---------------reload

         if (verbose) {
            System.out.println("Calling reload()");
         }
         try {
            result = adminClient.invoke(handle, "reload", new Object[] {}, new String[] {});
         } catch  MBeanException(mbe) {
            if (verbose) {
               System.out.println("\tMbean Exception calling reload" + mbe);
            }
         } catch  InstanceNotFoundException(infe) {
            System.out.println("Cannot find reload ");
         } catch  Exception(ex) {
            System.out.println("Exception occurred calling reload()"  + ex);
         }
         if (result==null && verbose) {
            System.out.println("OK reload()");
         }
         //---------------reload


         /* 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 " + dsClassName);
         }


         String user = "db2admin";
         String password = "db2admin";
         Properties props = new Properties();
         props.setProperty("databaseName", "section");
         // also pass in the locale i0226.09 onwards
         String[] signature2 = { "java.lang.String", "java.lang.String", "java.lang.String", "java.util.Properties", "java.lang.String","java.util.Locale"};
         Object[] params2 = { dsClassName, user, password,props ,providerLibPath, Locale.US};
         Object result2 = null;

         try {
            // OK lets test.
            result2 = adminClient.invoke(handle, "testConnectionToDataSource", params2, signature2);
         } catch  MBeanException(mbe) {
            if (verbose) {
               System.out.println("\tMbean Exception " + dsClassName);
            }
         } catch  InstanceNotFoundException(infe) {
            System.out.println("Cannot find " + dsClassName);
         } catch  RuntimeMBeanException(rme) {
            Exception ex = rme.getTargetException();
            ex.printStackTrace(System.out);
            throw ex;
         } catch  Exception(ex) {
            System.out.println("Exception occurred calling testConnectionToDataSource() for " + dsClassName + ex);
            ex.printStackTrace();
         }

         if (result2 != null) {
            System.out.println("ERROR Result= " + result2);
         } else if (verbose) {
            System.out.println("OK testConnectionToDataSource()");
         }

      } catch  RuntimeOperationsException(roe) {
         Exception ex = roe.getTargetException();
         ex.printStackTrace(System.out);
         throw ex;
      } catch  Exception(ex) {
         ex.printStackTrace(System.out);
         throw ex;
      }
   }

   /**
    * Format the string right justified in the space provided, 
    * or truncate the string.
    * 
    * @param in
    * @param length
    * @return 
    */
   public String format Object(in, int length) {
      if (in ==null) {
         in = "-null-";
      }

      String ins = in.toString();
      int insLength = ins.length();
      if ( insLength > length) {
         return ins.substring(0,length);
      } else {
         StringBuffer sb = new StringBuffer(length);
         while (length - insLength > 0) {
            sb.append(" ");
            length--;
         }
         sb.append(ins);
         return sb.toString();
      }
   }
}

 

See Also

Resource adapter
Data sources

 

---