DataDomain.cs 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
  1. using System;
  2. using System.Linq;
  3. using System.Reflection;
  4. using Microsoft.EntityFrameworkCore;
  5. using Quadarax.Foundation.Core.Data.Interface.Domain;
  6. namespace Quadarax.Foundation.Core.Data.Domain
  7. {
  8. public abstract class DataDomain : DbContext, IDataDomain
  9. {
  10. private MethodInfo _mtSet;
  11. private MethodInfo _mtgSet;
  12. protected DataDomain(DbContextOptions options) : base(options)
  13. {
  14. }
  15. public TEntitySet GetDbSet<TEntitySet>()
  16. {
  17. //TODO: comment because db constext is in this scope static
  18. //if (_mtSet == null)
  19. _mtSet = GetType().GetMethod(nameof(DbContext.Set), Type.EmptyTypes);//GetType().GetMethod("Set");
  20. //if (_mtgSet==null)
  21. _mtgSet = _mtSet.MakeGenericMethod(typeof(TEntitySet).GetGenericArguments().First());
  22. var returnValue = _mtgSet.Invoke(this, new object[] {});
  23. return (TEntitySet)returnValue;
  24. }
  25. public IUnitOfWork<TDomainContext> CreateUnitOfWork<TDomainContext>() where TDomainContext : IDomain
  26. {
  27. return new UnitOfWork<TDomainContext>((IDomainContextResolver<TDomainContext>)new DomainContextResolver<DataDomain>(this));
  28. }
  29. public void Commit()
  30. {
  31. this.SaveChanges();
  32. }
  33. public void Rollback()
  34. {
  35. var changedEntries = ChangeTracker.Entries()
  36. .Where(x => x.State != EntityState.Unchanged).ToList();
  37. foreach (var entry in changedEntries)
  38. {
  39. switch(entry.State)
  40. {
  41. case EntityState.Modified:
  42. entry.CurrentValues.SetValues(entry.OriginalValues);
  43. entry.State = EntityState.Unchanged;
  44. break;
  45. case EntityState.Added:
  46. entry.State = EntityState.Detached;
  47. break;
  48. case EntityState.Deleted:
  49. entry.State = EntityState.Unchanged;
  50. break;
  51. }
  52. }
  53. }
  54. }
  55. }