Merge pull request #256 from tyronegroves/counters_upsert

Changed Counters FindAndModify to upsert so that the collection is created on the first checkpoint
NEventStore · Sep 22, 2013 · fde08c6 · fde08c6
2 parents b36253e + 06a1639
commit fde08c6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/NEventStore.Persistence.MongoDB/MongoPersistenceEngine.cs b/src/NEventStore.Persistence.MongoDB/MongoPersistenceEngine.cs
@@ -49,9 +49,9 @@ public MongoPersistenceEngine(MongoDatabase store, IDocumentSerializer serialize
 
             _getNextCheckpointNumber = () => TryMongo(() =>
             {
-                IMongoQuery query = Query.And(Query.EQ("_id", "CheckpointNumber"));
+                IMongoQuery query = Query.EQ("_id", "CheckpointNumber");
                 IMongoUpdate update = Update.Inc("seq", 1);
-                FindAndModifyResult result = Counters.FindAndModify(query, null, update, true);
+                FindAndModifyResult result = Counters.FindAndModify(query, null, update, true, true);
                 return result.ModifiedDocument["seq"].ToInt32();
             });
         }