Вы не можете выбрать более 25 тем Темы должны начинаться с буквы или цифры, могут содержать дефисы(-) и должны содержать не более 35 символов.

LuEfCreateDataAccessTest.cs 13KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using Luticate2.Utils.Dbo;
  5. using Test.Utils.DataAccess;
  6. using Test.Utils.Dbo.PkBigSerial;
  7. using Test.Utils.Dbo.PkGuid;
  8. using Xunit;
  9. namespace Test.Utils.EfCrubDataAccess
  10. {
  11. public class LuEfCreateDataAccessTest
  12. {
  13. [Fact]
  14. public void TestAddMultiple1()
  15. {
  16. Tests.TestRealDb(context =>
  17. {
  18. var dbos = new List<PkBigSerialAddDbo>
  19. {
  20. new PkBigSerialAddDbo
  21. {
  22. SomeInt = 42,
  23. SomeText = "42"
  24. },
  25. new PkBigSerialAddDbo
  26. {
  27. SomeInt = 21,
  28. SomeText = "24"
  29. }
  30. };
  31. var service = new LuUtilsPkBigSerialDataAccess(context);
  32. var res = service.Add(dbos, enumerable => enumerable);
  33. Assert.Equal(LuStatus.Success, res.Status);
  34. foreach (var dbo in dbos.Zip(res.Data, (dbo, serialDbo) => new KeyValuePair<PkBigSerialAddDbo, PkBigSerialDbo>(dbo, serialDbo)))
  35. {
  36. Assert.NotNull(dbo.Key);
  37. Assert.NotNull(dbo.Value);
  38. Assert.NotEqual(0, dbo.Value.Id);
  39. Assert.Equal(dbo.Key.SomeText, dbo.Value.SomeText);
  40. Assert.Equal(dbo.Key.SomeInt, dbo.Value.SomeInt);
  41. var get = service.GetSingleById(dbo.Value.Id);
  42. Assert.Equal(LuStatus.Success, get.Status);
  43. Assert.Equal(dbo.Key.SomeText, get.Data.SomeText);
  44. Assert.Equal(dbo.Key.SomeInt, get.Data.SomeInt);
  45. Assert.Equal(dbo.Value.Id, get.Data.Id);
  46. }
  47. });
  48. }
  49. [Fact]
  50. public void TestAddMultiple2()
  51. {
  52. Tests.TestRealDb(context =>
  53. {
  54. var dbos = new List<PkBigSerialAddDbo>
  55. {
  56. new PkBigSerialAddDbo
  57. {
  58. SomeInt = 42,
  59. SomeText = "42"
  60. },
  61. new PkBigSerialAddDbo
  62. {
  63. SomeInt = 21,
  64. SomeText = "24"
  65. }
  66. };
  67. var service = new LuUtilsPkBigSerialDataAccess(context);
  68. var res = service.Add(dbos, enumerable => enumerable.Select(dbo => dbo.Id));
  69. Assert.Equal(LuStatus.Success, res.Status);
  70. foreach (var dbo in dbos.Zip(res.Data, (dbo, serialDbo) => new KeyValuePair<PkBigSerialAddDbo, long>(dbo, serialDbo)))
  71. {
  72. Assert.NotNull(dbo.Key);
  73. Assert.NotNull(dbo.Value);
  74. Assert.NotEqual(0, dbo.Value);
  75. var get = service.GetSingleById(dbo.Value);
  76. Assert.Equal(LuStatus.Success, get.Status);
  77. Assert.Equal(dbo.Key.SomeText, get.Data.SomeText);
  78. Assert.Equal(dbo.Key.SomeInt, get.Data.SomeInt);
  79. Assert.Equal(dbo.Value, get.Data.Id);
  80. }
  81. });
  82. }
  83. [Fact]
  84. public void TestAddMultiple3()
  85. {
  86. Tests.TestRealDb(context =>
  87. {
  88. var dbos = new List<PkBigSerialAddDbo>
  89. {
  90. new PkBigSerialAddDbo
  91. {
  92. SomeInt = 42,
  93. SomeText = "42"
  94. },
  95. new PkBigSerialAddDbo
  96. {
  97. SomeInt = 21,
  98. SomeText = "24"
  99. }
  100. };
  101. var service = new LuUtilsPkBigSerialDataAccess(context);
  102. var res = service.Add(dbos, enumerable => enumerable.Select(dbo => dbo.CreatedAt));
  103. Assert.Equal(LuStatus.Success, res.Status);
  104. foreach (var dbo in res.Data)
  105. {
  106. Assert.NotEqual(default(DateTime), dbo);
  107. }
  108. });
  109. }
  110. [Fact]
  111. public void TestAddMultiple4()
  112. {
  113. Tests.TestRealDb(context =>
  114. {
  115. var dbos = new List<PkBigSerialAddDbo>
  116. {
  117. new PkBigSerialAddDbo
  118. {
  119. SomeInt = 42,
  120. SomeText = "42"
  121. },
  122. new PkBigSerialAddDbo
  123. {
  124. SomeInt = 21,
  125. SomeText = "42"
  126. }
  127. };
  128. var service = new LuUtilsPkBigSerialDataAccess(context);
  129. var res = service.Add(dbos, enumerable => enumerable.Select(dbo => dbo.CreatedAt));
  130. Assert.Equal(LuStatus.DbError, res.Status);
  131. });
  132. }
  133. [Fact]
  134. public void TestAddSingle1()
  135. {
  136. Tests.TestRealDb(context =>
  137. {
  138. var service = new LuUtilsPkBigSerialDataAccess(context);
  139. var res = service.Add(new PkBigSerialAddDbo
  140. {
  141. SomeInt = 42,
  142. SomeText = "42"
  143. }, dbo => dbo);
  144. Assert.Equal(LuStatus.Success, res.Status);
  145. Assert.NotEqual(0, res.Data.Id);
  146. Assert.Equal("42", res.Data.SomeText);
  147. Assert.Equal(42, res.Data.SomeInt);
  148. var get = service.GetSingleById(res.Data.Id);
  149. Assert.Equal(LuStatus.Success, get.Status);
  150. Assert.Equal("42", get.Data.SomeText);
  151. Assert.Equal(42, get.Data.SomeInt);
  152. Assert.Equal(res.Data.Id, get.Data.Id);
  153. });
  154. }
  155. [Fact]
  156. public void TestAddSingle2()
  157. {
  158. Tests.TestRealDb(context =>
  159. {
  160. var service = new LuUtilsPkBigSerialDataAccess(context);
  161. var res = service.Add(new PkBigSerialAddDbo
  162. {
  163. SomeInt = 42,
  164. SomeText = "42"
  165. }, dbo => dbo.Id);
  166. Assert.Equal(LuStatus.Success, res.Status);
  167. Assert.NotEqual(0, res.Data);
  168. var get = service.GetSingleById(res.Data);
  169. Assert.Equal(LuStatus.Success, get.Status);
  170. Assert.Equal("42", get.Data.SomeText);
  171. Assert.Equal(42, get.Data.SomeInt);
  172. Assert.Equal(res.Data, get.Data.Id);
  173. });
  174. }
  175. [Fact]
  176. public void TestAddSingle3()
  177. {
  178. Tests.TestRealDb(context =>
  179. {
  180. var service = new LuUtilsPkBigSerialDataAccess(context);
  181. var res = service.Add(new PkBigSerialAddDbo
  182. {
  183. SomeInt = 42,
  184. SomeText = "42"
  185. }, dbo => dbo.CreatedAt);
  186. Assert.Equal(LuStatus.Success, res.Status);
  187. Assert.NotEqual(default(DateTime), res.Data);
  188. });
  189. }
  190. [Fact]
  191. public void TestAddGuidMultiple1()
  192. {
  193. Tests.TestRealDb(context =>
  194. {
  195. var dbos = new List<PkGuidAddDbo>
  196. {
  197. new PkGuidAddDbo
  198. {
  199. SomeInt = 42,
  200. SomeText = "42"
  201. },
  202. new PkGuidAddDbo
  203. {
  204. SomeInt = 21,
  205. SomeText = "24"
  206. }
  207. };
  208. var service = new LuUtilsPkGuidDataAccess(context);
  209. var res = service.AddGuid(dbos);
  210. Assert.Equal(LuStatus.Success, res.Status);
  211. foreach (var dbo in dbos.Zip(res.Data, (dbo, serialDbo) => new KeyValuePair<PkGuidAddDbo, string>(dbo, serialDbo)))
  212. {
  213. Assert.NotNull(dbo.Key);
  214. Assert.NotNull(dbo.Value);
  215. Assert.NotEqual(new Guid().ToString(), dbo.Value);
  216. var get = service.GetSingleById(dbo.Value);
  217. Assert.Equal(LuStatus.Success, get.Status);
  218. Assert.Equal(dbo.Key.SomeText, get.Data.SomeText);
  219. Assert.Equal(dbo.Key.SomeInt, get.Data.SomeInt);
  220. Assert.Equal(dbo.Value, get.Data.Id);
  221. }
  222. });
  223. }
  224. [Fact]
  225. public void TestAddGuidSingle1()
  226. {
  227. Tests.TestRealDb(context =>
  228. {
  229. var service = new LuUtilsPkGuidDataAccess(context);
  230. var res = service.AddGuid(new PkGuidAddDbo
  231. {
  232. SomeInt = 42,
  233. SomeText = "42"
  234. });
  235. Assert.Equal(LuStatus.Success, res.Status);
  236. Assert.NotEqual(new Guid().ToString(), res.Data);
  237. var get = service.GetSingleById(res.Data);
  238. Assert.Equal(LuStatus.Success, get.Status);
  239. Assert.Equal("42", get.Data.SomeText);
  240. Assert.Equal(42, get.Data.SomeInt);
  241. Assert.Equal(res.Data, get.Data.Id);
  242. });
  243. }
  244. [Fact]
  245. public void TestAddIdMultiple1()
  246. {
  247. Tests.TestRealDb(context =>
  248. {
  249. var dbos = new List<PkBigSerialAddDbo>
  250. {
  251. new PkBigSerialAddDbo
  252. {
  253. SomeInt = 42,
  254. SomeText = "42"
  255. },
  256. new PkBigSerialAddDbo
  257. {
  258. SomeInt = 21,
  259. SomeText = "24"
  260. }
  261. };
  262. var service = new LuUtilsPkBigSerialDataAccess(context);
  263. var res = service.AddId(dbos);
  264. Assert.Equal(LuStatus.Success, res.Status);
  265. foreach (var dbo in dbos.Zip(res.Data, (dbo, serialDbo) => new KeyValuePair<PkBigSerialAddDbo, long>(dbo, serialDbo)))
  266. {
  267. Assert.NotNull(dbo.Key);
  268. Assert.NotNull(dbo.Value);
  269. Assert.NotEqual(0, dbo.Value);
  270. var get = service.GetSingleById(dbo.Value);
  271. Assert.Equal(LuStatus.Success, get.Status);
  272. Assert.Equal(dbo.Key.SomeText, get.Data.SomeText);
  273. Assert.Equal(dbo.Key.SomeInt, get.Data.SomeInt);
  274. Assert.Equal(dbo.Value, get.Data.Id);
  275. }
  276. });
  277. }
  278. [Fact]
  279. public void TestAddIdSingle1()
  280. {
  281. Tests.TestRealDb(context =>
  282. {
  283. var service = new LuUtilsPkBigSerialDataAccess(context);
  284. var res = service.AddId(new PkBigSerialAddDbo
  285. {
  286. SomeInt = 42,
  287. SomeText = "42"
  288. });
  289. Assert.Equal(LuStatus.Success, res.Status);
  290. Assert.NotEqual(0, res.Data);
  291. var get = service.GetSingleById(res.Data);
  292. Assert.Equal(LuStatus.Success, get.Status);
  293. Assert.Equal("42", get.Data.SomeText);
  294. Assert.Equal(42, get.Data.SomeInt);
  295. Assert.Equal(res.Data, get.Data.Id);
  296. });
  297. }
  298. [Fact]
  299. public void TestAddDboMultiple1()
  300. {
  301. Tests.TestRealDb(context =>
  302. {
  303. var dbos = new List<PkBigSerialAddDbo>
  304. {
  305. new PkBigSerialAddDbo
  306. {
  307. SomeInt = 42,
  308. SomeText = "42"
  309. },
  310. new PkBigSerialAddDbo
  311. {
  312. SomeInt = 21,
  313. SomeText = "24"
  314. }
  315. };
  316. var service = new LuUtilsPkBigSerialDataAccess(context);
  317. var res = service.AddDbo(dbos);
  318. Assert.Equal(LuStatus.Success, res.Status);
  319. foreach (var dbo in dbos.Zip(res.Data, (dbo, serialDbo) => new KeyValuePair<PkBigSerialAddDbo, PkBigSerialDbo>(dbo, serialDbo)))
  320. {
  321. Assert.NotNull(dbo.Key);
  322. Assert.NotNull(dbo.Value);
  323. Assert.NotEqual(0, dbo.Value.Id);
  324. var get = service.GetSingleById(dbo.Value.Id);
  325. Assert.Equal(LuStatus.Success, get.Status);
  326. Assert.Equal(dbo.Key.SomeText, get.Data.SomeText);
  327. Assert.Equal(dbo.Key.SomeInt, get.Data.SomeInt);
  328. Assert.Equal(dbo.Value.Id, get.Data.Id);
  329. }
  330. });
  331. }
  332. [Fact]
  333. public void TestAddDboSingle1()
  334. {
  335. Tests.TestRealDb(context =>
  336. {
  337. var service = new LuUtilsPkBigSerialDataAccess(context);
  338. var res = service.AddDbo(new PkBigSerialAddDbo
  339. {
  340. SomeInt = 42,
  341. SomeText = "42"
  342. });
  343. Assert.Equal(LuStatus.Success, res.Status);
  344. Assert.NotEqual(0, res.Data.Id);
  345. var get = service.GetSingleById(res.Data.Id);
  346. Assert.Equal(LuStatus.Success, get.Status);
  347. Assert.Equal("42", get.Data.SomeText);
  348. Assert.Equal(42, get.Data.SomeInt);
  349. Assert.Equal(res.Data.Id, get.Data.Id);
  350. });
  351. }
  352. }
  353. }