-
Notifications
You must be signed in to change notification settings - Fork 397
/
OnDemandCollection.php
271 lines (231 loc) · 7.85 KB
/
OnDemandCollection.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
<?php
/**
* This file is part of the Propel package.
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*
* @license MIT License
*/
namespace Propel\Runtime\Collection;
use Propel\Runtime\Collection\Exception\ReadOnlyModelException;
use Propel\Runtime\Connection\StatementInterface;
use Propel\Runtime\Exception\PropelException;
use Propel\Runtime\Formatter\AbstractFormatter;
use Propel\Runtime\Map\TableMap;
/**
* Class for iterating over a statement and returning one Propel object at a time
*
* @author Francois Zaninotto
*/
class OnDemandCollection extends Collection
{
/**
* @var OnDemandIterator
*/
protected $iterator;
protected $currentRow;
protected $currentKey;
protected $isValid;
/**
* @param AbstractFormatter $formatter
* @param StatementInterface $stmt
*/
public function initIterator(AbstractFormatter $formatter, StatementInterface $stmt)
{
$this->currentKey = -1;
$this->iterator = new OnDemandIterator($formatter, $stmt);
}
/**
* Get an array representation of the collection
* Each object is turned into an array and the result is returned
*
* @param string $keyColumn If null, the returned array uses an incremental index.
* Otherwise, the array is indexed using the specified column
* @param boolean $usePrefix If true, the returned array prefixes keys
* with the model class name ('Article_0', 'Article_1', etc).
* @param string $keyType (optional) One of the class type constants TableMap::TYPE_PHPNAME,
* TableMap::TYPE_STUDLYPHPNAME, TableMap::TYPE_COLNAME, TableMap::TYPE_FIELDNAME,
* TableMap::TYPE_NUM. Defaults to TableMap::TYPE_PHPNAME.
* @param boolean $includeLazyLoadColumns (optional) Whether to include lazy loaded columns. Defaults to TRUE.
* @param array $alreadyDumpedObjects List of objects to skip to avoid recursion
*
* <code>
* $bookCollection->toArray();
* array(
* 0 => array('Id' => 123, 'Title' => 'War And Peace'),
* 1 => array('Id' => 456, 'Title' => 'Don Juan'),
* )
* $bookCollection->toArray('Id');
* array(
* 123 => array('Id' => 123, 'Title' => 'War And Peace'),
* 456 => array('Id' => 456, 'Title' => 'Don Juan'),
* )
* $bookCollection->toArray(null, true);
* array(
* 'Book_0' => array('Id' => 123, 'Title' => 'War And Peace'),
* 'Book_1' => array('Id' => 456, 'Title' => 'Don Juan'),
* )
* </code>
*
* @return array
*/
public function toArray($keyColumn = null, $usePrefix = false, $keyType = TableMap::TYPE_PHPNAME, $includeLazyLoadColumns = true, $alreadyDumpedObjects = array())
{
$ret = array();
$keyGetterMethod = 'get' . $keyColumn;
/** @var $obj BaseObject */
foreach ($this as $key => $obj) {
$key = null === $keyColumn ? $key : $obj->$keyGetterMethod();
$key = $usePrefix ? ($this->getModel() . '_' . $key) : $key;
$ret[$key] = $obj->toArray($keyType, $includeLazyLoadColumns, $alreadyDumpedObjects, true);
}
return $ret;
}
/**
* Populates the collection from an array
* Each object is populated from an array and the result is stored
* Does not empty the collection before adding the data from the array
*
* @param array $arr
*/
public function fromArray($arr)
{
throw new ReadOnlyModelException('The On Demand Collection is read only');
}
// IteratorAggregate Interface
/**
* @return OnDemandIterator
*/
public function getIterator()
{
return $this->iterator;
}
// ArrayAccess Interface
/**
* @throws \Propel\Runtime\Exception\PropelException
* @param integer $offset
*
* @return boolean
*/
public function offsetExists($offset)
{
if ($offset === $this->currentKey) {
return true;
}
throw new PropelException('The On Demand Collection does not allow access by offset');
}
/**
* @throws \Propel\Runtime\Exception\PropelException
* @param integer $offset
*
* @return mixed
*/
public function offsetGet($offset)
{
if ($offset === $this->currentKey) {
return $this->currentRow;
}
throw new PropelException('The On Demand Collection does not allow access by offset');
}
/**
* @throws \Propel\Runtime\Collection\Exception\ReadOnlyModelException
*
* @param integer $offset
* @param mixed $value
*/
public function offsetSet($offset, $value)
{
throw new ReadOnlyModelException('The On Demand Collection is read only');
}
/**
* @throws \Propel\Runtime\Collection\Exception\ReadOnlyModelException
* @param integer $offset
*/
public function offsetUnset($offset)
{
throw new ReadOnlyModelException('The On Demand Collection is read only');
}
// Serializable Interface
/**
* @throws \Propel\Runtime\Exception\PropelException
*/
public function serialize()
{
throw new PropelException('The On Demand Collection cannot be serialized');
}
/**
* @throws \Propel\Runtime\Exception\PropelException
* @param string $data
*/
public function unserialize($data)
{
throw new PropelException('The On Demand Collection cannot be serialized');
}
// Countable Interface
/**
* Returns the number of rows in the resultset
* Warning: this number is inaccurate for most databases. Do not rely on it for a portable application.
*
* @return integer Number of results
*/
public function count()
{
return $this->iterator->count();
}
// ArrayObject methods
public function append($value)
{
throw new ReadOnlyModelException('The On Demand Collection is read only');
}
public function prepend($value)
{
throw new ReadOnlyModelException('The On Demand Collection is read only');
}
public function asort()
{
throw new ReadOnlyModelException('The On Demand Collection is read only');
}
public function exchangeArray($input)
{
throw new ReadOnlyModelException('The On Demand Collection is read only');
}
public function getArrayCopy()
{
throw new PropelException('The On Demand Collection does not allow access by offset');
}
public function getFlags()
{
throw new PropelException('The On Demand Collection does not allow access by offset');
}
public function ksort()
{
throw new ReadOnlyModelException('The On Demand Collection is read only');
}
public function natcasesort()
{
throw new ReadOnlyModelException('The On Demand Collection is read only');
}
public function natsort()
{
throw new ReadOnlyModelException('The On Demand Collection is read only');
}
public function setFlags($flags)
{
throw new PropelException('The On Demand Collection does not allow acces by offset');
}
public function uasort($cmp_function)
{
throw new ReadOnlyModelException('The On Demand Collection is read only');
}
public function uksort($cmp_function)
{
throw new ReadOnlyModelException('The On Demand Collection is read only');
}
/**
* {@inheritdoc}
*/
public function exportTo($parser, $usePrefix = true, $includeLazyLoadColumns = true)
{
throw new PropelException('A OnDemandCollection cannot be exported.');
}
}