Commit 56c9840f authored by Antony Le Courtes's avatar Antony Le Courtes
Browse files

Catch exception pour rollback lors d'une transaction

parent d6c44c9b

src/Process/DbDiffProcess.php

+21 −16
Original line number Diff line number Diff line
@@ -71,6 +71,7 @@ class DbDiffProcess implements ProcessInterface 
        $conn->beginTransaction();



        $stmt = $conn->executeQuery($sql);

        try{

            while ($data = $stmt->fetchAssociative()) {

                $srcId = (int)$data['UNICAEN_TBL_SRC_ID'];

                $destId = (int)$data['UNICAEN_TBL_DEST_ID'];
@@ -89,6 +90,10 @@ class DbDiffProcess implements ProcessInterface 
            }



            $conn->commit();

        } catch (\Exception $e) {

            $conn->rollBack();

            throw $e;

        }

    }