User: d_jencks Date: 02/03/24 14:00:44 Added: src/main/org/jboss/test/jca/adapter TestConnection.java TestConnectionFactory.java TestConnectionRequestInfo.java TestManagedConnection.java TestManagedConnectionFactory.java TestXAResource.java Log: Tests for new ConnectionManager implementation. Many of these fail with the current less-than-spec-compliant jca-jdbc wrappers, but work ok with e.g. the firebird connector. Also, nojars combined targets removed, any test target can be run with -Dnojars=t. Also, log4j logging fixed and moved to xml config. Revision Changes Path 1.1 jbosstest/src/main/org/jboss/test/jca/adapter/TestConnection.java Index: TestConnection.java =================================================================== /* * JBoss, the OpenSource J2EE webOS * * Distributable under LGPL license. * See terms of license at gnu.org. * */ package org.jboss.test.jca.adapter; /** * TestConnection.java * * * Created: Sun Mar 10 19:35:48 2002 * * @author <a href="mailto:[EMAIL PROTECTED]">David Jencks</a> * @version */ public class TestConnection { private TestManagedConnection mc; private boolean mcIsNull = true; public TestConnection (TestManagedConnection mc) { this.mc = mc; mcIsNull = false; } public void close() { mc.connectionClosed(this); mcIsNull = true; } public boolean isInTx() { return mc.isInTx(); } void setMc(TestManagedConnection mc) { if (mc == null) { mcIsNull = true; } // end of if () else { this.mc = mc; } // end of else } }// TestConnection 1.1 jbosstest/src/main/org/jboss/test/jca/adapter/TestConnectionFactory.java Index: TestConnectionFactory.java =================================================================== /* * JBoss, the OpenSource J2EE webOS * * Distributable under LGPL license. * See terms of license at gnu.org. * */ package org.jboss.test.jca.adapter; import javax.naming.NamingException; import javax.naming.Reference; import javax.resource.ResourceException; import javax.resource.cci.Connection; import javax.resource.cci.ConnectionFactory; import javax.resource.cci.ConnectionSpec; import javax.resource.cci.RecordFactory; import javax.resource.cci.ResourceAdapterMetaData; // Generated package name /** * TestConnectionFactory.java * * * Created: Tue Jan 1 01:02:16 2002 * * @author <a href="mailto:[EMAIL PROTECTED]">David Jencks</a> * @version */ public class TestConnectionFactory implements ConnectionFactory { public TestConnectionFactory () { } // implementation of javax.resource.Referenceable interface /** * * @param param1 <description> */ public void setReference(Reference param1) { // TODO: implement this javax.resource.Referenceable method } // implementation of javax.naming.Referenceable interface /** * * @return <description> * @exception javax.naming.NamingException <description> */ public Reference getReference() throws NamingException { // TODO: implement this javax.naming.Referenceable method return null; } // implementation of javax.resource.cci.ConnectionFactory interface /** * * @return <description> * @exception javax.resource.ResourceException <description> */ public Connection getConnection() throws ResourceException { // TODO: implement this javax.resource.cci.ConnectionFactory method return null; } /** * * @param param1 <description> * @return <description> * @exception javax.resource.ResourceException <description> */ public Connection getConnection(ConnectionSpec param1) throws ResourceException { // TODO: implement this javax.resource.cci.ConnectionFactory method return null; } /** * * @return <description> * @exception javax.resource.ResourceException <description> */ public RecordFactory getRecordFactory() throws ResourceException { // TODO: implement this javax.resource.cci.ConnectionFactory method return null; } /** * * @return <description> * @exception javax.resource.ResourceException <description> */ public ResourceAdapterMetaData getMetaData() throws ResourceException { // TODO: implement this javax.resource.cci.ConnectionFactory method return null; } } 1.1 jbosstest/src/main/org/jboss/test/jca/adapter/TestConnectionRequestInfo.java Index: TestConnectionRequestInfo.java =================================================================== /* * JBoss, the OpenSource J2EE webOS * * Distributable under LGPL license. * See terms of license at gnu.org. * */ package org.jboss.test.jca.adapter; // Generated package name import javax.resource.spi.ConnectionRequestInfo; /** * TestConnectionRequestInfo.java * * * Created: Mon Dec 31 17:14:13 2001 * * @author <a href="mailto:[EMAIL PROTECTED]">David Jencks</a> * @version */ public class TestConnectionRequestInfo implements ConnectionRequestInfo { public TestConnectionRequestInfo () { } // implementation of javax.resource.spi.ConnectionRequestInfo interface /** * * @return <description> */ /*public int hashCode() { // TODO: implement this javax.resource.spi.ConnectionRequestInfo method return 0; }*/ /** * * @param param1 <description> * @return <description> */ /* public boolean equals(Object param1) { // TODO: implement this javax.resource.spi.ConnectionRequestInfo method return false; }*/ } 1.1 jbosstest/src/main/org/jboss/test/jca/adapter/TestManagedConnection.java Index: TestManagedConnection.java =================================================================== /* * JBoss, the OpenSource J2EE webOS * * Distributable under LGPL license. * See terms of license at gnu.org. * */ package org.jboss.test.jca.adapter; import java.io.PrintWriter; import java.util.ArrayList; import java.util.Collection; import java.util.Iterator; import java.util.LinkedList; import java.util.List; import javax.resource.ResourceException; import javax.resource.spi.ConnectionEvent; import javax.resource.spi.ConnectionEventListener; import javax.resource.spi.ConnectionRequestInfo; import javax.resource.spi.LocalTransaction; import javax.resource.spi.ManagedConnection; import javax.resource.spi.ManagedConnectionMetaData; import javax.security.auth.Subject; import javax.transaction.xa.XAException; import javax.transaction.xa.XAResource; import javax.transaction.xa.Xid; import org.jboss.logging.Logger; // Generated package name /** * TestManagedConnection.java * * * Created: Mon Dec 31 17:07:16 2001 * * @author <a href="mailto:[EMAIL PROTECTED]">David Jencks</a> * @version */ public class TestManagedConnection implements ManagedConnection, XAResource { private Logger log = Logger.getLogger(getClass()); private List handles = new LinkedList(); private List listeners = new LinkedList(); private Subject subject; private TestConnectionRequestInfo cri; private Xid xid; private boolean destroyed = false; public TestManagedConnection (final Subject subject, final TestConnectionRequestInfo cri) { this.subject = subject; this.cri = cri; } // implementation of javax.resource.spi.ManagedConnection interface /** * * @exception javax.resource.ResourceException <description> */ public void destroy() throws ResourceException { cleanup(); destroyed = true; } /** * * @exception javax.resource.ResourceException <description> */ public void cleanup() throws ResourceException { for (Iterator i = handles.iterator(); i.hasNext(); ) { TestConnection c = (TestConnection)i.next(); c.setMc(null); i.remove(); } // end of for () } /** * * @param param1 <description> * @param param2 <description> * @return <description> * @exception javax.resource.ResourceException <description> */ public Object getConnection(Subject param1, ConnectionRequestInfo param2) throws ResourceException { TestConnection c = new TestConnection(this); handles.add(c); return c; } /** * * @param param1 <description> * @exception javax.resource.ResourceException <description> */ public void associateConnection(Object p) throws ResourceException { if (p instanceof TestConnection) { ((TestConnection)p).setMc(this); handles.add(p); } // end of if () else { throw new ResourceException("wrong kind of Connection"); } // end of else } /** * * @param param1 <description> */ public void addConnectionEventListener(ConnectionEventListener cel) { log.info("adding 1 cel"); listeners.add(cel); } /** * * @param param1 <description> */ public void removeConnectionEventListener(ConnectionEventListener cel) { log.info("removing 1 cel"); listeners.remove(cel); } /** * * @return <description> * @exception javax.resource.ResourceException <description> */ public XAResource getXAResource() throws ResourceException { return this; } /** * * @return <description> * @exception javax.resource.ResourceException <description> */ public LocalTransaction getLocalTransaction() throws ResourceException { // TODO: implement this javax.resource.spi.ManagedConnection method return null; } /** * * @return <description> * @exception javax.resource.ResourceException <description> */ public ManagedConnectionMetaData getMetaData() throws ResourceException { // TODO: implement this javax.resource.spi.ManagedConnection method return null; } /** * * @param param1 <description> * @exception javax.resource.ResourceException <description> */ public void setLogWriter(PrintWriter param1) throws ResourceException { // TODO: implement this javax.resource.spi.ManagedConnection method } /** * * @return <description> * @exception javax.resource.ResourceException <description> */ public PrintWriter getLogWriter() throws ResourceException { // TODO: implement this javax.resource.spi.ManagedConnection method return null; } // implementation of javax.transaction.xa.XAResource interface /** * * @param param1 <description> * @param param2 <description> * @exception javax.transaction.xa.XAException <description> */ public void start(Xid xid, int flags) throws XAException { log.info("start with xid " + xid); this.xid = xid; } /** * * @param param1 <description> * @param param2 <description> * @exception javax.transaction.xa.XAException <description> */ public void end(final Xid xid, final int flags) throws XAException { log.info("end with xid " + xid); if (!xid.equals(this.xid)) { log.info("wrong xid ended: have " + this.xid + ", got: " + xid); } // end of if () this.xid = null; } /** * * @param param1 <description> * @param param2 <description> * @exception javax.transaction.xa.XAException <description> */ public void commit(Xid xid, boolean onePhase) throws XAException { log.info("commit with xid " + xid); // do nothing } /** * * @param param1 <description> * @exception javax.transaction.xa.XAException <description> */ public void rollback(Xid param1) throws XAException { log.info("rollback with xid " + xid); // do nothing } /** * * @param param1 <description> * @return <description> * @exception javax.transaction.xa.XAException <description> */ public int prepare(Xid param1) throws XAException { // do nothing return 0; } /** * * @param param1 <description> * @exception javax.transaction.xa.XAException <description> */ public void forget(Xid param1) throws XAException { // nothing doing } /** * * @param param1 <description> * @return <description> * @exception javax.transaction.xa.XAException <description> */ public Xid[] recover(int param1) throws XAException { // TODO: implement this javax.transaction.xa.XAResource method return null; } /** * * @param param1 <description> * @return <description> * @exception javax.transaction.xa.XAException <description> */ public boolean isSameRM(XAResource xar) throws XAException { return this == xar; } /** * * @return <description> * @exception javax.transaction.xa.XAException <description> */ public int getTransactionTimeout() throws XAException { // TODO: implement this javax.transaction.xa.XAResource method return 0; } /** * * @param param1 <description> * @return <description> * @exception javax.transaction.xa.XAException <description> */ public boolean setTransactionTimeout(int param1) throws XAException { // TODO: implement this javax.transaction.xa.XAResource method return false; } boolean isInTx() { log.info("isInTx, xid: " + xid); return xid != null; } void connectionClosed(TestConnection handle) { ConnectionEvent ce = new ConnectionEvent(this ,ConnectionEvent.CONNECTION_CLOSED); ce.setConnectionHandle(handle); Collection copy = new ArrayList(listeners); for (Iterator i = copy.iterator(); i.hasNext(); ) { log.info("notifying 1 cel connectionClosed"); ConnectionEventListener cel = (ConnectionEventListener)i.next(); cel.connectionClosed(ce); } // end of for () handles.remove(handle); } } 1.1 jbosstest/src/main/org/jboss/test/jca/adapter/TestManagedConnectionFactory.java Index: TestManagedConnectionFactory.java =================================================================== /* * JBoss, the OpenSource J2EE webOS * * Distributable under LGPL license. * See terms of license at gnu.org. * */ package org.jboss.test.jca.adapter; import java.io.PrintWriter; import java.util.Set; import javax.resource.ResourceException; import javax.resource.spi.ConnectionManager; import javax.resource.spi.ConnectionRequestInfo; import javax.resource.spi.ManagedConnection; import javax.resource.spi.ManagedConnectionFactory; import javax.security.auth.Subject; // Generated package name /** * ManagedConnectionFactory.java * * * Created: Mon Dec 31 17:01:55 2001 * * @author <a href="mailto:[EMAIL PROTECTED]">David Jencks</a> * @version */ public class TestManagedConnectionFactory implements ManagedConnectionFactory { public TestManagedConnectionFactory () { } // implementation of javax.resource.spi.ManagedConnectionFactory interface /** * * @return <description> */ public int hashCode() { // TODO: implement this javax.resource.spi.ManagedConnectionFactory method return 0; } /** * * @param param1 <description> * @return <description> */ public boolean equals(Object param1) { // TODO: implement this javax.resource.spi.ManagedConnectionFactory method return false; } /** * * @param param1 <description> * @exception javax.resource.ResourceException <description> */ public void setLogWriter(PrintWriter param1) throws ResourceException { // TODO: implement this javax.resource.spi.ManagedConnectionFactory method } /** * * @return <description> * @exception javax.resource.ResourceException <description> */ public PrintWriter getLogWriter() throws ResourceException { // TODO: implement this javax.resource.spi.ManagedConnectionFactory method return null; } /** * * @param param1 <description> * @return <description> * @exception javax.resource.ResourceException <description> */ public Object createConnectionFactory(ConnectionManager param1) throws ResourceException { // TODO: implement this javax.resource.spi.ManagedConnectionFactory method return null; } /** * * @return <description> * @exception javax.resource.ResourceException <description> */ public Object createConnectionFactory() throws ResourceException { // TODO: implement this javax.resource.spi.ManagedConnectionFactory method return null; } /** * * @param param1 <description> * @param param2 <description> * @return <description> * @exception javax.resource.ResourceException <description> */ public ManagedConnection createManagedConnection(Subject subject, ConnectionRequestInfo cri) throws ResourceException { return new TestManagedConnection(subject, (TestConnectionRequestInfo)cri); } /** * Describe <code>matchManagedConnections</code> method here. * * @param candidates a <code>Set</code> value * @param subject a <code>Subject</code> value * @param cri a <code>ConnectionRequestInfo</code> value * @return a <code>ManagedConnection</code> value * @exception ResourceException if an error occurs */ public ManagedConnection matchManagedConnections(Set candidates, Subject subject, ConnectionRequestInfo cri) throws ResourceException { if (candidates.isEmpty()) { return null; } // end of if () return (ManagedConnection)candidates.iterator().next(); } } 1.1 jbosstest/src/main/org/jboss/test/jca/adapter/TestXAResource.java Index: TestXAResource.java =================================================================== /* * JBoss, the OpenSource J2EE webOS * * Distributable under LGPL license. * See terms of license at gnu.org. * */ package org.jboss.test.jca.adapter; // Generated package name import javax.transaction.xa.XAException; import javax.transaction.xa.XAResource; import javax.transaction.xa.Xid; /** * TestXAResource.java * * * Created: Mon Dec 31 19:55:31 2001 * * @author <a href="mailto:[EMAIL PROTECTED]">David Jencks</a> * @version */ public class TestXAResource implements XAResource { public TestXAResource () { } // implementation of javax.transaction.xa.XAResource interface /** * * @param param1 <description> * @param param2 <description> * @exception javax.transaction.xa.XAException <description> */ public void start(Xid param1, int param2) throws XAException { // TODO: implement this javax.transaction.xa.XAResource method } /** * * @param param1 <description> * @param param2 <description> * @exception javax.transaction.xa.XAException <description> */ public void end(Xid param1, int param2) throws XAException { // TODO: implement this javax.transaction.xa.XAResource method } /** * * @param param1 <description> * @param param2 <description> * @exception javax.transaction.xa.XAException <description> */ public void commit(Xid param1, boolean param2) throws XAException { // TODO: implement this javax.transaction.xa.XAResource method } /** * * @param param1 <description> * @exception javax.transaction.xa.XAException <description> */ public void rollback(Xid param1) throws XAException { // TODO: implement this javax.transaction.xa.XAResource method } /** * * @param param1 <description> * @return <description> * @exception javax.transaction.xa.XAException <description> */ public int prepare(Xid param1) throws XAException { // TODO: implement this javax.transaction.xa.XAResource method return 0; } /** * * @param param1 <description> * @exception javax.transaction.xa.XAException <description> */ public void forget(Xid param1) throws XAException { // TODO: implement this javax.transaction.xa.XAResource method } /** * * @param param1 <description> * @return <description> * @exception javax.transaction.xa.XAException <description> */ public Xid[] recover(int param1) throws XAException { // TODO: implement this javax.transaction.xa.XAResource method return null; } /** * * @param param1 <description> * @return <description> * @exception javax.transaction.xa.XAException <description> */ public boolean isSameRM(XAResource param1) throws XAException { // TODO: implement this javax.transaction.xa.XAResource method return false; } /** * * @return <description> * @exception javax.transaction.xa.XAException <description> */ public int getTransactionTimeout() throws XAException { // TODO: implement this javax.transaction.xa.XAResource method return 0; } /** * * @param param1 <description> * @return <description> * @exception javax.transaction.xa.XAException <description> */ public boolean setTransactionTimeout(int param1) throws XAException { // TODO: implement this javax.transaction.xa.XAResource method return false; } }// TestXAResource
_______________________________________________ Jboss-development mailing list [EMAIL PROTECTED] https://lists.sourceforge.net/lists/listinfo/jboss-development