/***************************************************************************
* Copyright (c) 2004 - 2008 Eike Stepper, Germany.
* 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:
* Simon McDuff - initial API and implementation
* Eike Stepper - maintenance
**************************************************************************/
package org.eclipse.emf.cdo.tests;
import org.eclipse.emf.cdo.CDOAudit;
import org.eclipse.emf.cdo.CDOSession;
import org.eclipse.emf.cdo.CDOState;
import org.eclipse.emf.cdo.CDOTransaction;
import org.eclipse.emf.cdo.CDOView;
import org.eclipse.emf.cdo.eresource.CDOResource;
import org.eclipse.emf.cdo.tests.model1.Product1;
import org.eclipse.emf.cdo.tests.model1.VAT;
import org.eclipse.emf.cdo.util.CDOURIUtil;
import org.eclipse.emf.cdo.util.CDOUtil;
import org.eclipse.net4j.util.transaction.TransactionException;
import org.eclipse.emf.common.notify.Notification;
import org.eclipse.emf.common.notify.Notifier;
import org.eclipse.emf.common.notify.impl.AdapterImpl;
import org.eclipse.emf.common.util.URI;
import org.eclipse.emf.ecore.resource.Resource;
import org.eclipse.emf.ecore.resource.ResourceSet;
import org.eclipse.emf.ecore.resource.impl.ResourceSetImpl;
import java.util.ArrayList;
import java.util.List;
import junit.framework.Assert;
/**
* @author Eike Stepper
*/
public class ResourceTest extends AbstractCDOTest
{
public void testCreateResource_FromResourceSet() throws Exception
{
final URI uri = URI.createURI("cdo:/test1");
msg("Creating resourceSet");
ResourceSet resourceSet = new ResourceSetImpl();
msg("Opening session");
CDOSession session = openModel1Session();
msg("Opening transaction");
CDOTransaction transaction = session.openTransaction(resourceSet);
msg("Creating resource");
CDOResource resource = (CDOResource)resourceSet.createResource(uri);
assertActive(resource);
msg("Verifying resource");
assertNew(resource, transaction);
assertEquals(CDOURIUtil.createResourceURI(session, "test1"), resource.getURI());
assertEquals(transaction.getResourceSet(), resource.getResourceSet());
}
public void testCreateResource_FromTransaction() throws Exception
{
msg("Opening session");
CDOSession session = openModel1Session();
msg("Opening transaction");
CDOTransaction transaction = session.openTransaction();
// Test if Resource is well-formed after CDOResourceFactoryImpl.
// Adapter will be called right after and could be used!
transaction.getResourceSet().eAdapters().add(new TestAdapter());
msg("Creating resource");
CDOResource resource = transaction.createResource("/test1");
assertActive(resource);
CDOResource resourceCopy = transaction.getOrCreateResource("/test1");
assertEquals(resource, resourceCopy);
msg("Verifying resource");
assertNew(resource, transaction);
assertEquals(CDOURIUtil.createResourceURI(session, "test1"), resource.getURI());
assertEquals(transaction.getResourceSet(), resource.getResourceSet());
}
public void testRemoveResourceWithCloseView() throws Exception
{
{
msg("Opening session");
CDOSession session = openModel1Session();
msg("Opening transaction");
CDOTransaction transaction = session.openTransaction();
ResourceSet rset = transaction.getResourceSet();
msg("Creating resource");
CDOResource resource = transaction.createResource("/test1");
assertActive(resource);
transaction.commit();
Assert.assertEquals(1, rset.getResources().size());
Assert.assertEquals(1, CDOUtil.getViewSet(rset).getViews().length);
transaction.close();
Assert.assertEquals(0, CDOUtil.getViewSet(rset).getViews().length);
Assert.assertEquals(0, rset.getResources().size());
session.close();
}
{
CDOSession session = openModel1Session();
msg("Opening transaction");
CDOTransaction transaction = session.openTransaction();
msg("Getting resource");
CDOResource resource = (CDOResource)transaction.getResourceSet().getResource(
CDOURIUtil.createResourceURI(transaction, "/test1"), true);
assertNotNull(resource);
assertEquals(transaction.getResourceSet(), resource.getResourceSet());
assertEquals(1, transaction.getResourceSet().getResources().size());
assertEquals(CDOState.PROXY, resource.cdoState());
assertEquals(transaction, resource.cdoView());
assertNull(resource.cdoRevision());
}
}
public void testAttachManyResources() throws Exception
{
CDOSession session = openModel1Session();
CDOTransaction transaction = session.openTransaction();
CDOResource resource1 = transaction.createResource("/my/resource1");
CDOResource resource2 = transaction.createResource("/my/resource2");
CDOResource resource3 = transaction.createResource("/my/resource3");
List<Resource> tobeRemoved = new ArrayList<Resource>();
tobeRemoved.add(resource1);
tobeRemoved.add(resource3);
assertEquals(3, transaction.getResourceSet().getResources().size());
transaction.getResourceSet().getResources().removeAll(tobeRemoved);
assertEquals(1, transaction.getResourceSet().getResources().size());
assertEquals(null, transaction.getResourceSet().getResource(resource1.getURI(), false));
assertEquals(resource2, transaction.getResourceSet().getResource(resource2.getURI(), false));
assertEquals(null, transaction.getResourceSet().getResource(resource3.getURI(), false));
transaction.getResourceSet().getResources().addAll(tobeRemoved);
assertEquals(3, transaction.getResourceSet().getResources().size());
assertEquals(resource1, transaction.getResourceSet().getResource(resource1.getURI(), false));
assertEquals(resource2, transaction.getResourceSet().getResource(resource2.getURI(), false));
assertEquals(resource3, transaction.getResourceSet().getResource(resource3.getURI(), false));
transaction.commit();
session.close();
}
public void testDetachManyResources() throws Exception
{
CDOSession session = openModel1Session();
CDOTransaction transaction = session.openTransaction();
CDOResource resource1 = transaction.createResource("/my/resource1");
CDOResource resource2 = transaction.createResource("/my/resource2");
CDOResource resource3 = transaction.createResource("/my/resource3");
List<Resource> tobeRemoved = new ArrayList<Resource>();
tobeRemoved.add(resource1);
tobeRemoved.add(resource3);
assertEquals(3, transaction.getResourceSet().getResources().size());
transaction.getResourceSet().getResources().removeAll(tobeRemoved);
assertEquals(1, transaction.getResourceSet().getResources().size());
assertEquals(null, transaction.getResourceSet().getResource(resource1.getURI(), false));
assertEquals(resource2, transaction.getResourceSet().getResource(resource2.getURI(), false));
assertEquals(null, transaction.getResourceSet().getResource(resource3.getURI(), false));
transaction.commit();
session.close();
}
public void testDuplicatePath() throws Exception
{
CDOSession session = openModel1Session();
CDOTransaction transaction = session.openTransaction();
transaction.createResource("/my/resource");
transaction.commit();
transaction.createResource("/my/resource");
try
{
transaction.commit();
fail("TransactionException expected");
}
catch (TransactionException expected)
{
// Success
}
finally
{
session.close();
}
}
public void testDuplicatePathAfterDetach() throws Exception
{
CDOSession session = openModel1Session();
CDOTransaction transaction = session.openTransaction();
CDOResource resource = transaction.createResource("/my/resource");
transaction.commit();
resource.delete(null);
transaction.commit();
transaction.createResource("/my/resource");
transaction.commit();
session.close();
}
public void testChangePath() throws Exception
{
long commitTime1;
long commitTime2;
{
CDOSession session = openModel1Session();
CDOTransaction transaction = session.openTransaction();
CDOResource resource = transaction.createResource("/my/resource");
transaction.commit();
commitTime1 = transaction.getLastCommitTime();
resource.setPath("/renamed");
transaction.commit();
commitTime2 = transaction.getLastCommitTime();
session.close();
}
CDOSession session = openModel1Session();
CDOAudit audit1 = session.openAudit(commitTime1);
assertEquals(true, audit1.hasResource("/my/resource"));
assertEquals(false, audit1.hasResource("/renamed"));
CDOAudit audit2 = session.openAudit(commitTime2);
assertEquals(false, audit2.hasResource("/my/resource"));
assertEquals(true, audit2.hasResource("/renamed"));
session.close();
}
public void testChangeURI() throws Exception
{
long commitTime1;
long commitTime2;
{
CDOSession session = openModel1Session();
CDOTransaction transaction = session.openTransaction();
CDOResource resource = transaction.createResource("/my/resource");
transaction.commit();
commitTime1 = transaction.getLastCommitTime();
URI uri = URI.createURI("cdo://repo1/renamed");
assertEquals(CDOURIUtil.createResourceURI(session, "/renamed"), uri);
resource.setURI(uri);
transaction.commit();
commitTime2 = transaction.getLastCommitTime();
session.close();
}
CDOSession session = openModel1Session();
CDOAudit audit1 = session.openAudit(commitTime1);
assertEquals(true, audit1.hasResource("/my/resource"));
assertEquals(false, audit1.hasResource("/renamed"));
CDOAudit audit2 = session.openAudit(commitTime2);
assertEquals(false, audit2.hasResource("/my/resource"));
assertEquals(true, audit2.hasResource("/renamed"));
session.close();
}
/**
* http://bugs.eclipse.org/208689
*/
public void testQueryResources() throws Exception
{
{
CDOSession session = openModel1Session();
CDOTransaction transaction = session.openTransaction();
createResource(transaction, "/a/resource");
createResource(transaction, "/a/a/resource");
createResource(transaction, "/a/b/resource");
createResource(transaction, "/a/c/resource");
createResource(transaction, "/a/d/resource");
createResource(transaction, "/a/e/resource");
createResource(transaction, "/b/resource");
createResource(transaction, "/b/a/resource");
createResource(transaction, "/b/b/resource");
createResource(transaction, "/b/c/resource");
createResource(transaction, "/b/d/resource");
createResource(transaction, "/b/e/resource");
createResource(transaction, "/b/e/a/resource");
createResource(transaction, "/b/e/b/resource");
createResource(transaction, "/c/resource");
createResource(transaction, "/c/a/resource");
createResource(transaction, "/c/a/resource2");
createResource(transaction, "/c/a/resource3");
createResource(transaction, "/c/b/resource");
createResource(transaction, "/c/c/resource");
createResource(transaction, "/c/d/resource");
createResource(transaction, "/c/e/resource");
transaction.commit();
session.close();
}
CDOSession session = openModel1Session();
CDOView view = session.openView();
queryResources(view, "/a", 6);
queryResources(view, "/b", 8);
queryResources(view, "/c", 8);
queryResources(view, "/b/e", 3);
queryResources(view, "/c/a", 3);
session.close();
}
/**
* http://bugs.eclipse.org/208689
*/
public void testQueryModifiedResources() throws Exception
{
{
CDOSession session = openModel1Session();
CDOTransaction transaction = session.openTransaction();
createResource(transaction, "/a/resource");
createResource(transaction, "/a/a/resource");
createResource(transaction, "/a/b/resource");
createResource(transaction, "/a/c/resource");
createResource(transaction, "/a/d/resource");
createResource(transaction, "/a/e/resource");
createResource(transaction, "/b/resource");
createResource(transaction, "/b/a/resource");
createResource(transaction, "/b/b/resource");
createResource(transaction, "/b/c/resource");
createResource(transaction, "/b/d/resource");
createResource(transaction, "/b/e/resource");
createResource(transaction, "/b/e/a/resource");
createResource(transaction, "/b/e/b/resource");
createResource(transaction, "/c/resource");
createResource(transaction, "/c/a/resource");
createResource(transaction, "/c/a/resource2");
createResource(transaction, "/c/a/resource3");
createResource(transaction, "/c/b/resource");
createResource(transaction, "/c/c/resource");
createResource(transaction, "/c/d/resource");
createResource(transaction, "/c/e/resource");
transaction.commit();
modifyResource(transaction, "/a/resource");
modifyResource(transaction, "/a/a/resource");
modifyResource(transaction, "/a/b/resource");
modifyResource(transaction, "/a/c/resource");
modifyResource(transaction, "/a/d/resource");
modifyResource(transaction, "/a/e/resource");
modifyResource(transaction, "/b/resource");
modifyResource(transaction, "/b/a/resource");
modifyResource(transaction, "/b/b/resource");
modifyResource(transaction, "/b/c/resource");
modifyResource(transaction, "/b/d/resource");
modifyResource(transaction, "/b/e/resource");
modifyResource(transaction, "/b/e/a/resource");
modifyResource(transaction, "/b/e/b/resource");
modifyResource(transaction, "/c/resource");
modifyResource(transaction, "/c/a/resource");
modifyResource(transaction, "/c/a/resource2");
modifyResource(transaction, "/c/a/resource3");
modifyResource(transaction, "/c/b/resource");
modifyResource(transaction, "/c/c/resource");
modifyResource(transaction, "/c/d/resource");
modifyResource(transaction, "/c/e/resource");
transaction.commit();
session.close();
}
CDOSession session = openModel1Session();
CDOView view = session.openView();
queryResources(view, "/a", 6);
queryResources(view, "/b", 8);
queryResources(view, "/c", 8);
queryResources(view, "/b/e", 3);
queryResources(view, "/c/a", 3);
session.close();
}
private CDOResource createResource(CDOTransaction transaction, String path)
{
Product1 p = getModel1Factory().createProduct1();
p.setName("test-" + path);
p.setVat(VAT.VAT0);
CDOResource resource = transaction.createResource(path);
resource.getContents().add(p);
return resource;
}
private CDOResource modifyResource(CDOTransaction transaction, String path)
{
Product1 p = getModel1Factory().createProduct1();
p.setName("test-" + path + "-modified");
p.setVat(VAT.VAT0);
CDOResource resource = transaction.getResource(path);
resource.getContents().add(p);
return resource;
}
private void queryResources(CDOView view, String pathPrefix, int expected)
{
msg("Path prefix: " + pathPrefix);
List<CDOResource> resources = view.queryResources(pathPrefix);
for (CDOResource resource : resources)
{
msg("Result: " + resource.getPath());
}
assertEquals(expected, resources.size());
}
static class TestAdapter extends AdapterImpl
{
@Override
public void notifyChanged(Notification msg)
{
super.notifyChanged(msg);
if (msg.getNewValue() instanceof CDOResource)
{
((CDOResource)msg.getNewValue()).getPath();
}
}
@Override
public void setTarget(Notifier newTarget)
{
}
@Override
public boolean isAdapterForType(Object type)
{
return super.isAdapterForType(type);
}
};
}
