SqlPipe

在 SqlPipe 类中可以使用的方法中，最容易理解的就是 Execute 方法，它将命令对象作为参数接受。这个方法主要执行命令，并且没有使执行的结果可用于托管框架，而是将结果发送给存储过程的调用者。发送结果的这种形式在语义上与将语句嵌入 T-SQL 存储过程内是一样的。在本文前面描述的性能方面，SqlPipe.Execute 与 T-SQL 是等价的。

create proc proc1 as
   select col1 from dbo.table1;
The equivalent in C# would be:
public static void proc1()
{
   System.Data.SqlServer.SqlCommand cmd=SqlContext.GetCommand();
   cmd.CommandText= "select col1 from dbo.table1";
   SqlContext.GetPipe().Execute(cmd);
}

对于返回的数据是由执行的查询直接产生的情况，SqlPipe.Execute 可以很好地工作。然而，在某些情况下可能希望1）从数据库中获得结果，进行操作或者转换，然后发送它们，或者 2）将结果发送回原地而不是本地 SQL Server 实例。

SqlPipe 提供了一组可以协同工作以使应用程序可以将任何结果返回给调用者的方法：SendResultsStart、SendResultsRow 和 SendResultsEnd。在很大程度上，这些 API 类似于对扩展存储过程的开发人员可用的 srv_describe 和 srv_sendrow API。

SendResultsStart 将 SqlDataRecord 作为参数接受，并且指示返回的新结果集的开头。该 API 从记录对象读取元数据信息，并且将其发送给调用者。该方法有重载，以允许发送元数据以及记录中的实际值。

随后可以返回行，方法是对要发送的每行调用一次 SendResultsRowows。在发送完全部所需的行之后，需要调用 SendResultsEnd 来指示结果集的结尾。

例如，下面的 C# 代码片段表示一个存储过程，它读取 XML 文档（来自 MSDN 的 Really Simple Syndication [RSS] 供给），使用 System.Xml 类进行解析，并且以相关的形式返回信息。请注意，这些代码应该创建为 EXTERNAL_ACCESS（或 UNSAFE）程序集，因为访问 Internet 所需的代码访问安全 (CAS) 权限只有在这些权限集中才是可用的。

// Retrieve the RSS feed
XPathDocument doc = new XPathDocument("http://msdn.microsoft.com/sql/rss.xml");
XPathNavigator nav = doc.CreateNavigator();
XPathNodeIterator i = nav.Select("//item");

// create metadata for four columns
// three of them are string types and one of the is a datetime
SqlMetaData[] rss_results = new SqlMetaData[4];
rss_results[0] = new SqlMetaData("Title", SqlDbType.NVarChar, 250);
rss_results[1] = new SqlMetaData("Publication Date", SqlDbType.DateTime);
rss_results[2] = new SqlMetaData("Description", SqlDbType.NVarChar, 2000);
rss_results[3] = new SqlMetaData("Link", SqlDbType.NVarChar, 1000);

// construct the record which holds metadata and data buffers
SqlDataRecord record = new SqlDataRecord(rss_results);

// cache a SqlPipe instance to avoid repeated calls to SqlContext.GetPipe()
SqlPipe sqlpipe = SqlContext.GetPipe();

// send the metadata, do not send the values in the data record
sqlpipe.SendResultsStart(record, false);

// for each xml node returned, extract four pieces 
// of information and send back each item as a row
while (i.MoveNext())
{
   record.SetString(0, (string)
                       i.Current.Evaluate("string(title[1]/text())"));
   record.SetDateTime(1, DateTime.Parse((string) 
                       i.Current.Evaluate("string(pubDate[1]/text())")));
   record.SetString(2, (string)
                       i.Current.Evaluate("string(description[1]/text())"));
   record.SetString(3, (string)
                       i.Current.Evaluate("string(link[1]/text())"));

   sqlpipe.SendResultsRow(record);
}

// signal end of results
sqlpipe.SendResultsEnd();