Книга: ЯЗЫК ПРОГРАММИРОВАНИЯ С# 2005 И ПЛАТФОРМА .NET 2.0. 3-е издание

Асинхронный доступ к данным в .NET 2.0

Асинхронный доступ к данным в .NET 2.0

В .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.

Оглавление книги