Added support for querying indexed collections

ba-st · Jan 11, 2024 · 7e0ce12 · 7e0ce12
1 parent e2c5836
commit 7e0ce12
Show file tree

Hide file tree

Showing 2 changed files with 70 additions and 1 deletion.
diff --git a/source/Sagan-GemStone-Tests/GemStoneRepositoryProviderTest.class.st b/source/Sagan-GemStone-Tests/GemStoneRepositoryProviderTest.class.st
@@ -21,6 +21,67 @@ GemStoneRepositoryProviderTest >> setUpRepositoryWith: aConflictCheckingStrategy
 		         checkingConflictsAccordingTo: aConflictCheckingStrategy
 ]
 
+{ #category : 'tests' }
+GemStoneRepositoryProviderTest >> testFindApplyingWhenCollectionIsLarge [
+
+	4 timesRepeat: [
+		1000 timesRepeat: [
+			self extraterrestrials
+				store: self johnTravolta;
+				store: self johnLock;
+				store: self ellaTravolta
+			].
+
+		self extraterrestrials store: self silvesterStallone.
+
+		1000 timesRepeat: [
+			self extraterrestrials
+				store: self johnTravolta;
+				store: self johnLock;
+				store: self ellaTravolta
+			]
+		].
+	self
+		should: [
+			self
+				assert: ( self extraterrestrials findApplying: 'each.firstName = ''Silvester''' ) size
+				equals: 4
+			]
+		notTakeMoreThanMilliseconds: 1
+]
+
+{ #category : 'tests' }
+GemStoneRepositoryProviderTest >> testFindApplyingWhenCollectionIsLargeAndNotIndexed [
+
+	| notIndexed |
+
+	notIndexed := GemStoneRepositoryProvider new
+		              createRepositoryStoringObjectsOfType: Extraterrestrial
+		              checkingConflictsAccordingTo: DoNotCheckForConflictsStrategy new.
+
+	4 timesRepeat: [
+		1000 timesRepeat: [
+			notIndexed
+				store: self johnTravolta;
+				store: self johnLock;
+				store: self ellaTravolta
+			].
+
+		notIndexed store: self silvesterStallone.
+
+		1000 timesRepeat: [
+			notIndexed
+				store: self johnTravolta;
+				store: self johnLock;
+				store: self ellaTravolta
+			]
+		].
+	self
+		should: [
+		self assert: ( notIndexed findApplying: 'each.firstName = ''Silvester''' ) size equals: 4 ]
+		notTakeMoreThanMilliseconds: 17
+]
+
 { #category : 'tests' }
 GemStoneRepositoryProviderTest >> testSpaceshipQueryingForPositiveFirepower [
 

diff --git a/source/Sagan-GemStone/GemStoneRepository.class.st b/source/Sagan-GemStone/GemStoneRepository.class.st
@@ -62,6 +62,14 @@ GemStoneRepository >> findAllMatching: aCriteriaOrBlock sortedBy: aSortFunction
 	^ ( self findAllMatching: aCriteriaOrBlock ) sorted: aSortFunction
 ]
 
+{ #category : 'querying' }
+GemStoneRepository >> findApplying: aQueryString [
+
+	^ ( GsQuery fromString: aQueryString )
+		  on: contents;
+		  queryResult
+]
+
 { #category : 'configuring' }
 GemStoneRepository >> indexByEquality: aPath typed: aType [
 
@@ -84,7 +92,7 @@ GemStoneRepository >> indexByIdentity: aPath [
 GemStoneRepository >> initializeCheckingConflictsAccordingTo: aConflictCheckingStrategy [
 
 	conflictCheckingStrategy := aConflictCheckingStrategy.
-	contents := Set new
+	contents := RcIdentitySet new
 ]
 
 { #category : 'private - accessing' }