　C#　

您现在的位置：中国IT实验室 >> Dotnet >> C# >> 正文

使用C#创建SQL Server的存储过程

ChinaItLab

Bipin Jo…

2007-6-26

保存本文

推荐给好友

收藏本页

欢迎进入.NET社区论坛，与200万技术人员互动交流 >>进入

没有返回值的存储过程
　在这一节中，我们将会看到如何写一个执行了一些逻辑，但是却没有任何返回值和输出参数的存储过程。在这个例子里，我们将创建一个名为“ChangeCompanyName”的存储过程，它用来修改Customers表中CompanyName字段的值。这个存储过程需要两个参数 – CustomerID（需要更改公司名称的客户的ID）和CompanyName（新的公司名称）。 “ChangeCompanyName”存储过程完成后的代码如下：

[SqlProcedure]

public static void ChangeCompanyName

(SqlString CustomerID, SqlString CompanyName)

{

SqlConnection cnn = new SqlConnection

("context connection=true");

cnn.Open();

SqlCommand cmd = new SqlCommand();

cmd.Connection = cnn;

cmd.CommandText = "update customers set

companyname=@p1 where customerid=@p2";

SqlParameter p1 = new SqlParameter("@p1", CompanyName);

SqlParameter p2 = new SqlParameter("@p2", CustomerID);

cmd.Parameters.Add(p1);

cmd.Parameters.Add(p2);

int i=cmd.ExecuteNonQuery();

cnn.Close();

SqlContext.Pipe.Send(i.ToString());

}

　仔细看一下这个ChangeCompanyName()方法。它是一个静态方法并且没有返回值（void）。它需要两个名为CustomerID和CompanyName的参数。请注意这两个参数的数据类型都是SqlString。 SqlString可以用来代替SQL Server中的nvarchar数据类型。这个方法用了一个[SqlProcedure]属性来修饰。该属性用于标记ChangeCompanyName()方法是一个SQL Server存储过程。

　在方法内我们创建了一个SqlConnection对象，并设置其连接字符串为“context connection = true”。 “上下文连接”可以让你使用当前登录到数据库的用户作为你的登录数据库的验证信息。本例中，ChangeCompanyName()方法将会转换为存储过程，然后保存到Northwind数据库里。所以在这里的“上下文连接”指的就是Northwind数据库。这样你就不需要再写任何关于登录数据库的验证信息了。

　接下来是打开数据库连接。然后通过设置SqlCommand对象的Connection和CommandText属性，让其执行更新操作。同时，我们还需要设置两个参数。这样通过调用ExecuteNonQuery()方法就可以执行更新操作了。再接下来就是关闭连接。

　最后，将ExecuteNonQuery()方法的返回值发送到客户端。当然你也可以不做这一步。现在我们来了解一下SqlContext类的使用。 SqlContext类用于在服务端和客户端之间传递处理结果。本例使用了Send()方法发送一个字符串返回给调用者。

返回从表中读取的一条或多条记录的存储过程
　我们在使用存储过程时，经常会SELECT一条或多条记录。你可以采用两种方法来创建这样的存储过程。

　首先我们创建一个名为GetAllCustomers()的方法，代码如下：

[SqlProcedure]

public static void GetAllCustomers()

{

SqlConnection cnn = new SqlConnection

("context connection=true");

cnn.Open();

SqlCommand cmd = new SqlCommand();

cmd.Connection = cnn;

cmd.CommandText = "select * from customers";

SqlDataReader reader = cmd.ExecuteReader();

SqlContext.Pipe.Send(reader);

reader.Close();

cnn.Close();

}

　这个GetAllCustomers()方法用了一个[SqlProcedure]属性来修饰。在方法内创建一个SqlConnection和一个SqlCommand对象。然后使用ExecuteReader()方法来执行SELECT语句。接下来用Send()方法将取得的SqlDataReader数据发送到客户端。最后就是关闭SqlDataReader和SqlConnection。在这种方法中，是我们自己创建的SqlDataReader。其实，我们也可以把这个任务交给SqlContext类去完成，代码如下：

[SqlProcedure]

public static void GetCustomerByID

(SqlString CustomerID)

{

SqlConnection cnn = new SqlConnection

("context connection=true");

cnn.Open();

SqlCommand cmd = new SqlCommand();

cmd.Connection = cnn;

cmd.CommandText = "select * from customers

where customerid=@p1";

SqlParameter p1 = new SqlParameter("@p1", CustomerID);

cmd.Parameters.Add(p1);

SqlContext.Pipe.ExecuteAndSend(cmd);

cnn.Close();

}

　GetCustomerByID()方法需要一个参数 – CustomerID，它将从Customers表中返回某个customer的记录。这个方法内的代码，除了ExecuteAndSend()方法外，你应该都已经比较熟悉了。 ExecuteAndSend()方法接收一个SqlCommand对象作为参数，执行它就会返回数据集给客户端。

有输出参数的存储过程
　我们在使用存储过程时，经常会通过输出参数返回一个经过计算的值。所以，现在让我们来看一看如何创建具有一个或多个输出参数的存储过程。

[SqlProcedure]

public static void GetCompanyName

(SqlString CustomerID,out SqlString CompanyName)

{

SqlConnection cnn = new SqlConnection

("context connection=true");

cnn.Open();

SqlCommand cmd = new SqlCommand();

cmd.Connection = cnn;

cmd.CommandText = "select companyname from

customers where customerid=@p1";

SqlParameter p1 = new SqlParameter

("@p1", CustomerID);

cmd.Parameters.Add(p1);

object obj = cmd.ExecuteScalar();

cnn.Close();

CompanyName = obj.ToString();

}

　这是一个名为GetCompanyName()的方法，它需要两个参数。第一个参数是CustomerID，它是一个输入参数；第二个参数是CompanyName，它是一个输出参数（用关键字out来指明）。这两个参数都是SqlString类型的。 GetCompanyName()方法会接收一个CustomerID参数，然后返回CompanyName（作为输出参数）。

　该方法内的代码首先设置了SqlConnection和SqlCommand对象。然后，使用ExecuteScalar()方法来执行SELECT语句。 ExecuteScalar()方法返回的值是一个object类型，它其实就是公司名称。最后将输出参数CompanyName设置为这个值。

上一页 [1] [2] [3] 下一页

【责编:Peng】