• JW's Most Read

Recent:

• Java Tips: The Serialization algorithm revealed
• Know your Oracle application server
• SwingX, JRuby: Survivors?
• Cloud-ready, multicore-friendly apps, Part 2
• Lean service architectures with Java EE 6

Archives:

• Hello, OSGi: Bundles for beginners (2008)
• Sockets programming in Java: A tutorial (1996)
• Understanding JPA, Part 1 (2008)
• Smartly load your properties (2003)
• REST for Java developers, Part 1 (2008)

 
package myjca;
import java.io.PrintWriter;
import java.io.Serializable;
import java.sql.DriverManager;
import java.util.Iterator;
import java.util.Set;
import javax.resource.ResourceException;
import javax.resource.spi.*;
import javax.security.auth.Subject;
public class MyManagedConnectionFactory
    implements ManagedConnectionFactory, Serializable
{
    public MyManagedConnectionFactory() {
        System.out.println("In MyManagedConnectionFactory.constructor");
    }
    public Object createConnectionFactory(ConnectionManager cxManager) throws ResourceException {
        System.out.println("In MyManagedConnectionFactory.createConnectionFactory,1");
        return new MyDataSource(this, cxManager);
    }
    public Object createConnectionFactory() throws ResourceException {
              System.out.println("In MyManagedConnectionFactory.createManagedFactory,2");
        return new MyDataSource(this, null);
    }
    public ManagedConnection createManagedConnection(Subject subject, ConnectionRequestInfo info) {
        System.out.println("In MyManagedConnectionFactory.createManagedConnection");
        return new MyManagedConnection(this, "test");
    }
    public ManagedConnection matchManagedConnections(Set connectionSet, Subject subject, ConnectionRequestInfo info)
        throws ResourceException
    {
        System.out.println("In MyManagedConnectionFactory.matchManagedConnections");
        return null;
    }
    public void setLogWriter(PrintWriter out) throws ResourceException {
        System.out.println("In MyManagedConnectionFactory.setLogWriter");
    }
    public PrintWriter getLogWriter() throws ResourceException {
        System.out.println("In MyManagedConnectionFactory.getLogWriter");
        return DriverManager.getLogWriter();
    }
    public boolean equals(Object obj) {
        if(obj == null)
            return false;
        if(obj instanceof MyManagedConnectionFactory)
        {
            int hash1 = ((MyManagedConnectionFactory)obj).hashCode();
            int hash2 = hashCode();
            return hash1 == hash2;
        }
        else
        {
            return false;
        }
    }
    public int hashCode()
    {
              return 1;
    }
}

package myjca;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.*;
import javax.resource.NotSupportedException;
import javax.resource.ResourceException;
import javax.resource.spi.*;
import javax.security.auth.Subject;
import javax.transaction.xa.XAResource;
public class MyManagedConnection
  implements ManagedConnection
{
     private MyConnectionEventListener myListener;
     private String user;
     private ManagedConnectionFactory mcf;
     private PrintWriter logWriter;
     private boolean destroyed;
     private Set connectionSet;
  MyManagedConnection(ManagedConnectionFactory mcf, String user)
  {
    System.out.println("In MyManagedConnection");
    this.mcf = mcf;
    this.user = user;
    connectionSet = new HashSet();
    myListener = new MyConnectionEventListener(this);
  }
  private void throwResourceException(SQLException ex)
    throws ResourceException
  {
    ResourceException re = new ResourceException("SQLException: " +
ex.getMessage());
    re.setLinkedException(ex);
    throw re;
  }
  public Object getConnection(Subject subject, ConnectionRequestInfo
connectionRequestInfo)
    throws ResourceException
  {
    System.out.println("In MyManagedConnection.getConnection");
    MyConnection myCon = new MyConnection(this);
    addMyConnection(myCon);
    return myCon;
  }
  public void destroy()
  {
        System.out.println("In MyManagedConnection.destroy");
        destroyed = true;
  }
  public void cleanup()
   {
        System.out.println("In MyManagedConnection.cleanup");
  }
  public void associateConnection(Object connection)
   {
        System.out.println("In MyManagedConnection.associateConnection");
  }
  public void addConnectionEventListener(ConnectionEventListener listener)
  {
        System.out.println("In MyManagedConnection.addConnectionEventListener");
    myListener.addConnectorListener(listener);
  }
  public void removeConnectionEventListener(ConnectionEventListener listener)
  {
        System.out.println("In MyManagedConnection.removeConnectionEventListener");
    myListener.removeConnectorListener(listener);
  }
  public XAResource getXAResource()
    throws ResourceException
  {
        System.out.println("In MyManagedConnection.getXAResource");
    return null;
  }
  public LocalTransaction getLocalTransaction()
  {
           System.out.println("In MyManagedConnection.getLocalTransaction");
      return null;
  }
  public ManagedConnectionMetaData getMetaData()
    throws ResourceException
  {
    System.out.println("In MyManagedConnection.getMetaData");
    return new MyConnectionMetaData(this);
  }
  public void setLogWriter(PrintWriter out)
    throws ResourceException
  {
        System.out.println("In MyManagedConnection.setLogWriter");
    logWriter = out;
  }
  public PrintWriter getLogWriter()
    throws ResourceException
  {
        System.out.println("In MyManagedConnection.getLogWriter");
    return logWriter;
  }
  Connection getMyConnection()
    throws ResourceException
  {
        System.out.println("In MyManagedConnection.getMyConnection");
    return null;
  }
  boolean isDestroyed()
  {
        System.out.println("In MyManagedConnection.isDestroyed");
    return destroyed;
  }
  String getUserName()
  {
        System.out.println("In MyManagedConnection.getUserName");
    return user;
  }
  void sendEvent(int eventType, Exception ex)
  {
        System.out.println("In MyManagedConnection.sendEvent,1");
    myListener.sendEvent(eventType, ex, null);
  }
  void sendEvent(int eventType, Exception ex, Object connectionHandle)
  {
        System.out.println("In MyManagedConnection.sendEvent,2 ");
    myListener.sendEvent(eventType, ex, connectionHandle);
  }
  void removeMyConnection(MyConnection myCon)
  {
        System.out.println("In MyManagedConnection.removeMyConnection");
    connectionSet.remove(myCon);
  }
  void addMyConnection(MyConnection myCon)
  {
        System.out.println("In MyManagedConnection.addMyConnection");
    connectionSet.add(myCon);
  }
  ManagedConnectionFactory getManagedConnectionFactory()
  {
        System.out.println("In MyManagedConnection.getManagedConnectionFactory");
    return mcf;
  }
}

Good ArticleBy Anonymous on January 28, 2010, 9:18 amgives the basic understanding of jca architecture. nice article

Reply | Read entire comment

askBy Anonymous on December 16, 2009, 8:34 pmI am very interested with this article. But after I compile that java file, there is a lot of error,it said many objects that are not identificated.why? if I may...

Reply | Read entire comment

Very useful. Thanks.By Anonymous on October 6, 2009, 5:00 pmVery useful. Thanks.

Reply | Read entire comment

Nice article..By Anonymous on March 9, 2009, 3:56 pmNice article..

Reply | Read entire comment

View all comments