X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.modeling%2Fsrc%2Forg%2Fsimantics%2Fmodeling%2Fsubscription%2FFindSubscriptionItem.java;h=5113554f925b360c97a14fb4f9d737fb9385b2c2;hb=06ee0c4c71cd9e372969da1570e7fcac2c4397a5;hp=5bca0d820a9d9a4270fbfb63841db20b688ef291;hpb=969bd23cab98a79ca9101af33334000879fb60c5;p=simantics%2Fplatform.git diff --git a/bundles/org.simantics.modeling/src/org/simantics/modeling/subscription/FindSubscriptionItem.java b/bundles/org.simantics.modeling/src/org/simantics/modeling/subscription/FindSubscriptionItem.java index 5bca0d820..5113554f9 100644 --- a/bundles/org.simantics.modeling/src/org/simantics/modeling/subscription/FindSubscriptionItem.java +++ b/bundles/org.simantics.modeling/src/org/simantics/modeling/subscription/FindSubscriptionItem.java @@ -1,74 +1,74 @@ -/******************************************************************************* - * Copyright (c) 2007, 2011 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.modeling.subscription; - -import org.simantics.databoard.Databoard; -import org.simantics.databoard.binding.Binding; -import org.simantics.db.ReadGraph; -import org.simantics.db.Resource; -import org.simantics.db.common.request.UniqueRead; -import org.simantics.db.exception.DatabaseException; -import org.simantics.db.layer0.variable.RVI; -import org.simantics.layer0.Layer0; -import org.simantics.modeling.ModelingResources; - -/** - * This query finds subscription items by variable reference - * - * @author toni.kalajainen - */ -public class FindSubscriptionItem extends UniqueRead { - - Resource subscription; - RVI rvi; - - public FindSubscriptionItem(Resource subscription, RVI rvi) { - super(); - this.subscription = subscription; - this.rvi = rvi; - } - - @Override - public Resource perform(ReadGraph graph) throws DatabaseException { - Layer0 L0 = Layer0.getInstance(graph); - ModelingResources MOD = ModelingResources.getInstance(graph); - - Binding rviBinding = graph.getService(Databoard.class).getBindingUnchecked( RVI.class ); - for (Resource r : graph.getObjects(subscription, L0.ConsistsOf)) - { - if ( !graph.isInstanceOf(r, MOD.Subscription_Item) ) continue; - - RVI _rvi = (RVI) graph.getPossibleRelatedValue(r, MOD.Subscription_Item_VariableId, rviBinding); - if (_rvi.equals(rvi)) return r; - } - - return null; - } - - @Override - public int hashCode() { - return rvi.hashCode() + subscription.hashCode(); - } - - @Override - public boolean equals(Object object) { - if (this == object) return true; - if (object == null) return false; - if (getClass() != object.getClass()) return false; - FindSubscriptionItem r = (FindSubscriptionItem) object; - - return subscription.equals(r.subscription) && rvi.equals(r.rvi); - } - - - -} +/******************************************************************************* + * Copyright (c) 2007, 2011 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.modeling.subscription; + +import org.simantics.databoard.Databoard; +import org.simantics.databoard.binding.Binding; +import org.simantics.db.ReadGraph; +import org.simantics.db.Resource; +import org.simantics.db.common.request.UniqueRead; +import org.simantics.db.exception.DatabaseException; +import org.simantics.db.layer0.variable.RVI; +import org.simantics.layer0.Layer0; +import org.simantics.modeling.ModelingResources; + +/** + * This query finds subscription items by variable reference + * + * @author toni.kalajainen + */ +public class FindSubscriptionItem extends UniqueRead { + + Resource subscription; + RVI rvi; + + public FindSubscriptionItem(Resource subscription, RVI rvi) { + super(); + this.subscription = subscription; + this.rvi = rvi; + } + + @Override + public Resource perform(ReadGraph graph) throws DatabaseException { + Layer0 L0 = Layer0.getInstance(graph); + ModelingResources MOD = ModelingResources.getInstance(graph); + + Binding rviBinding = graph.getService(Databoard.class).getBindingUnchecked( RVI.class ); + for (Resource r : graph.getObjects(subscription, L0.ConsistsOf)) + { + if ( !graph.isInstanceOf(r, MOD.Subscription_Item) ) continue; + + RVI _rvi = (RVI) graph.getPossibleRelatedValue(r, MOD.Subscription_Item_VariableId, rviBinding); + if (_rvi.equals(rvi)) return r; + } + + return null; + } + + @Override + public int hashCode() { + return rvi.hashCode() + subscription.hashCode(); + } + + @Override + public boolean equals(Object object) { + if (this == object) return true; + if (object == null) return false; + if (getClass() != object.getClass()) return false; + FindSubscriptionItem r = (FindSubscriptionItem) object; + + return subscription.equals(r.subscription) && rvi.equals(r.rvi); + } + + + +}