46378 (665526), страница 2

using System;

using System.Data;

using System.Data.Sql;

using System.Data.SqlServer;

using System.Data.SqlTypes;

public class StoredProcedure

{

[SqlProcedure("HelloWorld")]

public static void MyProcedure()

{

SqlContext.GetPipe().Send("Hello, Yukon!");

}

};

Метод или свойство

Описание

public void Execute (System.Data.SqlServer.SqlCommand command )public void Execute

(System.Data.SqlServer.SqlExecutionContext request )

Выполняет указанную команду или запрос и возвращает результат клиенту. Аналог выполнения оператора SELECT … FROM … в хранимой процедуре на T-SQL.

public void Send (System.Data.SqlServer.SqlError se)

Возвращает клиенту указанную ошибку.

public void Send (System.Data.Sql.ISqlReader reader)

Отправляет клиенту все записи из указанного набора.

public void SendResultsStart (System.Data.Sql.ISqlRecord record , bool sendRow)

Посылает клиенту первую запись в наборе записей. Устанавливает свойство SendingResults в true.

public System.Boolean SendingResults { get; }

Указывает, что процесс отправки набора записей не окончен.

public void SendResultsRow (System.Data.Sql.ISqlRecord record)public void Send (System.Data.Sql.ISqlRecord record )

Посылает клиенту очередную запись в наборе. Требует SendingResults == true.

public void SendResultsEnd ( )

Сигнализирует об окончании набора записей и устанавливает свойство SendingResults в false.

[SqlProcedure()]

public static void CurrencyCourse(

[SqlMapping(typeof(SqlDateTime))] DateTime start,

[SqlMapping(typeof(SqlDateTime))] DateTime end)

{

using (SqlCommand cmd = SqlContext.GetCommand())

{

cmd.CommandText = @"

select changeDate, course from Course

where changeDate between @start and @end";

cmd.Parameters.AddWithValue("@start", start);

cmd.Parameters.AddWithValue("@end", end);

DateTime current = start;

SqlDecimal course = SqlDecimal.Null; // сначала курс отсутствует;

SqlMetaData[] recstruct = new SqlMetaData[2];

recstruct[0] = new SqlMetaData("D", SqlDbType.DateTime);

recstruct[1] = new SqlMetaData("course", SqlDbType.Decimal, 10, 4);

SqlDataRecord rec = new SqlDataRecord(recstruct);

SqlPipe pipe = SqlContext.GetPipe();

pipe.SendResultsStart(rec, false);

using (SqlDataReader r = cmd.ExecuteReader())

{

while (r.Read())

{

rec.SetSqlDecimal(1, course);

while(current < r.GetDateTime(0))

{

rec.SetDateTime(0, current);

pipe.SendResultsRow(rec);

current = current.AddDays(1);

}

course = r.GetDecimal(1);

}

}

rec.SetSqlDecimal(1, course);

while (current <= end)

{

rec.SetDateTime(0, current);

pipe.SendResultsRow(rec);

current = current.AddDays(1);

}

pipe.SendResultsEnd();

}

}

(

D datetime,

course decimal(10, 4)

)

pipe.SendResultsStart(rec, false);

pipe.SendResultsEnd();

ПРИМЕЧАНИЕ

Есть еще агрегатные функции, но их реализация существенным образом отличается от «обычных», и поэтому мы рассмотрим их в следующем разделе.

ПРИМЕЧАНИЕ

В отличие от встроенных функций, обращаться к «самодельным» нужно с уважением – предваряя имя функции именем схемы (которое по умолчанию совпадает с именем ее владельца). Например, я вызывал функцию из следующего подраздела примерно вот так:

select dbo.RevertString(“Beavis rulez”)

[SqlFunc()]

[SqlFunction(

DataAccess = DataAccessKind.None,

SystemDataAccess = SystemDataAccessKind.None,

IsDeterministic = true,

IsPrecise = true)]

public static SqlString RevertString(SqlString str)

{

if (str.IsNull)

return SqlString.Null;

System.Text.StringBuilder sb = new

System.Text.StringBuilder(str.Value.Length);

for (int i=str.Value.Length-1; i>=0; i--)

sb.Append(str.Value[i]);

return new SqlString(sb.ToString());

}

Имя параметра

Описание

DataAccess

Какой доступ осуществляет функция к пользовательским данным в базе:DataAccessKind.None – никакого.DataAccessKind.Read – читает данные.

SystemDataAccess

Какой доступ осуществляет функция к системным данным в базе:SystemDataAccessKind.None – никакого.SystemDataAccessKind.Read – читает данные.

IsDeterministic

Является ли функция детерминистической, т.е. зависит ли ее возвращаемое значение только от переданных параметров.

IsPrecise

Выполняет ли функция округления в процессе работы.

ПРИМЕЧАНИЕ

Это позволяет использовать эту функцию в максимально широком контексте – например, можно создать вычисляемую колонку на ее основе, и даже индекс по этой колонке. Это может быть полезно для сортировки, например, списка получателей e-mail. Сортировка по обращенному адресу поставит рядом адреса в одном домене, и можно будет оптимизировать рассылку писем.

[SqlFunc(TableDefinition = "D datetime, course decimal(10, 4)")]

[SqlFunction(DataAccess = DataAccessKind.Read,

SystemDataAccess = SystemDataAccessKind.None,

IsDeterministic = false, IsPrecise = true)]

public static ISqlReader GetCourseChanges(DateTime start, DateTime end)

{

SqlCommand cmd = SqlContext.GetCommand();

cmd.CommandText = @"

select changeDate, course from Course

where changeDate between @start and @end";

cmd.Parameters.AddWithValue("@start", start);

cmd.Parameters.AddWithValue("@end", end);

return cmd.ExecuteReader();

}

ПРЕДУПРЕЖДЕНИЕ

Увы, пока что мне не удалось заставить этот пример работать. Сервер неуклонно возвращает ошибку «Reader is closed». Каким образом избежать закрытия Reader после возвращения его серверу, я пока не понял.

[SqlFunc(TableDefinition = "D datetime, course decimal(10, 4) NULL")]

[SqlFunction(DataAccess = DataAccessKind.Read,

SystemDataAccess = SystemDataAccessKind.None,

IsDeterministic = false, IsPrecise = true)]

public static void GetCourseTable(DateTime start, DateTime end)

{

using (SqlCommand cmd = SqlContext.GetCommand())

{

cmd.CommandText = @"

select changeDate, course from Course

where changeDate between @start and @end";

cmd.Parameters.AddWithValue("@start", start);

cmd.Parameters.AddWithValue("@end", end);

DateTime current = start;

SqlDecimal course = SqlDecimal.Null;

SqlResultSet source = cmd.ExecuteResultSet(ResultSetOptions.None);

SqlResultSet dest = SqlContext.GetReturnResultSet();

SqlDataRecord rec;

while (source.Read())

{

while (current < source.GetDateTime(0))

{

rec = dest.CreateRecord();

rec.SetSqlDecimal(1, course);

rec.SetDateTime(0, current);

dest.Insert(rec);

current = current.AddDays(1);

}

course = source.GetDecimal(1);

}

while (current <= end)

{

rec = dest.CreateRecord();

rec.SetDateTime(0, current);

rec.SetSqlDecimal(1, course);

dest.Insert(rec);

current = current.AddDays(1);

}

}

}

ПРЕДУПРЕЖДЕНИЕ

Обратите внимание также на то, что на этот раз для доступа к данным мы используем SqlResultSet вместо SqlDataReader. Дело в том, что одновременно читать из базы и работать с возвращаемым набором записей нельзя – возникает исключение с сообщением о том, что данное соединение уже используется. Возможно, данная особенность поведения будет изменена при выпуске финальной версии. Но пока единственным способом написать подобную функцию является чтение данных целиком до начала формирования выходного набора данных.