Dağıtılmış hareketleri destekleme

SQL ServerYerel istemci ole db sağlayıcı tüketici kullanarak ITransactionJoin::JoinTransaction katılmasını yöntem bir dağıtılmış işlem Microsoft tarafından belirlenen dağıtılmış işlem Coordinator (ms dtc).

ms DTC'yi başlatmak ve çeşitli veri depoları için birden çok bağlantı üzerinden koordine hareketlerine katılan istemcilerin com nesneleri gösterir.Bir hareketi başlatmak için SQL Server yerel istemci ole db sağlayıcı tüketici kullanır ms dtc ITransactionDispenser arabirim.The BeginTransaction member of ITransactionDispenser returns a reference on a distributed transaction object.Bu başvuru için geçirilen SQL Server yerel istemci ole db sağlayıcı kullanarak JoinTransaction.

ms dtc yürütme zaman uyumsuz destekler ve dağıtılmış hareketleri iptal etmek.Zaman uyumsuz işlem durumu hakkında bildirim almak için tüketici uygulayan ITransactionOutcomeEvents arabirim ve arabirimin bir ms dtc işlem nesnesi için bağlanır.

Dağıtılmış işlemler için SQL Server yerel istemci ole db sağlayıcı uygular ITransactionJoin::JoinTransaction parametreleri aşağıdaki gibi.

Parameter	Açıklama
punkTransactionCoord	Bir ms dtc işlem nesnesi için bir işaretçi.
IsoLevel	Tarafından göz ardı SQL Server yerel istemci ole db sağlayıcı.yalıtım düzey Ne zaman bir ms dtc hareket nesneden tüketici isteklerdir ms dtc belirlenen işlemler için belirlenir.
İsoİşaretleri	0 Olmalıdır.The SQL Server Native Client OLE DB provider returns XACT_E_NOISORETAIN if any other value is specified by the consumer.
POtherOptions	Not null, SQL Server yerel istemci ole db sağlayıcı ister seçenekleri nesneden arabirim.The SQL Server Native Client OLE DB provider returns XACT_E_NOTIMEOUT if the options object's ulTimeout member is not zero.The SQL Server Native Client OLE DB provider ignores the value of the szDescription member.

Bu örnek işlem ms dtc kullanarak düzenler.

// Interfaces used in the example.
IDBCreateSession*       pIDBCreateSession   = NULL;
ITransactionJoin*       pITransactionJoin   = NULL;
IDBCreateCommand*       pIDBCreateCommand   = NULL;
IRowset*                pIRowset            = NULL;

// Transaction dispenser and transaction from MS DTC.
ITransactionDispenser*  pITransactionDispenser = NULL;
ITransaction*           pITransaction       = NULL;

    HRESULT             hr;

// Get the command creation interface for the session.
if (FAILED(hr = pIDBCreateSession->CreateSession(NULL,
     IID_IDBCreateCommand, (IUnknown**) &pIDBCreateCommand)))
    {
    // Process error from session creation. Release any references and
    // return.
    }

// Get a transaction dispenser object from MS DTC and
// start a transaction.
if (FAILED(hr = DtcGetTransactionManager(NULL, NULL,
    IID_ITransactionDispenser, 0, 0, NULL,
    (void**) &pITransactionDispenser)))
    {
    // Process error message from MS DTC, release any references,
    // and then return.
    }
if (FAILED(hr = pITransactionDispenser->BeginTransaction(
    NULL, ISOLATIONLEVEL_READCOMMITTED, ISOFLAG_RETAIN_DONTCARE,
    NULL, &pITransaction)))
    {
    // Process error message from MS DTC, release any references,
    // and then return.
    }

// Join the transaction.
if (FAILED(pIDBCreateCommand->QueryInterface(IID_ITransactionJoin,
    (void**) &pITransactionJoin)))
    {
    // Process failure to get an interface, release any references, and
    // then return.
    }
if (FAILED(pITransactionJoin->JoinTransaction(
    (IUnknown*) pITransaction, 0, 0, NULL)))
    {
    // Process join failure, release any references, and then return.
    }

// Get data into a rowset, then update the data. Functions are not
// illustrated in this example.
if (FAILED(hr = ExecuteCommand(pIDBCreateCommand, &pIRowset)))
    {
    // Release any references and return.
    }

// If rowset data update fails, then terminate the transaction, else
// commit. The example doesn't retain the rowset.
if (FAILED(hr = UpdateDataInRowset(pIRowset, bDelayedUpdate)))
    {
    // Get error from update, then abort.
    pITransaction->Abort(NULL, FALSE, FALSE);
    }
else
    {
    if (FAILED(hr = pITransaction->Commit(FALSE, 0, 0)))
        {
        // Get error from failed commit.
        //
        // If a distributed commit fails, application logic could
        // analyze failure and retry. In this example, terminate. The 
        // consumer must resolve this somehow.
        pITransaction->Abort(NULL, FALSE, FALSE);
        }
    }

if (FAILED(hr))
    {
    // Update of data or commit failed. Release any references and
    // return.
    }

// Un-enlist from the distributed transaction by setting 
// the transaction object pointer to NULL.
if (FAILED(pITransactionJoin->JoinTransaction(
    (IUnknown*) NULL, 0, 0, NULL)))
    {
    // Process failure, and then return.
    }

// Release any references and continue.

Ayrıca bkz.

Kavramlar

İşlemler