openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/kernel/TestEJBEmbedded.java

/*
 * 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.kernel;

import javax.persistence.EntityManager;

import org.apache.openjpa.persistence.kernel.common.apps.ComplexEmbeddedPC;
import org.apache.openjpa.persistence.kernel.common.apps.EmbeddedOwnerPC;
import org.apache.openjpa.persistence.kernel.common.apps.EmbeddedPC;

public class TestEJBEmbedded extends BaseKernelTest {

    private Object _oid1 = null;
    private Object _oid2 = null;

    EmbeddedOwnerPC.EmbKey id1;
    EmbeddedOwnerPC.EmbKey id2;

    public TestEJBEmbedded(String name) {
        super(name);
    }

    @Override
    @SuppressWarnings("unchecked")
    public void setUp() {
        deleteAll(EmbeddedOwnerPC.class);
        deleteAll(EmbeddedPC.class);

        EntityManager em = currentEntityManager();
        startTx(em);

        EmbeddedOwnerPC pc1 = new EmbeddedOwnerPC(1, 2);
        pc1.setStringField("string1");
        EmbeddedPC embed1 = new EmbeddedPC();
        embed1.setStringField("embedString1");
        embed1.setIntField(1);
        pc1.setEmbedded(embed1);

        EmbeddedPC embed2 = new EmbeddedPC();
        embed2.setStringField("embedString2");
        embed2.setIntField(2);

        EmbeddedOwnerPC pc2 = new EmbeddedOwnerPC(3, 4);

        em.persist(pc1);
        em.persist(pc2);

        endTx(em);

        id1 = new EmbeddedOwnerPC.EmbKey("1:2");

        id2 = new EmbeddedOwnerPC.EmbKey();
        id2.id1 = 3;
        id2.id2 = 4;

        endEm(em);
    }

    public void testInsert() {
        EntityManager pm = currentEntityManager();
        startTx(pm);

        EmbeddedOwnerPC pc = pm.find(EmbeddedOwnerPC.class, id1);
        EmbeddedOwnerPC pc2 = pm.find(EmbeddedOwnerPC.class, id2);
        assertNotNull("pc is null in testInsert", pc);
        assertNotNull("p2 is null in testInsert", pc2);

        assertEquals("string1", pc.getStringField());
        assertNotNull(pc.getEmbedded());
        assertEquals("embedString1", pc.getEmbedded().getStringField());
        assertEquals(1, pc.getEmbedded().getIntField());

        endTx(pm);
        endEm(pm);
    }

    public void testDelete() {
        EntityManager pm = currentEntityManager();
        startTx(pm);
        EmbeddedOwnerPC pc =
            (EmbeddedOwnerPC) pm.find(EmbeddedOwnerPC.class, id1);

        assertNotNull("pc is null in testDelete", pc);

        EmbeddedPC embed = pc.getEmbedded();

        pc.setEmbedded(null);

        endTx(pm);

        endEm(pm);

        pm = currentEntityManager();
        startTx(pm);
        pc = (EmbeddedOwnerPC) pm.find(EmbeddedOwnerPC.class, id1);

        assertEquals("the expt strng is not string1", "string1",
            pc.getStringField());
        assertNull("pc's embedded is null", pc.getEmbedded());
        endTx(pm);
        endEm(pm);
    }

    public void testUpdateRetain() {
        EntityManager pm = currentEntityManager();
        startTx(pm);
        EmbeddedOwnerPC pc =
            (EmbeddedOwnerPC) pm.find(EmbeddedOwnerPC.class, id1);

        assertNotNull("pc is null testUpdateRetain", pc);

        pc.setStringField("string2");
        pc.getEmbedded().setStringField("embedString2");

        endTx(pm);

        assertEquals("string2", pc.getStringField());
        assertNotNull(pc.getEmbedded());
        assertEquals("embedString2", pc.getEmbedded().getStringField());
        assertEquals(1, pc.getEmbedded().getIntField());

        endEm(pm);
    }

    public void testReplace() {
        EntityManager pm = currentEntityManager();
        startTx(pm);

        EmbeddedOwnerPC pc = pm.find(EmbeddedOwnerPC.class, id1);

        EmbeddedPC newEmbed = new EmbeddedPC();
        newEmbed.setStringField("embedString2");
        pc.setEmbedded(newEmbed);

        ComplexEmbeddedPC newComplexEmbed = new ComplexEmbeddedPC();
        newEmbed = new EmbeddedPC();
        newEmbed.setStringField("embedString3");
        newComplexEmbed.setStringField("complexEmbedString3");
        newComplexEmbed.setOwnerField(new EmbeddedOwnerPC(5, 6));
        pc.setComplexEmbedded(newComplexEmbed);

        endTx(pm);
        endEm(pm);

        pm = currentEntityManager();
        startTx(pm);

        pc = pm.find(EmbeddedOwnerPC.class, id1);
        assertEquals("string1", pc.getStringField());
        assertNotNull(pc.getEmbedded());
        assertEquals("the exp strng is not embedString1", "embedString1",
            pc.getEmbedded().getStringField());
        assertEquals("intfield is not 1", 1, pc.getEmbedded().getIntField());

        endTx(pm);
        endEm(pm);
    }

    public void testShare() {
        EntityManager pm = currentEntityManager();
        startTx(pm);

        EmbeddedOwnerPC pc1 = pm.find(EmbeddedOwnerPC.class, id1);
        assertNotNull("pc1 is null in testshare", pc1);

        EmbeddedOwnerPC pc2 = pm.find(EmbeddedOwnerPC.class, id2);
        assertNotNull("pc2 is null in testshare", pc2);

        EmbeddedPC embed1 = pc1.getEmbedded();

        pm.persist(embed1);
        Integer oid = 1;
        endTx(pm);

        assertEquals("embedString1", embed1.getStringField());
        assertEquals("embedString1", pc1.getEmbedded().getStringField());

        endEm(pm);

        // make sure the changes stick
        pm = currentEntityManager();
        startTx(pm);
        pc1 = pm.find(EmbeddedOwnerPC.class, id1);
        assertNotNull("pc1 is null in testshare 2nd find", pc1);
        pc2 = pm.find(EmbeddedOwnerPC.class, id2);
        assertNotNull("pc2 is null in testshare 2nd find", pc2);
        embed1 = pm.find(EmbeddedPC.class, oid);

        if (embed1 != null) {
            assertEquals("embedString1", embed1.getStringField());
            assertEquals("embedString1", pc1.getEmbedded().getStringField());
        }

        endTx(pm);
        endEm(pm);
    }

    public void testOptimisticLocking2() {
        EntityManager pm1 = getPM(true, false);
        startTx(pm1);

        EmbeddedOwnerPC pc1 = pm1.find(EmbeddedOwnerPC.class, id1);
        assertNotNull("pc1 is null in testoptlock2", pc1);

        EntityManager pm2 = currentEntityManager();

        startTx(pm2);
        EmbeddedOwnerPC pc2 = pm1.find(EmbeddedOwnerPC.class, id1);

        assertNotNull("pc2 is null in testoptlock2", pc2);

        EmbeddedPC embed2 = pc2.getEmbedded();
        embed2.setStringField("xxxx");

        endTx(pm2);
        endEm(pm2);

        EmbeddedPC embed1 = pc1.getEmbedded();
        embed1.setStringField("yyyy");
        try {
            endTx(pm1);
            fail("Should have thrown an OL exception.");
        }
        catch (Exception ove) {
        }
        finally {
            endEm(pm1);
        }
    }
}