jpa/nosql/mongo/src/example/Test.java

/*******************************************************************************
 * Copyright (c) 2012 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:
 *      Oracle - initial impl
 ******************************************************************************/
package example;

import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.Persistence;
import javax.persistence.Query;

import org.eclipse.persistence.internal.nosql.adapters.mongo.MongoConnection;

import com.mongodb.DB;

import model.*;

/**
 * Test performs CRUD operations on Orders persisting to a Mongo database.
 * @author James Sutherland
 */
public class Test {

    EntityManagerFactory factory;
    String oid;
    
    public static void main(String[] args) throws Exception {
        Test test = new Test();
        test.factory = Persistence.createEntityManagerFactory("mongo");
        
        EntityManager em = test.factory.createEntityManager();        
        // First clear old database.
        em.getTransaction().begin();
        DB db = ((MongoConnection)em.unwrap(javax.resource.cci.Connection.class)).getDB();
        db.dropDatabase();
        em.getTransaction().commit();
        em.close();
        
        test.testPersist();
        test.testFind();
        test.testQuery();
        test.testUpdate();
        test.testRemove();
        test.factory.close();
    }

    public void testPersist() {
        System.out.println("\nTesting persist() of orders and customers.\n"); 
        EntityManager em = factory.createEntityManager();
        em.getTransaction().begin();
        Customer customer = new Customer();
        customer.setName("AMCE");
        em.persist(customer);        
        Order order = new Order();
        order.setCustomer(customer);
        order.setDescription("Pinball machine");
        Address address = new Address();
        address.setStreet("17 Jane St.");
        address.setCity("Ottawa");
        address.setProvince("ON");
        address.setCountry("Canada");
        address.setPostalCode("L5J1H7");
        order.setBillingAddress(address);
        address = new Address();
        address.setStreet("17 Jane St.");
        address.setCity("Ottawa");
        address.setProvince("ON");
        address.setCountry("Canada");
        address.setPostalCode("L5J1H7");
        order.setShippingAddress(address);
        order.addOrderLine(new OrderLine("machine", 2999));
        order.addOrderLine(new OrderLine("shipping", 129));
        order.addOrderLine(new OrderLine("installation", 59));
        em.persist(order);
        
        order = new Order();
        order.setCustomer(customer);
        order.setDescription("Foosball");
        address = new Address();
        address.setStreet("7 Bank St.");
        address.setCity("Ottawa");
        address.setProvince("ON");
        address.setCountry("Canada");
        address.setPostalCode("L5J1H8");
        order.setBillingAddress(address);
        address = new Address();
        address.setStreet("17 Jane St.");
        address.setCity("Ottawa");
        address.setProvince("ON");
        address.setCountry("Canada");
        address.setPostalCode("L5J1H7");
        order.setShippingAddress(address);
        order.addOrderLine(new OrderLine("machine", 500));
        order.addOrderLine(new OrderLine("balls", 5));
        order.addOrderLine(new OrderLine("shipping", 60));
        em.persist(order);
        
        customer = new Customer();
        customer.setName("Smith");
        em.persist(customer);
        order = new Order();
        order.setCustomer(customer);
        order.setDescription("Pingpong table");
        address = new Address();
        address.setStreet("7 Bank St.");
        address.setCity("Ottawa");
        address.setProvince("ON");
        address.setCountry("Canada");
        address.setPostalCode("L5J1H8");
        order.setBillingAddress(address);
        address = new Address();
        address.setStreet("17 Jane St.");
        address.setCity("Ottawa");
        address.setProvince("ON");
        address.setCountry("Canada");
        address.setPostalCode("L5J1H7");
        order.setShippingAddress(address);
        order.addOrderLine(new OrderLine("table", 300));
        order.addOrderLine(new OrderLine("balls", 5));
        order.addOrderLine(new OrderLine("rackets", 15));
        order.addOrderLine(new OrderLine("net", 2));
        order.addOrderLine(new OrderLine("shipping", 80));
        em.persist(order);
        
        em.getTransaction().commit();
        oid = order.getId();
        em.close();
    }

    public void testFind() {
        System.out.println("\nTesting find() by Id.\n");
        EntityManager em = factory.createEntityManager();
        Order order = em.find(Order.class, oid);
        System.out.println("Found order:" + order + " by its oid: " + oid);
        em.close();
    }

    public void testQuery() {
        System.out.println("\nTesting querying.\n");
        EntityManager em = factory.createEntityManager();
        Query query = em.createQuery("Select o from Order o where o.totalCost > 1000");
        List<Order> orders = query.getResultList();
        System.out.println("\nFound orders with cost > 1,000: " + orders + "\n");
        query = em.createQuery("Select o from Order o where o.description like 'Pinball%'");
        orders = query.getResultList();
        System.out.println("\nFound orders for pinball: " + orders + "\n");
        query = em.createQuery("Select o from Order o join o.orderLines l where l.description = :desc");
        query.setParameter("desc", "shipping");
        orders = query.getResultList();
        System.out.println("\nFound orders with shipping charges: " + orders + "\n");

        query = em.createNativeQuery("db.ORDER.findOne({\"_id\":\"" + oid + "\"})", Order.class);
        Order order = (Order)query.getSingleResult();
        System.out.println("\nFound order using a native query: " + order + "\n");
        
        em.close();
    }

    public void testUpdate() {
        System.out.println("\nTesting update of order.\n");
        EntityManager em = factory.createEntityManager();
        em.getTransaction().begin();
        Order order = em.find(Order.class, oid);
        order.addOrderLine(new OrderLine("handling", 55));
        order.addOrderLine(new OrderLine("tax", 300));
        em.getTransaction().commit();
        em.close();
    }

    public void testRemove() {
        System.out.println("\nTesting remove of order.\n");
        EntityManager em = factory.createEntityManager();
        em.getTransaction().begin();
        Order order = em.find(Order.class, oid);
        em.remove(order);
        em.getTransaction().commit();
        em.close();
    }
}