fsmanagedconnectionfactory.java

jboss 的官方实例程序

package org.jboss.book.jca.ex1.ra;

import java.io.File;
import java.io.PrintWriter;
import java.io.Serializable;
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;

import org.apache.log4j.Category;

/**
 *
 * @author  [e-mail]
 * @version $Revision: 1.1 $
 */
public class FSManagedConnectionFactory 
    implements ManagedConnectionFactory, 
               Serializable
{
    static Category log = Category.getInstance(FSManagedConnectionFactory.class);
    private String rootDirPath;
    private transient File rootDir;
    
    /** Creates new FSManagedConnectionFactory */
    public FSManagedConnectionFactory()
    {
    }
    
    public Object createConnectionFactory()
        throws ResourceException
    {
        log.debug("createConnectionFactory");
        throw new UnsupportedOperationException("Cannot be used in unmanaged env");
    }

    public Object createConnectionFactory(ConnectionManager cm)
        throws ResourceException
    {
        log.debug("createConnectionFactory, cm=" + cm, new Exception("CalledBy:"));
        FSRequestInfo fsInfo = new FSRequestInfo(rootDir);
        return new DirContextFactoryImpl(cm, this, fsInfo);
    }

    public ManagedConnection createManagedConnection(Subject subject,
                                                     ConnectionRequestInfo info)
        throws ResourceException
    {
        log.debug("createManagedConnection, subject=" + subject + ", info=" + info,
                  new Exception("CalledBy:"));
        FSRequestInfo fsInfo = (FSRequestInfo) info;
        return new FSManagedConnection(subject, fsInfo);
    }

    public ManagedConnection matchManagedConnections(Set connectionSet, 
                                                     Subject subject,
                                                     ConnectionRequestInfo info)
        throws ResourceException
    {
        log.debug("matchManagedConnections, connectionSet=" + 
                  connectionSet + ", subject=" + subject  +", info="  +info);
        return (ManagedConnection) connectionSet.iterator().next();
    }
    
    public PrintWriter getLogWriter() 
        throws ResourceException
    {
        return null;
    }
    

    public void setLogWriter(PrintWriter out) 
        throws ResourceException
    {
    }

    public boolean equals(Object other)
    {
        return super.equals(other);
    }

    public int hashCode()
    {
        return super.hashCode();
    }
    
    public void setFileSystemRootDir(String rootDirPath)
    {
        this.rootDirPath = rootDirPath;
        rootDir = new File(rootDirPath);

        if (rootDir.exists() == false) {
            rootDir.mkdirs();
        }
        log.debug("setFileSystemRootDir, rootDir=" + rootDir.getAbsolutePath(),
                  new Exception("CalledBy:"));
   }
}