AtPlusExample

AtPlusExample.cs

private static void AtPlusExample()
{
    Console.WriteLine("========= AtPlus");

    // get the current count
    var result1 = _bucket.Query<dynamic>("SELECT COUNT(1) as airportCount FROM `travel-sample` WHERE type='airport'")
            .Rows.First();
    Console.WriteLine($"Initial count: {result1.airportCount}");

    // insert a new airport
    var doc = new Document<dynamic>
    {
        Id = "ScanConsistency::airport::" + _random.Next(10000),
        Content = new
        {
            type = "airport"
        }
    };
    var insertResult = _bucket.Insert(doc);

    // get the count again
    var state = MutationState.From(insertResult.Document);
    var request = new QueryRequest("SELECT COUNT(1) as airportCount FROM `travel-sample` WHERE type='airport'");
    var t = request.ConsistentWith(state);
    var result2 = _bucket.Query<dynamic>(t).Rows.First();
    Console.WriteLine($"Count after insert with AtPlus: {result2.airportCount}");
}