/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */
package org.apache.openjpa.persistence.proxy;

import java.math.BigDecimal;
import java.util.Arrays;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
import java.util.UUID;

import javax.persistence.EntityManager;

import org.apache.openjpa.conf.Compatibility;
import org.apache.openjpa.lib.log.Log;
import org.apache.openjpa.persistence.OpenJPAEntityManagerFactorySPI;
import org.apache.openjpa.persistence.OpenJPAPersistence;
import org.apache.openjpa.persistence.proxy.entities.Address;
import org.apache.openjpa.persistence.proxy.entities.Annuity;
import org.apache.openjpa.persistence.proxy.entities.AnnuityHolder;
import org.apache.openjpa.persistence.proxy.entities.AnnuityHolderCategory;
import org.apache.openjpa.persistence.proxy.entities.AnnuityPersistebleObject;
import org.apache.openjpa.persistence.proxy.entities.AnnuityType;
import org.apache.openjpa.persistence.proxy.entities.Contact;
import org.apache.openjpa.persistence.proxy.entities.ContactType;
import org.apache.openjpa.persistence.proxy.entities.EquityAnnuity;
import org.apache.openjpa.persistence.proxy.entities.FixedAnnuity;
import org.apache.openjpa.persistence.proxy.entities.IAnnuity;
import org.apache.openjpa.persistence.proxy.entities.IAnnuityHolder;
import org.apache.openjpa.persistence.proxy.entities.IContact;
import org.apache.openjpa.persistence.proxy.entities.IEquityAnnuity;
import org.apache.openjpa.persistence.proxy.entities.IFixedAnnuity;
import org.apache.openjpa.persistence.proxy.entities.IPayor;
import org.apache.openjpa.persistence.proxy.entities.IPayout;
import org.apache.openjpa.persistence.proxy.entities.IRider;
import org.apache.openjpa.persistence.proxy.entities.Payor;
import org.apache.openjpa.persistence.proxy.entities.Payout;
import org.apache.openjpa.persistence.proxy.entities.Person;
import org.apache.openjpa.persistence.proxy.entities.Rider;
import org.apache.openjpa.persistence.proxy.entities.RiderType;
import org.apache.openjpa.persistence.test.SingleEMFTestCase;


/*
 * Test the complicated interaction between Detached entities, Proxy classes
 * and Merging changes made in ProxyCollections back into entities.
 *
 * This code is based on AcmeTest2, which was originally written by
 * Mohammad at IBM and contributed under ASL 2.0.
 */
public class TestDetachMerge extends SingleEMFTestCase {

    @Override
    public void setUp() {
        setUp(DROP_TABLES, Address.class, Annuity.class, AnnuityHolder.class, AnnuityPersistebleObject.class,
            Contact.class, EquityAnnuity.class, FixedAnnuity.class, Payor.class, Payout.class,
            Person.class, Rider.class);
    }

    /*
     * Test default 1.0 compatibility behavior, which should pass AS-IS
     */
    public void testAnnuity1Compat() throws Exception {
        OpenJPAEntityManagerFactorySPI emf1 =
            (OpenJPAEntityManagerFactorySPI) OpenJPAPersistence.createEntityManagerFactory(
            "Annuity1Compat", "org/apache/openjpa/persistence/proxy/persistence1.xml");
        assertNotNull(emf1);

        Log log = emf1.getConfiguration().getLog("test");

        if (log.isTraceEnabled()) {
            Compatibility compat = emf1.getConfiguration().getCompatibilityInstance();
            assertNotNull(compat);
            log.trace("started testAnnuity1Compat()");
            log.trace("FlushBeforeDetach=" + compat.getFlushBeforeDetach());
            log.trace("CopyOnDetach=" + compat.getCopyOnDetach());
            log.trace("CascadeWithDetach=" + compat.getCascadeWithDetach());
            log.trace("IgnoreDetachedStateFieldForProxySerialization=" +
                compat.getIgnoreDetachedStateFieldForProxySerialization());
        }

        try {
            execute(emf1);
        } catch (RuntimeException e) {
            fail("testAnuity1Compat() should not have caused an execption!" + e);
        } finally {
            emf1.close();
        }
    }

    /*
     * Test default 2.0 compatibility behavior, which should PASS
     */
    public void testAnnuity2Compat() throws Exception {
        OpenJPAEntityManagerFactorySPI emf2 =
            (OpenJPAEntityManagerFactorySPI) OpenJPAPersistence.createEntityManagerFactory(
            "Annuity2Compat", "org/apache/openjpa/persistence/proxy/persistence2.xml");
        assertNotNull(emf2);

        Log log = emf2.getConfiguration().getLog("test");

        if (log.isTraceEnabled()) {
            Compatibility compat = emf2.getConfiguration().getCompatibilityInstance();
            assertNotNull(compat);
            log.trace("started testAnnuity2Compat()");
            log.trace("FlushBeforeDetach=" + compat.getFlushBeforeDetach());
            log.trace("CopyOnDetach=" + compat.getCopyOnDetach());
            log.trace("CascadeWithDetach=" + compat.getCascadeWithDetach());
            log.trace("IgnoreDetachedStateFieldForProxySerialization=" +
                compat.getIgnoreDetachedStateFieldForProxySerialization());
        }

        try {
            execute(emf2);
        } catch (RuntimeException e) {
            fail("testAnuity2Compat() should not have caused an execption!" + e);
        } finally {
            emf2.close();
        }
    }

    private void execute(OpenJPAEntityManagerFactorySPI myEMF) throws Exception {
        Log log = myEMF.getConfiguration().getLog("test");
        //EntityManager em = myEMF.createEntityManager();
        IContact contact = null;

        try {
            if (log.isTraceEnabled())
                log.trace("creating contact");
            try {
                contact = createContact(myEMF);
            } catch (Exception e) {
                log.error("Create Contact failed.", e);
                throw e;
            }

            try {
                verifyContactValues(myEMF, contact);
            } catch (Exception e) {
                log.error("Create Contact verification failed.", e);
                throw e;
                // do not return, as this might be a small bug that we can bypass
            }

            if (log.isTraceEnabled())
                log.trace("creating annuity holder");
            IAnnuityHolder annuityHolder = null;
            try {
                annuityHolder = createAnnuityHolder(myEMF, contact);
            } catch (Exception e) {
                log.error("failed to create Annuity Holder Successfully.", e);
                throw e;
            }

            try {
                verifyAnnuityHolderValues(myEMF, annuityHolder);
            } catch (Exception e) {
                log.info("failed to verify create annuity holder successfuly.", e);
                throw e;
            }

            if (log.isTraceEnabled())
                log.trace("creating payor");
            IPayor payor = null;
            try {
                payor = createPayor(myEMF);
            } catch(Exception e) {
                log.error("failed to create payor successfuly.", e);
                throw e;
            }

            try {
                verifyPayorValues(myEMF, payor);
            } catch (Exception e) {
                log.error("failed to verify create payor successfuly.", e);
                throw e;
            }

            if (log.isTraceEnabled())
                log.trace("creating annuity");
            IAnnuity annuity =null;
            AnnuityType annuityType = AnnuityType.FIXED;
            try {
                annuity = createAnnuityWithRider(myEMF, annuityType);
            } catch (Exception e) {
                log.error("failed to create annuity successfuly.", e);
                throw e;
            }

            try {
                log.trace("verify annuity with rider");
                verifyAnnuityValues(myEMF, annuity, annuityType);
            } catch (Exception e) {
                log.error("failed to verify create annuity successfuly.", e);
                throw e;
            }

            if (log.isTraceEnabled())
                log.trace("upating annuity");
            try {
                log.trace("create annuity with payout");
                annuity = createAnnuityPayout(myEMF, annuity);
            } catch (Exception e) {
                log.error("failed to create annuity successfuly.", e);
                throw e;
            }

            try {
                verifyAnnuityValues(myEMF, annuity, annuityType);
            } catch (Exception e) {
                log.error("failed to verify create annuity successfuly.", e);
                throw e;
            }

            if (log.isTraceEnabled())
                log.trace("upating annuity");
            try {
                EntityManager em = createEM(myEMF);
                em.getTransaction().begin();
                    annuity.getPayors().add(payor);
                    annuity.setAnnuityHolderId(annuityHolder.getId());
                    annuity = em.merge(annuity);
                em.getTransaction().commit();
                closeEM(em);
            } catch (Exception e) {
                log.error("failed to update annuity successfuly.", e);
                throw e;
            }

            try {
                verifyAnnuityValues(myEMF, annuity, annuityType);
            } catch (Exception e) {
                log.error("failed to verify annuity update successfuly.", e);
                throw e;
            }
        } finally {
            log.error("scenario: failed.");
        }

        if (log.isTraceEnabled())
            log.trace("scenario: completed.");
    }

    private IAnnuity createAnnuityPayout(OpenJPAEntityManagerFactorySPI myEMF, IAnnuity annuity) {
        EntityManager em = createEM(myEMF);
        em.getTransaction().begin();
        IPayout payout = new Payout();
        payout.setAnnuity(annuity);
        payout.setTaxableAmount(new BigDecimal(100.00));
        payout.setStartDate(Calendar.getInstance());
        payout.setEndDate(Calendar.getInstance());
        payout.setId(getId());
        em.persist(payout);
        em.getTransaction().commit();
        em.getTransaction().begin();
        annuity.getPayouts().add(payout);
        em.getTransaction().commit();
        closeEM(em);
        return annuity;
    }

    private IAnnuity createAnnuityWithRider(OpenJPAEntityManagerFactorySPI myEMF, AnnuityType annuityType) {
        EntityManager em = createEM(myEMF);
        em.getTransaction().begin();
        IAnnuity annuity = createAnnuity(annuityType);
        IRider rider1 = getRider();
        IRider rider2 = getRider();
        IRider rider3 = getRider();
        annuity.getRiders().add(rider1);
        annuity.getRiders().add(rider2);
        annuity.getRiders().add(rider3);
        em.persist(annuity);
        em.getTransaction().commit();
        closeEM(em);
        return annuity;
    }

    private IAnnuity createAnnuity(AnnuityType annuityType) {
        if (AnnuityType.BASIC.equals(annuityType)) {
            Annuity annuity = new Annuity();
            annuity.setId(getId());
            annuity.setAmount(500.00);
            annuity.setAccountNumber("123456");
            return annuity;
        }
        if (AnnuityType.EQUITY.equals(annuityType)) {
            EquityAnnuity annuity = new EquityAnnuity();
            annuity.setId(getId());
            annuity.setAmount(500.00);
            annuity.setAccountNumber("123456");
            annuity.setFundNames("Something nothing wrong");
            annuity.setIndexRate(10.99);
            annuity.setLastPaidAmt(100.00);
            return annuity;
        }
        if (AnnuityType.FIXED.equals(annuityType)) {
            FixedAnnuity annuity = new FixedAnnuity();
            ((FixedAnnuity)annuity).setRate(10.0);
            annuity.setId(getId());
            annuity.setAmount(500.00);
            annuity.setAccountNumber("123456");
            return annuity;
        }
        return null;
    }

    private IRider getRider() {
        IRider rider = new Rider();
        rider.setId(getId());
        rider.setRule("Pay");
        rider.setType(RiderType.REPLACE);
        rider.setEffectiveDate(new Date());
        return rider;
    }

    private void verifyAnnuityValues(OpenJPAEntityManagerFactorySPI myEMF, IAnnuity annuity, AnnuityType annuityType)
    throws Exception {
        IAnnuity results = findAnnuityById(myEMF, Annuity.class, annuity.getId());
        if (annuity instanceof IFixedAnnuity) {
            assertEqual((IFixedAnnuity)annuity, (IFixedAnnuity)results,
                "Fixed Annuity from Client is not equal to DB value", "Mismacth was found.");
        } else if (annuity instanceof IEquityAnnuity) {
            assertEqual((IEquityAnnuity)annuity, (IEquityAnnuity)results,
                    "Equity Annuity from Client is not equal to DB value", "Mismacth was found.");
        } else {
            assertEqual(annuity, results,
                    "Basic Annuity from Client is not equal to DB value", "Mismacth was found.");
        }

        assertEqual(annuity.getPayouts(), results.getPayouts(),
                "Annuity payouts from Client is not equal to DB value", "Mismacth was found in number of payouts");
        boolean found = false;
        if (annuity.getPayouts() != null) {
            IPayout clientPayout = null;
            for (int i=0; i<annuity.getPayouts().size(); i++) {
                found = false;  // reset
                clientPayout = annuity.getPayouts().get(i);
                for (IPayout resultPayout: results.getPayouts()) {
                    if (clientPayout.getId().equals(resultPayout.getId())){
                        found = true;
                        assertEqual(clientPayout, resultPayout,
                        "Annuity Payout from Client is not equal to DB value at location: " +i , "Mismacth was found");
                    }else{
                        continue;
                    }
                }
                if (!(found) && clientPayout != null) {
                    throw new RuntimeException("Annuity: Payout from client is not equal to DB.  " +
                            "Found Payout with id: " + clientPayout.getId() +
                            " on the client side, but not in the database for annuity id:" + annuity.getId());

                }
            }
        }

        assertRidersEqual(annuity.getRiders(), results.getRiders(),
                "Annuity rider from Client is not equal to DB value", "Mismacth was found in number of rider");
        if (annuity.getRiders() != null) {
            IRider clientRider = null;
            for (int i=0; i<annuity.getRiders().size(); i++) {
                found = false;  // reset
                clientRider = annuity.getRiders().get(i);
                for (IRider resultRider : results.getRiders()) {
                    if (clientRider.getId().equals(resultRider.getId())){
                        found = true;
                        assertEqual(clientRider, resultRider,
                        "Annuity rider from Client is not equal to DB value at location: " +i , "Mismacth was found");
                    }else{
                        continue;
                    }
                }
                if (!(found) && clientRider != null) {
                    throw new RuntimeException("Annuity: Rider from client is not equal to DB.  " +
                            "Found rider with id: " + clientRider.getId() +
                            " on the client side, but not in the database for annuity id:" + annuity.getId());

                }
            }
        }

        assertPayorsEqual(annuity.getPayors(), results.getPayors(),
                "Annuity Payor from Client is not equal to DB value", "Mismacth was found.");
        if (annuity.getPayors() != null) {
            IPayor clientPayor = null;
            for (int i=0; i<annuity.getPayors().size(); i++) {
                found = false;  // reset
                clientPayor = annuity.getPayors().get(i);
                for (IPayor resultPayor : results.getPayors()) {
                    if (clientPayor.getId().equals(resultPayor.getId())){
                        found = true;
                        assertEqual(annuity.getPayors().get(i), resultPayor,
                        "Annuity payor from Client is not equal to DB value at location: " +i , "Mismacth was found");
                    }else{
                        continue;
                    }
                }
                if (!(found) && clientPayor != null) {
                    throw new RuntimeException("Annuity: Payor from client is not equal to DB.  " +
                            "Found payor with id: " + clientPayor.getId() +
                            " on the client side, but not in the database for annuity id:" + annuity.getId());

                }
            }
        }
    }

    private void assertEqual(IAnnuity annuity, IAnnuity results, String string, String string2) throws Exception {
        if(annuity == null && results == null)
            return;
        if (annuity == null)
            throw new RuntimeException("Annuity: Annuities ! equal (Annuity was null).");
        if (!annuity.getId().equals(results.getId())) {
            throw new RuntimeException("Annuity: Annuities ! equal (Annuity ids not the same).");
        }
        assertPayorsEqual(annuity.getPayors(), results.getPayors(), string, string2);
        assertRidersEqual(annuity.getRiders(), results.getRiders(), string, string2);
        assertEqual(annuity.getPayouts(),results.getPayouts(), string, string2);
    }

    private void assertEqual(IEquityAnnuity annuity, IEquityAnnuity results, String string, String string2)
    throws Exception {
        if(annuity == null && results == null)
            return;
        if (annuity == null)
            throw new RuntimeException("Annuity: Annuities ! equal (EquityAnnuity was null).");
        if (!annuity.getId().equals(results.getId())) {
            throw new RuntimeException("Annuity: Annuities ! equal (EquityAnnuity ids not the same).");
        }

        assertPayorsEqual(annuity.getPayors(), results.getPayors(), string, string2);
        assertRidersEqual(annuity.getRiders(), results.getRiders(), string, string2);
        assertEqual(annuity.getPayouts(),results.getPayouts(), string, string2);
    }

    private void assertEqual(IFixedAnnuity annuity, IFixedAnnuity results, String string, String string2)
    throws Exception {
        if(annuity == null && results == null)
            return;
        if (annuity == null)
            throw new RuntimeException("Annuity: Annuities ! equal (FixedAnnuity was null).");
        if (!annuity.getId().equals(results.getId())) {
            throw new RuntimeException("Annuity: Annuities ! equal (FixedAnnuity ids not the same).");
        }
        assertPayorsEqual(annuity.getPayors(), results.getPayors(), string, string2);
        assertRidersEqual(annuity.getRiders(), results.getRiders(), string, string2);
        assertEqual(annuity.getPayouts(),results.getPayouts(), string, string2);
    }

    private IAnnuity findAnnuityById(OpenJPAEntityManagerFactorySPI myEMF, Class<Annuity> class1, String id) {
        EntityManager em = createEM(myEMF);
        IAnnuity ann = em.find(class1, id);
        closeEM(em);
        return ann;
    }

    private void assertEqual(List<IPayout> payouts, List<IPayout> payouts2, String string, String string2)
    throws Exception {
        if (payouts == null && payouts2 == null)
            return;
        if (payouts == null)
            throw new RuntimeException("Annuity: IPayout list not the same (payouts was null)!");
        if (payouts.size() != payouts2.size())
            throw new RuntimeException("Annuity: IPayout list not the same (payouts size not the same)!");
        for (int i = 0; i < payouts.size(); i++) {
            IPayout payout = payouts.get(i);
            boolean found = false;
            for (int j = 0; i < payouts2.size(); j++) {
                try {
                    assertEqual(payout, payouts2.get(j), string, string2);
                    found = true;
                    break;
                } catch (Exception e) {
                    continue;
                }
            }
            if (!found) {
                throw new RuntimeException("Annuity: IPayout list not the same (no match found)!");
            }
        }
    }

    private void assertEqual(IPayout clientPayout, IPayout resultPayout, String string, String string2)
    throws Exception {
        if (clientPayout == null && resultPayout == null)
            return;
        if (clientPayout == null)
            throw new RuntimeException("Annuity: IPayout not the same (clientPayout was null)! " +
                string + " " + string2);
        if (clientPayout.getId().equals(resultPayout.getId()))
            return;
        throw new RuntimeException("Annuity: IPayout not the same (clientPayout ids not the same)! " +
            string + " " + string2);
    }

    private void assertRidersEqual(List<IRider> riders, List<IRider> riders2, String string, String string2)
    throws Exception {
        if (riders == null && riders2 == null)
            return;
        if (riders == null)
            throw new RuntimeException("Annuity: IRider list not the same (riders was null)!");
        if (riders.size() != riders2.size())
            throw new RuntimeException("Annuity: IRider list not the same (riders size not the same)!");
        for (int i = 0; i < riders.size(); i++) {
            IRider rider = riders.get(i);
            boolean found = false;
            for (int j = 0; i < riders2.size(); j++) {
                try {
                    assertEqual(rider, riders2.get(j), string, string2);
                    found = true;
                    break;
                } catch (Exception e) {
                    continue;
                }
            }
            if (!found) {
                throw new RuntimeException("Annuity: IRider list not the same (match not found)!");
            }
        }
    }

    private void assertEqual(IRider clientRider, IRider resultRider, String string, String string2) throws Exception {
        if (clientRider == null && resultRider == null)
            return;
        if (clientRider == null)
            throw new RuntimeException("Annuity: IRider not the same (clientRider was null)! " +
                string + " " + string2);
        if (clientRider.getId().equals(resultRider.getId()))
            return;
        throw new RuntimeException("Annuity: IRider not the same (no match found)! " +
            string + " " + string2);
    }

    private void assertPayorsEqual(List<IPayor> payors, List<IPayor> payors2, String string, String string2)
    throws Exception {
        if (payors == null && payors2 == null)
            return;
        if (payors == null)
            throw new RuntimeException("Annuity: IPayor list not the same (payors was null)!");
        if (payors.size() != payors2.size())
            throw new RuntimeException("Annuity: IPayor list not the same (payors size not the same)! payors=" +
                    Arrays.toString(payors.toArray()) + ", payors2=" + payors2.toString());
        for (int i = 0; i < payors.size(); i++) {
            IPayor payor = payors.get(i);
            boolean found = false;
            for (int j = 0; i < payors2.size(); j++) {
                try {
                    assertEqual(payor, payors2.get(j), string, string2);
                    found = true;
                    break;
                } catch (Exception e) {
                    continue;
                }
            }
            if (!found) {
                throw new RuntimeException("Annuity: IPayor list not the same (no match found)!");
            }
        }
    }

    private void verifyPayorValues(OpenJPAEntityManagerFactorySPI myEMF, IPayor payor) throws Exception {
        IPayor results = null;
        results = findPayorById(myEMF, Payor.class, payor.getId());
        assertEqual(payor, results,
                "Payor from Client is not equal to DB value.", "Mismacth was found.");
    }

    private IPayor findPayorById(OpenJPAEntityManagerFactorySPI myEMF, Class<Payor> class1, String id) {
        EntityManager em = createEM(myEMF);
        IPayor ip = em.find(class1, id);
        closeEM(em);
        return ip;
    }

    private void assertEqual(IPayor payor, IPayor results, String string, String string2) throws Exception {
        if (payor == null && results == null)
            return;
        if (payor == null)
            throw new RuntimeException("Annuity: IPayor not the same (payor was null)! " +
                string + " " + string2);
        if (payor.getId().equals(results.getId()))
            return;
        throw new RuntimeException("Annuity: IPayor not the same (no match found)! " +
            string + " " + string2);
    }

    private IPayor createPayor(OpenJPAEntityManagerFactorySPI myEMF) {
        EntityManager em = createEM(myEMF);
        em.getTransaction().begin();
        IPayor payor = new Payor();
        payor.setId(getId());
        payor.setName("Payor");
        em.persist(payor);
        em.getTransaction().commit();
        closeEM(em);
        return payor;
    }

    private void verifyAnnuityHolderValues(OpenJPAEntityManagerFactorySPI myEMF, IAnnuityHolder annuityHolder)
    throws Exception {
        IAnnuityHolder result = null;
        result = findHolderById(myEMF, AnnuityHolder.class, annuityHolder.getId());
        assertEqual(annuityHolder, result,
            "Annuity Holder from Client is not equal to DB value.", "Mismacth was found.");
        assertEqual(annuityHolder.getContact(), result.getContact(),
                "Annuity Holder Contact from Client is not equal to DB value.", "Mismacth was found.");
    }

    private IAnnuityHolder findHolderById(OpenJPAEntityManagerFactorySPI myEMF, Class<AnnuityHolder> class1, String id)
    {
        EntityManager em = createEM(myEMF);
        IAnnuityHolder result = em.find(class1, id);
        closeEM(em);
        return result;
    }

    private EntityManager createEM(OpenJPAEntityManagerFactorySPI myEMF) {
        return myEMF.createEntityManager();
    }

    private void assertEqual(IAnnuityHolder annuityHolder, IAnnuityHolder results, String string, String string2)
    throws Exception {
            if (annuityHolder == null && results == null)
                return;
            if (annuityHolder == null)
                throw new RuntimeException("Annuity: IAnnuityHolder not the same (annuityHolder was null)! " +
                    string + " " + string2);
            if (annuityHolder.getId().equals(results.getId()))
                return;
            throw new RuntimeException("Annuity: IAnnuityHolder not the same (no match found)! " +
                string + " " + string2);
    }

    private void assertEqual(IContact contact, IContact contact2, String string, String string2) throws Exception {
        if (contact == null && contact2 == null)
            return;
        if (contact == null)
            throw new RuntimeException("Annuity: Contacts not the same (contact was null)! " +
                string + " " + string2);
        if (contact.getId().equals(contact2.getId()))
            return;
        throw new RuntimeException("Annuity: Contacts not the same (no match found)! " +
            string + " " + string2);
    }

    private IAnnuityHolder createAnnuityHolder(OpenJPAEntityManagerFactorySPI myEMF, IContact contact) {
        EntityManager em = createEM(myEMF);
        em.getTransaction().begin();
        IAnnuityHolder annuityHolder = new AnnuityHolder();
        annuityHolder.setCategory(AnnuityHolderCategory.METAL);
        annuityHolder.setContact(contact);
        annuityHolder.setId(getId());
        annuityHolder.setFirstName("bob");
        annuityHolder.setDateOfBirth(new Date());
        annuityHolder.setGovernmentId("US");
        annuityHolder.setLastName("dog");
        annuityHolder.setTimeOfBirth(new Date());
        em.persist(annuityHolder);
        em.getTransaction().commit();
        closeEM(em);
        return annuityHolder;
    }

    private void verifyContactValues(OpenJPAEntityManagerFactorySPI myEMF, IContact contact) throws Exception {
        // read the contact with id.
        IContact results = null;
        results = findContactById(myEMF, Contact.class, contact.getId());
        assertEqual(contact, results,
            "Contact from Client is not equal to DB value.", "Mismacth was found.");
    }

    private IContact findContactById(OpenJPAEntityManagerFactorySPI myEMF, Class<Contact> class1, String id) {
        EntityManager em = createEM(myEMF);
        IContact ic = em.find(class1, id);
        closeEM(em);
        return ic;
    }

    private IContact createContact(OpenJPAEntityManagerFactorySPI myEMF) {
        EntityManager em = createEM(myEMF);
        em.getTransaction().begin();
        IContact contact = null;
        contact = new Contact();
        contact.setContactType(ContactType.BUSINESS);
        contact.setId(getId());
        contact.setEmail("here@there");
        contact.setPhone("555-5555");
        em.persist(contact);
        em.getTransaction().commit();
        closeEM(em);
        return contact;
    }

    private String getId() {
        UUID uid = UUID.randomUUID();
        return uid.toString();
    }

}
