Table-values parameter(TVP)系列之二: 利用DataTable将其作为参数传给SP

前端之家收集整理的这篇文章主要介绍了Table-values parameter(TVP)系列之二: 利用DataTable将其作为参数传给SP前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

一,回顾 @H_404_1@        上一部分讲述了“在T-sql中创建和使用TVP”,通过T-sql建立如下的对象: @H_404_1@        1)Tables @H_404_1@          dbo.OrderItem @H_404_1@          dbo.OrderDetail @H_404_1@        2) User-Defined Table Types @H_404_1@            dbo.OrderDetail$Udt @H_404_1@            dbo.OrderItem$Udt @H_404_1@        3) Stored Procedures @H_404_1@            dbo.OrderItem$Insert @H_404_1@二,在ADO.NET中利用DataTable对象,将其作为参数传给存贮过程 @H_404_1@  相信大家对DataTable的利用已经非常熟悉了,在此主要以Sample为主。 @H_404_1@  ***这次的Sample数据,还是利用上一部分已有的对象,完成DataTable传输数据的操作。 @H_404_1@  主要包含两部分的内容: @H_404_1@  1)DataTable的数据传输给Stored Procedure @H_404_1@  2)利用DataTable的TVP数据,可以参与别的实体数据读写(DataReader)。 @H_404_1@  具体实例如下:

private void btnDataTable_Click(object sender,EventArgs e)
      {
          //---OrderItem
          DataTable dtOrderItem = new DataTable();
          dtOrderItem.Columns.Add("OrderId",typeof(int));
          dtOrderItem.Columns.Add("CustomerId",typeof(int));
          dtOrderItem.Columns.Add("OrderAt",typeof(DateTime));
          //---OrderDetail
          DataTable dtOrderDetail = new DataTable();
          dtOrderDetail.Columns.Add("OrderId",typeof(int));
          dtOrderDetail.Columns.Add("LineNumber",typeof(int));
          dtOrderDetail.Columns.Add("ProductId",typeof(int));
          dtOrderDetail.Columns.Add("Quantity",typeof(int));
          dtOrderDetail.Columns.Add("Price",typeof(decimal));
          //---Add data
          dtOrderItem.Rows.Add(new object[] { 1001,5001,DateTime.Now });
          dtOrderDetail.Rows.Add(new object[] { 1001,1,101,15,12.28 });
          dtOrderDetail.Rows.Add(new object[] { 1001,2,102,20,102.12 });
          dtOrderDetail.Rows.Add(new object[] { 1001,3,103,23,0.85 });
          dtOrderItem.Rows.Add(new object[] { 2001,6001,DateTime.Now });
          dtOrderDetail.Rows.Add(new object[] { 2001,201,5,79.59 });
          dtOrderDetail.Rows.Add(new object[] { 2001,202,200,3.25 });
          //----
          using (sqlConnection conn = new sqlConnection("Data Source=;Initial Catalog=AdventureWorks;UserID=sa;Password="))
          {
              conn.Open();
              //---Passing a Table-Valued Parameter to a Stored Pcocedure
              using (sqlCommand cmd = new sqlCommand("dbo.OrderItem$Insert",conn))
              {
                  cmd.CommandType = CommandType.StoredProcedure;
                  //---注意:下边的两个参数名,要和SP的参数名一致。
                  sqlParameter tvpOrderItem = cmd.Parameters.AddWithValue("@OrderHeaders",dtOrderItem);
                  sqlParameter tvpOrderDetail = cmd.Parameters.AddWithValue("@OrderDetails",dtOrderDetail);
                  tvpOrderItem.sqlDbType = sqlDbType.Structured;
                  tvpOrderDetail.sqlDbType = sqlDbType.Structured;
                  cmd.ExecuteNonQuery();
              }
              //---Streadming rows with a dataReader
              string sql= @"select tvp1.OrderId,tvp1.CustomerId,tvp2.LineNumber,tvp2.ProductId
                          from    dbo.OrderItem as tvp1 INNER JOIN @tvpDetail as tvp2 ON tvp1.OrderId=tvp2.OrderId
                          order by tvp2.OrderId,tvp2.LineNumber;";
              sqlCommand readCommand = new sqlCommand(sql,conn);
              readCommand.CommandType = CommandType.Text;
              sqlParameter tvpDetail = readCommand.Parameters.AddWithValue("@tvpDetail",dtOrderDetail);
              tvpDetail.sqlDbType = sqlDbType.Structured;
              tvpDetail.TypeName = "dbo.OrderDetail$Udt";
              sqlDataReader reader = readCommand.ExecuteReader();
              while (reader.Read())
              {
                  Console.WriteLine(string.Format("OrderId={0},CustomrId={1},LineNumber={2},ProductId={3}",reader.GetInt32(0),reader.GetInt32(1),reader.GetInt32(2),reader.GetInt32(3)));
              }
              reader.Close();
              //读出结果如下:
              //-----------------------
              //OrderId=1001,CustomrId=5001,LineNumber=1,ProductId=101
              //OrderId=1001,LineNumber=2,ProductId=102
              //OrderId=1001,LineNumber=3,ProductId=103
              //OrderId=2001,CustomrId=6001,ProductId=201
              //OrderId=2001,ProductId=202
              //-----------------------
              conn.Close();
          }
      } 

三,参照文献  @H_404_1@  MSDN:Table-Valued Parameters in sql Server 2008 (ADO.NET) @H_404_1@  URL: ms-help://MS.MSDNQTR.v90.en/wd_adonet/html/370c16d5-db7b-43e3-945b-ccaab35b739b.htm

猜你在找的程序笔记相关文章