C# 动态参数方式调用MYSQL存储过程

zhgc

未验证！

由于MYSQL或MSSQL存储过程参数不确定，一般情况下.net 调用存储过程时需针对具体存储过程写不同的调用方法。 本文通过实现先调用系统表中存储过程参数列表，针对参数名称、类型、精度、长度等，动态生成存储过程调用参数，为通用的存储过程调用提供方便。注意类型转换部分要仔细自行验证，确保转换正确。用于MSSQL时类型转换有所不同。

1. /// <summary>
   
2. /// 获取存储过程的参数,生成存储过程调用参数列表
   
3. /// </summary>
   
4. /// <param name="ProcedureName">存储过程名称</param>
   
5. /// <param name="parameters">存储过程调用参数值集合</param>
   
6. /// <returns></returns>
   
7. private MySqlParameter[] GetMySQLParameters(string ProcedureName, object[] parameters)
   
8. {
   
9.     DataTable dt = new DataTable();
   
10.     string sqlString = "select * from INFORMATION_SCHEMA.PARAMETERS where SPECIFIC_NAME='" + ProcedureName + "' order by ORDINAL_POSITION";
    
11.     if (!Select(sqlString, dt))
    
12.         return null;
    
13. 
    
14.     List<MySqlParameter> sqlParameters = new List<MySqlParameter>();
    
15.     for (int i = 0; i < dt.Rows.Count; i++)
    
16.     {
    
17.         MySqlParameter sqlParameter = new MySqlParameter();
    
18.         sqlParameter.ParameterName = dt.Rows[i]["PARAMETER_NAME"].ToString();
    
19.         sqlParameter.Direction = (dt.Rows[i]["PARAMETER_MODE"].ToString() == "IN") ? ParameterDirection.Input : ParameterDirection.Output;
    
20. 
    
21. 
    
22.         #region 匹配参数类型
    
23.         switch (dt.Rows[i]["DATA_TYPE"].ToString().ToLower ())
    
24.         {
    
25.             case "bit":
    
26.                 if (sqlParameter.Direction == ParameterDirection.Input)
    
27.                     sqlParameter.Value = (bool)(parameters[i]);
    
28.                 sqlParameter.MySqlDbType = MySqlDbType.Bit;
    
29.                 break;
    
30. 
    
31.             case "int64":
    
32.                 if (sqlParameter.Direction == ParameterDirection.Input)
    
33.                     sqlParameter.Value = Convert.ToInt64(parameters[i]);
    
34.                 sqlParameter.MySqlDbType = MySqlDbType.Int64;
    
35.                 break;
    
36.             case "int":
    
37.             case "int32":
    
38.                 if (sqlParameter.Direction == ParameterDirection.Input)
    
39.                     if (parameters[i] == DBNull.Value)//参数为DBNull时
    
40.                     {
    
41.                         sqlParameter.Value = DBNull.Value;
    
42.                     }
    
43.                     else
    
44.                     {
    
45.                         sqlParameter.Value = Convert.ToInt32(parameters[i]);
    
46.                     }
    
47. 
    
48.                 sqlParameter.MySqlDbType = MySqlDbType.Int32;
    
49.                 break;
    
50. 
    
51.             case "decimal":
    
52.                 if (sqlParameter.Direction == ParameterDirection.Input)
    
53.                     sqlParameter.Value = Convert.ToDecimal(parameters[i]);
    
54.                 sqlParameter.MySqlDbType = MySqlDbType.Decimal;
    
55.                 sqlParameter.Precision = Convert.ToByte(dt.Rows[i]["NUMERIC_PRECISION"]);
    
56.                 sqlParameter.Scale = Convert.ToByte(dt.Rows[i]["NUMERIC_SCALE"]);
    
57.                 break;
    
58. 
    
59.             case "varchar":
    
60.                 if (sqlParameter.Direction == ParameterDirection.Input)
    
61.                     sqlParameter.Value = parameters[i];
    
62.                 sqlParameter.Size = (int)dt.Rows[i]["CHARACTER_MAXIMUM_LENGTH"];
    
63.                 sqlParameter.MySqlDbType = MySqlDbType.VarChar;
    
64.                 break;
    
65. 
    
66. 
    
67.             case "tinyblob":
    
68.                 if (sqlParameter.Direction == ParameterDirection.Input)
    
69.                     sqlParameter.Value = (string)parameters[i];
    
70.                 sqlParameter.MySqlDbType = MySqlDbType.TinyBlob;
    
71.                 break;
    
72. 
    
73.             case "meduimblob":
    
74.                 if (sqlParameter.Direction == ParameterDirection.Input)
    
75.                     sqlParameter.Value = (string)parameters[i];
    
76.                 sqlParameter.MySqlDbType = MySqlDbType.MediumBlob;
    
77.                 break;
    
78.             case "longblob":
    
79.                 if (sqlParameter.Direction == ParameterDirection.Input)
    
80.                     sqlParameter.Value = (string)parameters[i];
    
81.                 sqlParameter.MySqlDbType = MySqlDbType.LongBlob;
    
82.                 break;
    
83.             case "blob":
    
84.                 if (sqlParameter.Direction == ParameterDirection.Input)
    
85.                     sqlParameter.Value = (string)parameters[i];
    
86.                 sqlParameter.MySqlDbType = MySqlDbType.Blob;
    
87.                 break;
    
88. 
    
89.             case "tinytext":
    
90.                 if (sqlParameter.Direction == ParameterDirection.Input)
    
91.                     sqlParameter.Value = (string)parameters[i];
    
92.                 sqlParameter.MySqlDbType = MySqlDbType.TinyText;
    
93.                 break;
    
94.             case "text":
    
95.                 if (sqlParameter.Direction == ParameterDirection.Input)
    
96.                     sqlParameter.Value = (string)parameters[i];
    
97.                 sqlParameter.MySqlDbType = MySqlDbType.Text;
    
98.                 break;
    
99. 
    
100.             case "datetime":
     
101.                 if (sqlParameter.Direction == ParameterDirection.Input)
     
102.                     sqlParameter.Value = parameters[i];
     
103.                 sqlParameter.MySqlDbType = MySqlDbType.DateTime;
     
104.                 break;
     
105.             case "smalldatetime":
     
106.                 if (sqlParameter.Direction == ParameterDirection.Input)
     
107.                     sqlParameter.Value = (DateTime)parameters[i];
     
108.                 sqlParameter.MySqlDbType = MySqlDbType.DateTime;
     
109.                 break;
     
110. 
     
111.             case "uniqueidentifier":
     
112.                 sqlParameter.MySqlDbType = MySqlDbType.Text;
     
113.                 break;
     
114. 
     
115.             default: break;
     
116.         }
     
117.         #endregion
     
118. 
     
119.         sqlParameters.Add(sqlParameter);
     
120.     }
     
121. 
     
122.     return sqlParameters.ToArray ();
     
123. }
     
124. 
     
125. /// <summary>
     
126. /// 调用存储过程基本方法，返回DataSet结果
     
127. /// </summary>
     
128. /// <param name="storedProcName">存储过程</param>
     
129. /// <param name="parameters">IDataParameter参数</param>
     
130. /// <returns></returns>
     
131. public DataSet RunProcedure(string storedProcName, IDataParameter[] parameters)
     
132. {
     
133.     using (MySqlConnection connection = new MySqlConnection(this.connectString))
     
134.     {
     
135.         connection.Open();
     
136.         MySqlCommand cmd = new MySqlCommand(storedProcName, connection);
     
137. 
     
138.         cmd.CommandType = CommandType.StoredProcedure;
     
139.         if (parameters != null)
     
140.         {
     
141.             foreach (MySqlParameter parameter in parameters)
     
142.             {
     
143.                 if ((parameter.Direction == ParameterDirection.InputOutput || parameter.Direction == ParameterDirection.Input) &&
     
144.                     (parameter.Value == null))
     
145.                 {
     
146.                     parameter.Value = DBNull.Value;
     
147.                 }
     
148.                 cmd.Parameters.Add(parameter);
     
149.             }
     
150. 
     
151.         }
     
152.         using (MySqlDataAdapter da = new MySqlDataAdapter(cmd))
     
153.         {
     
154.             DataSet ds = new DataSet();
     
155.             try
     
156.             {
     
157.                 da.Fill(ds, "ds");
     
158.                 cmd.Parameters.Clear();
     
159.             }
     
160.             catch (MySql.Data.MySqlClient.MySqlException ex)
     
161.             {
     
162.                 throw new Exception(ex.Message);
     
163.             }
     
164.             return ds;
     
165.         }
     
166.     }
     
167. 
     
168. }
     
169. 
     
170. 
     
171. //调用存储过程返回DataSet结果集：
     
172. public Dataset GetResultByProcedure(string ProcedureName, object[] parameters)
     
173. {
     
174.    MySqlParameter[] sqlParameters = GetMySQLParameters(ProcedureName,parameters);
     
175.    DataSet ds= RunProcedure(ProcedureName, sqlParameters);
     
176.    return ds;
     
177. }

复制代码

实际使用：
如通过ID获取某城市信息，存储过程为Procedure_GetCityByID，参数为ID，ID=1，则：
Dataset ds=GetResultByProcedure("Procedure_GetCityByID",1)