What's new: queries

samples/core/Miscellaneous/NewInEFCore7/GroupByEntityTypeSample.cs

@@ -0,0 +1,125 @@
+namespace NewInEfCore7;
+
+public static class GroupByEntityTypeSample
+{
+ public static Task GroupBy_entity_type_SqlServer()
+ {
+ PrintSampleName();
+ return QueryTest<BookContextSqlServer>();
+ }
+
+ public static Task GroupBy_entity_type_Sqlite()
+ {
+ PrintSampleName();
+ return QueryTest<BookContextSqlServer>();
+ }
+
+ public static Task GroupBy_entity_type_InMemory()
+ {
+ PrintSampleName();
+ return QueryTest<BookContextInMemory>();
+ }
+
+ private static async Task QueryTest<TContext>()
+ where TContext : BookContext, new()
+ {
+ await using (var context = new TContext())
+ {
+ await context.Database.EnsureDeletedAsync();
+ await context.Database.EnsureCreatedAsync();
+
+ var toast = new Author { Name = "Toast" };
+ var alice = new Author { Name = "Alice" };
+
+ await context.AddRangeAsync(
+ new Book { Author = alice, Price = 10 },
+ new Book { Author = alice, Price = 11 },
+ new Book { Author = toast, Price = 12 },
+ new Book { Author = toast, Price = 13 },
+ new Book { Author = toast, Price = 14 });
+
+ await context.SaveChangesAsync();
+ }
+
+ await using (var context = new TContext())
+ {
+ #region GroupByEntityType
+
+ var query = context.Books
+ .GroupBy(s => s.Author)
+ .Select(s => new { Author = s.Key, MaxPrice = s.Max(p => p.Price) });
+
+ #endregion
+
+ await foreach (var group in query.AsAsyncEnumerable())
+ {
+ Console.WriteLine($"Author: {group.Author.Name}; MaxPrice = {group.MaxPrice}");
+ }
+ }
+
+ await using (var context = new TContext())
+ {
+ #region GroupByEntityTypeReversed
+ var query = context.Authors
+ .Select(a => new { Author = a, MaxPrice = a.Books.Max(b => b.Price) });
+ #endregion
+
+ await foreach (var group in query.AsAsyncEnumerable())
+ {
+ Console.WriteLine($"Author: {group.Author.Name}; MaxPrice = {group.MaxPrice}");
+ }
+ }
+ }
+
+ private static void PrintSampleName([CallerMemberName] string? methodName = null)
+ {
+ Console.WriteLine($">>>> Sample: {methodName}");
+ Console.WriteLine();
+ }
+
+ public abstract class BookContext : DbContext
+ {
+ public DbSet<Book> Books => Set<Book>();
+ public DbSet<Author> Authors => Set<Author>();
+
+ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ => optionsBuilder
+ .LogTo(Console.WriteLine, LogLevel.Information)
+ .EnableSensitiveDataLogging();
+ }
+
+ public class BookContextSqlServer : BookContext
+ {
+ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ => base.OnConfiguring(
+ optionsBuilder.UseSqlServer(@"Server=(localdb)\mssqllocaldb;Database=Books"));
+ }
+
+ public class BookContextSqlite : BookContext
+ {
+ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ => base.OnConfiguring(
+ optionsBuilder.UseSqlite("Data Source = books.db"));
+ }
+
+ public class BookContextInMemory : BookContext
+ {
+ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ => base.OnConfiguring(
+ optionsBuilder.UseInMemoryDatabase(nameof(BookContextInMemory)));
+ }
+
+ public class Author
+ {
+ public int Id { get; set; }
+ public string Name { get; set; } = default!;
+ public ICollection<Book> Books { get; } = new List<Book>();
+ }
+
+ public class Book
+ {
+ public int Id { get; set; }
+ public Author Author { get; set; } = default!;
+ public int Price { get; set; }
+ }
+}

samples/core/Miscellaneous/NewInEFCore7/GroupByFinalOperatorSample.cs

@@ -0,0 +1,107 @@
+namespace NewInEfCore7;
+
+public static class GroupByFinalOperatorSample
+{
+ public static Task GroupBy_final_operator_SqlServer()
+ {
+ PrintSampleName();
+ return QueryTest<BookContextSqlServer>();
+ }
+
+ public static Task GroupBy_final_operator_Sqlite()
+ {
+ PrintSampleName();
+ return QueryTest<BookContextSqlServer>();
+ }
+
+ public static Task GroupBy_final_operator_InMemory()
+ {
+ PrintSampleName();
+ return QueryTest<BookContextInMemory>();
+ }
+
+ private static async Task QueryTest<TContext>()
+ where TContext : BookContext, new()
+ {
+ await using (var context = new TContext())
+ {
+ await context.Database.EnsureDeletedAsync();
+ await context.Database.EnsureCreatedAsync();
+
+ var toast = new Author { Name = "Toast" };
+ var alice = new Author { Name = "Alice" };
+
+ await context.AddRangeAsync(
+ new Book { Author = alice, Price = 10 },
+ new Book { Author = alice, Price = 10 },
+ new Book { Author = toast, Price = 12 },
+ new Book { Author = toast, Price = 12 },
+ new Book { Author = toast, Price = 14 });
+
+ await context.SaveChangesAsync();
+ }
+
+ await using (var context = new TContext())
+ {
+ #region GroupByFinalOperator
+ var query = context.Books.GroupBy(s => s.Price);
+ #endregion
+
+ await foreach (var group in query.AsAsyncEnumerable())
+ {
+ Console.WriteLine($"Price: {group.Key}; Count = {group.Count()}");
+ }
+ }
+ }
+
+ private static void PrintSampleName([CallerMemberName] string? methodName = null)
+ {
+ Console.WriteLine($">>>> Sample: {methodName}");
+ Console.WriteLine();
+ }
+
+ public abstract class BookContext : DbContext
+ {
+ public DbSet<Book> Books => Set<Book>();
+ public DbSet<Author> Authors => Set<Author>();
+
+ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ => optionsBuilder
+ .LogTo(Console.WriteLine, LogLevel.Information)
+ .EnableSensitiveDataLogging();
+ }
+
+ public class BookContextSqlServer : BookContext
+ {
+ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ => base.OnConfiguring(
+ optionsBuilder.UseSqlServer(@"Server=(localdb)\mssqllocaldb;Database=Books"));
+ }
+
+ public class BookContextSqlite : BookContext
+ {
+ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ => base.OnConfiguring(
+ optionsBuilder.UseSqlite("Data Source = books.db"));
+ }
+
+ public class BookContextInMemory : BookContext
+ {
+ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ => base.OnConfiguring(
+ optionsBuilder.UseInMemoryDatabase(nameof(BookContextInMemory)));
+ }
+
+ public class Author
+ {
+ public int Id { get; set; }
+ public string Name { get; set; } = default!;
+ }
+
+ public class Book
+ {
+ public int Id { get; set; }
+ public Author Author { get; set; } = default!;
+ public int? Price { get; set; }
+ }
+}

samples/core/Miscellaneous/NewInEFCore7/GroupJoinFinalOperatorSample.cs

@@ -0,0 +1,147 @@
+namespace NewInEfCore7;
+
+public static class GroupJoinFinalOperatorSample
+{
+ public static Task GroupJoin_final_operator_SqlServer()
+ {
+ PrintSampleName();
+ return QueryTest<GroupJoinContextSqlServer>();
+ }
+
+ public static Task GroupJoin_final_operator_Sqlite()
+ {
+ PrintSampleName();
+ return QueryTest<GroupJoinContextSqlServer>();
+ }
+
+ public static Task GroupJoin_final_operator_InMemory()
+ {
+ PrintSampleName();
+ return QueryTest<GroupJoinContextInMemory>();
+ }
+
+ private static async Task QueryTest<TContext>()
+ where TContext : GroupJoinContext, new()
+ {
+ await using (var context = new TContext())
+ {
+ await context.Database.EnsureDeletedAsync();
+ await context.Database.EnsureCreatedAsync();
+
+ var toast = new Customer { Name = "Toast" };
+ var alice = new Customer { Name = "Alice" };
+
+ await context.AddRangeAsync(
+ new Order { Customer = alice, Amount = 10 },
+ new Order { Customer = alice, Amount = 10 },
+ new Order { Customer = toast, Amount = 12 },
+ new Order { Customer = toast, Amount = 12 },
+ new Order { Customer = toast, Amount = 14 });
+
+ await context.SaveChangesAsync();
+ }
+
+ await using (var context = new TContext())
+ {
+ #region GroupJoinFinalOperator
+ var query = context.Customers.GroupJoin(
+ context.Orders, c => c.Id, o => o.CustomerId, (c, os) => new { Customer = c, Orders = os });
+ #endregion
+
+ await foreach (var group in query.AsAsyncEnumerable())
+ {
+ Console.WriteLine($"Customer: {group.Customer.Name}; Count = {group.Orders.Count()}");
+ }
+ }
+
+ await using (var context = new TContext())
+ {
+ var query = context.Customers
+ .GroupJoin(
+ context.Orders,
+ o => o.Id,
+ bt => bt.CustomerId,
+ (o, bt) => new { Customer = o, BotTasks = bt, });
+
+ await foreach (var group in query.AsAsyncEnumerable())
+ {
+ Console.WriteLine($"Customer: {group.Customer.Name}; Count = {group.BotTasks.Count()}");
+ }
+ }
+
+ await using (var context = new TContext())
+ {
+ var query =
+ from customer in context.Customers
+ join order in context.Orders on customer.Id equals order.CustomerId into orderDetails
+ select new CustomerWithNavigationProperties { Customer = customer, Orders = orderDetails.ToList() };
+
+ await foreach (var group in query.AsAsyncEnumerable())
+ {
+ Console.WriteLine($"Customer: {group.Customer.Name}; Count = {group.Orders.Count()}");
+ }
+ }
+ }
+
+ private static void PrintSampleName([CallerMemberName] string? methodName = null)
+ {
+ Console.WriteLine($">>>> Sample: {methodName}");
+ Console.WriteLine();
+ }
+
+ public abstract class GroupJoinContext : DbContext
+ {
+ public DbSet<Customer> Customers => Set<Customer>();
+ public DbSet<Order> Orders => Set<Order>();
+
+ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ => optionsBuilder
+ .LogTo(Console.WriteLine, LogLevel.Information)
+ .EnableSensitiveDataLogging();
+ }
+
+ public class GroupJoinContextSqlServer : GroupJoinContext
+ {
+ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ => base.OnConfiguring(
+ optionsBuilder.UseSqlServer(@"Server=(localdb)\mssqllocaldb;Database=Customers"));
+ }
+
+ public class GroupJoinContextSqlite : GroupJoinContext
+ {
+ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ => base.OnConfiguring(
+ optionsBuilder.UseSqlite("Data Source = customers.db"));
+ }
+
+ public class GroupJoinContextInMemory : GroupJoinContext
+ {
+ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+ => base.OnConfiguring(
+ optionsBuilder.UseInMemoryDatabase(nameof(GroupJoinContextInMemory)));
+ }
+
+ public class Customer
+ {
+ public int Id { get; set; }
+ public string Name { get; set; } = default!;
+ public List<Order> Orders { get; } = new();
+ }
+
+ public class Order
+ {
+ public int Id { get; set; }
+
+ public int? CustomerId { get; set; }
+ public Customer? Customer { get; set; }
+
+ [Precision(18, 2)]
+ public decimal Amount { get; set; }
+ }
+
+ public class CustomerWithNavigationProperties
+ {
+ public Customer Customer { get; set; } = null!;
+ public List<Order> Orders { get; set; } = null!;
+ }
+}