Key.cs 7.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299
  1. //
  2. // System.Data.Common.Key.cs
  3. //
  4. // Author:
  5. // Boris Kirzner <[email protected]>
  6. // Konstantin Triger ([email protected])
  7. //
  8. /*
  9. * Copyright (c) 2002-2004 Mainsoft Corporation.
  10. *
  11. * Permission is hereby granted, free of charge, to any person obtaining a
  12. * copy of this software and associated documentation files (the "Software"),
  13. * to deal in the Software without restriction, including without limitation
  14. * the rights to use, copy, modify, merge, publish, distribute, sublicense,
  15. * and/or sell copies of the Software, and to permit persons to whom the
  16. * Software is furnished to do so, subject to the following conditions:
  17. *
  18. * The above copyright notice and this permission notice shall be included in
  19. * all copies or substantial portions of the Software.
  20. *
  21. * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  22. * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  23. * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  24. * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  25. * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
  26. * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
  27. * DEALINGS IN THE SOFTWARE.
  28. */
  29. using System;
  30. using Mono.Data.SqlExpressions;
  31. using System.ComponentModel;
  32. namespace System.Data.Common
  33. {
  34. internal class Key
  35. {
  36. #region Fields
  37. DataTable _table;
  38. DataColumn[] _columns;
  39. ListSortDirection[] _sortDirection;
  40. DataViewRowState _rowStateFilter;
  41. IExpression _filter;
  42. //Currently IExpression.Eval does not receive DataRowVersion
  43. // and always uses the _current version
  44. //so need a temp row for Eval calls
  45. DataRow _tmpRow;
  46. #endregion //Fields
  47. #region Constructors
  48. internal Key(DataTable table,DataColumn[] columns,ListSortDirection[] sort, DataViewRowState rowState, IExpression filter)
  49. {
  50. _table = table;
  51. _filter = filter;
  52. if (_filter != null)
  53. _tmpRow = _table.NewNotInitializedRow();
  54. _columns = columns;
  55. if (sort != null && sort.Length == columns.Length) {
  56. _sortDirection = sort;
  57. }
  58. else {
  59. _sortDirection = new ListSortDirection[columns.Length];
  60. for(int i=0; i < _sortDirection.Length; i++) {
  61. _sortDirection[i] = ListSortDirection.Ascending;
  62. }
  63. }
  64. if (rowState != DataViewRowState.None) {
  65. _rowStateFilter = rowState;
  66. }
  67. else {
  68. // FIXME : what is the correct value ?
  69. _rowStateFilter = DataViewRowState.CurrentRows;
  70. }
  71. }
  72. #endregion // Constructors
  73. #region Properties
  74. internal DataColumn[] Columns
  75. {
  76. get {
  77. return _columns;
  78. }
  79. }
  80. internal DataTable Table
  81. {
  82. get {
  83. return _table;
  84. }
  85. }
  86. ListSortDirection[] Sort
  87. {
  88. get {
  89. return _sortDirection;
  90. }
  91. }
  92. internal DataViewRowState RowStateFilter
  93. {
  94. get {
  95. return _rowStateFilter;
  96. }
  97. set {
  98. _rowStateFilter = value;
  99. }
  100. }
  101. internal bool HasFilter
  102. {
  103. get { return _filter != null; }
  104. }
  105. #endregion // Properties
  106. #region Methods
  107. internal int CompareRecords(int first, int second)
  108. {
  109. if (first == second) {
  110. return 0;
  111. }
  112. for(int i = 0; i < Columns.Length; i++) {
  113. int res = Columns[i].CompareValues(first,second);
  114. if (res == 0) {
  115. continue;
  116. }
  117. return (Sort[i] == ListSortDirection.Ascending) ? res : -res;
  118. }
  119. return 0;
  120. }
  121. internal int GetRecord(DataRow row)
  122. {
  123. int index = Key.GetRecord(row,_rowStateFilter);
  124. if (_filter == null)
  125. return index;
  126. if (index < 0)
  127. return index;
  128. return CanContain (index) ? index : -1;
  129. }
  130. internal bool CanContain (int index)
  131. {
  132. if (_filter == null)
  133. return true;
  134. _tmpRow._current = index;
  135. return _filter.EvalBoolean(_tmpRow);
  136. }
  137. internal bool ContainsVersion (DataRowState state, DataRowVersion version)
  138. {
  139. switch (state) {
  140. case DataRowState.Unchanged: {
  141. if ((_rowStateFilter & DataViewRowState.Unchanged) != DataViewRowState.None) {
  142. return ((version & DataRowVersion.Default) != 0);
  143. }
  144. break;
  145. }
  146. case DataRowState.Added: {
  147. if ((_rowStateFilter & DataViewRowState.Added) != DataViewRowState.None) {
  148. return ((version & DataRowVersion.Default) != 0);
  149. }
  150. break;
  151. }
  152. case DataRowState.Deleted: {
  153. if ((_rowStateFilter & DataViewRowState.Deleted) != DataViewRowState.None) {
  154. return (version == DataRowVersion.Original);
  155. }
  156. break;
  157. }
  158. default:
  159. if ((_rowStateFilter & DataViewRowState.ModifiedCurrent) != DataViewRowState.None) {
  160. return ((version & DataRowVersion.Default) != 0);
  161. }
  162. else if ((_rowStateFilter & DataViewRowState.ModifiedOriginal) != DataViewRowState.None) {
  163. return (version == DataRowVersion.Original);
  164. }
  165. break;
  166. }
  167. return false;
  168. }
  169. internal static int GetRecord(DataRow row, DataViewRowState rowStateFilter)
  170. {
  171. switch (row.RowState) {
  172. case DataRowState.Unchanged: {
  173. if ((rowStateFilter & DataViewRowState.Unchanged) != DataViewRowState.None) {
  174. return row.Proposed >= 0 ? row.Proposed : row.Current;
  175. }
  176. break;
  177. }
  178. case DataRowState.Added: {
  179. if ((rowStateFilter & DataViewRowState.Added) != DataViewRowState.None) {
  180. return row.Proposed >= 0 ? row.Proposed : row.Current;
  181. }
  182. break;
  183. }
  184. case DataRowState.Deleted: {
  185. if ((rowStateFilter & DataViewRowState.Deleted) != DataViewRowState.None) {
  186. return row.Original;
  187. }
  188. break;
  189. }
  190. default:
  191. if ((rowStateFilter & DataViewRowState.ModifiedCurrent) != DataViewRowState.None) {
  192. return row.Proposed >= 0 ? row.Proposed : row.Current;
  193. }
  194. else if ((rowStateFilter & DataViewRowState.ModifiedOriginal) != DataViewRowState.None) {
  195. return row.Original;
  196. }
  197. break;
  198. }
  199. return -1;
  200. }
  201. /// <summary>
  202. /// Checks for key equality to parameters set given
  203. /// </summary>
  204. /// <param name="columns">Columns the key consits of. If this parameter is null, it does not affects equality check</param>
  205. /// <param name="sort">Sort order of columns. If this parameter is null, it does not affects equality check</param>
  206. /// <param name="rowState">DataViewRowState to check for.If this parameter is null, it does not affects equality check</param>
  207. /// <param name="unique">Indicates whenever the index managed by this key allows non-uniqie keys to appear.</param>
  208. /// <param name="strict">Indicates whenever unique parameter should affect the equality check.</param>
  209. /// <returns></returns>
  210. internal bool Equals(DataColumn[] columns, ListSortDirection[] sort, DataViewRowState rowState, IExpression filter)
  211. {
  212. if (rowState != DataViewRowState.None && RowStateFilter != rowState) {
  213. return false;
  214. }
  215. if (_filter != null) {
  216. if (!_filter.Equals (filter))
  217. return false;
  218. }
  219. else if (filter != null)
  220. return false;
  221. if (Columns.Length != columns.Length) {
  222. return false;
  223. }
  224. if (sort != null && Sort.Length != sort.Length) {
  225. return false;
  226. }
  227. if (sort != null) {
  228. for(int i=0; i < columns.Length; i++) {
  229. if (Sort[i] != sort[i] || Columns[i] != columns[i]) {
  230. return false;
  231. }
  232. }
  233. }
  234. else {
  235. for(int i=0; i < columns.Length; i++) {
  236. if (Columns[i] != columns[i]) {
  237. return false;
  238. }
  239. }
  240. }
  241. return true;
  242. }
  243. internal bool DependsOn (DataColumn column)
  244. {
  245. if (_filter == null)
  246. return false;
  247. return _filter.DependsOn (column);
  248. }
  249. #endregion // Methods
  250. }
  251. }