/******************************************************************************* * Copyright (c) 2007, 2010 Association for Decentralized Information Management * in Industry THTH ry. * All rights reserved. This program and the accompanying materials * are made available under the terms of the Eclipse Public License v1.0 * which accompanies this distribution, and is available at * http://www.eclipse.org/legal/epl-v10.html * * Contributors: * VTT Technical Research Centre of Finland - initial API and implementation *******************************************************************************/ package org.simantics.db.tests.api.support.undoRedoSupport; import org.junit.Test; import org.simantics.db.ReadGraph; import org.simantics.db.Resource; import org.simantics.db.Session; import org.simantics.db.WriteGraph; import org.simantics.db.common.request.ReadRequest; import org.simantics.db.common.request.WriteRequest; import org.simantics.db.exception.DatabaseException; import org.simantics.db.service.UndoRedoSupport; import org.simantics.db.testing.base.ExistingDatabaseTest; /** * Tests case where combined operation belongs to two contexts. */ public class UndoTest14 extends ExistingDatabaseTest { @Test public void testUndo14() throws DatabaseException { Session session = getSession(); final UndoRedoSupport support = session.getService(UndoRedoSupport.class); final Resource[] r = new Resource[2]; try { session.syncRequest(new WriteRequest() { @Override public void perform(WriteGraph g) throws DatabaseException { g.markUndoPoint(); r[0] = g.newResource(); g.claim(r[0], r[0], r[0]); } }); } catch (Throwable e) { fail("Write transaction threw an unknown exception " + e); } session.syncRequest(new WriteRequest() { @Override public void perform(WriteGraph g) throws DatabaseException { g.markUndoPoint(); r[1] = g.newResource(); g.claim(r[1], r[1], r[1]); } }); session.syncRequest(new ReadRequest() { @Override public void run(ReadGraph g) throws DatabaseException { if (!g.hasStatement(r[0], r[0], r[0])) fail("Claim did not work as expected."); if (!g.hasStatement(r[1], r[1], r[1])) fail("Claim did not work as expected."); } }); support.undo(session, 1); session.syncRequest(new ReadRequest() { @Override public void run(ReadGraph g) throws DatabaseException { if (!g.hasStatement(r[0], r[0], r[0])) fail("Undo did not work as expected."); if (g.hasStatement(r[1], r[1], r[1])) fail("Undo did not work as expected."); } }); } }