MapperManager.java

package org.objectweb.jonas_ejb.container.jorm;

import java.util.HashMap;
import java.util.Map;
import java.util.Properties;

import org.objectweb.jonas_ejb.container.JContainer;
import org.objectweb.jonas_ejb.container.TraceEjb;

import org.objectweb.jorm.lib.JormConfiguratorImpl;
import org.objectweb.jorm.api.JormConfigurator;
import org.objectweb.jorm.api.PException;
import org.objectweb.jorm.api.PMapper;
import org.objectweb.jorm.lib.Mapper;
import org.objectweb.jorm.util.api.Loggable;

import org.objectweb.medor.eval.prefetch.lib.PrefetchCacheImpl;

import org.objectweb.util.monolog.api.BasicLevel;
import org.objectweb.util.monolog.api.Logger;

public class MapperManager {

    private static MapperManager singleton = null;

    public static MapperManager getInstance() {
        if (singleton == null) {
            singleton = new MapperManager();
        }
        return singleton;
    }

    private Logger logger = null;

    private HashMap mappers = new HashMap();

    private JormConfigurator jormConfigurator;

    protected MapperManager() {
        logger = TraceEjb.logger;
        jormConfigurator = new JormConfiguratorImpl();
        Properties prop = new Properties();
        prop.put("jorm.generator", "org.objectweb.jorm.generator.lib.JormGenerator");
        prop.put("jorm.mimanager", "org.objectweb.jorm.metainfo.lib.JormManager");
        prop.put("jorm.parser", "org.objectweb.jorm.xml2mi.lib.BasicDomParser");
        prop.put("jorm.verifier", "org.objectweb.jorm.verifier.lib.JormVerifier");
        prop.put("jorm.writer", "org.objectweb.jorm.mi2xml.lib.BasicDomWriter");
        prop.put("jorm.mapper.list", "rdb");
        prop.put("jorm.mapper.mifactory.rdb", "org.objectweb.jorm.mapper.rdb.metainfo.RdbMappingFactory");
        prop.put("jorm.mapper.mopfactory.rdb", "org.objectweb.jorm.mapper.rdb.generator.RdbMOPFactory");
        prop.put("jorm.mapper.gcmapping.rdb", "org.objectweb.jorm.mapper.rdb.genclass.RdbGenClassMapping");
        prop.put("jorm.mapper.schmgr.rdb", "org.objectweb.jorm.mapper.rdb.lib.RdbPMappingStructuresManager");
        jormConfigurator.configure(prop);
        jormConfigurator.setLoggerFactory(TraceEjb.loggerFactory);
        logger.log(BasicLevel.DEBUG, "JormConfigurator created");
    }

    public PMapper getMapper(JContainer c, Object cf) {
        Map m = (Map) mappers.get(c);
        return (m == null ? null : (Mapper) m.get(cf));
    }

    public PMapper addMapper(PMapper m, JContainer c, Object cf) throws PException {
        Map map;
        PMapper pm = null;
        synchronized (mappers) {
            map = (Map) mappers.get(c);
            if (map == null) {
                map = new HashMap();
                mappers.put(c, map);
            }
        }
        pm = (PMapper) map.get(cf);
        if (pm != null) {
            return pm;
        }
        synchronized(map) {
            pm = (PMapper) map.get(cf);
            if (pm == null) {
                pm = m;
                //Allocate a new Cache of PreftechBuffer
                m.setPrefetchCache(new PrefetchCacheImpl());
                //Add a logger
                if (TraceEjb.loggerFactory == null) {
                    m.setLogger(logger);
                } else {
                    m.setLogger(TraceEjb.loggerFactory.getLogger(TraceEjb.prefix
                            + ".mapper." + m.getMapperName()));
                    if (m instanceof Loggable) {
                        ((Loggable) m).setLoggerFactory(TraceEjb.loggerFactory);
                    }
                }
                // start the mapper
                m.start();
                //register mapper
                map.put(cf, m);
                if (logger.isLoggable(BasicLevel.DEBUG)) {
                    logger.log(BasicLevel.DEBUG, "Mapper (" + m.getMapperName()
                            + ", " + cf + ") initialized");
                }
            }
        }
        return pm;
    }

    public Logger getLogger() {
        return logger;
    }

    public JormConfigurator getJormConfigurator() {
        return jormConfigurator;
    }
}

---