Come eseguire una transazione di commit Two-Phase su TCP/IP
Il commit in due fasi (2PC) è un protocollo installato dal server host che garantisce che gli aggiornamenti a più istanze di un database in una rete abbiano esito positivo o negativo nel loro insieme. Host Integration Server supporta 2PC su TCP/IP, consentendo di ottenere la sicurezza di una connessione 2PC tramite Internet.
Host Integration Server supporta 2PC usando due componenti: Microsoft Distributed Transaction Coordinator (DTC) e il log delle transazioni. Il DTC regola il normale flusso di transazione DTC: integrazione, preparazione, commit e interruzione. DTC gestisce anche il ripristino delle transazioni in caso di errore o disconnessione, mentre il log delle transazioni gestisce un log di informazioni necessarie in caso di ripristino.
È possibile eseguire una transazione 2PC con ADO.NET e la Provider gestito per DB2 usando lo spazio dei System.Transactions nomi . L'uso di una transazione 2PC è automatico quando si configura la proprietà di connessione Unità di lavoro=DUW.
Esempio
Nell'esempio di codice seguente viene illustrato come usare 2PC in una transazione DB2.
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using System.Transactions;
using Microsoft.HostIntegration.MsDb2Client;
namespace Db2DistributedTransaction
{
class Program
{
static void Main(string[] args)
{
Db2Tx();
}
static void Db2Tx()
{
string connectionStringDb2 = "Password=HISDEMO;User ID=HISDEMO;Initial Catalog=DSN1D037;Data Source=DSN8910;Network Transport Library=TCPIP;Host CCSID=37;PC Code Page=1208;Network Address=123.34.45.57;Network Port=446;Package Collection=HISDEMO;Default Schema=DSN8910;Default Qualifier=DSN8910;Units of Work=DUW;Defer Prepare=True;AutoCommit=False";
System.Transactions.CommittableTransaction transaction = new System.Transactions.CommittableTransaction();
MsDb2Connection connection = new MsDb2Connection(connectionStringDb2);
MsDb2Command command = new MsDb2Command();
try
{
connection.Open();
connection.EnlistTransaction(transaction);
command.Connection = connection;
command.CommandText = "INSERT INTO DSN8910.AREAS (AREAID, AREADESC, REGIONID) VALUES ('11111', 'Area 11111', 111)";
command.ExecuteNonQuery();
command.CommandText = "INSERT INTO DSN8910.AREAS (AREAID, AREADESC, REGIONID) VALUES ('22222', 'Area 22222', 222)";
command.ExecuteNonQuery();
while (true)
{
Console.Write("Commit or Rollback? [C|R] ");
ConsoleKeyInfo c = Console.ReadKey();
Console.WriteLine();
Console.ReadKey();
if ((c.KeyChar == 'C') || (c.KeyChar == 'c'))
{
transaction.Commit();
break;
}
else if ((c.KeyChar == 'R') || (c.KeyChar == 'r'))
{
transaction.Rollback();
break;
}
}
connection.Close();
transaction = null;
}
catch (Exception ex)
{
Console.WriteLine("Commit Exception Type: {0}", ex.GetType());
Console.WriteLine(" Message: {0}", ex.Message);
Console.ReadKey();
}
Console.WriteLine("Program end.");
Console.ReadKey();
}
}