| @@ 259-270 (lines=12) @@ | ||
| 256 | $persister->executeInserts(); |
|
| 257 | } |
|
| 258 | ||
| 259 | public function executeUpdates($className) { |
|
| 260 | $persister = $this->getEntityPersister($className); |
|
| 261 | ||
| 262 | foreach ($this->entityUpdates as $oid => $entity) { |
|
| 263 | if (get_class($entity) !== $className) { |
|
| 264 | continue; |
|
| 265 | } |
|
| 266 | ||
| 267 | $persister->update($entity); |
|
| 268 | unset($this->entityUpdates[$oid]); |
|
| 269 | } |
|
| 270 | } |
|
| 271 | ||
| 272 | public function executeDeletions($className) { |
|
| 273 | $persister = $this->getEntityPersister($className); |
|
| @@ 272-283 (lines=12) @@ | ||
| 269 | } |
|
| 270 | } |
|
| 271 | ||
| 272 | public function executeDeletions($className) { |
|
| 273 | $persister = $this->getEntityPersister($className); |
|
| 274 | ||
| 275 | foreach ($this->entityDeletions as $oid => $entity) { |
|
| 276 | if (get_class($entity) !== $className) { |
|
| 277 | continue; |
|
| 278 | } |
|
| 279 | ||
| 280 | $persister->delete($entity); |
|
| 281 | unset($this->entityDeletions[$oid]); |
|
| 282 | } |
|
| 283 | } |
|
| 284 | ||
| 285 | protected function dispatchOnFlushEvent() { |
|
| 286 | ||