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"); } }