vitalif
/
openesb-components
mirror of https://github.com/vitalif/openesb-components
1
0
Fork 0
Code Issues Releases Wiki Activity

ESBCOMP-89 Check if the MBean for datasource creation under GFv2 exists

master
David BRASSELY 2014-02-06 12:56:02 +01:00
parent c3c7ebbe2f
commit eab57bbd5a
1 changed files with 208 additions and 190 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

398
ojc-core/bpelse/bpeljbiadapter/src/com/sun/jbi/engine/bpel/ConnectionConfigurationImpl.java
View File

@ -43,221 +43,239 @@ import javax.naming.InitialContext;
import com.sun.jbi.engine.bpel.core.bpel.connection.ConnectionConfiguration; import com.sun.jbi.engine.bpel.core.bpel.connection.ConnectionConfiguration;
import com.sun.jbi.engine.bpel.core.bpel.exception.BPELConfigurationException; import com.sun.jbi.engine.bpel.core.bpel.exception.BPELConfigurationException;
import com.sun.jbi.engine.bpel.util.I18n; import com.sun.jbi.engine.bpel.util.I18n;
import java.util.Set;
import javax.management.MalformedObjectNameException;
/** /**
* Implemetation of the BPEL engine com.sun.jbi.engine.bpel.core.bpel.connection.ConnectionConfiguration * Implemetation of the BPEL engine
* interface. This Appserver context in which the BPEL engine resides, has the knowledge to create, configure * com.sun.jbi.engine.bpel.core.bpel.connection.ConnectionConfiguration
* and maintain the connection pools and jdbc resources. * interface. This Appserver context in which the BPEL engine resides, has the
* This class can be extended to implement all the connection requirements like schema creation, etc that * knowledge to create, configure and maintain the connection pools and jdbc
* the BPEL engine needs. * resources. This class can be extended to implement all the connection
* * requirements like schema creation, etc that the BPEL engine needs.
* Currently this class is used as an user friendly utility to programmatically create connection pools and *
* resources for the the Derby DB. This is done so that a user wanting to try out the product does not have * Currently this class is used as an user friendly utility to programmatically
* to worry about these connection configurations. * create connection pools and resources for the the Derby DB. This is done so
* This could be extended to all other DB that are supported with proper design. * that a user wanting to try out the product does not have to worry about these
* * connection configurations. This could be extended to all other DB that are
* supported with proper design.
*
* @author Sun Microsystems. * @author Sun Microsystems.
* *
*/ */
public class ConnectionConfigurationImpl implements ConnectionConfiguration { public class ConnectionConfigurationImpl implements ConnectionConfiguration {
private static final Logger LOGGER = Logger.getLogger(ConnectionConfigurationImpl.class.getName()); private static final Logger LOGGER = Logger.getLogger(ConnectionConfigurationImpl.class.getName());
private static final String RESOURCES_MBEAN_OBJ_NAME = "com.sun.appserv:type=resources,category=config"; private static final String RESOURCES_MBEAN_OBJ_NAME = "com.sun.appserv:type=resources,category=config";
private static final String XA_POOL_NAME = "bpelseXAPool"; private static final String XA_POOL_NAME = "bpelseXAPool";
private static final String NON_XA_POOL_NAME = "bpelseNonXAPool"; private static final String NON_XA_POOL_NAME = "bpelseNonXAPool";
private static final String DB_NAME = "bpelseDB"; // default name of the BPEL SE tablespace on Derby DB private static final String DB_NAME = "bpelseDB"; // default name of the BPEL SE tablespace on Derby DB
private static final String USR_NAME = "usr2"; private static final String USR_NAME = "usr2";
private static final String PASSWORD = "pass2"; private static final String PASSWORD = "pass2";
private static final String SERVER_NAME = "localhost"; //default is taken as the localhost where Derby DB is running private static final String SERVER_NAME = "localhost"; //default is taken as the localhost where Derby DB is running
private static final String PORT_NUM = "1527"; // Derby DB port number (taken as the default. private static final String PORT_NUM = "1527"; // Derby DB port number (taken as the default.
private ComponentContext mComponentContext;
private ComponentContext mComponentContext; private Properties mProperties;
private Properties mProperties;
public ConnectionConfigurationImpl(ComponentContext componentContext, Properties properties) {
mComponentContext = componentContext;
mProperties = properties;
}
/* (non-Javadoc) public ConnectionConfigurationImpl(ComponentContext componentContext, Properties properties) {
* @see com.sun.jbi.engine.bpel.core.bpel.connection.ConnectionConfiguration#createConnections() mComponentContext = componentContext;
*/ mProperties = properties;
public void createConnectionsPools() { }
try { /* (non-Javadoc)
String nonXaJndiResName = mProperties.getProperty(DatabaseNonXAJNDIName); * @see com.sun.jbi.engine.bpel.core.bpel.connection.ConnectionConfiguration#createConnections()
String xaJndiResName = mProperties.getProperty(DatabaseXAJNDIName); */
public void createConnectionsPools() {
//Create the Non-XA connection pool and JNDI JDBC resource. boolean mBeanAvailable = false;
String dataSrcClassName = "org.apache.derby.jdbc.ClientDataSource";
String resourceType = "javax.sql.DataSource";
createPoolandResource(NON_XA_POOL_NAME, nonXaJndiResName, dataSrcClassName, resourceType, false);
//create the XA connection pool and JNDI JDBC resource.
dataSrcClassName = "org.apache.derby.jdbc.ClientXADataSource";
resourceType = "javax.sql.XADataSource";
createPoolandResource(XA_POOL_NAME, xaJndiResName, dataSrcClassName, resourceType, true);
} catch (Exception configExep) {
String message = I18n.loc("BPCOR-7012: Exception thrown while creating ConnectionConfiguration. Exception Details : {0} ", configExep.getMessage());
LOGGER.log(Level.SEVERE, message);
throw new BPELConfigurationException(message);
}
}
/* (non-Javadoc)
* @see com.sun.jbi.engine.bpel.core.bpel.connection.ConnectionConfiguration#getNamingContext()
*/
public InitialContext getNamingContext() {
return mComponentContext.getNamingContext();
}
/** try {
* This method creates a connection pool and a jdbc resource pointing to that pool MBeanServer mBeanServer = mComponentContext.getMBeanServer();
* if the pool is not already created.
* Use non public, non published apis to lookup and create the pools and resources. Set<ObjectName> objectNames = mBeanServer.queryNames(
* Hence it is liable to change as and when the api's change. new ObjectName(RESOURCES_MBEAN_OBJ_NAME), null);
*
* @param connPoolName, String value for the connection pool name. mBeanAvailable = !objectNames.isEmpty();
* @param jndiResName, String value for the Jdbc jndi resource name. } catch (MalformedObjectNameException ex) {
* @param dataSrcClassName, String value of the actual datasource class name. // Nothing to do here... we are not running under Glassfish v2
* @param resourceType, String value of the resource type. ex: javax.sql.DataSource }
* @param isXA, boolean value indicating if this is a XA connection
* @throws Exception
*/
private void createPoolandResource(String connPoolName, String jndiResName,
String dataSrcClassName, String resourceType, boolean isXA)
throws Exception {
MBeanServer mBeanServer = mComponentContext.getMBeanServer(); if (mBeanAvailable) {
ObjectName configObjName = ObjectName try {
.getInstance(RESOURCES_MBEAN_OBJ_NAME); String nonXaJndiResName = mProperties.getProperty(DatabaseNonXAJNDIName);
String xaJndiResName = mProperties.getProperty(DatabaseXAJNDIName);
final String sFalse = "false"; //Create the Non-XA connection pool and JNDI JDBC resource.
final String sTrue = "true"; String dataSrcClassName = "org.apache.derby.jdbc.ClientDataSource";
final String sZero = "0"; String resourceType = "javax.sql.DataSource";
createPoolandResource(NON_XA_POOL_NAME, nonXaJndiResName, dataSrcClassName, resourceType, false);
Object retRes = null;
try {
retRes = mBeanServer.invoke(configObjName,
"getJdbcResourceByJndiName",
new Object[] { jndiResName },
new String[] { String.class.getName() });
} catch (Exception resourceExec) {
// if the JDBC Resource is not present then the above call throws an exception
// Do nothing as we have to create the pool and then the resource
}
// if the JDBC Resource exists then return. The assumption is that JDBC resource //create the XA connection pool and JNDI JDBC resource.
// can exist only for a valid connection pool. dataSrcClassName = "org.apache.derby.jdbc.ClientXADataSource";
if (retRes != null) { resourceType = "javax.sql.XADataSource";
if (LOGGER.isLoggable(Level.FINE)) { createPoolandResource(XA_POOL_NAME, xaJndiResName, dataSrcClassName, resourceType, true);
LOGGER.log(Level.FINE, I18n.loc("BPJBI-3012: JDBC Resource {0} exists hence is not created.",
jndiResName));
}
return;
}
// check to see if the connection pool is present
Object retPool = null;
try {
retPool = mBeanServer.invoke(configObjName,
"getJdbcConnectionPoolByName",
new Object[] { connPoolName },
new String[] { String.class.getName() });
} catch (Exception poolExec) { } catch (Exception configExep) {
// if the connPoolName is not there the above call throws an exception String message = I18n.loc("BPCOR-7012: Exception thrown while creating ConnectionConfiguration. Exception Details : {0} ", configExep.getMessage());
// Do Nothing as we have to create the pool and the resource LOGGER.log(Level.SEVERE, message);
} throw new BPELConfigurationException(message);
}
}
}
if (retPool == null) { /* (non-Javadoc)
// Create the connection pool and the JDBC JNDI resource. * @see com.sun.jbi.engine.bpel.core.bpel.connection.ConnectionConfiguration#getNamingContext()
AttributeList attrList = new AttributeList(); */
public InitialContext getNamingContext() {
return mComponentContext.getNamingContext();
}
// attributes of the General Tab in the admin console /**
attrList.add(new Attribute("name", connPoolName)); * This method creates a connection pool and a jdbc resource pointing to
attrList.add(new Attribute("datasource-classname", dataSrcClassName)); * that pool if the pool is not already created. Use non public, non
attrList.add(new Attribute("res-type", resourceType)); * published apis to lookup and create the pools and resources. Hence it is
* liable to change as and when the api's change.
*
* @param connPoolName, String value for the connection pool name.
* @param jndiResName, String value for the Jdbc jndi resource name.
* @param dataSrcClassName, String value of the actual datasource class
* name.
* @param resourceType, String value of the resource type. ex:
* javax.sql.DataSource
* @param isXA, boolean value indicating if this is a XA connection
* @throws Exception
*/
private void createPoolandResource(String connPoolName, String jndiResName,
String dataSrcClassName, String resourceType, boolean isXA)
throws Exception {
attrList.add(new Attribute("steady-pool-size", "8")); MBeanServer mBeanServer = mComponentContext.getMBeanServer();
attrList.add(new Attribute("max-pool-size", "32")); ObjectName configObjName = ObjectName
attrList.add(new Attribute("pool-resize-quantity", "2")); .getInstance(RESOURCES_MBEAN_OBJ_NAME);
attrList.add(new Attribute("idle-timeout-in-seconds", "300"));
attrList.add(new Attribute("max-wait-time-in-millis", "60000"));
attrList.add(new Attribute("is-connection-validation-required", final String sFalse = "false";
sFalse)); final String sTrue = "true";
attrList.add(new Attribute("connection-validation-method", final String sZero = "0";
"auto-commit"));
attrList.add(new Attribute("fail_all_connections", sFalse));
// String allowComponentCallers = (isXA) ? sTrue : sFalse;
attrList.add(new Attribute("allow-non-component-callers", sTrue));
attrList.add(new Attribute("non-transactional-connections", sFalse)); Object retRes = null;
attrList.add(new Attribute("is-isolation-level-guaranteed", sFalse));
// attributes of the Advanced tab in the admin console try {
// attrList.add(new Attribute("statement-timeout-in-seconds", retRes = mBeanServer.invoke(configObjName,
// "-1")); "getJdbcResourceByJndiName",
attrList.add(new Attribute("wrap-jdbc-objects", sFalse)); new Object[]{jndiResName},
attrList.add(new Attribute( new String[]{String.class.getName()});
"validate-atmost-once-period-in-seconds", sZero));
attrList.add(new Attribute("connection-leak-timeout-in-seconds",
sZero));
attrList.add(new Attribute("connection-leak-reclaim", sFalse));
attrList.add(new Attribute("connection-creation-retry-attempts",
sZero));
attrList.add(new Attribute(
"connection-creation-retry-interval-in-seconds", "10"));
attrList.add(new Attribute("lazy-connection-enlistment", sFalse));
attrList.add(new Attribute("lazy-connection-association", sFalse));
attrList.add(new Attribute("associate-with-thread", sFalse));
attrList.add(new Attribute("match-connections", sFalse));
attrList.add(new Attribute("max-connection-usage-count", sZero));
// addition properties tab in the admin console } catch (Exception resourceExec) {
Properties props = new Properties(); // if the JDBC Resource is not present then the above call throws an exception
props.setProperty("PortNumber", PORT_NUM); // Do nothing as we have to create the pool and then the resource
props.setProperty("DatabaseName", DB_NAME); }
props.setProperty("User", USR_NAME);
props.setProperty("Password", PASSWORD);
props.setProperty("serverName", SERVER_NAME);
props.setProperty("connectionAttributes", ";create=true");
// create the connection pool // if the JDBC Resource exists then return. The assumption is that JDBC resource
mBeanServer.invoke(configObjName, "createJdbcConnectionPool", // can exist only for a valid connection pool.
new Object[] { attrList, props, "domain" }, new String[] { if (retRes != null) {
javax.management.AttributeList.class.getName(), if (LOGGER.isLoggable(Level.FINE)) {
java.util.Properties.class.getName(), LOGGER.log(Level.FINE, I18n.loc("BPJBI-3012: JDBC Resource {0} exists hence is not created.",
String.class.getName() }); jndiResName));
} else { }
// the connection pool exits, log it. return;
if (LOGGER.isLoggable(Level.FINE)) { }
LOGGER.log(Level.FINE, I18n.loc("BPJBI-3013: Connection pool {0} exists hence is not created.", // check to see if the connection pool is present
connPoolName)); Object retPool = null;
} try {
retPool = mBeanServer.invoke(configObjName,
} "getJdbcConnectionPoolByName",
new Object[]{connPoolName},
new String[]{String.class.getName()});
AttributeList attrList2 = new AttributeList(); } catch (Exception poolExec) {
attrList2.add(new Attribute("jndi-name", jndiResName)); // if the connPoolName is not there the above call throws an exception
attrList2.add(new Attribute("pool-name", connPoolName)); // Do Nothing as we have to create the pool and the resource
attrList2.add(new Attribute("object-type", "user")); }
attrList2.add(new Attribute("enabled", sTrue));
// create the JNDI JDBC resource if (retPool == null) {
mBeanServer.invoke(configObjName, // Create the connection pool and the JDBC JNDI resource.
"createJdbcResource", AttributeList attrList = new AttributeList();
new Object[] { attrList2, new Properties(), "server" },
new String[] { javax.management.AttributeList.class.getName(), // attributes of the General Tab in the admin console
java.util.Properties.class.getName(), attrList.add(new Attribute("name", connPoolName));
String.class.getName() }); attrList.add(new Attribute("datasource-classname", dataSrcClassName));
attrList.add(new Attribute("res-type", resourceType));
attrList.add(new Attribute("steady-pool-size", "8"));
attrList.add(new Attribute("max-pool-size", "32"));
attrList.add(new Attribute("pool-resize-quantity", "2"));
attrList.add(new Attribute("idle-timeout-in-seconds", "300"));
attrList.add(new Attribute("max-wait-time-in-millis", "60000"));
attrList.add(new Attribute("is-connection-validation-required",
sFalse));
attrList.add(new Attribute("connection-validation-method",
"auto-commit"));
attrList.add(new Attribute("fail_all_connections", sFalse));
// String allowComponentCallers = (isXA) ? sTrue : sFalse;
attrList.add(new Attribute("allow-non-component-callers", sTrue));
attrList.add(new Attribute("non-transactional-connections", sFalse));
attrList.add(new Attribute("is-isolation-level-guaranteed", sFalse));
// attributes of the Advanced tab in the admin console
// attrList.add(new Attribute("statement-timeout-in-seconds",
// "-1"));
attrList.add(new Attribute("wrap-jdbc-objects", sFalse));
attrList.add(new Attribute(
"validate-atmost-once-period-in-seconds", sZero));
attrList.add(new Attribute("connection-leak-timeout-in-seconds",
sZero));
attrList.add(new Attribute("connection-leak-reclaim", sFalse));
attrList.add(new Attribute("connection-creation-retry-attempts",
sZero));
attrList.add(new Attribute(
"connection-creation-retry-interval-in-seconds", "10"));
attrList.add(new Attribute("lazy-connection-enlistment", sFalse));
attrList.add(new Attribute("lazy-connection-association", sFalse));
attrList.add(new Attribute("associate-with-thread", sFalse));
attrList.add(new Attribute("match-connections", sFalse));
attrList.add(new Attribute("max-connection-usage-count", sZero));
// addition properties tab in the admin console
Properties props = new Properties();
props.setProperty("PortNumber", PORT_NUM);
props.setProperty("DatabaseName", DB_NAME);
props.setProperty("User", USR_NAME);
props.setProperty("Password", PASSWORD);
props.setProperty("serverName", SERVER_NAME);
props.setProperty("connectionAttributes", ";create=true");
// create the connection pool
mBeanServer.invoke(configObjName, "createJdbcConnectionPool",
new Object[]{attrList, props, "domain"}, new String[]{
javax.management.AttributeList.class.getName(),
java.util.Properties.class.getName(),
String.class.getName()});
} else {
// the connection pool exits, log it.
if (LOGGER.isLoggable(Level.FINE)) {
LOGGER.log(Level.FINE, I18n.loc("BPJBI-3013: Connection pool {0} exists hence is not created.",
connPoolName));
}
}
AttributeList attrList2 = new AttributeList();
attrList2.add(new Attribute("jndi-name", jndiResName));
attrList2.add(new Attribute("pool-name", connPoolName));
attrList2.add(new Attribute("object-type", "user"));
attrList2.add(new Attribute("enabled", sTrue));
// create the JNDI JDBC resource
mBeanServer.invoke(configObjName,
"createJdbcResource",
new Object[]{attrList2, new Properties(), "server"},
new String[]{javax.management.AttributeList.class.getName(),
java.util.Properties.class.getName(),
String.class.getName()});
}
}
private boolean isEmpty(String str) { private boolean isEmpty(String str) {
return ((null == str) || (str.trim().length() == 0)); return ((null == str) || (str.trim().length() == 0));
} }