import org.simantics.db.common.procedure.wrapper.NoneToAsyncProcedure;
import org.simantics.db.common.procedure.wrapper.SyncToAsyncProcedure;
import org.simantics.db.exception.DatabaseException;
+import org.simantics.db.exception.NoSingleResultException;
import org.simantics.db.impl.ClusterI;
import org.simantics.db.impl.ClusterI.ClusterTypeEnum;
import org.simantics.db.impl.ForEachObjectContextProcedure;
import org.simantics.db.procore.cluster.ValueTableSmall;
import org.simantics.db.request.AsyncRead;
import org.simantics.db.service.DirectQuerySupport;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class DirectQuerySupportImpl implements DirectQuerySupport {
+ private static final Logger LOGGER = LoggerFactory.getLogger(DirectQuerySupportImpl.class);
+
final private SessionImplSocket session;
DirectQuerySupportImpl(SessionImplSocket session) {
int so = cluster.getSingleObject(subject, procedure, session.clusterTranslator);
if(so == 0) {
if(result == 0) {
- procedure.exception(graph, new DatabaseException("No objects " + subject + " " + procedure.predicateKey));
+ procedure.exception(graph, new NoSingleResultException("No objects " + subject + " " + procedure.predicateKey, result));
// graph.dec();
} else {
getValue4(graph, cluster, result, context, procedure);
if(result == 0) {
getValue4(graph, cluster, so, context, procedure);
} else {
- procedure.exception(graph, new DatabaseException("Multiple objects"));
+ procedure.exception(graph, new NoSingleResultException("Multiple objects for " + subject + " " + procedure.predicateKey, result));
// graph.dec();
}
}
} catch (DatabaseException e) {
- e.printStackTrace();
+ LOGGER.error("Could not compute related value for subject {} with predicate {}", subject, procedure.predicateKey);
}
}