catch up with development
Signed-off-by: Ralf Mollik <ramollik@compex-commerce.com>
diff --git a/org.eclipse.osbp.jpa.services/src/org/eclipse/osbp/jpa/services/history/HistorizedReferenceQueryRedirector.java b/org.eclipse.osbp.jpa.services/src/org/eclipse/osbp/jpa/services/history/HistorizedReferenceQueryRedirector.java
new file mode 100644
index 0000000..90cabc9
--- /dev/null
+++ b/org.eclipse.osbp.jpa.services/src/org/eclipse/osbp/jpa/services/history/HistorizedReferenceQueryRedirector.java
@@ -0,0 +1,74 @@
+package org.eclipse.osbp.jpa.services.history;
+
+import org.eclipse.osbp.runtime.common.annotations.HistReference;
+import org.eclipse.osbp.runtime.common.util.BeanUtils;
+import org.eclipse.persistence.descriptors.ClassDescriptor;
+import org.eclipse.persistence.expressions.Expression;
+import org.eclipse.persistence.expressions.ExpressionBuilder;
+import org.eclipse.persistence.internal.identitymaps.CacheId;
+import org.eclipse.persistence.internal.sessions.AbstractRecord;
+import org.eclipse.persistence.internal.sessions.AbstractSession;
+import org.eclipse.persistence.internal.sessions.EmptyRecord;
+import org.eclipse.persistence.mappings.DatabaseMapping;
+import org.eclipse.persistence.queries.DatabaseQuery;
+import org.eclipse.persistence.queries.QueryRedirector;
+import org.eclipse.persistence.queries.ReadObjectQuery;
+import org.eclipse.persistence.sessions.Record;
+import org.eclipse.persistence.sessions.Session;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Manages references to historized and timedependent entities.
+ */
+@SuppressWarnings("serial")
+public class HistorizedReferenceQueryRedirector implements QueryRedirector {
+ protected static Logger logger = LoggerFactory.getLogger(HistorizedReferenceQueryRedirector.class);
+
+ @Override
+ public Object invokeQuery(DatabaseQuery query, Record arguments, Session session) {
+ if (query instanceof ReadObjectQuery) {
+ ReadObjectQuery readQuery = (ReadObjectQuery) query;
+ DatabaseMapping mapping = readQuery.getSourceMapping();
+ if (mapping != null) {
+ ClassDescriptor descriptor = mapping.getDescriptor();
+ String att = mapping.getAttributeName();
+ Class<?> targetEntity = descriptor.getJavaClass();
+ if (!BeanUtils.isAnnotationPresent(targetEntity, att, HistReference.class)) {
+ return getCurrentManaged(readQuery, (AbstractRecord) arguments, mapping.getReferenceDescriptor(),
+ (AbstractSession) session);
+ }
+ }
+ }
+ query.setDoNotRedirect(true);
+ return query.execute((AbstractSession) session, (AbstractRecord) arguments);
+
+ }
+
+ private Object getCurrentManaged(ReadObjectQuery readQuery, AbstractRecord arguments,
+ ClassDescriptor targetDescriptor, AbstractSession session) {
+
+ HistorizedObjectWrapper wrapper = new HistorizedObjectWrapper(targetDescriptor, null);
+ Object objId = null;
+ CacheId id = (CacheId) readQuery.getSelectionId();
+ if (id != null) {
+ Object[] pk = id.getPrimaryKey();
+ objId = pk[0];
+ } else {
+ ClassDescriptor sourceDescriptor = readQuery.getSourceMapping().getDescriptor();
+ String refAttName = readQuery.getSourceMapping().getAttributeAccessor().getAttributeName();
+ DatabaseMapping id_idMapping = sourceDescriptor.getMappingForAttributeName(refAttName);
+ objId = arguments.get(id_idMapping.getFields().get(0));
+ }
+
+ ReadObjectQuery rq = new ReadObjectQuery(targetDescriptor.getJavaClass());
+ rq.conformResultsInUnitOfWork();
+
+ ExpressionBuilder eb = rq.getExpressionBuilder();
+ Expression exp = eb.get(wrapper.getIdAttName()).get(wrapper.getId_IdAttName()).equal(objId)
+ .and(eb.get(wrapper.getCurrentHistAttName()).equal(true));
+ rq.setSelectionCriteria(exp);
+ rq.setDoNotRedirect(true);
+ return rq.execute(session, EmptyRecord.getEmptyRecord());
+ }
+}
