SqlParameterCollection.cs 5.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251
  1. //
  2. // System.Data.SqlClient.SqlParameterCollection.cs
  3. //
  4. // Author:
  5. // Rodrigo Moya ([email protected])
  6. // Daniel Morgan ([email protected])
  7. // Tim Coleman ([email protected])
  8. //
  9. // (C) Ximian, Inc 2002
  10. // Copyright (C) Tim Coleman, 2002
  11. //
  12. using System;
  13. using System.ComponentModel;
  14. using System.Data;
  15. using System.Data.Common;
  16. using System.Collections;
  17. namespace System.Data.SqlClient {
  18. /// <summary>
  19. /// Collects all parameters relevant to a Command object
  20. /// and their mappings to DataSet columns.
  21. /// </summary>
  22. public sealed class SqlParameterCollection : MarshalByRefObject, IDataParameterCollection, IList, ICollection, IEnumerable
  23. {
  24. private ArrayList parameterList = new ArrayList();
  25. public IEnumerator GetEnumerator()
  26. {
  27. return parameterList.GetEnumerator ();
  28. }
  29. public int Add( object value)
  30. {
  31. // Call the add version that receives a SqlParameter
  32. // Check if value is a SqlParameter.
  33. CheckType(value);
  34. Add((SqlParameter) value);
  35. return IndexOf (value);
  36. }
  37. public SqlParameter Add(SqlParameter value)
  38. {
  39. parameterList.Add(value);
  40. return value;
  41. }
  42. public SqlParameter Add(string parameterName, object value)
  43. {
  44. SqlParameter sqlparam = new SqlParameter();
  45. sqlparam.Value = value;
  46. // TODO: Get the dbtype and Sqldbtype from system type of value.
  47. return Add(sqlparam);
  48. }
  49. public SqlParameter Add(string parameterName, SqlDbType sqlDbType)
  50. {
  51. SqlParameter sqlparam = new SqlParameter();
  52. sqlparam.ParameterName = parameterName;
  53. sqlparam.SqlDbType = sqlDbType;
  54. return Add(sqlparam);
  55. }
  56. public SqlParameter Add(string parameterName,
  57. SqlDbType sqlDbType, int size)
  58. {
  59. SqlParameter sqlparam = new SqlParameter();
  60. sqlparam.ParameterName = parameterName;
  61. sqlparam.SqlDbType = sqlDbType;
  62. sqlparam.Size = size;
  63. return Add(sqlparam);
  64. }
  65. public SqlParameter Add(string parameterName,
  66. SqlDbType sqlDbType, int size, string sourceColumn)
  67. {
  68. SqlParameter sqlparam = new SqlParameter();
  69. sqlparam.ParameterName = parameterName;
  70. sqlparam.SqlDbType = sqlDbType;
  71. sqlparam.Size = size;
  72. sqlparam.SourceColumn = sourceColumn;
  73. return Add(sqlparam);
  74. }
  75. [MonoTODO]
  76. public void Clear()
  77. {
  78. throw new NotImplementedException ();
  79. }
  80. public bool Contains(object value)
  81. {
  82. // Check if value is a SqlParameter
  83. CheckType(value);
  84. return Contains(((SqlParameter)value).ParameterName);
  85. }
  86. [MonoTODO]
  87. public bool Contains(string value)
  88. {
  89. for(int p = 0; p < parameterList.Count; p++) {
  90. if(((SqlParameter)parameterList[p]).ParameterName.Equals(value))
  91. return true;
  92. }
  93. return false;
  94. }
  95. [MonoTODO]
  96. public void CopyTo(Array array, int index)
  97. {
  98. throw new NotImplementedException ();
  99. }
  100. public int IndexOf (object value)
  101. {
  102. // Check if value is a SqlParameter
  103. CheckType(value);
  104. return IndexOf(((SqlParameter)value).ParameterName);
  105. }
  106. public int IndexOf (string parameterName)
  107. {
  108. return parameterList.IndexOf (parameterName);
  109. }
  110. public void Insert (int index, object value)
  111. {
  112. parameterList.Insert (index, value);
  113. }
  114. public void Remove (object value)
  115. {
  116. parameterList.Remove (value);
  117. }
  118. public void RemoveAt (int index)
  119. {
  120. parameterList.RemoveAt (index);
  121. }
  122. [MonoTODO]
  123. public void RemoveAt (string parameterName)
  124. {
  125. throw new NotImplementedException ();
  126. }
  127. [MonoTODO]
  128. public int Count {
  129. get { return parameterList.Count; }
  130. }
  131. object IList.this[int index] {
  132. [MonoTODO]
  133. get {
  134. return (SqlParameter) this[index];
  135. }
  136. [MonoTODO]
  137. set {
  138. this[index] = (SqlParameter) value;
  139. }
  140. }
  141. public SqlParameter this[int index] {
  142. get {
  143. return (SqlParameter) parameterList[index];
  144. }
  145. set {
  146. parameterList[index] = (SqlParameter) value;
  147. }
  148. }
  149. object IDataParameterCollection.this[string parameterName] {
  150. [MonoTODO]
  151. get {
  152. return this[parameterName];
  153. }
  154. [MonoTODO]
  155. set {
  156. CheckType(value);
  157. this[parameterName] = (SqlParameter) value;
  158. }
  159. }
  160. public SqlParameter this[string parameterName] {
  161. get {
  162. for(int p = 0; p < parameterList.Count; p++) {
  163. if(parameterName.Equals(((SqlParameter)parameterList[p]).ParameterName))
  164. return (SqlParameter) parameterList[p];
  165. }
  166. throw new IndexOutOfRangeException("The specified name does not exist: " + parameterName);
  167. }
  168. set {
  169. for(int p = 0; p < parameterList.Count; p++) {
  170. if(parameterName.Equals(((SqlParameter)parameterList[p]).ParameterName))
  171. parameterList[p] = value;
  172. }
  173. throw new IndexOutOfRangeException("The specified name does not exist: " + parameterName);
  174. }
  175. }
  176. bool IList.IsFixedSize {
  177. get {
  178. throw new NotImplementedException ();
  179. }
  180. }
  181. bool IList.IsReadOnly {
  182. get {
  183. throw new NotImplementedException ();
  184. }
  185. }
  186. bool ICollection.IsSynchronized {
  187. get {
  188. throw new NotImplementedException ();
  189. }
  190. }
  191. object ICollection.SyncRoot {
  192. get {
  193. throw new NotImplementedException ();
  194. }
  195. }
  196. /// <summary>
  197. /// This method checks if the parameter value is of
  198. /// SqlParameter type. If it doesn't, throws an InvalidCastException.
  199. /// </summary>
  200. private void CheckType(object value)
  201. {
  202. if(!(value is SqlParameter))
  203. throw new InvalidCastException("Only SQLParameter objects can be used.");
  204. }
  205. }
  206. }