Code Examples

// Find offices that have descendants with Budget > 100000 (decimal test!)
var sw = Stopwatch.StartNew();
var offices = await redb.TreeQuery<DepartmentProps>()
    .Where(d => d.Code.StartsWith("OFF-"))
    .WhereHasDescendant<DepartmentProps>(desc => desc.Budget > 100000m)
    .ToListAsync();
sw.Stop();

var codes = offices.Take(5).Select(o => o.Props.Code).ToArray();

// Find root
var roots = await redb.TreeQuery<DepartmentProps>()
    .Where(d => d.Code == "CORP")
    .Take(1)
    .ToListAsync();

if (roots.Count == 0)
    return Fail("E112", "Tree - GetStats", ExampleTier.Free, 0, "No tree. Run E088 first.");

var root = (TreeRedbObject<DepartmentProps>)roots[0];

// Load tree and build collection
var sw = Stopwatch.StartNew();
var tree = await redb.LoadTreeAsync<DepartmentProps>(root, maxDepth: 5);

// Build TreeCollection for stats
var collection = new TreeCollection<DepartmentProps>();
AddToCollection(collection, tree);

var stats = collection.GetStats();
sw.Stop();

var sw = Stopwatch.StartNew();

// Load root department
var root = await redb.TreeQuery<DepartmentProps>()
    .WhereRoots()
    .Take(1)
    .ToListAsync();

if (root.Count == 0)
{
    sw.Stop();
    return Fail("E113", "Tree Query - ToFlatListAsync", ExampleTier.Free, sw.ElapsedMilliseconds,
        "No tree found. Run E089 first.");
}

// Load tree as flat list (no Parent/Children links)
var query = redb.TreeQuery<DepartmentProps>(root[0].Id, maxDepth: 3)
    .Where(d => d.IsActive);

// Uncomment to see generated SQL:
//var sql = await query.ToSqlStringAsync();
//Console.WriteLine(sql);

var flatList = await query.ToFlatListAsync();

sw.Stop();

var sample = flatList.FirstOrDefault()?.Props.Name ?? "N/A";

var sw = Stopwatch.StartNew();

// Check if list already exists and delete it (with FK cleanup)
var existing = await redb.ListProvider.GetListByNameAsync("ExampleStatuses");
if (existing != null)
{
    // First delete all _values referencing list items (FK constraint)
    var items = await redb.ListProvider.GetListItemsAsync(existing.Id);
    var itemIds = items.Select(i => i.Id).ToList();
    if (itemIds.Count > 0)
    {
        await redb.Context.Bulk.BulkDeleteValuesByListItemIdsAsync(itemIds);
    }
    await redb.ListProvider.DeleteListAsync(existing.Id);
}

// Create a new list (dictionary)
var statusList = RedbList.Create("ExampleStatuses", "Example Statuses");

// Uncomment to see generated SQL:
// (Lists use direct ADO.NET, no ORM query)

var savedList = await redb.ListProvider.SaveListAsync(statusList);

sw.Stop();

var sw = Stopwatch.StartNew();

// Get existing list (created in E114)
var list = await redb.ListProvider.GetListByNameAsync("ExampleStatuses");
if (list == null)
{
    sw.Stop();
    return Fail("E115", "List - Add Items", ExampleTier.Free, sw.ElapsedMilliseconds,
        "List 'ExampleStatuses' not found. Run E114 first.");
}

// Prepare values and aliases
var values = new List<string> { "Active", "Inactive", "Pending", "Blocked" };
var aliases = new List<string> { "Active status", "Inactive status", "Pending review", "Blocked access" };

// Uncomment to see generated SQL:
// (Lists use direct ADO.NET, no ORM query)

// Batch add items
var addedItems = await redb.ListProvider.AddItemsAsync(list, values, aliases);

sw.Stop();

var itemsList = string.Join(", ", addedItems.Select(i => i.Value));

var sw = Stopwatch.StartNew();

// Get list by name
var list = await redb.ListProvider.GetListByNameAsync("ExampleStatuses");
if (list == null)
{
    sw.Stop();
    return Fail("E116", "List - Get Items", ExampleTier.Free, sw.ElapsedMilliseconds,
        "List 'ExampleStatuses' not found. Run E114 first.");
}

// Uncomment to see generated SQL:
// (Lists use direct ADO.NET, no ORM query)

// Get all items from the list
var items = await redb.ListProvider.GetListItemsAsync(list.Id);

sw.Stop();

var itemsPreview = string.Join(", ", items.Take(3).Select(i => $"{i.Value}"));
if (items.Count > 3) itemsPreview += "...";

var sw = Stopwatch.StartNew();

// Get existing list
var list = await redb.ListProvider.GetListByNameAsync("ExampleStatuses");
if (list == null)
{
    sw.Stop();
    return Fail("E117", "ListItem - With Object", ExampleTier.Free, sw.ElapsedMilliseconds,
        "List 'ExampleStatuses' not found. Run E114 first.");
}

// Sync City scheme and create a city object
await redb.SyncSchemeAsync<CityProps>();
var cityObj = new RedbObject<CityProps>
{
    name = "Moscow",
    Props = new CityProps
    {
        Name = "Moscow",
        Population = 12_655_000,
        Region = "Central Federal District",
        IsCapital = true,
        Coordinates = [55.7558, 37.6173]
    }
};
var cityId = await redb.SaveAsync(cityObj);

// Create a new list item with object reference
var item = new RedbListItem(list, "Capital", "Capital city status", cityObj);

// Uncomment to see generated SQL:
// (Lists use direct ADO.NET, no ORM query)

var savedItem = await redb.ListProvider.SaveListItemAsync(item);

sw.Stop();

var sw = Stopwatch.StartNew();

// Get existing list
var list = await redb.ListProvider.GetListByNameAsync("ExampleStatuses");
if (list == null)
{
    sw.Stop();
    return Fail("E118", "Props - ListItem Field", ExampleTier.Free, sw.ElapsedMilliseconds,
        "List 'ExampleStatuses' not found. Run E114 first.");
}

// Get list items
var items = await redb.ListProvider.GetListItemsAsync(list.Id);
var activeStatus = items.FirstOrDefault(i => i.Value == "Active");
if (activeStatus == null)
{
    sw.Stop();
    return Fail("E118", "Props - ListItem Field", ExampleTier.Free, sw.ElapsedMilliseconds,
        "Item 'Active' not found. Run E115 first.");
}

// Sync Person scheme
await redb.SyncSchemeAsync<PersonProps>();

// Create person with Status field (ListItem)
var person = new RedbObject<PersonProps>
{
    name = "John Doe",
    Props = new PersonProps
    {
        Name = "John Doe",
        Age = 30,
        Email = "john@example.com",
        Status = activeStatus  // Single ListItem field
    }
};

// Uncomment to see generated SQL:
// (Save uses COPY protocol for Pro)

var personId = await redb.SaveAsync(person);

// Load back to verify
redb.PropsCache.Clear();
var loaded = await redb.LoadAsync<PersonProps>(personId);

sw.Stop();

var statusValue = loaded?.Props?.Status?.Value ?? "N/A";

var sw = Stopwatch.StartNew();

// Get existing list
var list = await redb.ListProvider.GetListByNameAsync("ExampleStatuses");
if (list == null)
{
    sw.Stop();
    return Fail("E119", "Props - List<ListItem>", ExampleTier.Free, sw.ElapsedMilliseconds,
        "List 'ExampleStatuses' not found. Run E114 first.");
}

// Get list items
var items = await redb.ListProvider.GetListItemsAsync(list.Id);
if (items.Count < 2)
{
    sw.Stop();
    return Fail("E119", "Props - List<ListItem>", ExampleTier.Free, sw.ElapsedMilliseconds,
        "Need at least 2 items. Run E115 first.");
}

// Sync Person scheme
await redb.SyncSchemeAsync<PersonProps>();

// Create person with Roles field (List<ListItem>)
var person = new RedbObject<PersonProps>
{
    name = "Jane Smith",
    Props = new PersonProps
    {
        Name = "Jane Smith",
        Age = 28,
        Email = "jane@example.com",
        Roles = items.Take(3).ToList()  // Multiple ListItem references
    }
};

// Uncomment to see generated SQL:
// (Save uses COPY protocol for Pro)

var personId = await redb.SaveAsync(person);

// Load back to verify
redb.PropsCache.Clear();
var loaded = await redb.LoadAsync<PersonProps>(personId);

sw.Stop();

var rolesCount = loaded?.Props?.Roles?.Count ?? 0;
var rolesList = loaded?.Props?.Roles != null 
    ? string.Join(", ", loaded.Props.Roles.Select(r => r.Value))
    : "N/A";

var sw = Stopwatch.StartNew();

// Query persons where Status.Value == "Active"
var query = redb.Query<PersonProps>()
    .Where(p => p.Status!.Value == "Active")
    .Take(100);

// Uncomment to see generated SQL:
// var sql = await query.ToSqlStringAsync();
// Console.WriteLine(sql);

var results = await query.ToListAsync();

sw.Stop();

if (results.Count == 0)
{
    return Ok("E120", "ListItem - Where by Value", ExampleTier.Free, sw.ElapsedMilliseconds, 0,
        ["No persons with Status='Active' found", "Run E118 first to create test data"]);
}

var firstName = results.FirstOrDefault()?.Props?.Name ?? "N/A";