RdbFactory.java

package org.objectweb.jonas_ejb.container.jorm;

import javax.sql.DataSource;

import org.objectweb.jonas_ejb.container.JContainer;
import org.objectweb.jonas_ejb.deployment.api.EntityDesc;

import org.objectweb.jorm.api.PException;
import org.objectweb.jorm.lib.MapperJCA;
import org.objectweb.jorm.mapper.rdb.lib.MapperJDBC;

public abstract class RdbFactory extends MedorFactory {

    public RdbFactory() {
        super();
    }

    public void init(EntityDesc dd, JContainer cont, String mapperName) {
        super.init(dd, cont, mapperName);
    }

    public Object getConnection(Object hints) throws PException {
        if (hints == null) {
            return mapper.getConnection();
        } else {
            return mapper.getConnection(hints);
        }
    }

    public void releaseConnection(Object conn) throws PException {
        mapper.closeConnection(conn);
    }

    protected void setMapper(String mapperName) throws PException {
        MapperManager mm = MapperManager.getInstance();
        synchronized (mm) {
            mapper = mm.getMapper(cont, datasource);
            if (mapper == null) {
                // datasource has been found by its JNDI name in the bean DD
                if (datasource instanceof DataSource) {
                    mapper = new MapperJDBC(mm.getJormConfigurator());
                } else {
                    mapper = new MapperJCA(mm.getJormConfigurator());
                }
                mapper.setMapperName(mapperName);

                // to redirect getConnection() on our DataSource
                mapper.setConnectionFactory(datasource);

                //register and finish to configure the new mapper
                mm.addMapper(mapper, cont, datasource);
            }
        }
    }
}

---