/******************************************************************************* | |
* Copyright (c) 2011, 2013 Oracle and/or its affiliates. All rights reserved. | |
* This program and the accompanying materials are made available under the | |
* terms of the Eclipse Public License v1.0 and Eclipse Distribution License v. 1.0 | |
* which accompanies this distribution. | |
* The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html | |
* and the Eclipse Distribution License is available at | |
* http://www.eclipse.org/org/documents/edl-v10.php. | |
* | |
* Contributors: | |
* tware - initial | |
******************************************************************************/ | |
package org.eclipse.persistence.jpars.test.crud; | |
import static org.junit.Assert.assertNotNull; | |
import static org.junit.Assert.assertNull; | |
import static org.junit.Assert.assertTrue; | |
import static org.junit.Assert.fail; | |
import java.net.URI; | |
import java.util.HashMap; | |
import java.util.List; | |
import java.util.Map; | |
import javax.persistence.EntityManager; | |
import javax.persistence.Persistence; | |
import org.eclipse.persistence.config.PersistenceUnitProperties; | |
import org.eclipse.persistence.dynamic.DynamicClassLoader; | |
import org.eclipse.persistence.jpa.rs.PersistenceContext; | |
import org.eclipse.persistence.jpa.rs.PersistenceFactoryBase; | |
import org.eclipse.persistence.jpars.test.model.auction.StaticUser; | |
import org.eclipse.persistence.jpars.test.util.ExamplePropertiesLoader; | |
import org.junit.AfterClass; | |
import org.junit.BeforeClass; | |
import org.junit.Test; | |
/** | |
* Test basic CRUD operations on a dynamically created PersistenceContext | |
* @author tware | |
* | |
*/ | |
public class StaticCrudTests { | |
private static PersistenceContext persistenceContext; | |
private static PersistenceFactoryBase factory; | |
@BeforeClass | |
public static void setup(){ | |
Map<String, Object> properties = new HashMap<String, Object>(); | |
ExamplePropertiesLoader.loadProperties(properties); | |
properties.put(PersistenceUnitProperties.NON_JTA_DATASOURCE, null); | |
properties.put(PersistenceUnitProperties.DDL_GENERATION, PersistenceUnitProperties.DROP_AND_CREATE); | |
properties.put(PersistenceUnitProperties.CLASSLOADER, new DynamicClassLoader(Thread.currentThread().getContextClassLoader())); | |
factory = null; | |
try{ | |
factory = new PersistenceFactoryBase(); | |
persistenceContext = factory.bootstrapPersistenceContext("jpars_auction-static-local", Persistence.createEntityManagerFactory("jpars_auction-static-local", properties), new URI( | |
"http://localhost:9090/JPA-RS/"), null, true); | |
} catch (Exception e){ | |
e.printStackTrace(); | |
fail(e.toString()); | |
} | |
EntityManager em = persistenceContext.getEmf().createEntityManager(); | |
em.getTransaction().begin(); | |
em.createQuery("delete from StaticBid b").executeUpdate(); | |
em.createQuery("delete from StaticAuction a").executeUpdate(); | |
em.createQuery("delete from StaticUser u").executeUpdate(); | |
em.getTransaction().commit(); | |
} | |
@AfterClass | |
public static void tearDown(){ | |
EntityManager em = persistenceContext.getEmf().createEntityManager(); | |
em.getTransaction().begin(); | |
em.createQuery("delete from StaticBid b").executeUpdate(); | |
em.createQuery("delete from StaticAuction a").executeUpdate(); | |
em.createQuery("delete from StaticUser u").executeUpdate(); | |
em.getTransaction().commit(); | |
} | |
@Test | |
public void testCreateAndDelete() { | |
StaticUser user = new StaticUser(); | |
user.setName("Jim"); | |
user.setId(1); | |
persistenceContext.create(null, user); | |
user = (StaticUser)persistenceContext.find("StaticUser", user.getId()); | |
assertNotNull("Entity was not persisted", user); | |
assertTrue("Entity Name was incorrect", user.getName().equals("Jim")); | |
persistenceContext.delete(null, "StaticUser", user.getId()); | |
user = (StaticUser)persistenceContext.find("StaticUser",user.getId()); | |
assertNull("Entity was not deleted", user); | |
} | |
@Test | |
@SuppressWarnings("unchecked") | |
public void testQuery(){ | |
StaticUser user = new StaticUser(); | |
user.setName("Jill"); | |
user.setId(2); | |
persistenceContext.create(null, user); | |
user = new StaticUser(); | |
user.setName("Arthur"); | |
user.setId(3); | |
persistenceContext.create(null, user); | |
user = new StaticUser(); | |
user.setName("Judy"); | |
user.setId(4); | |
persistenceContext.create(null, user); | |
List<StaticUser> users = (List<StaticUser>) persistenceContext.queryMultipleResults(null, "User.all", null, null); | |
assertTrue(users.size() == 3); | |
} | |
@Test | |
public void testUpdate(){ | |
StaticUser user = new StaticUser(); | |
user.setName("Tom"); | |
user.setId(5); | |
persistenceContext.create(null, user); | |
user = (StaticUser)persistenceContext.find("StaticUser", user.getId()); | |
user.setName("Thomas"); | |
persistenceContext.merge(null, user); | |
user = (StaticUser)persistenceContext.find("StaticUser", user.getId()); | |
assertTrue("Entity name was not correctly updated.", user.getName().equals("Thomas")); | |
persistenceContext.delete(null, "StaticUser", user.getId()); | |
} | |
} |