StringStorage.cs 6.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188
  1. //------------------------------------------------------------------------------
  2. // <copyright file="StringStorage.cs" company="Microsoft">
  3. // Copyright (c) Microsoft Corporation. All rights reserved.
  4. // </copyright>
  5. // <owner current="true" primary="true">Microsoft</owner>
  6. // <owner current="true" primary="false">Microsoft</owner>
  7. // <owner current="false" primary="false">Microsoft</owner>
  8. //------------------------------------------------------------------------------
  9. namespace System.Data.Common {
  10. using System;
  11. using System.Diagnostics;
  12. using System.Globalization;
  13. using System.Data.SqlTypes;
  14. using System.Collections;
  15. // The string storage does not use BitArrays in DataStorage
  16. internal sealed class StringStorage : DataStorage {
  17. private String[] values;
  18. public StringStorage(DataColumn column)
  19. : base(column, typeof(String), String.Empty, StorageType.String) {
  20. }
  21. override public Object Aggregate(int[] recordNos, AggregateType kind) {
  22. int i;
  23. switch (kind) {
  24. case AggregateType.Min:
  25. int min = -1;
  26. for (i = 0; i < recordNos.Length; i++) {
  27. if (IsNull(recordNos[i]))
  28. continue;
  29. min = recordNos[i];
  30. break;
  31. }
  32. if (min >= 0) {
  33. for (i = i+1; i < recordNos.Length; i++) {
  34. if (IsNull(recordNos[i]))
  35. continue;
  36. if (Compare(min, recordNos[i]) > 0) {
  37. min = recordNos[i];
  38. }
  39. }
  40. return Get(min);
  41. }
  42. return NullValue;
  43. case AggregateType.Max:
  44. int max = -1;
  45. for (i = 0; i < recordNos.Length; i++) {
  46. if (IsNull(recordNos[i]))
  47. continue;
  48. max = recordNos[i];
  49. break;
  50. }
  51. if (max >= 0) {
  52. for (i = i+1; i < recordNos.Length; i++) {
  53. if (Compare(max, recordNos[i]) < 0) {
  54. max = recordNos[i];
  55. }
  56. }
  57. return Get(max);
  58. }
  59. return NullValue;
  60. case AggregateType.Count:
  61. int count = 0;
  62. for (i = 0; i < recordNos.Length; i++) {
  63. Object value = values[recordNos[i]];
  64. if (value != null)
  65. count++;
  66. }
  67. return count;
  68. }
  69. throw ExceptionBuilder.AggregateException(kind, DataType);
  70. }
  71. override public int Compare(int recordNo1, int recordNo2) {
  72. string valueNo1 = values[recordNo1];
  73. string valueNo2 = values[recordNo2];
  74. if ((Object)valueNo1 == (Object)valueNo2)
  75. return 0;
  76. if (valueNo1 == null)
  77. return -1;
  78. if (valueNo2 == null)
  79. return 1;
  80. return Table.Compare(valueNo1, valueNo2);
  81. }
  82. override public int CompareValueTo(int recordNo, Object value) {
  83. Debug.Assert(recordNo != -1, "Invalid (-1) parameter: 'recordNo'");
  84. Debug.Assert(null != value, "null value");
  85. string valueNo1 = values[recordNo];
  86. if (null == valueNo1) {
  87. if (NullValue == value) {
  88. return 0;
  89. }
  90. else {
  91. return -1;
  92. }
  93. }
  94. else if (NullValue == value) {
  95. return 1;
  96. }
  97. return Table.Compare(valueNo1, (string)value);
  98. }
  99. public override object ConvertValue(object value) {
  100. if (NullValue != value) {
  101. if (null != value) {
  102. value = value.ToString();
  103. }
  104. else {
  105. value = NullValue;
  106. }
  107. }
  108. return value;
  109. }
  110. override public void Copy(int recordNo1, int recordNo2) {
  111. values[recordNo2] = values[recordNo1];
  112. }
  113. override public Object Get(int recordNo) {
  114. String value = values[recordNo];
  115. if (null != value) {
  116. return value;
  117. }
  118. return NullValue;
  119. }
  120. override public int GetStringLength(int record) {
  121. string value = values[record];
  122. return ((null != value) ? value.Length : 0);
  123. }
  124. override public bool IsNull(int record) {
  125. return (null == values[record]);
  126. }
  127. override public void Set(int record, Object value) {
  128. System.Diagnostics.Debug.Assert(null != value, "null value");
  129. if (NullValue == value) {
  130. values[record] = null;
  131. }
  132. else {
  133. values[record] = value.ToString();
  134. }
  135. }
  136. override public void SetCapacity(int capacity) {
  137. string[] newValues = new string[capacity];
  138. if (values != null) {
  139. Array.Copy(values, 0, newValues, 0, Math.Min(capacity, values.Length));
  140. }
  141. values = newValues;
  142. }
  143. override public object ConvertXmlToObject(string s) {
  144. return s;
  145. }
  146. override public string ConvertObjectToXml(object value) {
  147. return (string)value;
  148. }
  149. override protected object GetEmptyStorage(int recordCount) {
  150. return new String[recordCount];
  151. }
  152. override protected void CopyValue(int record, object store, BitArray nullbits, int storeIndex) {
  153. String[] typedStore = (String[]) store;
  154. typedStore[storeIndex] = values[record];
  155. nullbits.Set(storeIndex, IsNull(record));
  156. }
  157. override protected void SetStorage(object store, BitArray nullbits) {
  158. values = (String[]) store;
  159. // SetNullStorage(nullbits);
  160. }
  161. }
  162. }