DataSource.cs 2.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
  1. using Vitorm.Sql;
  2. using Vit.Extensions;
  3. using Vit.Core.Util.ConfigurationManager;
  4. using System.ComponentModel.DataAnnotations.Schema;
  5. namespace Vitorm.MsTest
  6. {
  7. [System.ComponentModel.DataAnnotations.Schema.Table("User")]
  8. public class User
  9. {
  10. [System.ComponentModel.DataAnnotations.Key]
  11. [System.ComponentModel.DataAnnotations.Schema.DatabaseGenerated(DatabaseGeneratedOption.Identity)]
  12. public int id { get; set; }
  13. public string name { get; set; }
  14. public DateTime? birth { get; set; }
  15. public int? fatherId { get; set; }
  16. public int? motherId { get; set; }
  17. [System.ComponentModel.DataAnnotations.Schema.NotMapped]
  18. public string test { get; set; }
  19. public static User NewUser(int id, bool forAdd = false) => new User { id = forAdd ? 0 : id, name = "testUser" + id };
  20. public static List<User> NewUsers(int startId, int count = 1, bool forAdd = false)
  21. {
  22. return Enumerable.Range(startId, count).Select(id => NewUser(id, forAdd)).ToList();
  23. }
  24. }
  25. public class DataSource
  26. {
  27. static string connectionString = Appsettings.json.GetStringByPath("App.Db.ConnectionString");
  28. public static SqlDbContext CreateDbContextForWriting() => CreateDbContext();
  29. public static SqlDbContext CreateDbContext()
  30. {
  31. var dbContext = new SqlDbContext();
  32. dbContext.UseMySql(connectionString);
  33. dbContext.BeginTransaction();
  34. var dbSet = dbContext.DbSet<User>();
  35. dbContext.Execute(sql: "DROP TABLE if exists `User`;");
  36. dbSet.Create();
  37. var users = new List<User> {
  38. new User { name="u146", fatherId=4, motherId=6 },
  39. new User { name="u246", fatherId=4, motherId=6 },
  40. new User { name="u356", fatherId=5, motherId=6 },
  41. new User { name="u400" },
  42. new User { name="u500" },
  43. new User { name="u600" },
  44. };
  45. dbContext.AddRange(users);
  46. users.ForEach(user => { user.birth = DateTime.Parse("2021-01-01 00:00:00").AddHours(user.id); });
  47. dbContext.UpdateRange(users);
  48. return dbContext;
  49. }
  50. }
  51. }