feat: handle multivalued in search by example in CB ORM #2297

JanssenProject · Sep 2, 2022 · 35bb8c4 · 35bb8c4
1 parent f770878
commit 35bb8c4
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 8 deletions.
diff --git a/jans-orm/core/src/main/java/io/jans/orm/impl/BaseEntryManager.java b/jans-orm/core/src/main/java/io/jans/orm/impl/BaseEntryManager.java
@@ -60,6 +60,7 @@
 import io.jans.orm.reflect.property.Setter;
 import io.jans.orm.reflect.util.ReflectHelper;
 import io.jans.orm.search.filter.Filter;
+import io.jans.orm.search.filter.FilterProcessor;
 import io.jans.orm.util.ArrayHelper;
 import io.jans.orm.util.StringHelper;
 
@@ -108,6 +109,8 @@ public abstract class BaseEntryManager<O extends PersistenceOperationService> im
 	protected O operationService = null;
 	protected PersistenceExtension persistenceExtension = null;
 
+	protected FilterProcessor filterProcessor = new FilterProcessor();
+
 	@Override
 	public void persist(Object entry) {
 		if (entry == null) {
@@ -2234,6 +2237,10 @@ protected <T> Filter createFilterByEntry(Object entry, Class<T> entryClass, List
 		return addObjectClassFilter(attributesFilter, objectClasses);
 	}
 
+	protected Filter excludeObjectClassFilters(Filter genericFilter) {
+		return filterProcessor.excludeFilter(genericFilter, FilterProcessor.OBJECT_CLASS_EQUALITY_FILTER, FilterProcessor.OBJECT_CLASS_PRESENCE_FILTER);
+	}
+
 	protected Filter[] createAttributesFilter(List<AttributeData> attributes) {
 		if ((attributes == null) || (attributes.size() == 0)) {
 			return null;
@@ -2245,8 +2252,8 @@ protected Filter[] createAttributesFilter(List<AttributeData> attributes) {
 			String attributeName = attribute.getName();
 			for (Object value : attribute.getValues()) {
 				Filter filter = Filter.createEqualityFilter(attributeName, value);
-				if ((attribute.getMultiValued() != null) && attribute.getMultiValued()) {
-					filter.multiValued();
+				if (attribute.getMultiValued() != null) {
+					filter.multiValued(attribute.getMultiValued());
 				}
 
 				results.add(filter);

diff --git a/jans-orm/couchbase/src/main/java/io/jans/orm/couchbase/impl/CouchbaseEntryManager.java b/jans-orm/couchbase/src/main/java/io/jans/orm/couchbase/impl/CouchbaseEntryManager.java
@@ -838,6 +838,9 @@ protected Filter addObjectClassFilter(Filter filter, String[] objectClasses) {
 			return filter;
 		}
 
+		// Make sure that there is only one objectClass in filter
+		filter = excludeObjectClassFilters(filter);
+
 		// In Couchbase implementation we need to use first one as entry type
 		Filter searchFilter = Filter.createEqualityFilter(OBJECT_CLASS, objectClasses[0]);
 		if (filter != null) {

diff --git a/jans-orm/sql/src/main/java/io/jans/orm/sql/impl/SqlEntryManager.java b/jans-orm/sql/src/main/java/io/jans/orm/sql/impl/SqlEntryManager.java
@@ -75,7 +75,6 @@ public class SqlEntryManager extends BaseEntryManager<SqlOperationService> imple
     private Logger log;
 
     private final SqlFilterConverter filterConverter;
-	private FilterProcessor filterProcessor;
 
 	private static final GenericKeyConverter KEY_CONVERTER = new GenericKeyConverter(false);
 
@@ -84,7 +83,6 @@ public class SqlEntryManager extends BaseEntryManager<SqlOperationService> imple
     protected SqlEntryManager(SqlOperationService operationService) {
         this.operationService = operationService;
         this.filterConverter = new SqlFilterConverter(operationService);
-        this.filterProcessor = new FilterProcessor();
         subscribers = new LinkedList<DeleteNotifier>();
     }
 
@@ -800,10 +798,6 @@ private ConvertedExpression toSqlFilterWithEmptyAlias(Filter genericFilter, Map<
         return filterConverter.convertToSqlFilter(excludeObjectClassFilters(genericFilter), propertiesAnnotationsMap, processor, true);
     }
 
-	private Filter excludeObjectClassFilters(Filter genericFilter) {
-		return filterProcessor.excludeFilter(genericFilter, FilterProcessor.OBJECT_CLASS_EQUALITY_FILTER, FilterProcessor.OBJECT_CLASS_PRESENCE_FILTER);
-	}
-
     private ParsedKey toSQLKey(String dn) {
         return KEY_CONVERTER.convertToKey(dn);
     }