Changeset 217


Ignore:
Timestamp:
03/05/10 14:55:59 (14 years ago)
Author:
oschonef
Message:
  • make DataStore? property of virtualCollectionRegistry (again)
Location:
VirtualCollectionRegistry/trunk/VirtualCollectionRegistry/src/main/java/eu/clarin/cmdi/virtualcollectionregistry
Files:
5 edited

Legend:

Unmodified
Added
Removed

  • VirtualCollectionRegistry/trunk/VirtualCollectionRegistry/src/main/java/eu/clarin/cmdi/virtualcollectionregistry/DataStore.java

    r146 r217  
    11package eu.clarin.cmdi.virtualcollectionregistry;
    22
    3 import java.util.HashMap;
    43import java.util.Map;
    54import java.util.logging.Level;
    … …  
    2019                }
    2120        } // inner class ThreadLocalEntityManager
    22         private static final Logger logger = Logger.getLogger(DataStore.class
    23                         .getName());
    24         private static DataStore s_instance = new DataStore();
    25         private EntityManagerFactory emf = null;
    26         private ThreadLocalEntityManager em = new ThreadLocalEntityManager();
     21        private static final Logger logger =
     22                Logger.getLogger(DataStore.class.getName());
     23        private final EntityManagerFactory emf;
     24        private final ThreadLocalEntityManager em = new ThreadLocalEntityManager();
    2725
    28         private DataStore() {
    29         }
    30 
    31         public void initalize(Map<String, String> config)
    32                         throws VirtualCollectionRegistryException {
    33                 logger.fine("initializing");
    34                 if (config != null) {
    35                         config = new HashMap<String, String>();
    36                 }
     26        DataStore(Map<String, String> config)
     27                throws VirtualCollectionRegistryException {
    3728                try {
    3829                        emf = Persistence.createEntityManagerFactory(
    … …  
    4031                } catch (Exception e) {
    4132                        logger.log(Level.SEVERE, "error initializing data store", e);
    42                         throw new VirtualCollectionRegistryException(
    43                                         "error initializing", e);
     33                        throw new VirtualCollectionRegistryException("error initializing",
     34                                        e);
    4435                }
    4536                logger.finer("data store was successfully initialized");
    … …  
    5243        }
    5344
    54         public static DataStore instance() {
    55                 return s_instance;
    56         }
    57        
    5845        public EntityManager getEntityManager() {
    5946                return em.get();
    … …  
    7158                }
    7259        }
    73 }
     60
     61} // class DataStore

  • VirtualCollectionRegistry/trunk/VirtualCollectionRegistry/src/main/java/eu/clarin/cmdi/virtualcollectionregistry/VirtualCollectionRegistry.java

    r215 r217  
    22
    33import java.security.Principal;
     4import java.util.Collections;
    45import java.util.HashSet;
    56import java.util.List;
    … …  
    2930                new VirtualCollectionRegistry();
    3031        private AtomicBoolean intialized = new AtomicBoolean(false);
    31         private VirtualCollectionRegistryMarshaller marshaller;
     32        private DataStore datastore = null;
     33        private VirtualCollectionRegistryMarshaller marshaller = null;
    3234       
    3335        private VirtualCollectionRegistry() {
    … …  
    4749                logger.fine("initialize ...");
    4850                if (config == null) {
    49                         throw new NullPointerException("config == null");
     51                        config = Collections.emptyMap();
    5052                }
    5153                for (String key : config.keySet()) {
    5254                        logger.fine("XXX: " + key + " = \"" + config.get(key) + "\"");
    5355                }
     56                datastore  = new DataStore(config);
    5457                marshaller = new VirtualCollectionRegistryMarshaller();
    5558                intialized.set(true);
    … …  
    5760
    5861        public void destroy() throws VirtualCollectionRegistryException {
     62                if (datastore != null) {
     63                        datastore.destroy();
     64                }
    5965        }
    6066
    … …  
    6773        }
    6874
     75        public DataStore getDataStore() {
     76                return datastore;
     77        }
     78
    6979        public VirtualCollectionRegistryMarshaller getMarshaller() {
    7080                return marshaller;
    … …  
    8595
    8696                try {
    87                         EntityManager em = DataStore.instance().getEntityManager();
     97                        EntityManager em = datastore.getEntityManager();
    8898                        em.getTransaction().begin();
    8999
    … …  
    144154
    145155                try {
    146                         EntityManager em = DataStore.instance().getEntityManager();
     156                        EntityManager em = datastore.getEntityManager();
    147157                        em.getTransaction().begin();
    148158                        VirtualCollection c = em.find(VirtualCollection.class, new Long(id));
    … …  
    200210
    201211                try {
    202                         EntityManager em = DataStore.instance().getEntityManager();
     212                        EntityManager em = datastore.getEntityManager();
    203213                        em.getTransaction().begin();
    204214                        VirtualCollection vc = em.find(VirtualCollection.class, new Long(id));
    … …  
    231241
    232242                try {
    233                         EntityManager em = DataStore.instance().getEntityManager();
     243                        EntityManager em = datastore.getEntityManager();
    234244                        em.getTransaction().begin();
    235245                        VirtualCollection vc = em.find(VirtualCollection.class,
    … …  
    257267
    258268                try {
    259                         EntityManager em = DataStore.instance().getEntityManager();
     269                        EntityManager em = datastore.getEntityManager();
    260270                        em.getTransaction().begin();
    261271                        ResourceMetadata md = em.find(ResourceMetadata.class, new Long(id));
    … …  
    278288        public VirtualCollectionList getVirtualCollections(String query,
    279289                        int offset, int count) throws VirtualCollectionRegistryException {
    280                 EntityManager em = DataStore.instance().getEntityManager();
     290                EntityManager em = datastore.getEntityManager();
    281291                try {
    282292                        em.getTransaction().begin();
    … …  
    330340                        throw new NullPointerException("principal == null");
    331341                }
    332                 EntityManager em = DataStore.instance().getEntityManager();
     342                EntityManager em = datastore.getEntityManager();
    333343                try {
    334344                        em.getTransaction().begin();

  • VirtualCollectionRegistry/trunk/VirtualCollectionRegistry/src/main/java/eu/clarin/cmdi/virtualcollectionregistry/rest/ContextListener.java

    r146 r217  
    88import javax.servlet.ServletContextListener;
    99
    10 import eu.clarin.cmdi.virtualcollectionregistry.DataStore;
    1110import eu.clarin.cmdi.virtualcollectionregistry.VirtualCollectionRegistry;
    1211import eu.clarin.cmdi.virtualcollectionregistry.VirtualCollectionRegistryException;
    … …  
    2726                }
    2827                try {
    29                         DataStore.instance().initalize(config);
    3028                        VirtualCollectionRegistry.initalize(config);
    3129                } catch (VirtualCollectionRegistryException e) {
    … …  
    3836                try {
    3937                        VirtualCollectionRegistry.instance().destroy();
    40                         DataStore.instance().destroy();
    4138                } catch (VirtualCollectionRegistryException e) {
    4239                        ctx.log("error destroying registry", e);
    4340                }
    4441        }
    45 }
     42
     43} // class ContextListener

  • VirtualCollectionRegistry/trunk/VirtualCollectionRegistry/src/main/java/eu/clarin/cmdi/virtualcollectionregistry/rest/PersistenceFilter.java

    r171 r217  
    1010import javax.servlet.ServletResponse;
    1111
    12 import eu.clarin.cmdi.virtualcollectionregistry.DataStore;
     12import eu.clarin.cmdi.virtualcollectionregistry.VirtualCollectionRegistry;
    1313
    1414public class PersistenceFilter implements Filter {
    … …  
    2727                        throw new ServletException("error while processing request", e);
    2828                } finally {
    29                         DataStore.instance().closeEntityManager();
     29                        VirtualCollectionRegistry.instance().getDataStore()
     30                                        .closeEntityManager();
    3031                }
    3132        }
    … …  
    3435                // DO NOTHING
    3536        }
    36 } // class PersitenceFilter
     37
     38} // class PersistenceFilter

  • VirtualCollectionRegistry/trunk/VirtualCollectionRegistry/src/main/java/eu/clarin/cmdi/virtualcollectionregistry/rest/VirtualCollectionRegistryRestService.java

    r215 r217  
    2828import javax.ws.rs.core.UriInfo;
    2929
    30 import eu.clarin.cmdi.virtualcollectionregistry.DataStore;
    3130import eu.clarin.cmdi.virtualcollectionregistry.VirtualCollectionRegistry;
    3231import eu.clarin.cmdi.virtualcollectionregistry.VirtualCollectionRegistryException;
    … …  
    210209        public Response getHandle(@PathParam("pid") String pid) {
    211210                System.err.println("Pid: " + pid);
    212                 EntityManager em = DataStore.instance().getEntityManager();
     211                EntityManager em = registry.getDataStore().getEntityManager();
    213212                try {
    214213                        em.getTransaction().begin();
Note: See TracChangeset for help on using the changeset viewer.