Эндрю Троелсен - ЯЗЫК ПРОГРАММИРОВАНИЯ С# 2005 И ПЛАТФОРМА .NET 2.0. 3-е издание

Для иллюстрации соответствующего процесса давайте добавим в программу CarInventoryUpdate новую опцию, которая позволит пользователю выяснить название автомобиля с помощью хранимой процедуры GetPetName. Этот объект базы данных был создан при установке базы данных Cars, и выглядит он так.

CREATE PROCEDURE GetPetName

@carID int,

@petName char(20) output

AS

SELECT @petName = PetName from Inventory where CarID = @carID

Сначала обновите имеющийся в Main() оператор switch, добавив в него обработку нового случая "P" для вызова новой вспомогательной функции с именем LookUpPetName(). которая принимает параметр SqlConnection и возвращает void. Обновите также метод ShowInstructions(), учитывая новый вариант выбора.

Чтобы выполнить хранимую процедуру, следует, как всегда, сначала создать новый объект соединения, сконфигурировать строку соединения и открыть сеанс. Но при создании объекта команды свойству CommandText следует присвоить имя хранимой процедуры (а не SQL-запрос). Также вы обязательно должны установить для свойства CommandType значение CommandType.StoredProcedure (значением по умолчанию является CommandType.Text).

Поскольку наша хранимая процедура имеет один входной и один выходной параметры, нашей целью является построение объекта команды, содержащего два объекта SqlParameter в своей коллекции параметров.

private static void LookUpPetName(SqlConnection cn) {

// Получение номера машины.

Console.Write("Введите номер машины: ");

int carID = int.Parse(Console.ReadLine());

// Установка имени хранимой процедуры.

SqlCommand cmd = new SqlCommand("GetPetName", cn);

cmd.CommandType = CommandType.StoredProcedure;

// Входной параметр.

SqlParameter param = new SqlParameter();

param.ParameterName = "@carID";

param.SqlDbType = SqlDbType.Int;

param.Value = carID;

param.Direction = ParameterDirection.Input;

cmd.Parameters.Add(param);

// Выходной параметр.

param = new SqlParameter();

param.ParameterName = "@petName";

param.SqlDbType = SqlDbType.Char;

param.Size = 20;

param.Direction = ParameterDirection.Output();

cmd.Parameters.Add(param);

// Выполнение хранимой процедуры.

cmd.ExecuteNonQuery();

// Печать выходного параметра.

Console.WriteLine("Машина {0} называется {1}'', carID, cmd.Parameters["@petName"].Value);

}

Обратите внимание на то, что свойство Direction объекта параметра позволяет указать входные и выходные параметры. По завершении вызова хранимой процедуры с помощью ExecuteNonQuery() вы можете получить значение выходного параметра, обратившись к коллекции параметров объекта команды. На рис. 22.9 показан один из возможных вариантов тестового запуска программы.

Рис. 22.9. Вызов хранимой процедуры

Исходный код. Проект СarsInventoryUpdater размещен в подкаталоге, соответствующем главе 22.

В .NET 2.0 поставщик данных SQL (представленный пространством имен System.Data.SqlClient) усовершенствован с тем, чтобы он мог поддерживать асинхронное взаимодействие с базой данных, используя следующие новые члены SqlCommand.

• BeginExecuteReader()/EndExecuteReader()

• BeginExecuteNonQuery()/EndExecuteNonQuery()

• BeginExecuteXmlReader()/EndExecuteXmlReader()

С учетом материала, представленного в главе 14, названия пар этих методов можно считать "триумфом" соглашения о присвоении имен. Напомним, что в шаблоне асинхронного делегата .NET используется метод "begin" для выполнения задач во вторичном потоке, тогда как метод "end" может использоваться для получения результата асинхронного вызова с помощью членов IAsyncResult и необязательного делегата AsyncCallback. Поскольку работа с асинхронными командами моделируется по образцу делегата, простого примера в этом случае должно быть достаточно (но не забудьте снова заглянуть в главу 14, чтобы освежить в памяти подробности, касающиеся использования делегатов асинхронного вызова).

Предположим, что нам нужно выбрать записи из таблицы Inventory во вторичном потоке выполнения, используя объект чтения данных. Вот полный текст соответствующего метода Main() с последующим анализом.

static void Main(string[] args) {

Console.WriteLine ("***** Забавы с ASNYC DataReader *****\n");

// Создание открытого соединения в асинхронном режиме.

SqlConnection cn = new SqlConnection();

cn.ConnectionString = "uid=sa;pwd=;Initial Catalog=Cars;" +

"Asynchronous Processing=true;Data Source=(local)";

cn.Open();

// Создание объекта SQL-команды, ожидающего около 2 с.

string strSQL = "WaitFor Delay '00:00:02';Select * From Inventory";

SqlCommand myCommand = new SqlCommand(strSQL, cn);

// Выполнение чтения во втором потоке.

IAsyncResult itfAsynch;

itfAsynch = myCornmand.BeginExecuteReader(CommandBehavior.CloseConnection);

// Выполнение действий во время работы другого потока.

while (!itfAsynch.IsCompleted) {

Console.WriteLine("Работа в главном потоке…");

Thread.Sleep(1000);

}

Console.WriteLine();

// Все готово! Выполнение цикла по результатам

// с помощью объекта чтения данных.

SqlDataReader myDataReader = myCommand.EndExecuteReader(itfAsynch);

while (myDataReader.Read()) {

Console.WriteLine("-› Марка – {0) название – {1}, цвет – {2}.",

myDataReader["Make"].ToString.Trim(),

myDataReader["PetName"].ToString().Trim() ,

myDataReader["Color"].ToString().Trim());

}

myDataReader.Close();

}

Первый интересным моментом здесь является то, что вы должны разрешить асинхронное взаимодействие с помощью нового сегмента Asynchronous Processing в строке соединения. Также отметьте, что в текст объекта команды SqlCommand был добавлен сегмент WaitFor Delay для имитации длительного взаимодействия с базой данных.

Кроме этого обратите внимание на то, что вызов BeginExecuteDataReader() возвращает ожидаемый IAsyncResult-совместимый тип, который используется для синхронизации потока вызова (с помощью свойства IsCompleted), а также для получения SqlDataReader по завершении выполнения запроса.

Исходный код. Проект AsyncCmdObject размещен в подкаталоге, соответствующем главе22.

Как вы убедились, работе, со связным слоем позволяет взаимодействовать с базой данных, используя объекты соединения, команд и чтения данных. С помощью небольшого набора типов вы можете по желанию выбирать, вставлять, обновлять и удалять записи (а также запускать хранимые процедуры). Но на самом деле вы пока что узнали только половину того, что вам следует знать о возможностях ADO.NET. Поэтому напоминаем, что объектная модель ADO.NET может использоваться для взаимодействия в несвязной форме.

При работе на несвязном уровне ADO.NET вы по-прежнему должны использовать объекты соединения и команды. Кроме того, вы должны использовать специальный объект, называемый адаптером данных (и расширяющий абстрактный DbDataAdapter), чтобы извлекать и обновлять данные. В отличие от связного слоя, данные, полученные с помощью адаптера данных, не обрабатываются с помощью объекта чтения данных. Вместо этого для перемещения данных между вызывающей стороной и источником данных объекты адаптера данных используют объекты DataSet. Тип DataSet – это контейнер, используемый для любого числа объектов DataTable, каждый из которых содержит коллекцию объектов DataRow и DataColumn.