一,回顾 @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