bugfix: dynamodb query error

jacqueskang · Feb 17, 2020 · cbb6662 · cbb6662
1 parent 2b87dc7
commit cbb6662
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/JKang.EventSourcing.Persistence.DynamoDB/DynamoDBEventStore.cs b/src/JKang.EventSourcing.Persistence.DynamoDB/DynamoDBEventStore.cs
@@ -68,8 +68,7 @@ public async Task<IAggregateEvent<TKey>[]> GetEventsAsync(
             int maxVersion,
             CancellationToken cancellationToken = default)
         {
-            var filter = new QueryFilter("aggregateVersion", QueryOperator.GreaterThanOrEqual, minVersion);
-            filter.AddCondition("aggregateVersion", QueryOperator.LessThanOrEqual, maxVersion);
+            var filter = new QueryFilter("aggregateVersion", QueryOperator.Between, minVersion, maxVersion);
             Search search = this._table.Query(aggregateId as dynamic, filter);
 
             var events = new List<IAggregateEvent<TKey>>();