Move JDO from core-java to libraries (#1758)

2017-04-30 13:26:23 -04:00
parent f5f3e48f61
commit a2b327cc9d
6 changed files with 52 additions and 55 deletions
--- a/libraries/src/test/java/com/baeldung/jdo/GuideToJDOIntegrationTest.java
+++ b/libraries/src/test/java/com/baeldung/jdo/GuideToJDOIntegrationTest.java
@@ -0,0 +1,113 @@
+package com.baeldung.jdo;
+
+import org.datanucleus.api.jdo.JDOPersistenceManagerFactory;
+import org.datanucleus.metadata.PersistenceUnitMetaData;
+import org.junit.Test;
+
+import javax.jdo.PersistenceManager;
+import javax.jdo.PersistenceManagerFactory;
+import javax.jdo.Query;
+import javax.jdo.Transaction;
+import java.util.Iterator;
+import java.util.List;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.fail;
+
+public class GuideToJDOIntegrationTest {
+    @Test
+    public void givenProduct_WhenNewThenPerformTransaction() {
+        PersistenceUnitMetaData pumd = new PersistenceUnitMetaData("dynamic-unit", "RESOURCE_LOCAL", null);
+        pumd.addClassName("com.baeldung.jdo.Product");
+        pumd.setExcludeUnlistedClasses();
+        pumd.addProperty("javax.jdo.option.ConnectionDriverName", "org.h2.Driver");
+        pumd.addProperty("javax.jdo.option.ConnectionURL", "jdbc:h2:mem:mypersistence");
+        pumd.addProperty("javax.jdo.option.ConnectionUserName", "sa");
+        pumd.addProperty("javax.jdo.option.ConnectionPassword", "");
+        pumd.addProperty("datanucleus.autoCreateSchema", "true");        
+
+        PersistenceManagerFactory pmf = new JDOPersistenceManagerFactory(pumd, null);
+        PersistenceManager pm = pmf.getPersistenceManager();
+        Transaction tx = pm.currentTransaction();
+        try {
+            tx.begin();
+            for (int i = 0; i < 100; i++){
+                String nam = "Product-" + i;
+                Product productx = new Product(nam, (double) i);
+                pm.makePersistent(productx);
+            }
+            tx.commit();
+        } catch (Throwable thr) {
+            fail("Failed test : " + thr.getMessage());
+        } finally {
+            if (tx.isActive()) {
+                tx.rollback();
+            }
+            pm.close();
+        }
+
+        pmf.close();
+    }
+
+    @Test
+    public void givenProduct_WhenQueryThenExist() {
+        PersistenceUnitMetaData pumd = new PersistenceUnitMetaData("dynamic-unit", "RESOURCE_LOCAL", null);
+        pumd.addClassName("com.baeldung.jdo.Product");
+        pumd.setExcludeUnlistedClasses();
+        pumd.addProperty("javax.jdo.option.ConnectionDriverName", "org.h2.Driver");
+        pumd.addProperty("javax.jdo.option.ConnectionURL", "jdbc:h2:mem:mypersistence");
+        pumd.addProperty("javax.jdo.option.ConnectionUserName", "sa");
+        pumd.addProperty("javax.jdo.option.ConnectionPassword", "");
+        pumd.addProperty("datanucleus.autoCreateSchema", "true");        
+
+        PersistenceManagerFactory pmf = new JDOPersistenceManagerFactory(pumd, null);
+        PersistenceManager pm = pmf.getPersistenceManager();
+        Transaction tx = pm.currentTransaction();
+        try {
+            tx.begin();
+            Product product = new Product("Tablet", 80.0);
+            pm.makePersistent(product);
+            Product product2 = new Product("Phone", 20.0);
+            pm.makePersistent(product2);
+            Product product3 = new Product("Laptop", 200.0);
+            pm.makePersistent(product3);
+            tx.commit();
+        } catch (Throwable thr) {
+            fail("Failed test : " + thr.getMessage());
+        } finally {
+            if (tx.isActive()) {
+                tx.rollback();
+            }
+            pm.close();
+        }
+
+        pmf.close();
+
+        PersistenceManagerFactory pmf2 = new JDOPersistenceManagerFactory(pumd, null);
+        PersistenceManager pm2 = pmf2.getPersistenceManager();
+        Transaction tx2 = pm2.currentTransaction();
+        try {
+            tx2.begin();
+
+            @SuppressWarnings("rawtypes")
+            Query q = pm2.newQuery("SELECT FROM " + Product.class.getName() + " WHERE price == 200");
+            @SuppressWarnings("unchecked")
+            List<Product> products = (List<Product>) q.execute();
+            Iterator<Product> iter = products.iterator();
+            while (iter.hasNext()) {
+                Product p = iter.next();
+                assertEquals("Laptop", p.name);
+            }
+
+            tx2.commit();
+        } finally {
+            if (tx2.isActive()) {
+                tx2.rollback();
+            }
+
+            pm2.close();
+        }
+    }
+
+
+}