X-Git-Url: https://dev.e-taxonomy.eu/gitweb/cdmlib.git/blobdiff_plain/5c8e8d607a9088a98f081c3e20e2262709ccfc81..fdf9eec2eb7b4806e1a1cdc4020db83ce65345bc:/cdmlib-services/src/main/java/eu/etaxonomy/cdm/api/service/ServiceBase.java

diff --git a/cdmlib-services/src/main/java/eu/etaxonomy/cdm/api/service/ServiceBase.java b/cdmlib-services/src/main/java/eu/etaxonomy/cdm/api/service/ServiceBase.java
index f476f65713..509535861f 100644
--- a/cdmlib-services/src/main/java/eu/etaxonomy/cdm/api/service/ServiceBase.java
+++ b/cdmlib-services/src/main/java/eu/etaxonomy/cdm/api/service/ServiceBase.java
@@ -1,9 +1,9 @@
 // $Id$
 /**
 * Copyright (C) 2007 EDIT
-* European Distributed Institute of Taxonomy 
+* European Distributed Institute of Taxonomy
 * http://www.e-taxonomy.eu
-* 
+*
 * The contents of this file are subject to the Mozilla Public License Version 1.1
 * See LICENSE.TXT at the top of this package for the full license terms.
 */
@@ -12,219 +12,207 @@ package eu.etaxonomy.cdm.api.service;
 
 import java.util.ArrayList;
 import java.util.Collection;
-import java.util.HashMap;
-import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
 import java.util.UUID;
 
 import org.apache.log4j.Logger;
-import org.springframework.beans.factory.annotation.Qualifier;
+import org.hibernate.LockMode;
+import org.hibernate.Session;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
-import org.springframework.transaction.TransactionStatus;
 import org.springframework.transaction.annotation.Transactional;
 
+import eu.etaxonomy.cdm.api.service.exception.ReferencedObjectUndeletableException;
 import eu.etaxonomy.cdm.api.service.pager.Pager;
 import eu.etaxonomy.cdm.api.service.pager.impl.DefaultPagerImpl;
 import eu.etaxonomy.cdm.model.common.CdmBase;
 import eu.etaxonomy.cdm.persistence.dao.common.ICdmEntityDao;
+import eu.etaxonomy.cdm.persistence.query.Grouping;
 import eu.etaxonomy.cdm.persistence.query.OrderHint;
 
-@Transactional(readOnly=true)
 public abstract class ServiceBase<T extends CdmBase, DAO extends ICdmEntityDao<T>> implements IService<T>, ApplicationContextAware {
-	private static final Logger logger = Logger.getLogger(ServiceBase.class);
-	
-	//flush after saving this number of objects
-	int flushAfterNo = 2000;
-	protected ApplicationContext appContext;
-
-	@Qualifier("baseDao")
-	protected DAO dao;
-
-	protected abstract void setDao(DAO dao);
-	
-	/* (non-Javadoc)
-	 * @see eu.etaxonomy.cdm.api.service.Iyyy#setApplicationContext(org.springframework.context.ApplicationContext)
-	 */
-	public void setApplicationContext(ApplicationContext appContext){
-		this.appContext = appContext;
-	}
-
-	public T getCdmObjectByUuid(UUID uuid) {
-		return dao.findByUuid(uuid);
-	}
-	
-	public <TYPE extends T> int count(Class<TYPE> clazz) {
-		return dao.count(clazz);
-	}
-	
-	public int count() {
-		return dao.count();
-	}
-
-	/**
-	 * FIXME harmonise with saveOrUpdate
-	 * @param cdmObj
-	 * @return
-	 */
-	@Transactional(readOnly = false)
-	protected UUID saveCdmObject(T cdmObj){
-		if (logger.isDebugEnabled()){logger.debug("Save cdmObj: " + (cdmObj == null? null: cdmObj.toString()));}
-		return dao.saveOrUpdate(cdmObj);
-	}
-	
-
-	/**
-	 * FIXME harmonise with saveOrUpdate
-	 * @param cdmObj
-	 * @return
-	 */
-	@Transactional(readOnly = false)
-	protected UUID saveCdmObject(T cdmObj, TransactionStatus txStatus){
-		// TODO: Implement with considering txStatus
-		if (logger.isDebugEnabled()){logger.debug("Save cdmObj: " + (cdmObj == null? null: cdmObj.toString()));}
-		return dao.saveOrUpdate(cdmObj);
-	}
-	
-	/**
-	 * FIXME harmonise with saveAll
-	 * @param <S>
-	 * @param cdmObjCollection
-	 * @return
-	 */
-	@Transactional(readOnly = false)
-	protected <S extends T> Map<UUID, S> saveCdmObjectAll(Collection<? extends S> cdmObjCollection){
-		int types = cdmObjCollection.getClass().getTypeParameters().length;
-		if (types > 0){
-			if (logger.isDebugEnabled()){logger.debug("ClassType: + " + cdmObjCollection.getClass().getTypeParameters()[0]);}
-		}
-		
-		Map<UUID, S> resultMap = new HashMap<UUID, S>();
-		Iterator<? extends S> iterator = cdmObjCollection.iterator();
-		int i = 0;
-			while(iterator.hasNext()){
-				if ( ( (i % 5000) == 0) && (i > 0)   ){logger.debug("Saved " + i + " objects" );}
-				S cdmObj = iterator.next();
-				UUID uuid = saveCdmObject(cdmObj);
-//				if (logger.isDebugEnabled()){logger.debug("Save cdmObj: " + (cdmObj == null? null: cdmObj.toString()));}
-				resultMap.put(uuid, cdmObj);
-				i++;
-				if ( (i % flushAfterNo) == 0){
-					try{
-									logger.debug("flush");
-					dao.flush();
-					}catch(Exception e){
-						logger.error("UUUIIIII");
-						e.printStackTrace();
-					}
-				}
-			}
-
-		if ( logger.isInfoEnabled() ){logger.info("Saved " + i + " objects" );}
-		return resultMap;
-	}
-
-	@Transactional(readOnly = false)
-	public UUID delete(T persistentObject) {
-		return dao.delete(persistentObject);
-	}
-
-	public boolean exists(UUID uuid) {
-		return dao.exists(uuid);
-	}
-
-	public T findByUuid(UUID uuid) {
-		return dao.findByUuid(uuid);
-	}
-	
-	public T load(UUID uuid) {
-		return dao.load(uuid);
-	}
-	
-	public T load(UUID uuid, List<String> propertyPaths){
-		return dao.load(uuid, propertyPaths);
-	}
-
-	public <TYPE extends T> List<TYPE> list(Class<TYPE> type, int limit,int start) {
-		return dao.list(type, limit, start);
-	}
-	
-	public Pager<T> list(Integer pageSize, Integer pageNumber){
-		return list(pageSize, pageNumber, null);
-	}
-	
-	public Pager<T> list(Integer pageSize, Integer pageNumber, List<OrderHint> orderHints){
-		return list(pageSize,pageNumber,orderHints,null);
-	}
-	
-	public Pager<T> list(Integer pageSize, Integer pageNumber, List<OrderHint> orderHints, List<String> propertyPaths){
-		Integer numberOfResults = dao.count();
-		List<T> results = new ArrayList<T>();
-		pageNumber = pageNumber == null ? 0 : pageNumber;
-		if(numberOfResults > 0) { // no point checking again
-			Integer start = pageSize == null ? 0 : pageSize * (pageNumber - 1);
-			results = dao.list(pageSize, start, orderHints,propertyPaths);
-		}
-		return new DefaultPagerImpl<T>(pageNumber, numberOfResults, pageSize, results);
-	}
-	
-	public <TYPE extends T> Pager<TYPE> list(Class<TYPE> type, Integer pageSize, Integer pageNumber, List<OrderHint> orderHints, List<String> propertyPaths){
-		Integer numberOfResults = dao.count(type);
-		List<TYPE> results = new ArrayList<TYPE>();
-		pageNumber = pageNumber == null ? 0 : pageNumber;
-		if(numberOfResults > 0) { // no point checking again
-			Integer start = pageSize == null ? 0 : pageSize * (pageNumber - 1);
-			results = dao.list(type,pageSize, start, orderHints,propertyPaths);
-		}
-		return new DefaultPagerImpl<TYPE>(pageNumber, numberOfResults, pageSize, results);
-	}
-
-	@Transactional(readOnly = false)
-	public UUID save(T newInstance) {
-		return dao.save(newInstance);
-	}
-	
-	@Transactional(readOnly = false)
-	public UUID merge(T newInstance) {
-		return dao.merge(newInstance);
-	}
-	
-	@Transactional(readOnly = false)
-	public Map<UUID, T> saveAll(Collection<T> newInstances) {
-		return dao.saveAll(newInstances);
-	}
-
-	@Transactional(readOnly = false)
-	public UUID saveOrUpdate(T transientObject) {
-		return dao.saveOrUpdate(transientObject);
-	}
-
-	@Transactional(readOnly = false)
-	public UUID update(T transientObject) {
-		return dao.update(transientObject);
-	}
-
-	public UUID refresh(T persistentObject) {
-		return dao.refresh(persistentObject);
-	}
-	
-	/**
-	 * FIXME harmonise with delete()
-	 * @param cdmObj
-	 * @return
-	 */
-	@Transactional(readOnly = false)
-	protected UUID removeCdmObject(T cdmObj){
-		if (logger.isDebugEnabled()){logger.debug("Save cdmObj: " + (cdmObj == null? null: cdmObj.toString()));}
-		return dao.delete(cdmObj);
-	}
-
-	public List<T> list(int limit, int start) {
-		return dao.list(limit, start);
-	}
-
-	public List<T> rows(String tableName, int limit, int start) {
-		return dao.rows(tableName, limit, start);
-	}
+    @SuppressWarnings("unused")
+    private static final Logger logger = Logger.getLogger(ServiceBase.class);
+
+    //flush after saving this number of objects
+    int flushAfterNo = 2000;
+    protected ApplicationContext appContext;
+
+    protected DAO dao;
+
+    @Override
+    @Transactional(readOnly = true)
+    public void lock(T t, LockMode lockMode) {
+        dao.lock(t, lockMode);
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public void refresh(T t, LockMode lockMode, List<String> propertyPaths) {
+        dao.refresh(t, lockMode, propertyPaths);
+    }
+
+    @Override
+    @Transactional(readOnly = false)
+    public void clear() {
+        dao.clear();
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public int count(Class<? extends T> clazz) {
+        return dao.count(clazz);
+    }
+
+    @Override
+    @Transactional(readOnly = false)
+    public String delete(T persistentObject) {
+        return dao.delete(persistentObject).toString();
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public boolean exists(UUID uuid) {
+        return dao.exists(uuid);
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public List<T> find(Set<UUID> uuidSet) {
+        return dao.list(uuidSet, null, null, null, null);
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public List<T> findById(Set<Integer> idSet) {  //can't be called find(Set<Integer>) as this conflicts with find(Set<UUID)
+        return dao.listByIds(idSet, null, null, null, null);
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public T find(UUID uuid) {
+        return dao.findByUuid(uuid);
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public T find(int id) {
+        return dao.findById(id);
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public Session getSession() {
+        return dao.getSession();
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public List<Object[]> group(Class<? extends T> clazz,Integer limit, Integer start, List<Grouping> groups, List<String> propertyPaths) {
+        return dao.group(clazz, limit, start, groups, propertyPaths);
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public <S extends T> List<S> list(Class<S> type, Integer limit, Integer start, List<OrderHint> orderHints, List<String> propertyPaths){
+        return dao.list(type,limit, start, orderHints,propertyPaths);
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public T load(UUID uuid) {
+        return dao.load(uuid);
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public T load(UUID uuid, List<String> propertyPaths){
+        return dao.load(uuid, propertyPaths);
+    }
+
+    @Override
+    @Transactional(readOnly = false)
+    public T merge(T newInstance) {
+        return dao.merge(newInstance);
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public  <S extends T> Pager<S> page(Class<S> type, Integer pageSize, Integer pageNumber, List<OrderHint> orderHints, List<String> propertyPaths){
+        Integer numberOfResults = dao.count(type);
+        List<S> results = new ArrayList<S>();
+        pageNumber = pageNumber == null ? 0 : pageNumber;
+        if(numberOfResults > 0) { // no point checking again  //TODO use AbstractPagerImpl.hasResultsInRange(numberOfResults, pageNumber, pageSize)
+            Integer start = pageSize == null ? 0 : pageSize * pageNumber;
+            results = dao.list(type, pageSize, start, orderHints,propertyPaths);
+        }
+        return new DefaultPagerImpl<S>(pageNumber, numberOfResults, pageSize, results);
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public UUID refresh(T persistentObject) {
+        return dao.refresh(persistentObject);
+    }
+
+    /**
+     * FIXME Candidate for harmonization
+     * is this method used, and if so, should it be exposed in the service layer?
+     * it seems a bit incongruous that we use an ORM to hide the fact that there is a
+     * database, then expose a method that talks about "rows" . . .
+     */
+    @Override
+    @Transactional(readOnly = true)
+    public List<T> rows(String tableName, int limit, int start) {
+        return dao.rows(tableName, limit, start);
+    }
+
+    @Override
+    @Transactional(readOnly = false)
+    public Map<UUID, T> save(Collection<T> newInstances) {
+        return dao.saveAll(newInstances);
+    }
+
+    @Override
+    @Transactional(readOnly = false)
+    public UUID save(T newInstance) {
+        return dao.save(newInstance);
+    }
+
+    @Override
+    @Transactional(readOnly = false)
+    public UUID saveOrUpdate(T transientObject) {
+        return dao.saveOrUpdate(transientObject);
+    }
+
+    @Override
+    @Transactional(readOnly = false)
+    public Map<UUID, T> saveOrUpdate(Collection<T> transientInstances) {
+        return dao.saveOrUpdateAll(transientInstances);
+    }
+
+    @Override
+    public void setApplicationContext(ApplicationContext appContext){
+        this.appContext = appContext;
+    }
+
+
+    protected abstract void setDao(DAO dao);
+
+    @Override
+    @Transactional(readOnly = false)
+    public UUID update(T transientObject) {
+        return dao.update(transientObject);
+    }
+
+    @Override
+    @Transactional(readOnly = true)
+    public List<T> list(T example, Set<String> includeProperties, Integer limit, Integer start, List<OrderHint> orderHints, List<String> propertyPaths) {
+        return dao.list(example, includeProperties, limit, start, orderHints, propertyPaths);
+    }
+    
+    
+
 }