I've a problem using multithreading and MTS.
I'm using framework 1.1
Basically I want, from the Main Thread , to start a (distributed)
transaction.
then I want to start 2 new threads to perform some Database operations, each
thread will do some work on the DB using its own SQLConnection.
I want the 2 SQLConnections of the two threads partecipate to the same
(distributed) transaction.
The problem is that i do not know how to propagate the Object Context from
the Main thread to the 2 subThreads.
I start a new Transactional Context from the Main Thread with the following
code:
sc = new ServiceConfig() ;
sc.Transaction = TransactionOpti on.Required;
ServiceDomain.E nter(sc);
Then I run two Threads that will open two distinct SQLConnections
to perform some work at the same time .
ClasseTest CTest1 = new ClasseChiamata. ClasseTest() ;
ClasseTest CTest2 = new ClasseChiamata. ClasseTest() ;
Thread workThread1 = new Thread (new ThreadStart(CTe st1.EseguiOp));
workThread1.Sta rt();
Thread workThread2 = new Thread (new ThreadStart(CTe st2.EseguiOp));
workThread2.Sta rt();
workThread1.Joi n();
workThread2.Joi n();
The problem is that the SQLConnection created inside the method:
CTest2.EseguiOp ()
is not automatically enlisted in the (Distributed)Tr ansaction created before
the methods have been invoked asynchronously.
All works fine if I invoke the method synchronously, while if I use
multithreading to recall
the same method, the MTS object Context is not available to the subThreads.
Do you know how to pass the MTS Context to the 2 subThreads?
this is the code of the method that I want to recall asynchronously:
using System;
using System.Data;
using System.Enterpri seServices;
using System.Data.Sql Client;
namespace ClasseChiamata
{
public class ClasseTest
{
public bool hasError = false;
private SqlConnection mySqlConnection ;
public ClasseTest()
{
}
public void EseguiOp()
{
try
{
mySqlConnection = new SqlConnection
("database=TEST ;server=localho st;Persist Security
Info=False;uid= sa;pwd=xxxx");
SqlCommand mySqlCommand = new SqlCommand();
mySqlConnection .Open();
//mySqlConnection .EnlistDistribu tedTransaction( trans);
mySqlCommand.Co nnection = mySqlConnection ;
mySqlCommand.Co mmandText = "UPDATE Table1 SET Description = 'AAA' WHERE
Code = 'A1'";
mySqlCommand.Ex ecuteNonQuery() ;
ContextUtil.Set Abort(); // this will work in synchronous mode, but will
fail if recalled in a secondary thread, with the error "there is no MTS
object Context"!
}
catch(System.Ex ception ex)
{
hasErrore = true;
}
}
}
}
the line that fails is the
ContextUtil.Set Abort(); // this will work in synchronous mode, but will
fail if recalled in a secondary thread, with the error "there is no MTS
object Context"!
any help will be apreciated!
JPC
