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

一,回顾

上一部分讲述了“在ADO.NET中利用DataTable对象,将其作为参数传给存贮过程”。
通过DataTable实例,完成了两部分的内容:
  1)DataTable的数据传输给Stored Procedure
  2)利用DataTable的TVP数据,可以参与别的实体数据读写(DataReader)。
这一部分的内容,通过Collection对象,还是要实现上边的两个实例。

二,在ADO.NET中利用Collection对象,将其作为参数传给存贮过程

  通过实例,大家对各个特性和参数的如何使用,有更深刻的感性认识。同时,通过
这些实例的改造,也可做出符合自己的程序代码。
  这次,还是主要输出Sample,包含两部分的内容:
  1)DataTable的数据传输给Stored Procedure
  2)利用DataTable的TVP数据,可以参与别的实体数据读写(DataReader)。
  具体实例如下:

    //---Main Sub
      private void btnCollection_Click(object sender, EventArgs e)
        {
            //------利用OrderItem object
List<OrderItem> orderItems = new List<OrderItem>();
            orderItems.Add(new OrderItem() { OrderId = 901, CustomerId = 67, OrderedAt = DateTime.Now });
            orderItems.Add(new OrderItem() { OrderId = 902, CustomerId = 68, OrderedAt = DateTime.Now });
OrderItemCollection itemCollection = new OrderItemCollection();
            itemCollection.AddRange(orderItems);
            //------利用OrderDetail object
List<OrderDetail> orderDetails = new List<OrderDetail>();
            orderDetails.Add(new OrderDetail() { OrderId = 901, LineNumber = 1, ProductId = 34, Quantity = 2, Price = 10.5m });
            orderDetails.Add(new OrderDetail() { OrderId = 901, LineNumber = 2, ProductId = 100, Quantity = 45, Price = 3.8m });
            orderDetails.Add(new OrderDetail() { OrderId = 901, LineNumber = 3, ProductId = 56, Quantity = 67, Price = 9.1m });
            orderDetails.Add(new OrderDetail() { OrderId = 902, LineNumber = 1, ProductId = 88, Quantity = 5, Price = 88.5m });
            orderDetails.Add(new OrderDetail() { OrderId = 902, LineNumber = 2, ProductId = 1, Quantity = 345, Price = 0.465m });
OrderDetailCollection detailCollection = new OrderDetailCollection();
            detailCollection.AddRange(orderDetails);
          //----
            using (SqlConnection conn = new SqlConnection("Data Source=;Initial Catalog=AdventureWorks;User ID=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", itemCollection);
                    SqlParameter tvpOrderDetail = cmd.Parameters.AddWithValue("@OrderDetails", detailCollection);
                    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", detailCollection);
                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();
                // Output results:
                //------------------
                //OrderId=901, CustomrId=67, LineNumber=1, ProductId=34
                //OrderId=901, CustomrId=67, LineNumber=2, ProductId=100
                //OrderId=901, CustomrId=67, LineNumber=3, ProductId=56
                //OrderId=902, CustomrId=68, LineNumber=1, ProductId=88
                //OrderId=902, CustomrId=68, LineNumber=2, ProductId=1
                //------------------
                conn.Close();
            }
        }
  //---OrderItem object
  public sealed class OrderItem
    {
        public int OrderId { get; set; }
        public int CustomerId { get; set; }
        public DateTime OrderedAt { get; set; }
    }
    //---OrderDetail object
    public sealed class OrderDetail
    {
        public int OrderId { get; set; }
        public int LineNumber { get; set; }
        public int ProductId { get; set; }
        public int Quantity { get; set; }
        public decimal Price { get; set; }
    }
  //---OrderItemCollection
    public sealed class OrderItemCollection: List<OrderItem>, IEnumerable<SqlDataRecord>
    {
        #region IEnumerable<SqlDataRecord> Members
        public new IEnumerator<SqlDataRecord> GetEnumerator()
        {
            SqlDataRecord record = new SqlDataRecord(
                                    new SqlMetaData("OrderId", SqlDbType.Int),
                                    new SqlMetaData("CustomerId", SqlDbType.Int),
                                    new SqlMetaData("OrderedAt", SqlDbType.DateTime));
            foreach(OrderItem item in this.ToArray())
            {
                record.SetInt32(0, item.OrderId);
                record.SetInt32(1, item.CustomerId);
                record.SetDateTime(2, item.OrderedAt);
                yield return record;
            }
        }
        #endregion
    }
    //---OrderDetailCollection
    public sealed class OrderDetailCollection: List<OrderDetail>, IEnumerable<SqlDataRecord>
    {
        #region IEnumerable<SqlDataRecord> Members
        public new IEnumerator<SqlDataRecord> GetEnumerator()
        {
            SqlDataRecord record = new SqlDataRecord(
                                    new SqlMetaData("OrderId", SqlDbType.Int),
                                    new SqlMetaData("LineNumber", SqlDbType.Int),
                                    new SqlMetaData("ProductId", SqlDbType.Int),
                                    new SqlMetaData("Quantity", SqlDbType.Int),
                                    new SqlMetaData("Price", SqlDbType.Money));
            foreach (OrderDetail detail in this.ToArray())
            {
                record.SetInt32(0, detail.OrderId);
                record.SetInt32(1, detail.LineNumber);
                record.SetInt32(2, detail.ProductId);
                record.SetInt32(3, detail.Quantity);
                record.SetDecimal(4, detail.Price);
                yield return record;
            }
        }
        #endregion
    }

三,其他

  通过Table-Values三部分的内容描述和实例,相信大家对TVP的应用有了一定的了解。

在编程中也许有人还是习惯在插入多项或Select多行数据时,使用笨拙的逗号分隔列表或XML,

虽其能够胜任,但不是以习惯的对象方式存在,而且存取速度也很慢。

所以,我建议大家在使用IN语句等需要发送多行数据的编程时,多考虑使用TVP的方式,会取满意的效果。

关于这方面的内容,还需要大家不断的交流和探讨。

四,参考文档

参看URL:

ms-help://MS.SQLCC.v10/MS.SQLSVR.v10.en/s10de_1devconc/html/5e95a382-1e01-4c74-81f5-055612c2ad99.htm

ms-help://MS.MSDNQTR.v90.en/wd_adonet/html/370c16d5-db7b-43e3-945b-ccaab35b739b.htm

时间: 2024-09-25 11:30:11

Table-values parameter(TVP)系列之三: 利用Collection将其作为参数传给SP的相关文章

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

一,回顾         上一部分讲述了"在T-SQL中创建和使用TVP",通过T-SQL建立如下的对象:         1)Tables           dbo.OrderItem           dbo.OrderDetail         2) User-Defined Table Types             dbo.OrderDetail$Udt             dbo.OrderItem$Udt         3) Stored Procedur

Table-values parameter(TVP)系列之一:在T-SQL中创建和使用TVP

一.摘要   表值参数(Table-valued parameters)简称TVP,是SQL Server 2008中引入的一种新特性,它提供了一种内置的方式,让客户端应用可以只通过单独的一条参化数SQL语句,就可以向SQL Server发送多行数据. 二.简介   在表值参数出现以前,当需要发送多行数据到SQL Server,我们只能使用一些替代方案来实现:   (1) 使用一连串的独立参数来表示多列和多行数据的值.       使用这一方法,可以被传递的数据总量受限于可用参数的个数.SQL

艾伟_转载:.NET Discovery 系列之三--深入理解.NET垃圾收集机制(上)

本系列文章导航 .NET Discovery 系列之一--string从入门到精通(上) .NET Discovery 系列之二--string从入门到精通(勘误版下) .NET Discovery 系列之三--深入理解.NET垃圾收集机制(上) .NET Discovery 系列之四--深入理解.NET垃圾收集机制(下) .Net Discovery 系列之五--Me JIT(上) .NET Discovery 系列之六--Me JIT(下) .NET Discovery 系列之七--深入理解

ASP.NET企业开发框架IsLine FrameWork系列之三--七种武器

IsLine FrameWork Provider介绍 其中IsLine.Data.IsLine.AppLog是我要重点介绍的,不过现在先来简单说说各个Provider的作用. DataProvider 与其他框架一样,DataProvider为项目提供了与数据库交互的能力,它的优点在这里不再阐述,这里 只说一下它与其他框架的数据访问层不同的地方. DataProvider同时兼容SQL SERVER与ORACLE两种数据库,并开放IDBOperater接口,用户只要实现 IDBOperater

Red Gate系列之三 SQL Server 开发利器 SQL Prompt 5.3.4.1 Edition T-SQL智能感知分析器 完全破解+使用教程

原文:Red Gate系列之三 SQL Server 开发利器 SQL Prompt 5.3.4.1 Edition T-SQL智能感知分析器 完全破解+使用教程 Red Gate系列之三 SQL Server 开发利器 SQL Prompt 5.3.4.1 Edition T-SQL智能感知分析器 完全破解+使用教程 Red Gate系列文章: Red Gate系列之一 SQL Compare 10.2.0.1337 Edition 数据库比较工具 完全破解+使用教程 Red Gate系列之二

完成端口(CompletionPort)详解 - 手把手教你玩转网络编程系列之三

转载自 PiggyXP(小猪) 完成端口(CompletionPort)详解 - 手把手教你玩转网络编程系列之三 手把手叫你玩转网络编程系列之三    完成端口(Completion Port)详解                                                              ----- By PiggyXP(小猪) 前 言         本系列里完成端口的代码在两年前就已经写好了,但是由于许久没有写东西了,不知该如何提笔,所以这篇文档总是在酝酿之中

Docker生态系统系列之三:服务发现和分布式配置存储

本文讲的是Docker生态系统系列之三:服务发现和分布式配置存储,[编者的话]本文介绍了服务发现与全局可读配置存储两部分内容,不仅介绍了工作原理和工作方式,也介绍了与之相关的故障检测.重配置和安全问题,最后还介绍了常用的服务发现项目.整篇文章将这个知识点介绍的很全面细致,让读者能够对服务发现和全局可读配置存储有一个全面的认识,值得学习. 介绍 容器给寻找大规模设计与部署应用的需求提供了一个优雅的解决方案.在Docker提供实际容器技术的同时,许多其他的项目也在协助开发在部署环境中所需要的引导和沟

web标准实现高效开发系列之三

web|web标准 先点击这里下载Editplus CSS语法自动完成文件 先点击这里下载Editplus xHTML语法自动完成文件应版中朋友的要求我编写了一下xHtml的自动完成文件.下载后解压到EP的根目录下,然后在EP的首选项的语法中设定这个文件.然后用EP打开这个文件,看一下就清楚怎么用了. 举例:打一个"d"然后空格,然后EP就会把这个"d"变成<div></div> 先点击这里下载TopStyle 剪贴库文件 软件下载:TopS

破解索尼PS4系列:利用网页漏洞实现相关的ROP攻击(一)

本文讲的是破解索尼PS4系列:利用网页漏洞实现相关的ROP攻击(一), 目前关于PS4的黑客攻击还非常的少,但这并不能说明PS4 系统非常安全,黑客不会对其发动攻击.本文的目的就是找出PS4的一系列漏洞,最终来获得PS4的内核执行代码. PlayStation 4(简称PS4),是索尼电脑娱乐公司(SCE)推出的家用游戏机.是PlayStation游戏机系列的第四代游戏主机.PlayStation 4采用以AMD为基础的x86-64架构处理器(8核) 除了有一个记录良好的架构处理器,PS4中使用