IEntityState.cs 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138
  1. using Ant.Common;
  2. using Ant.Descriptors;
  3. using Ant.ORM;
  4. using Ant.Utility;
  5. using System;
  6. using System.Collections.Generic;
  7. using System.Linq;
  8. using System.Reflection;
  9. using System.Text;
  10. using System.Threading.Tasks;
  11. namespace Ant.Core
  12. {
  13. /// <summary>
  14. ///
  15. /// </summary>
  16. public interface IEntityState
  17. {
  18. /// <summary>
  19. ///
  20. /// </summary>
  21. object Entity { get; }
  22. /// <summary>
  23. ///
  24. /// </summary>
  25. MetaData TypeDescriptor { get; }
  26. /// <summary>
  27. ///
  28. /// </summary>
  29. /// <param name="memberDescriptor"></param>
  30. /// <param name="val"></param>
  31. /// <returns></returns>
  32. bool HasChanged(MappingMemberDescriptor memberDescriptor, object val);
  33. /// <summary>
  34. ///
  35. /// </summary>
  36. void Refresh();
  37. }
  38. class EntityState : IEntityState
  39. {
  40. Dictionary<MemberInfo, object> _fakes;
  41. object _entity;
  42. MetaData _typeDescriptor;
  43. public EntityState(MetaData typeDescriptor, object entity)
  44. {
  45. this._typeDescriptor = typeDescriptor;
  46. this._entity = entity;
  47. this.Refresh();
  48. }
  49. public object Entity { get { return this._entity; } }
  50. public MetaData TypeDescriptor { get { return this._typeDescriptor; } }
  51. public bool HasChanged(MappingMemberDescriptor memberDescriptor, object val)
  52. {
  53. object oldVal;
  54. if (!this._fakes.TryGetValue(memberDescriptor.MemberInfo, out oldVal))
  55. {
  56. return true;
  57. }
  58. if (memberDescriptor.MemberInfoType == UtilConstants.TypeOfByteArray)
  59. {
  60. //byte[] is a big big hole~
  61. return !AreEqual((byte[])oldVal, (byte[])val);
  62. }
  63. return !AntUtils.AreEqual(oldVal, val);
  64. }
  65. public void Refresh()
  66. {
  67. Dictionary<MemberInfo, MappingMemberDescriptor> mappingMemberDescriptors = this.TypeDescriptor.FiledMeta.MappingMemberDescriptors;
  68. if (this._fakes == null)
  69. {
  70. this._fakes = new Dictionary<MemberInfo, object>(mappingMemberDescriptors.Count);
  71. }
  72. else
  73. {
  74. this._fakes.Clear();
  75. }
  76. object entity = this._entity;
  77. foreach (var kv in mappingMemberDescriptors)
  78. {
  79. MemberInfo key = kv.Key;
  80. MappingMemberDescriptor memberDescriptor = kv.Value;
  81. var val = memberDescriptor.GetValue(entity);
  82. //I hate the byte[].
  83. if (memberDescriptor.MemberInfoType == UtilConstants.TypeOfByteArray)
  84. {
  85. val = Clone((byte[])val);
  86. }
  87. this._fakes[key] = val;
  88. }
  89. }
  90. static byte[] Clone(byte[] arr)
  91. {
  92. if (arr == null)
  93. return null;
  94. byte[] ret = new byte[arr.Length];
  95. for (int i = 0; i < arr.Length; i++)
  96. {
  97. ret[i] = arr[i];
  98. }
  99. return ret;
  100. }
  101. static bool AreEqual(byte[] obj1, byte[] obj2)
  102. {
  103. if (obj1 == obj2)
  104. return true;
  105. if (obj1 != null && obj2 != null)
  106. {
  107. if (obj1.Length != obj2.Length)
  108. return false;
  109. for (int i = 0; i < obj1.Length; i++)
  110. {
  111. if (obj1[i] != obj2[i])
  112. return false;
  113. }
  114. return true;
  115. }
  116. return false;
  117. }
  118. }
  119. }