@@ 117-131 (lines=15) @@ | ||
114 | $row = $result[0]; |
|
115 | ||
116 | $relatedEntityIds = []; |
|
117 | foreach ($this->with as $relatedEntityName => $cascadeWith) { |
|
118 | $relatedField = $this->getRelatedField($relatedEntityName); |
|
119 | ||
120 | if (!array_key_exists($relatedField, $row)) { |
|
121 | throw new \RuntimeException(get_class($this) . ": relation field $relatedEntityName not fetched"); |
|
122 | } |
|
123 | ||
124 | if (!isset($relatedEntityIds[$relatedEntityName])) { |
|
125 | $relatedEntityIds[$relatedEntityName] = new ArrayObject(); |
|
126 | } |
|
127 | ||
128 | if (!in_array($row[$relatedField], (array)$relatedEntityIds[$relatedEntityName])) { |
|
129 | $relatedEntityIds[$relatedEntityName]->append($row[$relatedField]); |
|
130 | } |
|
131 | } |
|
132 | ||
133 | $relatedEntities = []; |
|
134 | foreach ($this->with as $relatedEntityName => $cascadeWith) { |
|
@@ 192-208 (lines=17) @@ | ||
189 | } |
|
190 | ||
191 | $relatedEntityIds = []; |
|
192 | foreach ($rows as $row) { |
|
193 | foreach ($this->with as $relatedEntityName => $cascadeWith) { |
|
194 | $relatedField = $this->getRelatedField($relatedEntityName); |
|
195 | ||
196 | if (!array_key_exists($relatedField, $row)) { |
|
197 | throw new \RuntimeException(get_class($this) . ": relation field $relatedEntityName not fetched"); |
|
198 | } |
|
199 | ||
200 | if (!isset($relatedEntityIds[$relatedEntityName])) { |
|
201 | $relatedEntityIds[$relatedEntityName] = new ArrayObject(); |
|
202 | } |
|
203 | ||
204 | if (!in_array($row[$relatedField], (array)$relatedEntityIds[$relatedEntityName])) { |
|
205 | $relatedEntityIds[$relatedEntityName]->append($row[$relatedField]); |
|
206 | } |
|
207 | } |
|
208 | } |
|
209 | ||
210 | $relatedEntities = []; |
|
211 | foreach ($this->with as $relatedEntityName => $cascadeWith) { |