Come si influisce sui dati utilizzando cicli con transazione di rollback

Question

While @@Fetch_Status = 0 
Begin 
    INSERT INTO [server].MyDatabase.dbo.Mytabletobeinserted (

    UPC, 
    Sale_date) 
    VALUES(
    @UPC, 
    @Sale_date) 

    'Inserting the error trapping here' 

    IF (@@ERROR <> 0) 
    BEGIN 
     ROLLBACK TRANSACTION; 
     RETURN; 
    END 

    Update t_sale_from_pos 
    set been_sent = 'y' 
    where UPC = @UPC and sale_date=@sale_date 

    Fetch Next from CursorSale 
    into 
    @UPC, 
    @Sale_date 
end 
close CursorSale 

deallocate CursorSale 

Questa procedura memorizzata viene eseguita ogni giorno con uno scheduler ei dati vengono passati sulla rete. Quando si esegue questa stored procedure e quindi lungo il processo di esecuzione, si verifica un improvviso timeout di rete. Questo esegue ogni riga da inviare all'altro server sulla rete.

---

Ora, il mio problema è:

• Quali saranno le conseguenze i dati chiamando l'operazione di rollback all'interno del ciclo?
• Leggerà di nuovo tutte le righe e lo invierà al server per l'inserimento o leggerà solo la riga dove fallisce durante l'esecuzione?

Hai bisogno di un consiglio. Grazie

Answer 1

Si potrebbe provare begin distributed transaction. Distributed transaction si adatta perfettamente in questo caso poiché le transazioni distribuite sono state progettate per estendersi su due o più server. Con la transazione, anche il sistema si blocca, o c'è un'interruzione di corrente, il sistema è ancora in grado di ripristinare il suo stato coerente.

BEGIN DISTRIBUTED TRANSACTION; 

BEGIN TRY 
    //Your code here to create the cursor. 
    While @@Fetch_Status = 0 
    Begin 
     INSERT INTO [server].MyDatabase.dbo.Mytabletobeinserted(UPC,Sale_date) 
                  VALUES(@UPC,@Sale_date) 

     Update t_sale_from_pos 
     set been_sent = 'y' 
     where UPC = @UPC and sale_date=@sale_date 

     Fetch Next from CursorSale into @UPC,@Sale_date 
    END 
    close CursorSale 

    deallocate CursorSale 
END TRY 
BEGIN CATCH 
    close CursorSale 

    deallocate CursorSale 

    IF @@TRANCOUNT > 0 
     ROLLBACK TRANSACTION; 
END CATCH; 

IF @@TRANCOUNT > 0 
    COMMIT TRANSACTION; 
GO 

In realtà, con le transazioni distribuite non è necessario utilizzare il cursore. Nel tuo caso, è meglio considerare anche di evitare i problemi di concorrenza creando una tabella temporanea. La ragione di ciò è la seguente: l'istruzione di inserimento può richiedere tempo e mentre inserisce dati, la tabella può essere aggiornata da un altro utente e l'istruzione di aggiornamento che si verifica dopo può aggiornare le righe errate.

BEGIN DISTRIBUTED TRANSACTION; 

BEGIN TRY 
    CREATE TABLE #LocalTempTable(UPC int,Sale_date datetime) 
    INSERT INTO #LocalTempTable(UPC,Sale_date) 
    SELECT UPC,Sale_date 
    FROM YourTable 

    INSERT INTO [server].MyDatabase.dbo.Mytabletobeinserted(UPC,Sale_date) 
    SELECT UPC,Sale_date 
    FROM #LocalTempTable 

    Update t_sale_from_pos 
    set been_sent = 'y' 
    where EXISTS (SELECT * 
        FROM #LocalTempTable 
        WHERE #LocalTempTable.UPC = t_sale_from_pos.UPC 
         AND #LocalTempTable.Sale_date = t_sale_from_pos.Sale_date) 

END 
END TRY 
BEGIN CATCH 
    IF @@TRANCOUNT > 0 
     ROLLBACK TRANSACTION; 
END CATCH; 

IF @@TRANCOUNT > 0 
    COMMIT TRANSACTION; 
GO 

Answer 2

Se ho capito bene. Try/catch dovrebbe aiutare -

WHILE @@FETCH_STATUS = 0 BEGIN 

    BEGIN TRY 

      INSERT INTO [server].MyDatabase.dbo.Mytabletobeinserted (UPC, Sale_date) 
      SELECT @UPC, @Sale_date 

      UPDATE dbo.t_sale_from_pos 
      SET been_sent = 'y' 
      WHERE UPC = @UPC 
      AND sale_date = @sale_date 

    END TRY 
    BEGIN CATCH 

      UPDATE dbo.t_sale_from_pos 
      SET been_sent = 'n' 
      WHERE UPC = @UPC 
      AND sale_date = @sale_date 

    END CATCH 

    FETCH NEXT FROM CursorSale INTO @UPC, @Sale_date 

END 

CLOSE CursorSale 
DEALLOCATE CursorSale 

Answer 3

Penso che si sta confondendo al posto sbagliato,

refere @@fetch_status

qui, 0 = The FETCH statement was successful.

Così fino a quando il recupero è successo il ciclo andrà on, e se si verifica un errore @@, termina con tutte le righe del cursore creato. E se non si sono verificati errori

si è logicamente a destra, e funzionerà bene se il CursorSale è definito correttamente, al posto giusto ..

Per ulteriori Idea riferimento esempio dal link qui sopra

spero questo lo farà ..

Answer 4

Suggerirei invece di eseguire il ciclo di ogni record, facendo l'inserto in blocchi. Come 5000 record alla volta, se si tratta di un lavoro automatico, questo sarebbe fattibile.

Ecco un collegamento che ho trovato, ma in pratica si farebbero i primi 5000 ogni volta nel ciclo in alto. Immagino che se hai un lavoro con un cursore su ogni record per un inserto, è probabile che diventi molto costoso.

http://social.msdn.microsoft.com/Forums/sqlserver/en-US/1b3dbf8d-252f-43c4-80d6-d5724fe912b4/how-to-insert-rows-in-chunk-size