Apache
/
olingo-odata4
mirror of https://github.com/apache/olingo-odata4.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[OLINGO-365] revert previous commit

This commit is contained in:
fmartelli 2014-07-28 22:23:54 +02:00
parent a5e983c9b8
commit 8c68516dcb
4 changed files with 50 additions and 117 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
ext/client-proxy/src/main/java/org/apache/olingo/ext/proxy/commons/AbstractCollectionInvocationHandler.java
View File

@ -56,8 +56,6 @@ public abstract class AbstractCollectionInvocationHandler<T extends Serializable
protected Collection<String> referenceItems; protected Collection<String> referenceItems;
protected Collection<T> newest;
protected final URI baseURI; protected final URI baseURI;
protected CommonURIBuilder<?> uri; protected CommonURIBuilder<?> uri;
@ -82,7 +80,6 @@ public abstract class AbstractCollectionInvocationHandler<T extends Serializable
this.itemRef = itemRef; this.itemRef = itemRef;
this.items = items; this.items = items;
this.referenceItems = new ArrayList<String>(); this.referenceItems = new ArrayList<String>();
this.newest = new ArrayList<T>();
this.uri = uri; this.uri = uri;
this.baseURI = this.uri == null ? null : this.uri.build(); this.baseURI = this.uri == null ? null : this.uri.build();
} }
@ -182,7 +179,6 @@ public abstract class AbstractCollectionInvocationHandler<T extends Serializable
} }
} }
changed = true; changed = true;
newest.add(element);
return items.add(element); return items.add(element);
} }
@ -258,7 +254,6 @@ public abstract class AbstractCollectionInvocationHandler<T extends Serializable
@Override @Override
public boolean addAll(final Collection<? extends T> collection) { public boolean addAll(final Collection<? extends T> collection) {
changed = true; changed = true;
newest.addAll(collection);
return items.addAll(collection); return items.addAll(collection);
} }

133
ext/client-proxy/src/main/java/org/apache/olingo/ext/proxy/commons/AbstractPersistenceManager.java
View File

@ -174,13 +174,51 @@ abstract class AbstractPersistenceManager implements PersistenceManager {
: ODataLinkType.ENTITY_NAVIGATION; : ODataLinkType.ENTITY_NAVIGATION;
final Set<EntityInvocationHandler> toBeLinked = new HashSet<EntityInvocationHandler>(); final Set<EntityInvocationHandler> toBeLinked = new HashSet<EntityInvocationHandler>();
for (Object proxy : type == ODataLinkType.ENTITY_SET_NAVIGATION for (Object proxy : type == ODataLinkType.ENTITY_SET_NAVIGATION
? (Collection<?>) property.getValue() : Collections.singleton(property.getValue())) { ? (Collection<?>) property.getValue() : Collections.singleton(property.getValue())) {
final EntityInvocationHandler target = (EntityInvocationHandler) Proxy.getInvocationHandler(proxy); final EntityInvocationHandler target = (EntityInvocationHandler) Proxy.getInvocationHandler(proxy);
toBeLinked.addAll(processLinkChanges( final AttachedEntityStatus status;
handler, target, property.getKey(), type, pos, items, delayedUpdates, changeset)); if (!service.getContext().entityContext().isAttached(target)) {
status = resolveNavigationLink(property.getKey(), target);
} else {
status = service.getContext().entityContext().getStatus(target);
}
LOG.debug("Found link to '{}({})'", target, status);
final URI editLink = target.getEntity().getEditLink();
if ((status == AttachedEntityStatus.ATTACHED || status == AttachedEntityStatus.LINKED) && !target.isChanged()) {
LOG.debug("Add link to '{}'", target);
entity.addLink(buildNavigationLink(
property.getKey().name(),
URIUtils.getURI(service.getClient().getServiceRoot(), editLink.toASCIIString()), type));
} else {
if (!items.contains(target)) {
pos = processEntityContext(target, pos, items, delayedUpdates, changeset);
pos++;
}
final Integer targetPos = items.get(target);
if (targetPos == null) {
// schedule update for the current object
LOG.debug("Schedule '{}' from '{}' to '{}'", type.name(), handler, target);
toBeLinked.add(target);
} else if (status == AttachedEntityStatus.CHANGED) {
LOG.debug("Changed: '{}' from '{}' to (${}) '{}'", type.name(), handler, targetPos, target);
entity.addLink(buildNavigationLink(
property.getKey().name(),
URIUtils.getURI(service.getClient().getServiceRoot(), editLink.toASCIIString()), type));
} else {
// create the link for the current object
LOG.debug("'{}' from '{}' to (${}) '{}'", type.name(), handler, targetPos, target);
entity.addLink(buildNavigationLink(property.getKey().name(), URI.create("$" + targetPos), type));
}
}
} }
if (!toBeLinked.isEmpty()) { if (!toBeLinked.isEmpty()) {
@ -198,41 +236,6 @@ abstract class AbstractPersistenceManager implements PersistenceManager {
} }
} }
// Required by linking provided on existent object. Say:
// container.getCustomers().getByKey(1).getOrders().add(order)
// Required by linking provided via entity reference ID. Say:
// container.getCustomers().getByKey(1).getOrders().addRef(order)
for (Map.Entry<NavigationProperty, Object> property : handler.linkCache.entrySet()) {
if (property.getValue() instanceof Proxy) {
final InvocationHandler target = Proxy.getInvocationHandler(property.getValue());
if (target instanceof EntityCollectionInvocationHandler
&& ((EntityCollectionInvocationHandler) target).isChanged()) {
final ODataLinkType type = Collection.class.isAssignableFrom(property.getValue().getClass())
? ODataLinkType.ENTITY_SET_NAVIGATION
: ODataLinkType.ENTITY_NAVIGATION;
final Set<EntityInvocationHandler> toBeLinked = new HashSet<EntityInvocationHandler>();
for (Object proxy : ((EntityCollectionInvocationHandler) target).newest) {
final EntityInvocationHandler targetEntity = (EntityInvocationHandler) Proxy.getInvocationHandler(proxy);
toBeLinked.addAll(processLinkChanges(
handler, targetEntity, property.getKey(), type, pos, items, delayedUpdates, changeset));
}
if (!toBeLinked.isEmpty()) {
delayedUpdates.add(new EntityLinkDesc(property.getKey().name(), handler, toBeLinked, type));
}
for (String ref : ((EntityCollectionInvocationHandler<?>) target).referenceItems) {
delayedUpdates.add(new EntityLinkDesc(property.getKey().name(), handler, ref));
}
}
}
}
if (entity instanceof ODataEntity) { if (entity instanceof ODataEntity) {
for (Map.Entry<String, AnnotatableInvocationHandler> entry : handler.getNavPropAnnotatableHandlers().entrySet()) { for (Map.Entry<String, AnnotatableInvocationHandler> entry : handler.getNavPropAnnotatableHandlers().entrySet()) {
@ -302,62 +305,6 @@ abstract class AbstractPersistenceManager implements PersistenceManager {
return pos; return pos;
} }
protected Set<EntityInvocationHandler> processLinkChanges(
final EntityInvocationHandler source,
final EntityInvocationHandler target,
final NavigationProperty property,
final ODataLinkType type,
int pos,
final TransactionItems items,
final List<EntityLinkDesc> delayedUpdates,
final PersistenceChanges changeset) {
final Set<EntityInvocationHandler> toBeLinked = new HashSet<EntityInvocationHandler>();
final AttachedEntityStatus status;
if (!service.getContext().entityContext().isAttached(target)) {
status = resolveNavigationLink(property, target);
} else {
status = service.getContext().entityContext().getStatus(target);
}
LOG.debug("Found link to '{}({})'", target, status);
final URI editLink = target.getEntity().getEditLink();
if ((status == AttachedEntityStatus.ATTACHED || status == AttachedEntityStatus.LINKED) && !target.isChanged()) {
LOG.debug("Add link to '{}'", target);
source.getEntity().addLink(buildNavigationLink(
property.name(),
URIUtils.getURI(service.getClient().getServiceRoot(), editLink.toASCIIString()), type));
} else {
if (!items.contains(target)) {
pos = processEntityContext(target, pos, items, delayedUpdates, changeset);
pos++;
}
final Integer targetPos = items.get(target);
if (targetPos == null) {
// schedule update for the current object
LOG.debug("Schedule '{}' from '{}' to '{}'", type.name(), source, target);
toBeLinked.add(target);
} else if (status == AttachedEntityStatus.CHANGED) {
LOG.debug("Changed: '{}' from '{}' to (${}) '{}'", type.name(), source, targetPos, target);
source.getEntity().addLink(buildNavigationLink(
property.name(),
URIUtils.getURI(service.getClient().getServiceRoot(), editLink.toASCIIString()), type));
} else {
// create the link for the current object
LOG.debug("'{}' from '{}' to (${}) '{}'", type.name(), source, targetPos, target);
source.getEntity().addLink(
buildNavigationLink(property.name(), URI.create("$" + targetPos), type));
}
}
return toBeLinked;
}
protected void processDelayedUpdates( protected void processDelayedUpdates(
final List<EntityLinkDesc> delayedUpdates, final List<EntityLinkDesc> delayedUpdates,
int pos, int pos,

13
ext/client-proxy/src/main/java/org/apache/olingo/ext/proxy/commons/EntityInvocationHandler.java
View File

@ -295,20 +295,9 @@ public class EntityInvocationHandler extends AbstractStructuredInvocationHandler
} }
public boolean isChanged(final boolean deep) { public boolean isChanged(final boolean deep) {
boolean linkedChanges = false;
for (Map.Entry<NavigationProperty, Object> link : linkCache.entrySet()) {
final InvocationHandler handler = Proxy.getInvocationHandler(link.getValue());
if (handler instanceof EntityInvocationHandler) {
linkedChanges = linkedChanges || ((EntityInvocationHandler) handler).isChanged();
} else if (handler instanceof EntityCollectionInvocationHandler) {
linkedChanges = linkedChanges || ((EntityCollectionInvocationHandler) handler).isChanged();
}
}
return this.linkChanges.hashCode() != this.linksTag return this.linkChanges.hashCode() != this.linksTag
|| this.propertyChanges.hashCode() != this.propertiesTag || this.propertyChanges.hashCode() != this.propertiesTag
|| (deep && (linkedChanges || (deep && (this.stream != null
|| this.stream != null
|| !this.streamedPropertyChanges.isEmpty())); || !this.streamedPropertyChanges.isEmpty()));
} }

16
fit/src/test/java/org/apache/olingo/fit/proxy/v4/APIBasicDesignTestITCase.java
View File

@ -116,13 +116,6 @@ public class APIBasicDesignTestITCase extends AbstractTestITCase {
container.flush(); container.flush();
} }
@Test
public void addViaReference2() {
final Order order = container.getOrders().getByKey(8).load();
container.getCustomers().getByKey(1).getOrders().addRef(order);
container.flush();
}
@Test @Test
public void readAndCheckForPrimitive() { public void readAndCheckForPrimitive() {
final Customer customer = getContainer().getCustomers().getByKey(1); final Customer customer = getContainer().getCustomers().getByKey(1);
@ -491,6 +484,15 @@ public class APIBasicDesignTestITCase extends AbstractTestITCase {
assertEquals("new name", container.getCompany().load().getName()); assertEquals("new name", container.getCompany().load().getName());
} }
@Test
public void createAndCallOperation() {
final Product product = container.newEntityInstance(Product.class);
product.setProductID(1001);
container.flush();
container.getProducts().getByKey(1000).operations().getProductDetails(1).execute();
}
@Test @Test
public void workingWithOperations() { public void workingWithOperations() {
// Primitive collections (available only skip and top) // Primitive collections (available only skip and top)