Симон Робинсон - C# для профессионалов. Том II
С другой стороны, если где-то в PlaceOrder возникает ошибка и порождается исключение, управление программой будет передано предложению catch(). В этом предложении PlaceOrder() вызовет метод SetAbort() объекта ContextUtil. Этот метод посылает голос PlaceOrder() за отмену транзакции, в которую он вовлечен, и DTC после получения этого голоса от менеджера ресурсов прикажет каждому участнику транзакции отменить свою работу.
Помните, что не требуется создавать экземпляр объекта ContextUtil, чтобы вызвать его методы SetComplete() и SetAbort(). Эти методы класса, поэтому их можно вызывать прямо на классе.
Практически любой код, поддерживающий транзакции будет походить на код в примере. Он вызывает SetComplete() перед своей точкой выхода для фиксации всей работы, которая была успешно выполнена, или он вызывает метод SetAbort() класса ContextUtil в своем обработчике ошибок, чтобы все отменить в связи с ошибкой. Существует, правда, еще более простой способ.
Компания Microsoft предоставляет атрибут .NET, называемый AutoComplete. Методы, модифицированные с помощью этого атрибута, автоматически применяют подход, описанный выше. И хотя такие методы никогда явно не ссылаются на класс ContextUtil, они неявно завершают свои транзакции, если те заканчиваются нормально, или отменяют всю работу если выход происходит в связи с ошибкой (когда порождается исключение). По прежнему необходимо вызывать SetAbort(), чтобы отменить работу транзакции если порождается исключение.
[AutoComplete]
public bool PlaceOrder(bool CommitTrans) {
try {
if (CommitTrans) {
// Эта транзакция должна быть зафиксирована
// шаг 1 — Увеличить число единиц продукта ID=2 на 10
IncreaseUnits(2, 10);
// шаг 2 - Сократить запас продукта ID=2 на 10 единиц
ReduceStock(2, 10);
} else {
// Эта транзакция должна быть отменена
// шаг 1 - Увеличить число единиц продукта ID=5 на 5
IncreaseUnits(5, 5);
// шаг 2 — Сократить запас продукта ID=5 на 5 единиц
ReduceStock(5, 5);
}
return true;
} catch (Exception e) {
ContextUtil.SetAbort();
return false;
}
}
Это полный код примера всей транзакции, он показывает, как все части объединяются. Следующее просто встроено в библиотеку классов с заданным сильным именем и зарегистрировано в глобальном кэше сборок.
using System;
using System.EnterpriseServices;
using System.Data.SqlClient;
namespace OrderTransaction {
[Transaction(TransactionOptiоn.Required)]
public class Purchase : ServicedComponent {
public Purchase() { }
public bool PlaceOrder(bool CommitTrans) {
// Попытка работы
try {
if (CommitTrans) {
// Эта транзакция должна быть зафиксирована
// шаг 1 - Увеличить число единиц продукта ID=2 на 10
IncreaseUnits(2, 10);
// шаг 2 - Сократить запас продукта ID=2 на 10 единиц
ReduceStock(2, 10);
} else {
// Эта транзакция должна быть отменена
// шаг 3 — Увеличить число единиц продукта ID=5 на 5
IncreaseUnits(5, 5);
// шаг 2 — Сократить запас продукта ID=5 на 5
единиц ReduceStock(5, 5);
}
// Если все прошло хорошо, закончить транзакцию.
ContextUtil.SetComplete();
return true;
}
// Этот код выполняется, если встречается ошибка.
catch (Exception e) {
// Отменить работу, которую выполнила эта функция.
ContextUtil.SetAbort();
return false;
}
}
public void ReduceStock(int ProductID, int amount) {
string source = "server ephemeral;uid=sa;pwd=garysql;database Northwind";
SqlConnection conn = new SqlConnection(source);
string command =
"UPDATE Products SET UnitsInStock = UnitsInStock - " +
amount.ToString() + " WHERE ProductID = " + ProductID.ToString();
conn.Open;
sqlCommand cmd = new SqlCommand(command, conn);
cmd.ExecuteNonQuery();
conn.Close();
}
public void IncreaseUnits(int ProductID, int amount) {
string source = "server=ephemeral;uid=sa;pwd=garysql;database=Northwind";
SqlConnection conn = new SqlConnection(source);
string command =
"UPDATE Products SET UnitsOnOrder = UnitsOnOrder +
" amount.ToString() + " WHERE ProductID = " + ProductID.ToString();
conn.Open();
SqlCommand cmd = new SqlCommand(command, conn);
cmd.ExecuteNonQuery();
conn.Close();
}
public void Restore() {
// Восстановить запас продукта ID=2
ReduceStock(2, -10);
// Восстановить единицы продукта для ID=2
IncreaseUnits(2, -10);
// Не требуется восстанавливать запас или единицы продукта для ID=5,
// так так транзакция должна быть отменена
}
}
}
Можно создать клиента для тестирования этой библиотеки классов. Здесь клиент создан так, что он ожидает, пока пользователь проверит содержимое базы данных, прежде чем восстановить базу данных в исходное состояние. Это позволяет увидеть результаты транзакций.
statiс void Main(string[] args) {
Purchase order = new Purchase();
Console.WriteLine("nThis transaction should commit");
Console.WriteLine("ProductID = 2, ordering 10 items");
if (Order.PlaceOrder(true)) Console.WriteLine("Transaction Successful");
else Console.WriteLine("Transaction Unsuccessful");
Console.WriteLine("nThis transaction should roll back");
Console.WriteLine("ProductID = 5, ordering 5 items");
if (Order.PlaceOrder(false)) Console.WriteLine("Transaction Successful");
else Console.WriteLine("Transaction Unsuccessful");
Console.WriteLine(
"nTake a look at the database then hit enter to
+ "return database to original state");
Console.ReadLine();
Order.Restore();
}
Другие полезные методы ContextUtil
Рассмотрим еще пару методов класса ContextUtil которые могут оказаться полезны при программировании на C#.
Первый метод IsCallerInRole() предназначен для безопасности на основе ролей. В качестве входной переменной этот метод получает строковую переменную, содержащую имя определенной роли системы безопасности Windows 2000. Он возвращает булево значение, указывающее, является или нет пользователь, который в данный момент вызывает объект, членом указанной роли.
В примере кода ниже добавлена проверка, чтобы убедиться, что пользователь, пытающийся вызвать PlaceOrder(), является авторизованным членом роли Administrators. Если пользователь не является членом этой роли, то PlaceOrder() порождает исключение.
[AutoComplete]
public bool PlaceOrder(bool CommitTrans) {
if (!ContextUtil.IsCallerInRole("Administrators") {
throw new AccessViolationException("User is not authorized to place" + "orders.");
}
// Поместить код транзакции здесь
}
Вторым полезным методом класса ContextUtil является IsInTransaction(). Этот метод возвращает булево значение, указывающее, участвует ли объект в данный момент в транзакции.
Профессиональным программистам C# приходится иногда разрабатывать транзакционные компоненты для удаленной установки, которую они не контролируют. Чтобы убедиться, что сборки, требующие транзакционной поддержки, правильно для нее сконфигурированы, можно вызвать свойство IsInTransaction класса ContextUtil и инициировать ошибку, если это свойство задано как false.
В примере кода ниже свойство IsInTransaction используется для гарантии, что сборка правильно сконфигурирована, прежде чем ей будет разрешено ей начать какую-либо работу. Код порождает исключение, если IsInTransaction имеет значение false. Можно протестировать это, изменяя атрибут класса на TransactionalOptionDisabled.
[AutoComplete]
public bool PlaceOrder(bool CommitTrans) {
if (!ContextUtil.IsInTransaction) {
throw new
ConfigurationException("This assembly needs to be configured for" + " transactions.");
}
// Выполнить транзакцию
}
Этим мы завершаем обсуждение транзакций COM+ и класса ContextUtil. Давайте перейдем к пулам объектов.
Использование пудов объектов со сборками .NET
Нетрудно сконфигурировать компонент .NET для пула объектов. Для этого необходимо изменить класс с помощью атрибута и реализовать интерфейс в этом классе.
Атрибут ObjectPooling
Атрибутом с помощью которого необходимо изменить класс, является ObjectPooling. Этот атрибут получает четыре аргумента.
1. Аргумент Enabled является первым. Ему должно быть присвоено значение true.
