C#调用SQL Server中有参数的存储过程
时间：2022-12-26 10:53:21|栏目：.NET代码|点击： 次
一、使用SqlParameter的方式
代码：
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Data.SqlClient;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Configuration;
using System.Collections.ObjectModel;
using System.Reflection;
namespace ExecuteProcBySQLServer
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
}
private void btn_LoadData_Click(object sender, EventArgs e)
{
// 存储过程名称
string strProcName = "usp_yngr_getInfectionCard_test";
//定义存储过程的参数数组
SqlParameter[] paraValues = {
new SqlParameter("@BeginTime",SqlDbType.VarChar),
new SqlParameter("@EndTime",SqlDbType.VarChar),
new SqlParameter("@DateType",SqlDbType.Int),
new SqlParameter("@PtName",SqlDbType.VarChar),
new SqlParameter("@PtChartNo",SqlDbType.VarChar),
new SqlParameter("@DeptCode",SqlDbType.VarChar),
new SqlParameter("@CheckedStatus",SqlDbType.Int)
};
// 给存储过程参数数组赋值
paraValues[0].Value = "2017-06-01";
paraValues[1].Value = "2017-07-01";
paraValues[2].Value = 1;
paraValues[3].Value = "";
paraValues[4].Value = "";
paraValues[5].Value = "";
paraValues[6].Value = 1;
this.dgv_Demo.DataSource = LoadData(strProcName, paraValues);
}
/// <summary>
/// 通过存储过程获取数据
/// </summary>
/// <param name="strProcName">存储过程名称</param>
/// <param name="paraValues">可变的参数数组 数组的个数可以为0，也可以为多个</param>
/// <returns></returns>
private DataTable LoadData(string strProcName, params object[] paraValues)
{
DataTable dt = new DataTable();
string strConn = ConfigurationManager.ConnectionStrings["HealthHospInfection"].ConnectionString;
using (SqlConnection conn = new SqlConnection(strConn))
{
try
{
SqlCommand cmd = new SqlCommand();
cmd.CommandText = strProcName;
// 设置CommandType的类型
cmd.CommandType = CommandType.StoredProcedure;
cmd.Connection = conn;
conn.Open();
if (paraValues != null)
{
//添加参数
cmd.Parameters.AddRange(paraValues);
}
// 取数据
using (SqlDataAdapter adapter = new SqlDataAdapter(cmd))
{
adapter.Fill(dt);
}
}
catch (Exception ex)
{
MessageBox.Show("错误:" + ex.Message + "/r/n跟踪:" + ex.StackTrace);
}
finally
{
conn.Close();
}
}
return dt;
}
}
}
二、使用SqlCommandBuilder
在上面的例子中，得到一个SqlCommand之后要一个一个地去设置参数，这样很麻烦，幸好SqlCommandBuilder有一个静态的方法：
public static void DeriveParameters(SqlCommand command);
使用这个方法有两个局限性：
- 1、参数必须是SqlCommand。
- 2、该方法只能在调用存储过程的时候使用。
同时还要注意到：在使用的时候，数据库连接必须是打开的。
下面的例子演示如何使用这个方法设置存储过程的参数:
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.ComponentModel;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
using System.Drawing;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Windows.Forms;
namespace ExecuteProcBySQLServer
{
public partial class Form2 : Form
{
public Form2()
{
InitializeComponent();
}
private void btn_LoadData_Click(object sender, EventArgs e)
{
// 存储过程名称
string strProcName = "usp_yngr_getInfectionCard_test";
// 定义参数类
object objParams = new
{
BeginTime = "2017-06-01",
EndTime = "2017-07-01",
DateType = 1,
PtName = "",
PtChartNo = "",
DeptCode = "",
CheckedStatus = 1
};
this.dgv_Demo.DataSource = LoadData(strProcName,objParams);
}
private DataTable LoadData(string strProcName,object objParams)
{
DataTable dtInit = new DataTable();
string strConn = ConfigurationManager.ConnectionStrings["HealthHospInfection"].ConnectionString;
using (SqlConnection conn = new SqlConnection(strConn))
{
try
{
SqlCommand cmd = new SqlCommand();
cmd.CommandText = strProcName;
// 设置CommandType的类型
cmd.CommandType = CommandType.StoredProcedure;
cmd.Connection = conn;
conn.Open();
// 添加参数
foreach (var item in GetParameters(cmd, objParams))
{
cmd.Parameters.Add(item);
}
// 取数据
using (SqlDataAdapter adapter = new SqlDataAdapter(cmd))
{
adapter.Fill(dtInit);
}
}
catch (Exception ex)
{
MessageBox.Show("错误:" + ex.Message + "/r/n跟踪:" + ex.StackTrace);
}
finally
{
conn.Close();
}
}
return dtInit;
}
private Collection<SqlParameter> GetParameters(SqlCommand command, object objParam)
{
Collection<SqlParameter> collection = new Collection<SqlParameter>();
if (objParam != null)
{
// 使用反射获取属性
PropertyInfo[] properties = objParam.GetType().GetProperties();
SqlCommandBuilder.DeriveParameters(command);
//int index = 0;
foreach (SqlParameter parameter in command.Parameters)
{
foreach (PropertyInfo property in properties)
{
if (("@" + property.Name.ToLower()).Equals(parameter.ParameterName.ToLower()))
{
parameter.Value = property.GetValue(objParam, null);
collection.Add(parameter);
}
}
}
// 清空所有参数对象
command.Parameters.Clear();
}
return collection;
}
}
}
示例代码下载地址：点此下载
