Объект SqlPipe

Область применения: SQL Server

В предыдущих версиях SQL Server очень часто записывает хранимую процедуру (или расширенную хранимую процедуру), которая отправляет результаты или выходные параметры вызывающему клиенту.

В хранимой процедуре Transact-SQL любая инструкция SELECT , возвращающая ноль или больше строк, отправляет результаты в канал подключенного вызывающего абонента.

Для объектов базы данных среды CLR, работающих в SQL Server, можно отправлять результаты в подключенный канал с помощью методов Send объекта SqlPipe. Обратитесь к свойству Pipe объекта SqlContext , чтобы получить объект SqlPipe . Класс SqlPipe принципиально подобен классу Response в ASP.NET. Дополнительные сведения см. в справочной документации по классу SqlPipe в пакете средств разработки программного обеспечения .NET Framework.

Возврат табличных результатов и сообщений

Класс SqlPipe имеет метод Send , который имеет три перегрузки. В их число входят:

• void Send(string message)

• void Send(SqlDataReader reader)

• void Send(SqlDataRecord record)

Метод Send пересылает данные напрямую клиенту или вызывающему. Обычно клиент использует выход из SqlPipe, но в случае вложенных хранимых процедур CLR потребителем выхода также может быть хранимая процедура. Например, Procedure1 вызывает SqlCommand.ExecuteReader() с текстом команды «EXEC Procedure2». Procedure2 — это также управляемая хранимая процедура. Если Procedure2 вызывает SqlPipe.Send( SqlDataRecord ), строка передается модулю чтения Procedure1, но не клиенту.

Метод Send отправляет строковое сообщение, которое отображается на клиенте как информационное сообщение, эквивалентное PRINT в Transact-SQL. Метод может также послать однострочный результирующий набор с помощью SqlDataRecordили многострочный результирующий набор с использованием SqlDataReader.

Объект SqlPipe также имеет метод ExecuteAndSend . Этот метод можно использовать, чтобы выполнять команды (переданные как объект SqlCommand ) и напрямую отправлять результаты назад вызывающему. Если в представленной команде есть ошибки, исключения передаются в канал, но копия пересылается также вызывающему управляемому коду. Если вызывающий код не перехватывает исключение, он распространяет стек на код Transact-SQL и отображается в выходных данных дважды. Если вызывающий код перехватывает исключение, потребитель канала по-прежнему видит ошибку, но повторяющейся ошибки нет.

Он может принять только команду SqlCommand , которая ассоциирована с контекстным соединением. Этот метод не может принять команду, которая сопоставлена соединению вне данного контекста.

Возвращение пользовательских результирующих наборов

Управляемые хранимые процедуры могут отправлять результирующие наборы, которые не исходят из SqlDataReader. Метод SendResultsStart вместе с методами SendResultsRow и SendResultsEndпозволяет хранимым процедурам отправлять клиенту пользовательские результирующие наборы.

МетодSendResultsStart принимает объект SqlDataRecord в качестве ввода. Он отмечает начало результирующего набора и при помощи метаданных записи составляет метаданные, описывающие результирующий набор. Он не отправляет значение записи с SendResultsStart. Все последующие строки, отправленные при помощи метода SendResultsRow, должны соответствовать этому определению метаданных.

Примечание.

После вызова метода SendResultsStart можно вызвать только методы SendResultsRow и SendResultsEnd . Вызов любого другого метода в том же экземпляре объекта SqlPipe приводит к исключению InvalidOperationException. МетодSendResultsEnd возвращает объект SqlPipe в исходное состояние, в котором можно вызывать другие методы.

Пример

Хранимая процедура uspGetProductLine возвращает название, номер продукта, цвет и цену по прейскуранту всех продуктов в указанной линейке продуктов. Эта хранимая процедура принимает точные совпадения с prodLine.

C#

using System;  
using System.Data;  
using System.Data.SqlClient;  
using System.Data.SqlTypes;  
using Microsoft.SqlServer.Server;  
  
public partial class StoredProcedures  
{  
[Microsoft.SqlServer.Server.SqlProcedure]  
public static void uspGetProductLine(SqlString prodLine)  
{  
    // Connect through the context connection.  
    using (SqlConnection connection = new SqlConnection("context connection=true"))  
    {  
        connection.Open();  
  
        SqlCommand command = new SqlCommand(  
            "SELECT Name, ProductNumber, Color, ListPrice " +  
            "FROM Production.Product " +   
            "WHERE ProductLine = @prodLine;", connection);  
  
        command.Parameters.AddWithValue("@prodLine", prodLine);  
  
        try  
        {  
            // Execute the command and send the results to the caller.  
            SqlContext.Pipe.ExecuteAndSend(command);  
        }  
        catch (System.Data.SqlClient.SqlException ex)  
        {  
            // An error occurred executing the SQL command.  
        }  
     }  
}  
};  

Visual Basic

Imports System  
Imports System.Data  
Imports System.Data.SqlClient  
Imports System.Data.SqlTypes  
Imports Microsoft.SqlServer.Server  
  
Partial Public Class StoredProcedures  
<Microsoft.SqlServer.Server.SqlProcedure()> _  
Public Shared Sub uspGetProductLine(ByVal prodLine As SqlString)  
    Dim command As SqlCommand  
  
    ' Connect through the context connection.  
    Using connection As New SqlConnection("context connection=true")  
        connection.Open()  
  
        command = New SqlCommand( _  
        "SELECT Name, ProductNumber, Color, ListPrice " & _  
        "FROM Production.Product " & _  
        "WHERE ProductLine = @prodLine;", connection)  
        command.Parameters.AddWithValue("@prodLine", prodLine)  
  
        Try  
            ' Execute the command and send the results   
            ' directly to the caller.  
            SqlContext.Pipe.ExecuteAndSend(command)  
        Catch ex As System.Data.SqlClient.SqlException  
            ' An error occurred executing the SQL command.  
        End Try  
    End Using  
End Sub  
End Class  

Следующая инструкция Transact-SQL выполняет процедуру uspGetProduct , которая возвращает список гастролей велосипедных продуктов.

EXEC uspGetProductLineVB 'T';  

См. также

Объект SqlDataRecord
Хранимые процедуры CLR
Внутрипроцессные расширения SQL Server для ADO.NET