/*******************************************************************************
 * Copyright (c) 2012 Oracle. 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 javax.persistence.TypedQuery;

import model.Address;
import model.Customer;
import model.Order;
import model.OrderLine;

import org.eclipse.persistence.internal.nosql.adapters.mongo.MongoConnection;
import org.junit.AfterClass;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;

import com.mongodb.DB;

/**
 * Test performs CRUD operations on Orders persisting to a Mongo database.  For ease of use
 * with Maven this demo was converted into a Junit test.
 * 
 * @author James Sutherland
 * @author Shaun Smith
 */
public class MongoNoSQLTest {

    protected static EntityManagerFactory emf;
    protected String oid;
   
    @BeforeClass
    public static void initEMF() throws Exception {
        emf = Persistence.createEntityManagerFactory("mongo");
    }
    
    @AfterClass
    public static void closeEMF() throws Exception {
    	emf.close();
    }
    
    @Before
    public void initDatabase() throws Exception {
        EntityManager em = emf.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
    public void test() {
    	testPersist();
    	testFind();
    	testQuery();
    	testUpdate();
    	testRemove();
    }
    
    public void testPersist() {
        System.out.println("\nTesting persist() of orders and customers.\n"); 
        EntityManager em = emf.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 = emf.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 = emf.createEntityManager();
        TypedQuery<Order> query = em.createQuery("Select o from Order o where o.totalCost > 1000", Order.class);
        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%'", Order.class);
        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", Order.class);
        query.setParameter("desc", "shipping");
        orders = query.getResultList();
        System.out.println("\nFound orders with shipping charges: " + orders + "\n");

        Query nativeQuery = em.createNativeQuery("db.ORDER.findOne({\"_id\":\"" + oid + "\"})", Order.class);
        Order order = (Order)nativeQuery.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 = emf.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 = emf.createEntityManager();
        em.getTransaction().begin();
        Order order = em.find(Order.class, oid);
        em.remove(order);
        em.getTransaction().commit();
        em.close();
    }
}