快读《ASP.NET Core技术内幕与项目实战》EFCore2.5：集合查询原理揭秘（IQueryable和IEnumerable）

//LINQ返回IEnumerable
var nums = new int[] { 1, 2, 3, 4 };
var numsNew = nums.Where(n => n > 2);

//EFCore返回IQueryable
using var ctx = new MyDbContext();
var books= ctx.Book.Where(a => a.Id > 0);

//利用IQueryable延迟执行，拼接复杂查询

//定义一个复杂查询的方法，接受参数①关键词；②是否同时匹配书名和作者名；③是否按价格排序；④最高价格
void QueryBooks(string searchWords, bool searchAll, bool orderByPrice, double upperPrice)
{
    using var ctx = new MyDbContext();

    //查询低于最高价
    var books = ctx.Books.Where(b => b.Price <= upperPrice);

    //同时匹配书名和作者
    if(searchAll)
    {
        books = books.Where(b => b.Title.Contains(searchWords) || b.AuthorName.Contains(searchWords));
    }
    //只匹配书名
    else
    {
        books = books.Where(b =>b.Title.Contains(searchWords));
    }

    //按照价格排序
    if(orderByPrice)
    {
        books = books.OrderBy(b => b.Price);
    }

    //立即执行方法，遍历
    foreach(var item in books)
    {
        Console.WriteLine($"书名：{item.Title}，作者：{item.AuthorName}");
    }
}


//调用方法
QueryBooks("LINQ", true, true, 30);  //查询书名或作者名，按价格排序
QueryBooks("LINQ", false, false, 50); //只查询书名，不按价格排序

//获得一个IQueryable集合books，并三次复用它
var books = ctx.Books.Where(b => b.Price >=20);

//使用books集合，执行一次立即查询
Console.WriteLine(books.Count());

//再次使用books集合，执行第二次立即查询
Console.WriteLine(books.Max(b => b.Price));

//第三次立即查询
foreach (var item in books.Where(b => b.PubTime.Year > 2000))
{
    Console.WriteLine(item.Title);
}

//使用立即执行方法ToList，执行SQL查询（服务端评估），将结果存到服务器的内存中
var books = await ctx.Books.Take(100000).ToListAsync();

//使用服务器内存中的集合books，进行遍历查询，在服务器上执行（客户端评估）
foreach (var item in books)
{
    Console.WriteLine(item.Title);
}

//由于遍历条数比较多，需要一定时间
//如果在遍历过程中，我们关闭数据库服务器，程序仍然可以正常进行
//说明遍历前，已经将数据下载到客户端



//大多数情况下，我们应该复用IQueryable，但在方法返回IQueryable，或嵌套遍历不同的DbSet时，需要考虑特别注意

//出错情况1：方法返回IQueryable
//方法中返回IQueryable时，会销毁上下文
//正确应该返回：return ctx.Books.Where(b => b.Id>5).ToList();
IQueryable<Book> QueryBooks()
{
    using var ctx = MyDbContext();
    return ctx.Books.Where(b => b.Id>5);
}

foreach(var item in QueryBooks())
{
    Console.WriteLine(item.Title);
}

//出错情况2：嵌套遍历不同的DbSet
//嵌套循环，导致两个DataReader执行，大多数数据库不允许多个DataReader同时执行
var books = ctx.Books.Where(b => b.Id > 1);
foreach(var item1 in books)
{
    Console.WriteLine(item1.Title);
    foreach(var item2 in ctx.Authors)
        {
            Console.WriteLive(item2.Id);
        }
}

//定义一个分页查询方法，参数为获取第几页-pageIndex，每页显示几条-pageSize
void OutputPage(int pageIndex, int pageSize)
{
    using var ctx = new MyDbContext();

    //获取IQueryable集合books
    var books = ctx.Books(); 

    //复用books，计算集合总条数。LongCount方法和Count的功能一样
    long count = books.LongCount(); 

    //按每页显示条数pageSize，计算总页数
    //使用了Math的Ceiling方法，如有小数，取天花板值，最后转换类型为long
    long pageCount = (long)Math.Ceiling(count * 1.0 / pageSize);
    Console.WriteLine($"总页数：{pageCount}");

    //复用books，获取指定页码的数据，并遍历
    //使用了Skip和Take方法
    var pageIndexBooks = books.Skip((pageIndex - 1) * pageSize).Take(pageSize);
    foreach( var item in pageIndexBooks)
    {
        Console.WriteLine(item.Title)
    }
}


//调用方法
OutputPage(1,10); //第1页，每页显示10条
OutputPage(3,5); //第3页，每页显示5条