| /*******************************************************************************
|
| * Copyright (c) 1998, 2015 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 API and implementation from Oracle TopLink
|
| ******************************************************************************/
|
| package org.eclipse.persistence.testing.tests.unitofwork;
|
|
|
| import java.io.ByteArrayInputStream;
|
| import java.io.ByteArrayOutputStream;
|
| import java.io.IOException;
|
| import java.io.ObjectInputStream;
|
| import java.io.ObjectOutputStream;
|
| import java.util.Collection;
|
|
|
| import org.eclipse.persistence.indirection.IndirectCollectionsFactory; |
| import org.eclipse.persistence.sessions.Session;
|
| import org.eclipse.persistence.sessions.UnitOfWork;
|
| import org.eclipse.persistence.testing.framework.TestErrorException;
|
| import org.eclipse.persistence.testing.framework.TestWarningException;
|
| import org.eclipse.persistence.testing.models.transparentindirection.Order;
|
| import org.eclipse.persistence.testing.models.transparentindirection.OrderLine;
|
|
|
|
|
| /**
|
| * This test checks on a previous problem TopLink had with merging clones and
|
| * serialization. If an existing object was serialized and deserialized and another
|
| * reference added to that object. Then the object was serialized and deserialized
|
| * and deepMergeClone'd into a unit of work and committed.
|
| * When the origional object was then serialized and deserialized and modified, then serialized
|
| * and deserialized and deepMergeClone'd with another unit of work and committed the changes are
|
| * not saved
|
| */
|
| public class DeepMergeCloneIndirectionTest extends org.eclipse.persistence.testing.framework.AutoVerifyTestCase {
|
| public Order orderObject;
|
|
|
| public DeepMergeCloneIndirectionTest() {
|
| setDescription("This test verifies that deepMergeClone works after a serialized transaction. When nested objects use indirection.");
|
| }
|
|
|
| public void setup() {
|
| if (getSession() instanceof org.eclipse.persistence.sessions.remote.RemoteSession) {
|
| throw new TestWarningException("This test cannot be run through the remote.");
|
| }
|
| getAbstractSession().beginTransaction();
|
| this.orderObject = new Order();
|
| this.orderObject.contacts = IndirectCollectionsFactory.createIndirectList(); |
| this.orderObject.lines = IndirectCollectionsFactory.createIndirectList(); |
| this.orderObject.setTotal(56789);
|
| this.orderObject.customerName = "henry";
|
| //Using a unit of work here becuase this test is used in the clientSession Tests
|
| UnitOfWork uow = getSession().acquireUnitOfWork();
|
| uow.registerObject(this.orderObject);
|
| uow.commit();
|
| }
|
|
|
| public void reset() {
|
| if (getAbstractSession().isInTransaction()) {
|
| getAbstractSession().rollbackTransaction();
|
| getSession().getIdentityMapAccessor().initializeIdentityMaps();
|
| }
|
| }
|
|
|
| /**
|
| * This test creates an object and registers it with a unit of work. It then serializes that
|
| * object and deserializes it. Adds an object onto the origional then performs serialization
|
| * sequence again. Then deepMergeClone is attempted and the results are compared to verify that
|
| * the merge worked.
|
| */
|
| public void test() {
|
| try {
|
| ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
|
| ObjectOutputStream stream = new ObjectOutputStream(byteStream);
|
|
|
| //create the phoneNumber object
|
| Order orderClone;
|
| Session session = getSession();
|
| org.eclipse.persistence.sessions.UnitOfWork uow = session.acquireUnitOfWork();
|
|
|
| this.orderObject = (Order)session.readObject(Order.class);
|
| //force instantiations of value holders before serialization
|
| ((Collection)this.orderObject.getLineContainer()).size();
|
|
|
| //serialize object by writing to a stream
|
| stream.writeObject(this.orderObject);
|
| stream.flush();
|
| byte[] arr = byteStream.toByteArray();
|
| ByteArrayInputStream inByteStream = new ByteArrayInputStream(arr);
|
| ObjectInputStream inObjStream = new ObjectInputStream(inByteStream);
|
| Order deserialOrder;
|
|
|
| //deserialize the object
|
| try {
|
| deserialOrder = (Order)inObjStream.readObject();
|
| } catch (ClassNotFoundException e) {
|
| throw new TestErrorException("Could not deserialize object " + e.toString());
|
| }
|
|
|
| //add a new manager, test 1-m's
|
| OrderLine newLine = new OrderLine();
|
| ((Collection)deserialOrder.getLineContainer()).clear();
|
| deserialOrder.addLine(newLine);
|
| newLine.order = deserialOrder;
|
|
|
| orderClone = (Order)uow.registerObject(this.orderObject);
|
|
|
| orderClone = (Order)uow.deepMergeClone(deserialOrder);
|
| uow.commit();
|
| } catch (IOException e) {
|
| throw new TestErrorException("Error running Test " + e.toString());
|
| } catch (NullPointerException exception) {
|
| throw new TestErrorException("Test Failed. Backup clone indirection was not triggered in mergeIntoObject.");
|
| }
|
| }
|
|
|
| /*
|
| * Checks to see that the names of the updated version and the origional are the same
|
| */
|
|
|
| public void verify() {
|
| }
|
| }
|