diff --git a/library/Director/Import/Sync.php b/library/Director/Import/Sync.php index 5a29e2ed..4b418415 100644 --- a/library/Director/Import/Sync.php +++ b/library/Director/Import/Sync.php @@ -127,6 +127,8 @@ class Sync } } + $dba = $db->getDbAdapter(); + $dba->beginTransaction(); foreach ($objects as $object) { if ($object->hasBeenLoadedFromDb() && $rule->purge_existing === 'y') { /* @@ -138,6 +140,8 @@ class Sync } $object->store($db); } + + $dba->commit(); } } }