<target name="server-test-advanced-multitenant">

        <antcall target="server-run-all" inheritRefs="true">

            <param name="PERSISTENCE_UNIT_NAME" value="default"/>

            <param name="USE_MULTIPLE_PERSISTENCE_UNITS" value="true"/>

            <param name="MODEL_DIR" value="org/eclipse/persistence/testing/models/jpa/advanced"/>

            <param name="MODEL_NAME" value="eclipselink-advanced-multitenant-model"/>

            <param name="TEST_DIR" value="org/eclipse/persistence/testing/tests/jpa/advanced"/>

            <param name="TEST_NAME" value="eclipselink-advanced-multitenant-model"/>

            <param name="EAR_NAME" value="eclipselink-advanced-multitenant-model"/>

            <param name="TEST_SUITE" value="org.eclipse.persistence.testing.tests.jpa.advanced.multitenant.AdvancedMultiTenantServerTestSuite"/>

            <param name="eclipselink.jpa.test.dir" value="."/>

        </antcall>

    </target>

<persistence xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence persistence_1_0.xsd" version="1.0">

    <persistence-unit name="%%default%%" transaction-type="%%transaction-type%%">

        <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>

        <%%datasource-type%%>%%data-source-name%%</%%datasource-type%%>

        <exclude-unlisted-classes>false</exclude-unlisted-classes>

        <properties>

            <property name="eclipselink.target-server" value="%%server-platform%%"/>

            <property name="eclipselink.target-database" value="%%database-platform%%"/>

            <property name="eclipselink.weaving" value="%%server-weaving%%"/>

            <property name="eclipselink.validate-existence" value="true"/>

            <property name="eclipselink.logging.level" value="INFO"/>

        </properties>

    </persistence-unit>

    <!--multi-tenant-shared-emf PU-->

    <persistence-unit name="MulitPU-1" transaction-type="%%transaction-type%%">

        <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>

        <%%datasource-type%%>%%data-source-name%%</%%datasource-type%%>

        <class>org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Boss</class>

        <class>org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Capo</class>

        <class>org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Contract</class>

        <class>org.eclipse.persistence.testing.models.jpa.advanced.multitenant.MafiaFamily</class>

        <class>org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Mafioso</class>

        <class>org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Soldier</class>

        <class>org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Underboss</class>

        <exclude-unlisted-classes>true</exclude-unlisted-classes>

        <properties>

            <property name="eclipselink.target-server" value="%%server-platform%%"/>

            <property name="eclipselink.target-database" value="%%database-platform%%"/>

            <property name="eclipselink.weaving" value="%%server-weaving%%"/>

            <property name="eclipselink.validate-existence" value="true"/>

            <property name="eclipselink.logging.level" value="INFO"/>

            <property name="eclipselink.multitenant.tenants-share-cache" value="true"/>

            <property name="eclipselink.ddl-generation" value="drop-and-create-tables"/>

            <property name="eclipselink.create-ddl-jdbc-file-name" value="createMafia_ddlGeneration.jdbc"/>

            <property name="eclipselink.drop-ddl-jdbc-file-name" value="dropMafia_ddlGeneration.jdbc"/>

            <property name="eclipselink.ddl-generation.output-mode" value="sql-script"/>

        </properties>

    </persistence-unit>

    <!--multi-tenant-123 PU-->

    <persistence-unit name="MulitPU-2" transaction-type="%%transaction-type%%">

        <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>

        <%%datasource-type%%>%%data-source-name%%</%%datasource-type%%>

        <class>org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Boss</class>

        <class>org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Capo</class>

        <class>org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Contract</class>

        <class>org.eclipse.persistence.testing.models.jpa.advanced.multitenant.MafiaFamily</class>

        <class>org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Mafioso</class>

        <class>org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Soldier</class>

        <class>org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Underboss</class>

        <exclude-unlisted-classes>true</exclude-unlisted-classes>

        <properties>

            <property name="eclipselink.target-server" value="%%server-platform%%"/>

            <property name="eclipselink.target-database" value="%%database-platform%%"/>

            <property name="eclipselink.weaving" value="%%server-weaving%%"/>

            <property name="eclipselink.validate-existence" value="true"/>

            <property name="eclipselink.logging.level" value="INFO"/>

            <property name="tenant.id" value="123"/>

            <property name="eclipselink.tenant-id" value="123"/>

            <property name="eclipselink.session-name" value="multi-tenant-123"/>

        </properties>

    </persistence-unit>

    <persistence-unit name="MulitPU-3" transaction-type="%%transaction-type%%">

        <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>

        <%%datasource-type%%>%%data-source-name%%</%%datasource-type%%>

    </persistence-unit>

    <persistence-unit name="MulitPU-4" transaction-type="%%transaction-type%%">

        <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>

        <%%datasource-type%%>%%data-source-name%%</%%datasource-type%%>

    </persistence-unit>

    <persistence-unit name="MulitPU-5" transaction-type="%%transaction-type%%">

        <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>

        <%%datasource-type%%>%%data-source-name%%</%%datasource-type%%>

    </persistence-unit>

</persistence>

/*******************************************************************************

 * Copyright (c) 2011 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:

 *     03/23/2011-2.3 Guy Pelletier 

 *       - 337323: Multi-tenant with shared schema support (part 1)

 *     04/01/2011-2.3 Guy Pelletier 

 *       - 337323: Multi-tenant with shared schema support (part 2)

 *     04/21/2011-2.3 Guy Pelletier 

 *       - 337323: Multi-tenant with shared schema support (part 5)

 ******************************************************************************/  

package org.eclipse.persistence.testing.tests.jpa.advanced.multitenant;

import java.util.ArrayList;

import java.util.List;

import javax.persistence.EntityManager;

import junit.framework.*;

import org.eclipse.persistence.testing.framework.junit.JUnitTestCase;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Boss;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Capo;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Contract;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.MafiaFamily;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Mafioso;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Soldier;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Underboss;

public class AdvancedMultiTenant123JunitTest extends JUnitTestCase { 

    public static final String MULTI_TENANT_PU_123 = "MulitPU-2";

    public static int family123;

    public static List<Integer> family123Mafiosos = new ArrayList<Integer>();

    public static List<Integer> family123Contracts = new ArrayList<Integer>();

    public AdvancedMultiTenant123JunitTest() {

        super();

    }

    public AdvancedMultiTenant123JunitTest(String name) {

        super(name);

        setPuName(MULTI_TENANT_PU_123);

    }

    public void setUp() {}

    public static Test suite() {

        TestSuite suite = new TestSuite();

        suite.setName("AdvancedMultiTenant123JunitTest");

        if (! JUnitTestCase.isJPA10()) {

            suite.addTest(new AdvancedMultiTenant123JunitTest("testCreateMafiaFamily123"));

            suite.addTest(new AdvancedMultiTenant123JunitTest("testValidateMafiaFamily123"));

        }

        return suite;

    }

    public void testCreateMafiaFamily123() {

        EntityManager em = createEntityManager(MULTI_TENANT_PU_123);

        try {

            beginTransaction(em);

            MafiaFamily family = new MafiaFamily();

            family.setName("Galore");

            family.setRevenue(4321.03);

            family.addTag("newtag1");

            Boss boss = new Boss();

            boss.setFirstName("Kitty");

            boss.setLastName("Galore");

            boss.setGender(Mafioso.Gender.Female);

            Underboss underboss = new Underboss();

            underboss.setFirstName("Number2");

            underboss.setLastName("Galore");

            underboss.setGender(Mafioso.Gender.Male);

            Capo capo1 = new Capo();

            capo1.setFirstName("Capo");

            capo1.setLastName("Galore");

            capo1.setGender(Mafioso.Gender.Male);

            Soldier soldier1 = new Soldier();

            soldier1.setFirstName("Grunt");

            soldier1.setLastName("Galore");

            soldier1.setGender(Mafioso.Gender.Male);

            Contract contract1 = new Contract();

            contract1.setDescription("Whack all other family boss");

            Contract contract2 = new Contract();

            contract2.setDescription("Pillage, pillage, pillage!");

            // Populate the relationships.

            contract1.addSoldier(soldier1);

            contract2.addSoldier(soldier1);

            boss.setUnderboss(underboss);

            capo1.setUnderboss(underboss);

            capo1.addSoldier(soldier1);

            underboss.addCapo(capo1);

            family.addMafioso(boss);

            family.addMafioso(underboss);

            family.addMafioso(capo1);

            family.addMafioso(soldier1);

            // Will cascade through the whole family.

            em.persist(family);

            family123 = family.getId();

            family123Mafiosos.add(boss.getId());

            family123Mafiosos.add(underboss.getId());

            family123Mafiosos.add(capo1.getId());

            family123Mafiosos.add(soldier1.getId());

            family123Contracts.add(contract1.getId());

            family123Contracts.add(contract2.getId());

            commitTransaction(em);

        } catch (RuntimeException e) {

            if (isTransactionActive(em)){

                rollbackTransaction(em);

            }

            throw e;

        } finally {

            closeEntityManager(em);

        }

    }

    public void testValidateMafiaFamily123() {

        EntityManager em = createEntityManager(MULTI_TENANT_PU_123);

        try {

            clearCache(MULTI_TENANT_PU_123);

            em.clear();

            MafiaFamily family =  em.find(MafiaFamily.class, family123);

            assertNotNull("The Mafia Family with id: " + family123 + ", was not found", family);

            assertTrue("The Mafia Family had an incorrect number of tags [" + family.getTags().size() + "], expected [1]", family.getTags().size() == 1);

            assertNull("The Mafia Family with id: " + AdvancedMultiTenantSharedEMFJunitTest.family707 + ", was found (when it should not have been)", em.find(MafiaFamily.class, AdvancedMultiTenantSharedEMFJunitTest.family707));

            assertNull("The Mafia Family with id: " + AdvancedMultiTenantSharedEMFJunitTest.family007 + ", was found (when it should not have been)", em.find(MafiaFamily.class, AdvancedMultiTenantSharedEMFJunitTest.family007));

            assertFalse("No mafiosos part of 123 family", family.getMafiosos().isEmpty());

            // See if we can find any members of the other family.

            for (Integer id : AdvancedMultiTenantSharedEMFJunitTest.family707Mafiosos) {

                assertNull("Found family 707 mafioso.", em.find(Mafioso.class, id));

            }

            // Query directly for the boss from the other family.

            Boss otherBoss = em.find(Boss.class, AdvancedMultiTenantSharedEMFJunitTest.family707Mafiosos.get(0));

            assertNull("Found family 707 boss.", otherBoss);

            // See if we can find any contracts of the other family.

            for (Integer id : AdvancedMultiTenantSharedEMFJunitTest.family707Contracts) {

                assertNull("Found family 707 contract. ", em.find(Contract.class, id));

            }

            // Try a select named query

            List families = em.createNamedQuery("findJPQLMafiaFamilies").getResultList();

            assertTrue("Incorrect number of families were returned [" + families.size() + "], expected [1]",  families.size() == 1);

        } catch (RuntimeException e) {

            if (isTransactionActive(em)){

                rollbackTransaction(em);

            }

            throw e;

        } finally {

            closeEntityManager(em);

        }

    }

}

/*******************************************************************************

 * Copyright (c) 1998, 2011 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 API and implementation from Oracle TopLink

 ******************************************************************************/  

package org.eclipse.persistence.testing.tests.jpa.advanced.multitenant;

import org.eclipse.persistence.testing.tests.jpa.advanced.multitenant.AdvancedMultiTenantSharedEMFJunitTest;

import org.eclipse.persistence.testing.tests.jpa.advanced.multitenant.AdvancedMultiTenant123JunitTest;

import org.eclipse.persistence.testing.framework.junit.JUnitTestCase;

import junit.framework.TestSuite;

import junit.framework.Test;

/**

 * <p><b>Purpose</b>: To collect the tests that will run against Application Server only.

 */

public class AdvancedMultiTenantServerTestSuite extends TestSuite {

    public static Test suite() {

        JUnitTestCase.initializePlatform();

        TestSuite suite = new TestSuite();

        suite.setName("Advanced Multitenant ServerTestSuite");

        suite.addTest(AdvancedMultiTenantSharedEMFJunitTest.suite());

        suite.addTest(AdvancedMultiTenant123JunitTest.suite());

        return suite;

    }

}

/*******************************************************************************

 * Copyright (c) 2011 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:

 *     03/23/2011-2.3 Guy Pelletier 

 *       - 337323: Multi-tenant with shared schema support (part 1)

 *     04/01/2011-2.3 Guy Pelletier 

 *       - 337323: Multi-tenant with shared schema support (part 2)

 *     04/21/2011-2.3 Guy Pelletier 

 *       - 337323: Multi-tenant with shared schema support (part 5)

 ******************************************************************************/  

package org.eclipse.persistence.testing.tests.jpa.advanced.multitenant;

import java.util.ArrayList;

//import java.util.HashMap;

import java.util.List;

//import java.util.Map;

import javax.persistence.EntityManager;

//import javax.persistence.EntityManagerFactory;

//import javax.persistence.NamedQuery;

//import javax.persistence.Persistence;

import javax.persistence.Query;

import junit.framework.*;

import org.eclipse.persistence.testing.framework.junit.JUnitTestCase;

import org.eclipse.persistence.config.EntityManagerProperties;

//import org.eclipse.persistence.config.PersistenceUnitProperties;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.AdvancedMultiTenantTableCreator;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Boss;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Capo;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Contract;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.MafiaFamily;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Mafioso;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Soldier;

import org.eclipse.persistence.testing.models.jpa.advanced.multitenant.Underboss;

public class AdvancedMultiTenantSharedEMFJunitTest extends JUnitTestCase { 

    public static final String MULTI_TENANT_PU = "MulitPU-1";

    public static int family707;

    public static int family007;

    public static List<Integer> family707Mafiosos = new ArrayList<Integer>();

    public static List<Integer> family707Contracts = new ArrayList<Integer>();

    public static List<Integer> family007Mafiosos = new ArrayList<Integer>();

    public static List<Integer> family007Contracts = new ArrayList<Integer>();

    public AdvancedMultiTenantSharedEMFJunitTest() {

        super();

    }

    public AdvancedMultiTenantSharedEMFJunitTest(String name) {

        super(name);

        setPuName(MULTI_TENANT_PU);

    }

    public void setUp() {}

    public static Test suite() {

        TestSuite suite = new TestSuite();

        suite.setName("AdvancedMultiTenantSharedEMFJunitTest");

        if (! JUnitTestCase.isJPA10()) {

            suite.addTest(new AdvancedMultiTenantSharedEMFJunitTest("testSetup"));

            suite.addTest(new AdvancedMultiTenantSharedEMFJunitTest("testCreateMafiaFamily707"));

            suite.addTest(new AdvancedMultiTenantSharedEMFJunitTest("testCreateMafiaFamily007"));

            suite.addTest(new AdvancedMultiTenantSharedEMFJunitTest("testValidateMafiaFamily707"));

            suite.addTest(new AdvancedMultiTenantSharedEMFJunitTest("testValidateMafiaFamily007"));

            suite.addTest(new AdvancedMultiTenantSharedEMFJunitTest("testValidateMafiaFamily707and007WithSameEM"));

        }

        return suite;

    }

    /**

     * The setup is done as a test, both to record its failure, and to allow execution in the server.

     */

    public void testSetup() {

        new AdvancedMultiTenantTableCreator().replaceTables(JUnitTestCase.getServerSession(MULTI_TENANT_PU));

    }

    public void testCreateMafiaFamily707() {

        EntityManager em = createEntityManager(MULTI_TENANT_PU);

        try {

            beginTransaction(em);

            //on server side, you have to set the em properties after transaction begins

            em.setProperty("tenant.id", "707");

            em.setProperty(EntityManagerProperties.MULTITENANT_PROPERTY_DEFAULT, "707");

            MafiaFamily family = new MafiaFamily();

            family.setName("Gonzo");

            family.setRevenue(10000000.00);

            family.addTag("firstTag");

            family.addTag("secondTag");

            family.addTag("thirdTag");

            Boss boss = new Boss();

            boss.setFirstName("707");

            boss.setLastName("Boss");

            boss.setGender(Mafioso.Gender.Male);

            Underboss underboss = new Underboss();

            underboss.setFirstName("Under");

            underboss.setLastName("Boss");

            underboss.setGender(Mafioso.Gender.Male);

            Capo capo1 = new Capo();

            capo1.setFirstName("Capo");

            capo1.setLastName("Giggaloo");

            capo1.setGender(Mafioso.Gender.Female);

            Capo capo2 = new Capo();

            capo2.setFirstName("Capo");

            capo2.setLastName("CrazyGlue");

            capo2.setGender(Mafioso.Gender.Male);

            Soldier soldier1 = new Soldier();

            soldier1.setFirstName("Soldier");

            soldier1.setLastName("One");

            soldier1.setGender(Mafioso.Gender.Female);

            Soldier soldier2 = new Soldier();

            soldier2.setFirstName("Soldier");

            soldier2.setLastName("Two");

            soldier2.setGender(Mafioso.Gender.Male);

            Soldier soldier3 = new Soldier();

            soldier3.setFirstName("Soldier");

            soldier3.setLastName("Three");

            soldier3.setGender(Mafioso.Gender.Male);

            Soldier soldier4 = new Soldier();

            soldier4.setFirstName("Soldier");

            soldier4.setLastName("Four");

            soldier4.setGender(Mafioso.Gender.Male);

            Soldier soldier5 = new Soldier();

            soldier5.setFirstName("Soldier");

            soldier5.setLastName("Four");

            soldier5.setGender(Mafioso.Gender.Female);

            Contract contract1 = new Contract();

            contract1.setDescription("Whack 007 family boss");

            Contract contract2 = new Contract();

            contract2.setDescription("Acquire fully-automatic guns");

            Contract contract3 = new Contract();

            contract3.setDescription("Steal some money");

            // Populate the relationships.

            contract1.addSoldier(soldier1);

            contract1.addSoldier(soldier5);

            contract2.addSoldier(soldier1);

            contract2.addSoldier(soldier3);

            contract2.addSoldier(soldier5);

            contract3.addSoldier(soldier2);

            contract3.addSoldier(soldier3);

            contract3.addSoldier(soldier4);

            contract3.addSoldier(soldier5);

            boss.setUnderboss(underboss);

            capo1.setUnderboss(underboss);

            capo2.setUnderboss(underboss);

            capo1.addSoldier(soldier1);

            capo1.addSoldier(soldier2);

            capo2.addSoldier(soldier3);

            capo2.addSoldier(soldier4);

            capo2.addSoldier(soldier5);

            underboss.addCapo(capo1);

            underboss.addCapo(capo2);

            family.addMafioso(boss);

            family.addMafioso(underboss);

            family.addMafioso(capo1);

            family.addMafioso(capo2);

            family.addMafioso(soldier1);

            family.addMafioso(soldier2);

            family.addMafioso(soldier3);

            family.addMafioso(soldier4);

            family.addMafioso(soldier5);

            // Will cascade through the whole family.

            em.persist(family);

            // Store the ids to verify

            family707 = family.getId();

            family707Mafiosos.add(boss.getId());

            family707Mafiosos.add(underboss.getId());

            family707Mafiosos.add(capo1.getId());

            family707Mafiosos.add(capo2.getId());

            family707Mafiosos.add(soldier1.getId());

            family707Mafiosos.add(soldier2.getId());

            family707Mafiosos.add(soldier3.getId());

            family707Mafiosos.add(soldier4.getId());

            family707Mafiosos.add(soldier5.getId());

            family707Contracts.add(contract1.getId());

            family707Contracts.add(contract2.getId());

            family707Contracts.add(contract3.getId());

            commitTransaction(em);

        } catch (RuntimeException e) {

            if (isTransactionActive(em)){

                rollbackTransaction(em);

            }

            throw e;

        } finally {

            closeEntityManager(em);

        }

    }

    public void testCreateMafiaFamily007() {

        EntityManager em = createEntityManager(MULTI_TENANT_PU);

        try {

            beginTransaction(em);

            //on server side, you have to set the em properties after transaction begins

            em.setProperty("tenant.id", "007");

            em.setProperty(EntityManagerProperties.MULTITENANT_PROPERTY_DEFAULT, "007");

            MafiaFamily family = new MafiaFamily();

            family.setName("Bond");

            family.setRevenue(987654321.03);

            family.addTag("tag1");

            family.addTag("tag2");

            family.addTag("tag3");

            family.addTag("tag4");

            family.addTag("tag5");

            Boss boss = new Boss();

            boss.setFirstName("007");

            boss.setLastName("Boss");

            boss.setGender(Mafioso.Gender.Female);

            Underboss underboss = new Underboss();

            underboss.setFirstName("Second");

            underboss.setLastName("InCommand");

            underboss.setGender(Mafioso.Gender.Female);

            Capo capo1 = new Capo();

            capo1.setFirstName("Capo");

            capo1.setLastName("Lubey");

            capo1.setGender(Mafioso.Gender.Male);

            Capo capo2 = new Capo();

            capo2.setFirstName("Capo");

            capo2.setLastName("Greasy");

            capo2.setGender(Mafioso.Gender.Female);

            Soldier soldier1 = new Soldier();

            soldier1.setFirstName("First");

            soldier1.setLastName("Grunt");

            soldier1.setGender(Mafioso.Gender.Male);

            Soldier soldier2 = new Soldier();

            soldier2.setFirstName("Second");

            soldier2.setLastName("Grunt");

            soldier2.setGender(Mafioso.Gender.Female);

            Soldier soldier3 = new Soldier();

            soldier3.setFirstName("Third");

            soldier3.setLastName("Grunt");

            soldier3.setGender(Mafioso.Gender.Female);

            Soldier soldier4 = new Soldier();

            soldier4.setFirstName("Fourth");

            soldier4.setLastName("Grunt");

            soldier4.setGender(Mafioso.Gender.Female);

            Soldier soldier5 = new Soldier();

            soldier5.setFirstName("Fifth");

            soldier5.setLastName("Grunt");

            soldier5.setGender(Mafioso.Gender.Male);

            Soldier soldier6 = new Soldier();

            soldier6.setFirstName("Sixth");

            soldier6.setLastName("Grunt");

            soldier6.setGender(Mafioso.Gender.Male);

            Soldier soldier7 = new Soldier();

            soldier7.setFirstName("Seventh");

            soldier7.setLastName("Grunt");

            soldier7.setGender(Mafioso.Gender.Male);

            Contract contract1 = new Contract();

            contract1.setDescription("Whack 707 family boss");

            Contract contract2 = new Contract();

            contract2.setDescription("Acquire semi-automatic guns");

            Contract contract3 = new Contract();

            contract3.setDescription("Set up new financing deals");

            // Populate the relationships.

            contract1.addSoldier(soldier1);

            contract1.addSoldier(soldier5);

            contract2.addSoldier(soldier1);

            contract2.addSoldier(soldier3);

            contract2.addSoldier(soldier7);

            contract3.addSoldier(soldier2);

            contract3.addSoldier(soldier3);

            contract3.addSoldier(soldier4);

            contract3.addSoldier(soldier5);

            boss.setUnderboss(underboss);

            capo1.setUnderboss(underboss);

            capo2.setUnderboss(underboss);

            capo1.addSoldier(soldier1);

            capo1.addSoldier(soldier2);

            capo2.addSoldier(soldier3);

            capo2.addSoldier(soldier4);

            capo2.addSoldier(soldier5);

            capo2.addSoldier(soldier6);

            capo2.addSoldier(soldier7);

            underboss.addCapo(capo1);

            underboss.addCapo(capo2);

            family.addMafioso(boss);

            family.addMafioso(underboss);

            family.addMafioso(capo1);

            family.addMafioso(capo2);

            family.addMafioso(soldier1);

            family.addMafioso(soldier2);

            family.addMafioso(soldier3);

            family.addMafioso(soldier4);

            family.addMafioso(soldier5);

            family.addMafioso(soldier6);

            family.addMafioso(soldier7);

            // Will cascade through the whole family.

            em.persist(family);

            family007 = family.getId();

            family007Mafiosos.add(boss.getId());

            family007Mafiosos.add(underboss.getId());

            family007Mafiosos.add(capo1.getId());

            family007Mafiosos.add(capo2.getId());

            family007Mafiosos.add(soldier1.getId());

            family007Mafiosos.add(soldier2.getId());

            family007Mafiosos.add(soldier3.getId());

            family007Mafiosos.add(soldier4.getId());

            family007Mafiosos.add(soldier5.getId());

            family007Mafiosos.add(soldier6.getId());

            family007Mafiosos.add(soldier7.getId());

            family007Contracts.add(contract1.getId());

            family007Contracts.add(contract2.getId());

            family007Contracts.add(contract3.getId());

            commitTransaction(em);

        } catch (RuntimeException e) {

            if (isTransactionActive(em)){

                rollbackTransaction(em);

            }

            throw e;

        } finally {

            closeEntityManager(em);

        }

    }

    public void testValidateMafiaFamily707() {

        EntityManager em = createEntityManager(MULTI_TENANT_PU);

        try {

            validateMafiaFamily707(em);

        } catch (RuntimeException e) {

            if (isTransactionActive(em)){

                rollbackTransaction(em);

            }

            throw e;

        } finally {

            closeEntityManager(em);

        }

    }

    public void testValidateMafiaFamily007() {

        EntityManager em = createEntityManager(MULTI_TENANT_PU);

        try {

            validateMafiaFamily007(em);

        } catch (RuntimeException e) {

            if (isTransactionActive(em)){

                rollbackTransaction(em);

            }

            throw e;

        } finally {

            closeEntityManager(em);

        }

    }

    public void testValidateMafiaFamily707and007WithSameEM() {

        EntityManager em = createEntityManager(MULTI_TENANT_PU);

        try {

            validateMafiaFamily707(em);

            validateMafiaFamily007(em);

        } catch (RuntimeException e) {

            if (isTransactionActive(em)){

                rollbackTransaction(em);

            }

            throw e;

        } finally {

            closeEntityManager(em);

        }

    }

    protected void validateMafiaFamily007(EntityManager em) {

        clearCache(MULTI_TENANT_PU);

        em.clear();

        beginTransaction(em);

        em.setProperty("tenant.id", "007");

        em.setProperty(EntityManagerProperties.MULTITENANT_PROPERTY_DEFAULT, "007");

        MafiaFamily family =  em.find(MafiaFamily.class, family007);

        assertNotNull("The Mafia Family with id: " + family007 + ", was not found", family);

        assertTrue("The Mafia Family had an incorrect number of tags [" + family.getTags().size() + "], expected [5]", family.getTags().size() == 5);

        assertNull("The Mafia Family with id: " + family707 + ", was found (when it should not have been)", em.find(MafiaFamily.class, family707));

        //for multipersistence units tests, we have seperate the test suite based on persistence unit, validateMafiaFamily007 is running ahead of testCreateMafiaFamily123

        //so family123 won't have value at this moment

        //assertNull("The Mafia Family with id: " + family123 + ", was found (when it should not have been)", em.find(MafiaFamily.class, family123));

        // following line will fail, Guy is investigating

        assertFalse("No mafiosos part of 007 family", family.getMafiosos().isEmpty());

        // See if we can find any members of the other family.

        for (Integer id : family707Mafiosos) {

            assertNull("Found family 707 mafioso.", em.find(Mafioso.class, id));

        }

        // Query directly for the boss from the other family.

        Boss otherBoss = em.find(Boss.class, family707Mafiosos.get(0));

        assertNull("Found family 707 boss.", otherBoss);

        // See if we can find any contracts of the other family.

        for (Integer id : family707Contracts) {

            assertNull("Found family 707 contract.", em.find(Contract.class, id));

        }

        // Read and validate our contracts

        List<Contract> contracts = em.createNamedQuery("FindAllContracts").getResultList();

        assertTrue("Incorrect number of contracts were returned [" + contracts.size() + "], expected[3]", contracts.size() == 3);

        for (Contract contract : contracts) {

            assertFalse("Contract description was voided.", contract.getDescription().equals("voided"));

        }

        // Try a select named query

        List families = em.createNamedQuery("findJPQLMafiaFamilies").getResultList();

        assertTrue("Incorrect number of families were returned [" + families.size() + "], expected [1]",  families.size() == 1);

        // Find our boss and make sure his name has not been compromised from the 707 family.

        Boss boss = em.find(Boss.class, family007Mafiosos.get(0));

        assertFalse("The Boss name has been compromised", boss.getFirstName().equals("Compromised"));

        commitTransaction(em);

    }

    protected void validateMafiaFamily707(EntityManager em) {

        clearCache(MULTI_TENANT_PU);

        em.clear();

        beginTransaction(em);

        em.setProperty("tenant.id", "707");

        em.setProperty(EntityManagerProperties.MULTITENANT_PROPERTY_DEFAULT, "707");

        MafiaFamily family = em.find(MafiaFamily.class, family707);

        assertNotNull("The Mafia Family with id: " + family707 + ", was not found", family);

        assertTrue("The Mafia Family had an incorrect number of tags [" + family.getTags().size() + "], expected [3]", family.getTags().size() == 3);

        assertNull("The Mafia Family with id: " + family007 + ", was found (when it should not have been)", em.find(MafiaFamily.class, family007));

        //for multipersistence units tests, we have seperate the test suite based on persistence unit, validateMafiaFamily007 is running ahead of testCreateMafiaFamily123

        //so family123 won't have value at this moment

        //assertNull("The Mafia Family with id: " + family123 + ", was found (when it should not have been)", em.find(MafiaFamily.class, family123));

        assertFalse("No mafiosos part of 707 family", family.getMafiosos().isEmpty());

        // See if we can find any members of the other family.

        for (Integer id : family007Mafiosos) {

            assertNull("Found family 007 mafioso.", em.find(Mafioso.class, id));

        }

        // Query directly for the boss from the other family.

        Boss otherBoss = em.find(Boss.class, family007Mafiosos.get(0));

        assertNull("Found family 007 boss.", otherBoss);

        // See if we can find any contracts of the other family.

        for (Integer id : family007Contracts) {

            assertNull("Found family 007 contract.", em.find(Contract.class, id));

        }

        // Update all our contract descriptions to be 'voided'

        getServerSession(MULTI_TENANT_PU).setLogLevel(0);

        em.createNamedQuery("UpdateAllContractDescriptions").executeUpdate();

        // Read and validate the contracts

        List<Contract> contracts = em.createNamedQuery("FindAllContracts").getResultList();

        assertTrue("Incorrect number of contracts were returned [" + contracts.size() + "], expected[3]", contracts.size() == 3);

        for (Contract contract : contracts) {

            assertTrue("Contract description was not voided.", contract.getDescription().equals("voided"));

        }

        // See how many soldiers are returned from a jpql query

        List soldiers = em.createQuery("SELECT s from Soldier s").getResultList();

        assertTrue("Incorrect number of soldiers were returned [" + soldiers.size() + "], expected [5]",  soldiers.size() == 5);

        // We know what the boss's id is for the 007 family to try to update him from the 707 pu.

        // The 007 family is validated after this test.

        Query query = em.createNamedQuery("UpdateBossName");

        query.setParameter("name", "Compromised");

        query.setParameter("id", family007Mafiosos.get(0));

        query.executeUpdate();

        commitTransaction(em);

    }

}