New file |
| | |
| | | package de.hsadmin.processor; |
| | | |
| | | import static org.junit.Assert.assertNotNull; |
| | | import static org.junit.Assert.fail; |
| | | |
| | | import javax.persistence.EntityManager; |
| | | import javax.persistence.EntityManagerFactory; |
| | | import javax.persistence.Persistence; |
| | | import javax.persistence.Query; |
| | | |
| | | import org.junit.After; |
| | | import org.junit.AfterClass; |
| | | import org.junit.Before; |
| | | import org.junit.BeforeClass; |
| | | import org.junit.Test; |
| | | |
| | | import de.hsadmin.core.qserv.Processor; |
| | | import de.hsadmin.core.qserv.ProcessorException; |
| | | import de.hsadmin.mods.cust.Customer; |
| | | import de.hsadmin.mods.pac.BasePac; |
| | | import de.hsadmin.mods.pac.Hive; |
| | | import de.hsadmin.mods.pac.Pac; |
| | | import de.hsadmin.mods.pac.PacProcessorFactory; |
| | | |
| | | public class PacProcessor { |
| | | |
| | | private static EntityManagerFactory emFactory; |
| | | private EntityManager entityManager; |
| | | private PacProcessorFactory pacProcFactory; |
| | | |
| | | @BeforeClass |
| | | public static void setUpBeforeClass() throws Exception { |
| | | emFactory = Persistence.createEntityManagerFactory("hsadmin"); |
| | | } |
| | | |
| | | @AfterClass |
| | | public static void tearDownAfterClass() throws Exception { |
| | | emFactory.close(); |
| | | } |
| | | |
| | | @Before |
| | | public void setUp() throws Exception { |
| | | entityManager = emFactory.createEntityManager(); |
| | | pacProcFactory = new PacProcessorFactory(); |
| | | } |
| | | |
| | | @After |
| | | public void tearDown() throws Exception { |
| | | if (entityManager != null) { |
| | | entityManager.close(); |
| | | } |
| | | } |
| | | |
| | | @Test |
| | | public void createCreateProcessor() { |
| | | Customer cust = findCustomer("hsh00-hsh"); |
| | | assertNotNull(cust); |
| | | BasePac basepac = findBasePacDW(); |
| | | assertNotNull(basepac); |
| | | Hive hive = findHive("h99"); |
| | | assertNotNull(hive); |
| | | try { |
| | | Processor processor = pacProcFactory.createCreateProcessor(entityManager, new Pac("pac01", cust, basepac, hive)); |
| | | System.out.println(processor.toString()); |
| | | } catch (ProcessorException e) { |
| | | fail(e.getMessage()); |
| | | } |
| | | } |
| | | |
| | | private BasePac findBasePacDW() { |
| | | Query basepacQuery = entityManager.createQuery("SELECT b FROM BasePacs b WHERE b.name = :basepacName AND b.valid = :valid"); |
| | | basepacQuery.setParameter("basepacName", "DW/B"); |
| | | basepacQuery.setParameter("valid", Boolean.TRUE); |
| | | return (BasePac) basepacQuery.getSingleResult(); |
| | | } |
| | | |
| | | private Customer findCustomer(String name) { |
| | | Query custQuery = entityManager.createQuery("SELECT c FROM Customers c WHERE c.name = :custName"); |
| | | custQuery.setParameter("custName", name); |
| | | return (Customer) custQuery.getSingleResult(); |
| | | } |
| | | |
| | | private Hive findHive(String name) { |
| | | Query hiveQuery = entityManager.createQuery("SELECT h FROM Hives h WHERE h.name = :hiveName"); |
| | | hiveQuery.setParameter("hiveName", name); |
| | | return (Hive) hiveQuery.getSingleResult(); |
| | | } |
| | | |
| | | @Test |
| | | public void createUpdateProcessor() { |
| | | fail("Not yet implemented"); |
| | | } |
| | | |
| | | @Test |
| | | public void createDeleteProcessor() { |
| | | fail("Not yet implemented"); |
| | | } |
| | | |
| | | } |