Query_Count_Test.cs 9.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235
  1. using System.Data;
  2. using Microsoft.VisualStudio.TestTools.UnitTesting;
  3. namespace Vitorm.MsTest.CommonTest
  4. {
  5. [TestClass]
  6. public class Query_Count_Test
  7. {
  8. [TestMethod]
  9. public void Test_Count()
  10. {
  11. using var dbContext = DataSource.CreateDbContext();
  12. var userQuery = dbContext.Query<User>();
  13. TestAllCase(userQuery);
  14. }
  15. [TestMethod]
  16. public void Test_SkipAndTake_Count()
  17. {
  18. using var dbContext = DataSource.CreateDbContext();
  19. var userQuery = dbContext.Query<User>();
  20. TestAllCase(userQuery, new Config { skip = 0 });
  21. TestAllCase(userQuery, new Config { skip = 1 });
  22. TestAllCase(userQuery, new Config { skip = 10 });
  23. TestAllCase(userQuery, new Config { take = 0 });
  24. TestAllCase(userQuery, new Config { take = 2 });
  25. TestAllCase(userQuery, new Config { take = 20 });
  26. TestAllCase(userQuery, new Config { skip = 0, take = 0 });
  27. TestAllCase(userQuery, new Config { skip = 0, take = 2 });
  28. TestAllCase(userQuery, new Config { skip = 0, take = 20 });
  29. TestAllCase(userQuery, new Config { skip = 1, take = 0 });
  30. TestAllCase(userQuery, new Config { skip = 1, take = 2 });
  31. TestAllCase(userQuery, new Config { skip = 1, take = 20 });
  32. TestAllCase(userQuery, new Config { skip = 10, take = 0 });
  33. TestAllCase(userQuery, new Config { skip = 10, take = 2 });
  34. TestAllCase(userQuery, new Config { skip = 10, take = 20 });
  35. }
  36. [TestMethod]
  37. public void Test_Distinct_Count()
  38. {
  39. using var dbContext = DataSource.CreateDbContext();
  40. var userQuery = dbContext.Query<User>();
  41. TestAllCase(userQuery, new Config { distinct = true });
  42. }
  43. [TestMethod]
  44. public void Test_Distinct_SkipAndTake_Count()
  45. {
  46. using var dbContext = DataSource.CreateDbContext();
  47. var userQuery = dbContext.Query<User>();
  48. TestAllCase(userQuery, new Config { distinct = true, skip = 1, take = 100 });
  49. }
  50. void TestAllCase(IQueryable<User> users, Config config = null)
  51. {
  52. #region no orderBy
  53. {
  54. // single table
  55. Test(users.Select(user => user.fatherId), config);
  56. Test(users.Select(user => new { user.fatherId }), config);
  57. Test(users.Select(user => user), config);
  58. Test(users.Select(user => new { user }), config);
  59. Test(users.Select(user => new { user, user.fatherId }), config);
  60. Test(users.Select(user => new { user.id, user.fatherId }), config);
  61. // joinedTable
  62. Test(users.SelectMany(user => users.Where(father => father.id == user.fatherId), (user, father) => user.fatherId), config);
  63. Test(users.SelectMany(user => users.Where(father => father.id == user.fatherId), (user, father) => new { user.fatherId }), config);
  64. Test(users.SelectMany(user => users.Where(father => father.id == user.fatherId), (user, father) => user), config);
  65. Test(users.SelectMany(user => users.Where(father => father.id == user.fatherId), (user, father) => new { user }), config);
  66. Test(users.SelectMany(user => users.Where(father => father.id == user.fatherId), (user, father) => new { user, user.id }), config);
  67. Test(users.SelectMany(user => users.Where(father => father.id == user.fatherId), (user, father) => new { user, father }), config);
  68. // groupedTable Lambda Expression
  69. {
  70. var query =
  71. users
  72. .GroupBy(user => new { user.fatherId, user.motherId })
  73. .Select(userGroup => new
  74. {
  75. userGroup.Key.fatherId,
  76. userGroup.Key.motherId,
  77. sumId = userGroup.Sum(m => m.id),
  78. });
  79. Test(query, config);
  80. }
  81. // groupedTable Linq Expression
  82. {
  83. var query =
  84. from user in users
  85. group user by new { user.fatherId, user.motherId } into userGroup
  86. select new
  87. {
  88. userGroup.Key.fatherId,
  89. userGroup.Key.motherId,
  90. sumId = userGroup.Sum(m => m.id),
  91. };
  92. Test(query, config);
  93. }
  94. }
  95. #endregion
  96. #region with orderBy
  97. {
  98. // single table
  99. Test(users.OrderBy(m => m.fatherId).Select(user => user.fatherId), config);
  100. Test(users.OrderBy(m => m.fatherId).Select(user => new { user.fatherId }), config);
  101. Test(users.OrderBy(m => m.fatherId).Select(user => user), config);
  102. Test(users.OrderBy(m => m.fatherId).Select(user => new { user }), config);
  103. Test(users.OrderBy(m => m.fatherId).Select(user => new { user, user.fatherId }), config);
  104. Test(users.OrderBy(m => m.fatherId).Select(user => new { user.id, user.fatherId }), config);
  105. // joinedTable
  106. Test(users.SelectMany(user => users.Where(father => father.id == user.fatherId), (user, father) => user.fatherId).OrderBy(m => m), config);
  107. Test(users.SelectMany(user => users.Where(father => father.id == user.fatherId), (user, father) => new { user.fatherId }).OrderBy(m => m.fatherId), config);
  108. Test(users.SelectMany(user => users.Where(father => father.id == user.fatherId), (user, father) => user).OrderBy(m => m.fatherId), config);
  109. Test(users.SelectMany(user => users.Where(father => father.id == user.fatherId), (user, father) => new { user }).OrderBy(m => m.user.fatherId), config);
  110. Test(users.SelectMany(user => users.Where(father => father.id == user.fatherId), (user, father) => new { user, user.id }).OrderBy(m => m.user.fatherId), config);
  111. Test(users.SelectMany(user => users.Where(father => father.id == user.fatherId), (user, father) => new { user, father }).OrderBy(m => m.user.fatherId), config);
  112. // order by alias column
  113. {
  114. Test(users.Select(user => user.fatherId).OrderBy(m => m), config);
  115. Test(users.Select(user => new { user.fatherId }).OrderBy(m => m.fatherId), config);
  116. Test(users.Select(user => user).OrderBy(m => m.fatherId), config);
  117. Test(users.Select(user => new { user }).OrderBy(m => m.user.fatherId), config);
  118. Test(users.Select(user => new { user, user.fatherId }).OrderBy(m => m.fatherId), config);
  119. Test(users.Select(user => new { user.id, user.fatherId }).OrderBy(m => m.fatherId), config);
  120. Test(users.Select(user => new { user.id, fid = user.fatherId ?? -1 }).OrderBy(m => m.id), config);
  121. }
  122. // groupedTable Lambda Expression
  123. {
  124. var query =
  125. users
  126. .GroupBy(user => new { user.fatherId, user.motherId })
  127. .OrderBy(m => m.Key.fatherId)
  128. .Select(userGroup => new
  129. {
  130. userGroup.Key.fatherId,
  131. userGroup.Key.motherId,
  132. sumId = userGroup.Sum(m => m.id),
  133. });
  134. Test(query, config);
  135. }
  136. // groupedTable Linq Expression
  137. {
  138. var query =
  139. from user in users
  140. group user by new { user.fatherId, user.motherId } into userGroup
  141. orderby userGroup.Key.fatherId
  142. select new
  143. {
  144. userGroup.Key.fatherId,
  145. userGroup.Key.motherId,
  146. sumId = userGroup.Sum(m => m.id),
  147. };
  148. Test(query, config);
  149. }
  150. }
  151. #endregion
  152. }
  153. void Test<Entity>(IQueryable<Entity> query, Config config = null)
  154. {
  155. if (config?.distinct == true) query = query.Distinct();
  156. if (config?.skip.HasValue == true) query = query.Skip(config.skip.Value);
  157. if (config?.take.HasValue == true) query = query.Take(config.take.Value);
  158. var rows = query.ToList();
  159. int expectedCount = rows.Count;
  160. var count = query.Count();
  161. Assert.AreEqual(expectedCount, count);
  162. }
  163. class Config
  164. {
  165. public bool? distinct;
  166. public int? skip;
  167. public int? take;
  168. }
  169. }
  170. }