|
1 | 1 | using System; |
| 2 | +using System.Collections; |
2 | 3 | using System.Collections.Generic; |
3 | 4 | using System.Linq; |
4 | 5 | using System.Linq.Expressions; |
| 6 | +using System.Threading.Tasks; |
5 | 7 | using Microsoft.VisualStudio.TestTools.UnitTesting; |
6 | 8 |
|
7 | 9 | #if EF_CORE |
| 10 | +using Microsoft.EntityFrameworkCore; |
| 11 | + |
8 | 12 | namespace EntityFrameworkCore.CommonTools.Tests |
9 | 13 | #elif EF_6 |
10 | 14 | using System.Data.Entity; |
@@ -238,5 +242,101 @@ public void ShouldExpandNestedExtensions() |
238 | 242 |
|
239 | 243 | Assert.IsNull(query.FirstOrDefault()); |
240 | 244 | } |
| 245 | + |
| 246 | + [TestMethod] |
| 247 | + public void ShouldWorkWithInclude() |
| 248 | + { |
| 249 | + using (var context = CreateSqliteDbContext()) |
| 250 | + { |
| 251 | + var user = new User(); |
| 252 | + context.Users.Add(user); |
| 253 | + |
| 254 | + var post = new Post { Title = "first", Author = user }; |
| 255 | + context.Posts.Add(post); |
| 256 | + |
| 257 | + context.SaveChanges(); |
| 258 | + |
| 259 | + var query = context.Users.AsExpandable() |
| 260 | + .SelectMany(u => u.Posts.FilterIsActive()) |
| 261 | + .Include(p => p.Author); |
| 262 | + |
| 263 | + var expected = context.Users.AsExpandable() |
| 264 | + .SelectMany(u => u.Posts.Where(p => !p.IsDeleted)) |
| 265 | + .Include(p => p.Author); |
| 266 | + |
| 267 | + Assert.AreEqual(expected.ToString(), query.ToString()); |
| 268 | + |
| 269 | + Assert.AreNotSame(expected.Expression, query.Expression); |
| 270 | + |
| 271 | + Assert.That.MethodCallsAreMatch(expected.Expression, query.Expression); |
| 272 | + |
| 273 | + var queryPosts = query.ToList(); |
| 274 | + var expectedPosts = expected.ToList(); |
| 275 | + |
| 276 | + Assert.That.SequenceEqual(expectedPosts.Select(p => p.Id), queryPosts.Select(p => p.Id)); |
| 277 | + Assert.That.SequenceEqual(expectedPosts.Select(p => p.Author.Id), queryPosts.Select(p => p.Author.Id)); |
| 278 | + } |
| 279 | + } |
| 280 | + |
| 281 | + [TestMethod] |
| 282 | + public void ShouldWorkAsNonGeneric() |
| 283 | + { |
| 284 | + using (var context = CreateSqliteDbContext()) |
| 285 | + { |
| 286 | + var user = new User(); |
| 287 | + context.Users.Add(user); |
| 288 | + |
| 289 | + var post = new Post { Title = "first", Author = user }; |
| 290 | + context.Posts.Add(post); |
| 291 | + |
| 292 | + context.SaveChanges(); |
| 293 | + |
| 294 | + var query = context.Users.AsExpandable() |
| 295 | + .SelectMany(u => u.Posts.FilterIsActive()); |
| 296 | + |
| 297 | + var posts = new List<Post>(); |
| 298 | + |
| 299 | + foreach (Post p in query as IEnumerable) |
| 300 | + { |
| 301 | + posts.Add(p); |
| 302 | + } |
| 303 | + |
| 304 | + Assert.AreEqual(1, posts.Count); |
| 305 | + Assert.AreEqual("first", posts[0].Title); |
| 306 | + Assert.AreEqual(typeof(Post), (query as IQueryable).ElementType); |
| 307 | + } |
| 308 | + } |
| 309 | + |
| 310 | + [TestMethod] |
| 311 | + public async Task ShouldWorkAsAsync() |
| 312 | + { |
| 313 | + using (var context = CreateSqliteDbContext()) |
| 314 | + { |
| 315 | + var user = new User(); |
| 316 | + context.Users.Add(user); |
| 317 | + |
| 318 | + var post = new Post { Title = "first", Author = user }; |
| 319 | + context.Posts.Add(post); |
| 320 | + |
| 321 | + context.SaveChanges(); |
| 322 | + |
| 323 | + var query = context.Users.AsExpandable() |
| 324 | + .SelectMany(u => u.Posts.FilterIsActive()); |
| 325 | + |
| 326 | + var posts = await query.ToListAsync(); |
| 327 | + |
| 328 | + Assert.AreEqual(1, posts.Count); |
| 329 | + Assert.AreEqual("first", posts[0].Title); |
| 330 | + |
| 331 | + var groupQuery = query |
| 332 | + .GroupBy(p => p.CreatorUserId) |
| 333 | + .Select(g => g.ToList()); |
| 334 | + |
| 335 | + var groupPosts = await groupQuery.FirstOrDefaultAsync(); |
| 336 | + |
| 337 | + Assert.AreEqual(1, groupPosts.Count); |
| 338 | + Assert.AreEqual("first", groupPosts[0].Title); |
| 339 | + } |
| 340 | + } |
241 | 341 | } |
242 | 342 | } |
0 commit comments