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()
//
// "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();
}
}
}
Resource adapter
Data sources