Problème de TransactionScope

Version imprimable

Bonjour, j'ai du code C# qui utilise le TransactionScope, mais il n'y a jamais de rollback.

Le code est appelé depuis le backgroundworker.

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
private int ExecuteOrd()
{
    TransactionScope scope = new TransactionScope();
 
    using (scope)
    {
        try
        {
             foreach (mDataSet.mRow row in m_InsertToDo)
              {
                  dt.AddRow(row); //Insert dans table SQL2005
              }
 
              presenter.BusinessServiceClient.Update(CLE, row.NUM, IsLast); //Update dans une table SQL2000
 
              //Génération du pdf (utilise le webservice reportingservices)
              this.Dispatcher.Invoke(DispatcherPriority.Normal, new DelegateChangeLabelProgressBar(ChangeLabelProgressBar), "Génération du PDF en cours...");
              GeneratePDF();
 
              scope.Complete();
        }
        catch (Exception ex)
        {
            throw new Exception(ex.message);
         }
    }
}

Le rollback ne se fait jamais (je fais planter la sp appellée par la méthode Update)

J'ai un message sur mon exception (exception was unhandled by user code).

Si j'enlève le try catch, cela ne fait pas de rollback non plus.

Quelqu'un peut-il m'aider ?

Merci d'avance.

06/03/2008, 17h55
Sphax

Salut,

D'abord je ne maitrise pas les TransactionScope, donc si je dis une bêtise j'en suis désolé. Voilà ce qui me vient à l'esprit en lisant ton message:

Citation:

dt.AddRow(row); //Insert dans table SQL2005

Il me semble que là tu insères une ligne dans une datatable (donc en mémoire) et non pas dans une base SQL2005. A moins que les opérations sur les datatable soient concernées par une transaction, ceci ne sera pas concerné par un éventuel rollback, non ?

Citation:

Le rollback ne se fait jamais (je fais planter la sp appellée par la méthode Update)

Si la sp appelée par la méthode Update plante, je ne vois pas ce qu'il y a à "rollbacker". Tu voudrais annuler le dt.AddRow(row) ?

Citation:

J'ai un message sur mon exception (exception was unhandled by user code).

Normal si ton exception n'est pas gérée qque part par toi :).

Dernier point, je vois que tu as mis ces lignes :

Citation:

this.Dispatcher.Invoke(DispatcherPriority.Normal, new DelegateChangeLabelProgressBar(ChangeLabelProgressBar), "Génération du PDF en cours...");
GeneratePDF();

dans le scope du transactionScope. Est-ce vraiment judicieux ? C'est à dire que si la génération du PDF échoue alors la transaction sera annulée. C'est peut être ce que tu veux faire, maisça me semble étrange.
06/03/2008, 22h01
blowdesign

D'abord, merci de ton intérêt

Ensuite,

Citation:

dt.AddRow(row); //Insert dans table SQL2005

Oui, je n'ai pas mis tout le code pour ne pas surcharger ce post. Après cet enregistrement dans la datatable, je fais un insert dans une DB sql 2005

Citation:

Si la sp appelée par la méthode Update plante, je ne vois pas ce qu'il y a à "rollbacker". Tu voudrais annuler le dt.AddRow(row) ?

Oui, je veux rollbacker l'insert dans la base SQL 2005

Citation:

dans le scope du transactionScope. Est-ce vraiment judicieux ? C'est à dire que si la génération du PDF échoue alors la transaction sera annulée. C'est peut être ce que tu veux faire, maisça me semble étrange.

Oui, car la génération du pdf fait partie du process. S'il échoue, je veux rollbacker l'insert SQL 2005 ET l'update SQL 2000

J'espère t'avoir éclairci.

Merci d'avance.
06/03/2008, 22h06
Sphax

Oui c'est plus clair. Peut-être que tu devrais nous montrer ce code qui insère des données dans la base sql2005, le pb vient surement de là.

Tu as essayé avec ?

Code:

1
2
3
4
using (TransactionScope scope = new TransactionScope())
{
    [...]
}

Citation:

Tu as essayé avec ?
Code :

Code:

1
2
3
4
using (TransactionScope scope = new TransactionScope())
{
    [...]
}

Oui j'avais essayé, c'est pareil. Pas de rollback

Citation:

Oui c'est plus clair. Peut-être que tu devrais nous montrer ce code qui insère des données dans la base sql2005, le pb vient surement de là.

Voici le code qui fait l'insert dans SQL 2005

Code:

presenter.BusinessServiceClient.CreateOperations(dt, out num_mvts);

La fonction CreateOperations qui est appelée

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
public int CreateOperations(MouvementDataSet.MouvementDataTable operations, out int[] num_mvt)
        {
            int retVal = -1;
            num_mvt = new int[operations.Rows.Count];
            for (int j = 0; j < num_mvt.Length; j++) { num_mvt[j] = -1; }
            TransactionScope scope = new TransactionScope(TransactionScopeOption.Required, TimeSpan.MaxValue);
            using (scope)
            {
                PositionDataSet.PositionDataTable positions = new PositionDataSet.PositionDataTable();
                for (int i = 0; i < operations.Rows.Count; i++)
                {
                    MouvementDataSet.MouvementRow operation = (MouvementDataSet.MouvementRow)operations[i];
                        operation.DT_OPE = SystemManager.GetInstance().DateJour;
                        this.SignerOperation(ref operation);
                        PositionDataSet.PositionRow position = m_positionHelper.UpdatePositionAfterCreate(operation.NUM_CLI, operation.NUM_OPC, operation.DATE_OP,
                            operation.CODE_ENR, operation.DEVISE, operation.QUANTITE, operation.NET, operation.SENS, ref positions);
                        //positions.ImportRow(position);                             
                        retVal = m_entitiesManager.UpdateMouvementPosition(operations, positions, out num_mvt);
                }
                scope.Complete();
            }
            return retVal;
        }

et la fonction UpdateMouvementPosition

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
public int UpdateMouvementPosition(MouvementDataSet.MouvementDataTable operations, PositionDataSet.PositionDataTable positions, out int[] num_mvt)
        {
            int r1 = 0;
            int r2 = 0;
            TransactionScope scope = new TransactionScope();
            using (scope)
            {
                try
                {
                    r1 = m_mouvementTA.Update(operations);
                    r2 = m_positionTA.Update(positions);
                    num_mvt = new int[operations.Rows.Count];
                    for (int i = 0; i < operations.Rows.Count; i++ )
                    {
                        MouvementDataSet.MouvementRow operation = (MouvementDataSet.MouvementRow)operations.Rows[i];
                        num_mvt[i] = operation.NUM_MVT;
                    }
                }
                catch (Exception e)
                {
 
                    throw new Exception("Erreur lors de la mise à jour des mouvements et des positions correspondantes.\r\n" + e.Message, e);
                }
                scope.Complete();
            }
            return r1 + r2;
        }