RetailCRM-Mirror/doctrine2
1
0
Fork 0
mirror of synced 2025-02-02 21:41:45 +03:00
Code Issues Projects Releases Wiki Activity

Merge pull request #1574 from Ma27/patch-1

Browse Source 
deduplication of internal UnitOfWork methods
This commit is contained in:
Marco Pivetta 2015-12-08 19:02:28 +01:00
commit bd94931201
1 changed files with 17 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
lib/Doctrine/ORM/UnitOfWork.php
View File

@ -3259,41 +3259,35 @@ class UnitOfWork implements PropertyChangedListener
*/ */
private function afterTransactionComplete() private function afterTransactionComplete()
{ {
if ( ! $this->hasCache) { $this->performCallbackOnCachedPersister(function (CachedPersister $persister) {
return; $persister->afterTransactionComplete();
} });
foreach ($this->persisters as $persister) {
if ($persister instanceof CachedPersister) {
$persister->afterTransactionComplete();
}
}
foreach ($this->collectionPersisters as $persister) {
if ($persister instanceof CachedPersister) {
$persister->afterTransactionComplete();
}
}
} }
/** /**
* Perform whatever processing is encapsulated here after completion of the rolled-back. * Perform whatever processing is encapsulated here after completion of the rolled-back.
*/ */
private function afterTransactionRolledBack() private function afterTransactionRolledBack()
{
$this->performCallbackOnCachedPersister(function (CachedPersister $persister) {
$persister->afterTransactionRolledBack();
});
}
/**
* Performs an action after the transaction.
*
* @param callable $callback
*/
private function performCallbackOnCachedPersister(callable $callback)
{ {
if ( ! $this->hasCache) { if ( ! $this->hasCache) {
return; return;
} }
foreach ($this->persisters as $persister) { foreach (array_merge($this->persisters, $this->collectionPersisters) as $persister) {
if ($persister instanceof CachedPersister) { if ($persister instanceof CachedPersister) {
$persister->afterTransactionRolledBack(); $callback($persister);
}
}
foreach ($this->collectionPersisters as $persister) {
if ($persister instanceof CachedPersister) {
$persister->afterTransactionRolledBack();
} }
} }
} }