Получение исключения «дублирующий идентификатор транзакции» при использовании Transaction.Current.DependentClone

Question

Я создаю механизм для массового вставки (импорта) большого количества новых записей в базу данных ORACLE. Я использую несколько потоков и зависимых операций:

Создание нитей:

const int ThreadCount = 4; 
using (TransactionScope transaction = new TransactionScope()) 
{ 
    List<Thread> threads = new List<Thread>(threadCount); 
    for (int i = 0; i < ThreadCount; i++) 
    { 
     Thread thread = new Thread(WorkerThread); 
     thread.Start(Transaction.Current.DependentClone(DependentCloneOption.BlockCommitUntilComplete)); 
     threads.Add(thread); 
    } 
    threads.ForEach(thread => thread.Join()); 
    transaction.Complete(); 
} 

Метод, который делает фактическую работу:

private void WorkerThread(object transaction) 
{ 
    using (DependentTransaction dTx = (DependentTransaction)transaction) 
    using (TransactionScope ts = new TransactionScope(dTx)) 
    { 
     // The actual work, the inserts on the database, are executed here. 
    } 
} 

Во время этой операции, я получаю исключение типа System.Data.OracleClient.OracleException с сообщением ORA-24757: duplicate transaction identifier.

Что я делаю неправильно? Я неправильно выполняю зависимую транзакцию? Это несовместимо с Oracle? Если да, есть ли рабочий стол?

Answer 1

Я не знаю, почему у получить это исключение, но работа вокруг может быть:

const int ThreadCount = 4; 
using (var connection = new OracleConnection(MyConnectionstring)) 
{ 
    connection.Open(); 
    using (var transaction = connection.BeginTransaction()) 
    { 
     List<Thread> threads = new List<Thread>(ThreadCount); 
     for (int i = 0; i < ThreadCount; i++) 
     { 
      Thread thread = new Thread(WorkerThread); 
      thread.Start(transaction); 
      threads.Add(thread); 
     } 
     threads.ForEach(thread => thread.Join()); 

     transaction.Commit(); 
    } 
} 

и рабочий класс будет выглядеть примерно так:

private void WorkerThread(object transaction) 
{ 
    OracleTransaction trans = (OracleTransaction) transaction; 

    using (OracleCommand command = trans.Connection.CreateCommand()) 
    { 
     command.CommandText = "INSERT INTO mytable (x) values (1) "; 
     command.ExecuteNonQuery(); 
    } 
}