Язык программирования C#9 и платформа .NET5 - Эндрю Троелсен

catch (Exception ex)

{

  Console.WriteLine($"An exception occurred: {ex.Message}");

                   // Сгенерировано исключение

}

dal.InsertAuto(new Car { Color = "Blue", MakeId = 5, PetName = "TowMonster" });

list = dal.GetAllInventory();

var newCar = list.First(x => x.PetName == "TowMonster");

Console.WriteLine(" ************** New Car ************** ");

Console.WriteLine("CarIdtMaketColortPet Name");

Console.WriteLine($"{newCar.Id}t{newCar.Make}t{newCar.Color}t{newCar.PetName}");

dal.DeleteCar(newCar.Id);

var petName = dal.LookUpPetName(car.Id);

Console.WriteLine(" ************** New Car ************** ");

Console.WriteLine($"Car pet name: {petName}");

Console.Write("Press enter to continue...");

Console.ReadLine();

Понятие транзакций базы данных

Давайте завершим исследование ADO.NET рассмотрением концепции транзакций базы данных. Выражаясь просто, транзакция — это набор операций базы данных, которые успешно выполняются или терпят неудачу как единая группа. Если одна из операций отказывает, тогда осуществляется откат всех остальных операций, как будто ничего не происходило. Несложно предположить, что транзакции по-настоящему важны для обеспечения безопасности, достоверности и согласованности табличных данных.

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

1. Банк должен снять $500 с вашего депозитного счета.

2. Банк должен добавить $500 на ваш текущий чековый счет.

Вряд ли бы вам понравилось, если бы деньги были сняты с депозитного счета, но не переведены (из-за какой-то ошибки со стороны банка) на текущий чековый счет, потому что вы попросту лишились бы $500. Однако если поместить указанные шаги внутрь транзакции базы данных, тогда СУБД гарантирует, что все взаимосвязанные шаги будут выполнены как единое целое. Если любая часть транзакции откажет, то будет произведен откат всей операции в исходное состояние. С другой стороны, если все шаги выполняются успешно, то транзакция будет зафиксирована.

На заметку! Из литературы, посвященной транзакциям, вам может быть известно сокращение АСЮ. Оно обозначает четыре ключевых характеристики транзакций: атомарность (atomic; все или ничего), согласованность (consistent; данные остаются устойчивыми на протяжении транзакции), изоляция (isolated; транзакции не влияют друг на друга) и постоянство (durable; транзакции сохраняются и протоколируются в журнале).

В свою очередь платформа .NET Core поддерживает транзакции различными способами. Здесь мы рассмотрим объект транзакции поставщика данных ADO.NET (SqlTransaction в случае Microsoft.Data.SqlClient).

В дополнение к готовой поддержке транзакций внутри библиотек базовых классов .NET Core можно также использовать язык SQL имеющейся СУБД. Например, вы могли бы написать хранимую процедуру, в которой применяются операторы BEGIN TRANSACTION, ROLLBACK и COMMIT.

Основные члены объекта транзакции ADO.NET

Все транзакции, которые будут использоваться, реализуют интерфейс IDbTransaction. Как упоминалось в начале главы, интерфейс IDbTransaction определяет несколько членов:

public interface IDbTransaction : IDisposable

{

  IDbConnection Connection { get; }

  IsolationLevel IsolationLevel { get; }

  void Commit();

  void Rollback();

}

Обратите внимание на свойство Connection, возвращающее ссылку на объект подключения, который инициировал текущую транзакцию (как вы вскоре увидите, объект транзакции получается из заданного объекта подключения). Метод Commit() вызывается, если все операции в базе данных завершились успешно, что приводит к сохранению в хранилище данных всех ожидающих изменений. И наоборот, метод Rollback() можно вызвать в случае генерации исключения времени выполнения, что информирует СУБД о необходимости проигнорировать все ожидающие изменения и оставить первоначальные данные незатронутыми.

На заметку! Свойство IsolationLevel объекта транзакции позволяет указать, насколько активно транзакция должна защищаться от действий со стороны других параллельно выполняющихся транзакций. По умолчанию транзакции полностью изолируются вплоть до их фиксации.

Помимо членов, определенных в интерфейсе IDbTransaction, тип SqlTransaction определяет дополнительный член под названием Save(), который предназначен для определения точек сохранения. Такая концепция позволяет откатить отказавшую транзакцию до именованной точки вместо того, чтобы осуществлять откат всей транзакции. При вызове метода Save() с использованием объекта SqlTransaction можно задавать удобный строковый псевдоним, а при вызове Rollback() этот псевдоним можно указывать в качестве аргумента для выполнения частичного отката. Вызов Rollback() без аргументов приводит к отмене всех ожидающих изменений.

Добавление метода транзакции в inventoryDal

Давайте посмотрим, как работать с транзакциями ADO.NET программным образом. Начните с открытия созданного ранее проекта библиотеки кода AutoLot.Dal и добавьте в класс InventoryDal новый открытый метод по имени ProcessCreditRisk(), предназначенный для работы с кредитными рисками. Метод будет искать клиента, в случае нахождения поместит его в таблицу CreditRisks и добавит к фамилии метку "(Credit Risk)".

public void ProcessCreditRisk(bool throwEx, int customerId)

{

  OpenConnection();

  // Найти имя текущего клиента по идентификатору.

  string fName;

  string lName;

  var cmdSelect = new SqlCommand(

    "Select * from Customers where Id = @customerId",

    _sqlConnection);

  SqlParameter paramId = new SqlParameter

  {

    ParameterName = "@customerId",

    SqlDbType = SqlDbType.Int,

    Value = customerId,

    Direction = ParameterDirection.Input

  };

  cmdSelect.Parameters.Add(paramId);

  using (var dataReader = cmdSelect.ExecuteReader())

  {

    if (dataReader.HasRows)

    {

      dataReader.Read();

      fName = (string) dataReader["FirstName"];

      lName = (string) dataReader["LastName"];

    }

    else

    {

      CloseConnection();

      return;

    }

  }

  cmdSelect.Parameters.Clear();

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

  var cmdUpdate = new SqlCommand(

    "Update Customers set LastName = LastName + ' (CreditRisk) '

     where Id = @customerId", _sqlConnection);

  cmdUpdate.Parameters.Add(paramId);

  var cmdInsert = new SqlCommand(

     "Insert Into CreditRisks (CustomerId,FirstName, LastName)

      Values( @CustomerId, @FirstName, @LastName)", _sqlConnection);

  SqlParameter parameterId2 = new SqlParameter

  {

    ParameterName = "@CustomerId",

    SqlDbType = SqlDbType.Int,

    Value = customerId,

    Direction = ParameterDirection.Input

  };

  SqlParameter parameterFirstName = new SqlParameter

  {

    ParameterName = "@FirstName",