DataDomain.cs 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465
  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. var dcr = new DomainContextResolver();
  28. dcr.Register(this);
  29. return new UnitOfWork<TDomainContext>(dcr);
  30. }
  31. public void Commit()
  32. {
  33. this.SaveChanges();
  34. }
  35. public void Rollback()
  36. {
  37. var changedEntries = ChangeTracker.Entries()
  38. .Where(x => x.State != EntityState.Unchanged).ToList();
  39. foreach (var entry in changedEntries)
  40. {
  41. switch(entry.State)
  42. {
  43. case EntityState.Modified:
  44. entry.CurrentValues.SetValues(entry.OriginalValues);
  45. entry.State = EntityState.Unchanged;
  46. break;
  47. case EntityState.Added:
  48. entry.State = EntityState.Detached;
  49. break;
  50. case EntityState.Deleted:
  51. entry.State = EntityState.Unchanged;
  52. break;
  53. }
  54. }
  55. }
  56. }
  57. }