package com.trendmicro.grid.acl.ds.jpa;
   
   import com.trendmicro.grid.acl.ds.VendorRepository;
   import com.trendmicro.grid.acl.ds.jpa.entities.JpaVendor;
   import com.trendmicro.grid.acl.l0.datatypes.NameListPage;
   import com.trendmicro.grid.acl.l0.datatypes.Vendor;
   import com.trendmicro.grid.acl.metadata.Metadata;
   import org.springframework.stereotype.Repository;
   import org.springframework.transaction.annotation.Transactional;
  
  import javax.persistence.EntityManager;
  import javax.persistence.PersistenceContext;
  import java.util.Date;
  import java.util.List;
  
  import static com.trendmicro.grid.acl.ds.jpa.util.JpaUtils.toNameListPage;
  import static net.sf.tinyjee.util.Assert.assertNotNull;
  
  /**
   * Implements VendorRepository using JPA.
   *
   * @author Juergen_Kellerer, 2010-06-11
   * @version 1.0
   */
  @Repository
  @Transactional(readOnly = true)
  public class JpaVendorRepository implements VendorRepository {
  
  	private static int pageSize = 1000;
  
  	public static int getPageSize() {
  		return pageSize;
  	}
  
  	public static void setPageSize(int pageSize) {
  		JpaVendorRepository.pageSize = pageSize;
  	}
  
  	@PersistenceContext(unitName = "CoreDB")
  	EntityManager em;
  
  	/**
  	 * {@inheritDoc}
  	 */
  	@Transactional(readOnly = false)
  	public JpaVendor create(String name, String displayName, Metadata metadata) {
  		JpaVendor vendor = getByName(name);
  		if (vendor == null)
  			em.persist(vendor = new JpaVendor(name, displayName, new Date(), metadata));
  		return vendor;
  	}
  
  	/**
  	 * {@inheritDoc}
  	 */
  	@Transactional(readOnly = false)
  	public void update(Vendor vendor) {
  		assertNotNull("vendor", vendor);
  
  		JpaVendor v = getByName(vendor.getName());
  
  		if (v == null) {
  			throw new IllegalArgumentException("Failed updating vendor. " +
  					"No entry exists with name '" + vendor.getName() + "'");
  		}
  
  		v.setMetadata(vendor.getMetadata());
  		v.setDisplayName(vendor.getDisplayName());
  	}
  
  	/**
  	 * {@inheritDoc}
  	 */
  	public JpaVendor getByName(String name) {
  		List<JpaVendor> result = em.createNamedQuery("Vendor.SelectByName", JpaVendor.class).
  				setParameter("name", name).getResultList();
  		return result.isEmpty() ? null : result.get(0);
  	}
  
  	/**
  	 * Returns a lightweight reference used to satisfy foreign key constraints.
  	 *
  	 * @param name the name of the vendor.
  	 * @return a lightweight reference used to satisfy foreign key constraints.
  	 */
  	public JpaVendor getReferenceByName(String name) {
  		List<Integer> result = em.createNamedQuery("Vendor.SelectPrimaryKeyByName", Integer.class).
  				setParameter("name", name).getResultList();
  		return result.isEmpty() ? null : em.getReference(JpaVendor.class, result.get(0));
  	}
  
  	/**
  	 * {@inheritDoc}
  	 */
  	public NameListPage listNames(int pageNumber) {
  		return toNameListPage(em.createNamedQuery("Vendor.SelectNames", String.class), pageNumber, pageSize);
  	}
  }