Completed
Push — 4.0 ( e1def4...8f8e98 )
by David
15:31
created
src/Mouf/Database/TDBM/DbRow.php 2 patches
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -353,7 +353,7 @@
 block discarded – undo
353 353
             $pkValues = array_values($firstRefDbRow->_getPrimaryKeys());
354 354
             $localColumns = $fk->getLocalColumns();
355 355
 
356
-            for ($i = 0, $count = count($localColumns); $i < $count; ++$i) {
356
+            for ($i = 0, $count = count($localColumns); $i<$count; ++$i) {
357 357
                 $dbRow[$localColumns[$i]] = $pkValues[$i];
358 358
             }
359 359
         }
Please login to merge, or discard this patch.
Indentation   +354 added lines, -354 removed lines patch added patch discarded remove patch
@@ -27,163 +27,163 @@  discard block
 block discarded – undo
27 27
  */
28 28
 class DbRow
29 29
 {
30
-    /**
31
-     * The service this object is bound to.
32
-     *
33
-     * @var TDBMService
34
-     */
35
-    protected $tdbmService;
36
-
37
-    /**
38
-     * The object containing this db row.
39
-     *
40
-     * @var AbstractTDBMObject
41
-     */
42
-    private $object;
43
-
44
-    /**
45
-     * The name of the table the object if issued from.
46
-     *
47
-     * @var string
48
-     */
49
-    private $dbTableName;
50
-
51
-    /**
52
-     * The array of columns returned from database.
53
-     *
54
-     * @var array
55
-     */
56
-    private $dbRow = array();
57
-
58
-    /**
59
-     * @var AbstractTDBMObject[]
60
-     */
61
-    private $references = array();
62
-
63
-    /**
64
-     * One of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
65
-     * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
66
-     * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
67
-     * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
68
-     *
69
-     * @var string
70
-     */
71
-    private $status;
72
-
73
-    /**
74
-     * The values of the primary key.
75
-     * This is set when the object is in "loaded" state.
76
-     *
77
-     * @var array An array of column => value
78
-     */
79
-    private $primaryKeys;
80
-
81
-    /**
82
-     * You should never call the constructor directly. Instead, you should use the
83
-     * TDBMService class that will create TDBMObjects for you.
84
-     *
85
-     * Used with id!=false when we want to retrieve an existing object
86
-     * and id==false if we want a new object
87
-     *
88
-     * @param AbstractTDBMObject $object      The object containing this db row.
89
-     * @param string             $table_name
90
-     * @param array              $primaryKeys
91
-     * @param TDBMService        $tdbmService
92
-     *
93
-     * @throws TDBMException
94
-     * @throws TDBMInvalidOperationException
95
-     */
96
-    public function __construct(AbstractTDBMObject $object, $table_name, array $primaryKeys = array(), TDBMService $tdbmService = null, array $dbRow = array())
97
-    {
98
-        $this->object = $object;
99
-        $this->dbTableName = $table_name;
100
-
101
-        $this->status = TDBMObjectStateEnum::STATE_DETACHED;
102
-
103
-        if ($tdbmService === null) {
104
-            if (!empty($primaryKeys)) {
105
-                throw new TDBMException('You cannot pass an id to the DbRow constructor without passing also a TDBMService.');
106
-            }
107
-        } else {
108
-            $this->tdbmService = $tdbmService;
109
-
110
-            if (!empty($primaryKeys)) {
111
-                $this->_setPrimaryKeys($primaryKeys);
112
-                if (!empty($dbRow)) {
113
-                    $this->dbRow = $dbRow;
114
-                    $this->status = TDBMObjectStateEnum::STATE_LOADED;
115
-                } else {
116
-                    $this->status = TDBMObjectStateEnum::STATE_NOT_LOADED;
117
-                }
118
-                $tdbmService->_addToCache($this);
119
-            } else {
120
-                $this->status = TDBMObjectStateEnum::STATE_NEW;
121
-                $this->tdbmService->_addToToSaveObjectList($this);
122
-            }
123
-        }
124
-    }
125
-
126
-    public function _attach(TDBMService $tdbmService)
127
-    {
128
-        if ($this->status !== TDBMObjectStateEnum::STATE_DETACHED) {
129
-            throw new TDBMInvalidOperationException('Cannot attach an object that is already attached to TDBM.');
130
-        }
131
-        $this->tdbmService = $tdbmService;
132
-        $this->status = TDBMObjectStateEnum::STATE_NEW;
133
-        $this->tdbmService->_addToToSaveObjectList($this);
134
-    }
135
-
136
-    /**
137
-     * Sets the state of the TDBM Object
138
-     * One of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
139
-     * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
140
-     * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
141
-     * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
142
-     *
143
-     * @param string $state
144
-     */
145
-    public function _setStatus($state)
146
-    {
147
-        $this->status = $state;
148
-    }
149
-
150
-    /**
151
-     * This is an internal method. You should not call this method yourself. The TDBM library will do it for you.
152
-     * If the object is in state 'not loaded', this method performs a query in database to load the object.
153
-     *
154
-     * A TDBMException is thrown is no object can be retrieved (for instance, if the primary key specified
155
-     * cannot be found).
156
-     */
157
-    public function _dbLoadIfNotLoaded()
158
-    {
159
-        if ($this->status == TDBMObjectStateEnum::STATE_NOT_LOADED) {
160
-            $connection = $this->tdbmService->getConnection();
161
-
162
-            /// buildFilterFromFilterBag($filter_bag)
163
-            list($sql_where, $parameters) = $this->tdbmService->buildFilterFromFilterBag($this->primaryKeys);
164
-
165
-            $sql = 'SELECT * FROM '.$connection->quoteIdentifier($this->dbTableName).' WHERE '.$sql_where;
166
-            $result = $connection->executeQuery($sql, $parameters);
167
-
168
-            if ($result->rowCount() === 0) {
169
-                throw new TDBMException("Could not retrieve object from table \"$this->dbTableName\" using filter \"\".");
170
-            }
171
-
172
-            $this->dbRow = $result->fetch(\PDO::FETCH_ASSOC);
173
-
174
-            $result->closeCursor();
175
-
176
-            $this->status = TDBMObjectStateEnum::STATE_LOADED;
177
-        }
178
-    }
179
-
180
-    public function get($var)
181
-    {
182
-        $this->_dbLoadIfNotLoaded();
183
-
184
-        // Let's first check if the key exist.
185
-        if (!isset($this->dbRow[$var])) {
186
-            /*
30
+	/**
31
+	 * The service this object is bound to.
32
+	 *
33
+	 * @var TDBMService
34
+	 */
35
+	protected $tdbmService;
36
+
37
+	/**
38
+	 * The object containing this db row.
39
+	 *
40
+	 * @var AbstractTDBMObject
41
+	 */
42
+	private $object;
43
+
44
+	/**
45
+	 * The name of the table the object if issued from.
46
+	 *
47
+	 * @var string
48
+	 */
49
+	private $dbTableName;
50
+
51
+	/**
52
+	 * The array of columns returned from database.
53
+	 *
54
+	 * @var array
55
+	 */
56
+	private $dbRow = array();
57
+
58
+	/**
59
+	 * @var AbstractTDBMObject[]
60
+	 */
61
+	private $references = array();
62
+
63
+	/**
64
+	 * One of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
65
+	 * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
66
+	 * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
67
+	 * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
68
+	 *
69
+	 * @var string
70
+	 */
71
+	private $status;
72
+
73
+	/**
74
+	 * The values of the primary key.
75
+	 * This is set when the object is in "loaded" state.
76
+	 *
77
+	 * @var array An array of column => value
78
+	 */
79
+	private $primaryKeys;
80
+
81
+	/**
82
+	 * You should never call the constructor directly. Instead, you should use the
83
+	 * TDBMService class that will create TDBMObjects for you.
84
+	 *
85
+	 * Used with id!=false when we want to retrieve an existing object
86
+	 * and id==false if we want a new object
87
+	 *
88
+	 * @param AbstractTDBMObject $object      The object containing this db row.
89
+	 * @param string             $table_name
90
+	 * @param array              $primaryKeys
91
+	 * @param TDBMService        $tdbmService
92
+	 *
93
+	 * @throws TDBMException
94
+	 * @throws TDBMInvalidOperationException
95
+	 */
96
+	public function __construct(AbstractTDBMObject $object, $table_name, array $primaryKeys = array(), TDBMService $tdbmService = null, array $dbRow = array())
97
+	{
98
+		$this->object = $object;
99
+		$this->dbTableName = $table_name;
100
+
101
+		$this->status = TDBMObjectStateEnum::STATE_DETACHED;
102
+
103
+		if ($tdbmService === null) {
104
+			if (!empty($primaryKeys)) {
105
+				throw new TDBMException('You cannot pass an id to the DbRow constructor without passing also a TDBMService.');
106
+			}
107
+		} else {
108
+			$this->tdbmService = $tdbmService;
109
+
110
+			if (!empty($primaryKeys)) {
111
+				$this->_setPrimaryKeys($primaryKeys);
112
+				if (!empty($dbRow)) {
113
+					$this->dbRow = $dbRow;
114
+					$this->status = TDBMObjectStateEnum::STATE_LOADED;
115
+				} else {
116
+					$this->status = TDBMObjectStateEnum::STATE_NOT_LOADED;
117
+				}
118
+				$tdbmService->_addToCache($this);
119
+			} else {
120
+				$this->status = TDBMObjectStateEnum::STATE_NEW;
121
+				$this->tdbmService->_addToToSaveObjectList($this);
122
+			}
123
+		}
124
+	}
125
+
126
+	public function _attach(TDBMService $tdbmService)
127
+	{
128
+		if ($this->status !== TDBMObjectStateEnum::STATE_DETACHED) {
129
+			throw new TDBMInvalidOperationException('Cannot attach an object that is already attached to TDBM.');
130
+		}
131
+		$this->tdbmService = $tdbmService;
132
+		$this->status = TDBMObjectStateEnum::STATE_NEW;
133
+		$this->tdbmService->_addToToSaveObjectList($this);
134
+	}
135
+
136
+	/**
137
+	 * Sets the state of the TDBM Object
138
+	 * One of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
139
+	 * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
140
+	 * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
141
+	 * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
142
+	 *
143
+	 * @param string $state
144
+	 */
145
+	public function _setStatus($state)
146
+	{
147
+		$this->status = $state;
148
+	}
149
+
150
+	/**
151
+	 * This is an internal method. You should not call this method yourself. The TDBM library will do it for you.
152
+	 * If the object is in state 'not loaded', this method performs a query in database to load the object.
153
+	 *
154
+	 * A TDBMException is thrown is no object can be retrieved (for instance, if the primary key specified
155
+	 * cannot be found).
156
+	 */
157
+	public function _dbLoadIfNotLoaded()
158
+	{
159
+		if ($this->status == TDBMObjectStateEnum::STATE_NOT_LOADED) {
160
+			$connection = $this->tdbmService->getConnection();
161
+
162
+			/// buildFilterFromFilterBag($filter_bag)
163
+			list($sql_where, $parameters) = $this->tdbmService->buildFilterFromFilterBag($this->primaryKeys);
164
+
165
+			$sql = 'SELECT * FROM '.$connection->quoteIdentifier($this->dbTableName).' WHERE '.$sql_where;
166
+			$result = $connection->executeQuery($sql, $parameters);
167
+
168
+			if ($result->rowCount() === 0) {
169
+				throw new TDBMException("Could not retrieve object from table \"$this->dbTableName\" using filter \"\".");
170
+			}
171
+
172
+			$this->dbRow = $result->fetch(\PDO::FETCH_ASSOC);
173
+
174
+			$result->closeCursor();
175
+
176
+			$this->status = TDBMObjectStateEnum::STATE_LOADED;
177
+		}
178
+	}
179
+
180
+	public function get($var)
181
+	{
182
+		$this->_dbLoadIfNotLoaded();
183
+
184
+		// Let's first check if the key exist.
185
+		if (!isset($this->dbRow[$var])) {
186
+			/*
187 187
             // Unable to find column.... this is an error if the object has been retrieved from database.
188 188
             // If it's a new object, well, that may not be an error after all!
189 189
             // Let's check if the column does exist in the table
@@ -203,30 +203,30 @@  discard block
 block discarded – undo
203 203
             $str = "Could not find column \"$var\" in table \"$this->dbTableName\". Maybe you meant one of those columns: '".implode("', '",$result_array)."'";
204 204
 
205 205
             throw new TDBMException($str);*/
206
-            return;
207
-        }
208
-
209
-        return $this->dbRow[$var];
210
-    }
211
-
212
-    /**
213
-     * Returns true if a column is set, false otherwise.
214
-     *
215
-     * @param string $var
216
-     *
217
-     * @return bool
218
-     */
219
-    /*public function has($var) {
206
+			return;
207
+		}
208
+
209
+		return $this->dbRow[$var];
210
+	}
211
+
212
+	/**
213
+	 * Returns true if a column is set, false otherwise.
214
+	 *
215
+	 * @param string $var
216
+	 *
217
+	 * @return bool
218
+	 */
219
+	/*public function has($var) {
220 220
         $this->_dbLoadIfNotLoaded();
221 221
 
222 222
         return isset($this->dbRow[$var]);
223 223
     }*/
224 224
 
225
-    public function set($var, $value)
226
-    {
227
-        $this->_dbLoadIfNotLoaded();
225
+	public function set($var, $value)
226
+	{
227
+		$this->_dbLoadIfNotLoaded();
228 228
 
229
-        /*
229
+		/*
230 230
         // Ok, let's start by checking the column type
231 231
         $type = $this->db_connection->getColumnType($this->dbTableName, $var);
232 232
 
@@ -236,184 +236,184 @@  discard block
 block discarded – undo
236 236
         }
237 237
         */
238 238
 
239
-        /*if ($var == $this->getPrimaryKey() && isset($this->dbRow[$var]))
239
+		/*if ($var == $this->getPrimaryKey() && isset($this->dbRow[$var]))
240 240
             throw new TDBMException("Error! Changing primary key value is forbidden.");*/
241
-        $this->dbRow[$var] = $value;
242
-        if ($this->tdbmService !== null && $this->status === TDBMObjectStateEnum::STATE_LOADED) {
243
-            $this->status = TDBMObjectStateEnum::STATE_DIRTY;
244
-            $this->tdbmService->_addToToSaveObjectList($this);
245
-        }
246
-    }
247
-
248
-    /**
249
-     * @param string             $foreignKeyName
250
-     * @param AbstractTDBMObject $bean
251
-     */
252
-    public function setRef($foreignKeyName, AbstractTDBMObject $bean = null)
253
-    {
254
-        $this->references[$foreignKeyName] = $bean;
255
-
256
-        if ($this->tdbmService !== null && $this->status === TDBMObjectStateEnum::STATE_LOADED) {
257
-            $this->status = TDBMObjectStateEnum::STATE_DIRTY;
258
-            $this->tdbmService->_addToToSaveObjectList($this);
259
-        }
260
-    }
261
-
262
-    /**
263
-     * @param string $foreignKeyName A unique name for this reference
264
-     *
265
-     * @return AbstractTDBMObject|null
266
-     */
267
-    public function getRef($foreignKeyName)
268
-    {
269
-        if (isset($this->references[$foreignKeyName])) {
270
-            return $this->references[$foreignKeyName];
271
-        } elseif ($this->status === TDBMObjectStateEnum::STATE_NEW) {
272
-            // If the object is new and has no property, then it has to be empty.
273
-            return;
274
-        } else {
275
-            $this->_dbLoadIfNotLoaded();
276
-
277
-            // Let's match the name of the columns to the primary key values
278
-            $fk = $this->tdbmService->_getForeignKeyByName($this->dbTableName, $foreignKeyName);
279
-
280
-            $values = [];
281
-            foreach ($fk->getLocalColumns() as $column) {
282
-                $values[] = $this->dbRow[$column];
283
-            }
284
-
285
-            $filter = array_combine($this->tdbmService->getPrimaryKeyColumns($fk->getForeignTableName()), $values);
286
-
287
-            return $this->tdbmService->findObjectByPk($fk->getForeignTableName(), $filter, [], true);
288
-        }
289
-    }
290
-
291
-    /**
292
-     * Returns the name of the table this object comes from.
293
-     *
294
-     * @return string
295
-     */
296
-    public function _getDbTableName()
297
-    {
298
-        return $this->dbTableName;
299
-    }
300
-
301
-    /**
302
-     * Method used internally by TDBM. You should not use it directly.
303
-     * This method returns the status of the TDBMObject.
304
-     * This is one of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
305
-     * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
306
-     * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
307
-     * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
308
-     *
309
-     * @return string
310
-     */
311
-    public function _getStatus()
312
-    {
313
-        return $this->status;
314
-    }
315
-
316
-    /**
317
-     * Override the native php clone function for TDBMObjects.
318
-     */
319
-    public function __clone()
320
-    {
321
-        // Let's load the row (before we lose the ID!)
322
-        $this->_dbLoadIfNotLoaded();
323
-
324
-        //Let's set the status to detached
325
-        $this->status = TDBMObjectStateEnum::STATE_DETACHED;
326
-
327
-        $this->primaryKeys = [];
328
-
329
-        //Now unset the PK from the row
330
-        if ($this->tdbmService) {
331
-            $pk_array = $this->tdbmService->getPrimaryKeyColumns($this->dbTableName);
332
-            foreach ($pk_array as $pk) {
333
-                $this->dbRow[$pk] = null;
334
-            }
335
-        }
336
-    }
337
-
338
-    /**
339
-     * Returns raw database row.
340
-     *
341
-     * @return array
342
-     */
343
-    public function _getDbRow()
344
-    {
345
-        // Let's merge $dbRow and $references
346
-        $dbRow = $this->dbRow;
347
-
348
-        foreach ($this->references as $foreignKeyName => $reference) {
349
-            // Let's match the name of the columns to the primary key values
350
-            $fk = $this->tdbmService->_getForeignKeyByName($this->dbTableName, $foreignKeyName);
351
-            $refDbRows = $reference->_getDbRows();
352
-            $firstRefDbRow = reset($refDbRows);
353
-            $pkValues = array_values($firstRefDbRow->_getPrimaryKeys());
354
-            $localColumns = $fk->getLocalColumns();
355
-
356
-            for ($i = 0, $count = count($localColumns); $i < $count; ++$i) {
357
-                $dbRow[$localColumns[$i]] = $pkValues[$i];
358
-            }
359
-        }
360
-
361
-        return $dbRow;
362
-    }
363
-
364
-    /**
365
-     * Returns references array.
366
-     *
367
-     * @return AbstractTDBMObject[]
368
-     */
369
-    public function _getReferences()
370
-    {
371
-        return $this->references;
372
-    }
373
-
374
-    /**
375
-     * Returns the values of the primary key.
376
-     * This is set when the object is in "loaded" state.
377
-     *
378
-     * @return array
379
-     */
380
-    public function _getPrimaryKeys()
381
-    {
382
-        return $this->primaryKeys;
383
-    }
384
-
385
-    /**
386
-     * Sets the values of the primary key.
387
-     * This is set when the object is in "loaded" state.
388
-     *
389
-     * @param array $primaryKeys
390
-     */
391
-    public function _setPrimaryKeys(array $primaryKeys)
392
-    {
393
-        $this->primaryKeys = $primaryKeys;
394
-        foreach ($this->primaryKeys as $column => $value) {
395
-            $this->dbRow[$column] = $value;
396
-        }
397
-    }
398
-
399
-    /**
400
-     * Returns the TDBMObject this bean is associated to.
401
-     *
402
-     * @return AbstractTDBMObject
403
-     */
404
-    public function getTDBMObject()
405
-    {
406
-        return $this->object;
407
-    }
408
-
409
-    /**
410
-     * Sets the TDBMObject this bean is associated to.
411
-     * Only used when cloning.
412
-     *
413
-     * @param AbstractTDBMObject $object
414
-     */
415
-    public function setTDBMObject(AbstractTDBMObject $object)
416
-    {
417
-        $this->object = $object;
418
-    }
241
+		$this->dbRow[$var] = $value;
242
+		if ($this->tdbmService !== null && $this->status === TDBMObjectStateEnum::STATE_LOADED) {
243
+			$this->status = TDBMObjectStateEnum::STATE_DIRTY;
244
+			$this->tdbmService->_addToToSaveObjectList($this);
245
+		}
246
+	}
247
+
248
+	/**
249
+	 * @param string             $foreignKeyName
250
+	 * @param AbstractTDBMObject $bean
251
+	 */
252
+	public function setRef($foreignKeyName, AbstractTDBMObject $bean = null)
253
+	{
254
+		$this->references[$foreignKeyName] = $bean;
255
+
256
+		if ($this->tdbmService !== null && $this->status === TDBMObjectStateEnum::STATE_LOADED) {
257
+			$this->status = TDBMObjectStateEnum::STATE_DIRTY;
258
+			$this->tdbmService->_addToToSaveObjectList($this);
259
+		}
260
+	}
261
+
262
+	/**
263
+	 * @param string $foreignKeyName A unique name for this reference
264
+	 *
265
+	 * @return AbstractTDBMObject|null
266
+	 */
267
+	public function getRef($foreignKeyName)
268
+	{
269
+		if (isset($this->references[$foreignKeyName])) {
270
+			return $this->references[$foreignKeyName];
271
+		} elseif ($this->status === TDBMObjectStateEnum::STATE_NEW) {
272
+			// If the object is new and has no property, then it has to be empty.
273
+			return;
274
+		} else {
275
+			$this->_dbLoadIfNotLoaded();
276
+
277
+			// Let's match the name of the columns to the primary key values
278
+			$fk = $this->tdbmService->_getForeignKeyByName($this->dbTableName, $foreignKeyName);
279
+
280
+			$values = [];
281
+			foreach ($fk->getLocalColumns() as $column) {
282
+				$values[] = $this->dbRow[$column];
283
+			}
284
+
285
+			$filter = array_combine($this->tdbmService->getPrimaryKeyColumns($fk->getForeignTableName()), $values);
286
+
287
+			return $this->tdbmService->findObjectByPk($fk->getForeignTableName(), $filter, [], true);
288
+		}
289
+	}
290
+
291
+	/**
292
+	 * Returns the name of the table this object comes from.
293
+	 *
294
+	 * @return string
295
+	 */
296
+	public function _getDbTableName()
297
+	{
298
+		return $this->dbTableName;
299
+	}
300
+
301
+	/**
302
+	 * Method used internally by TDBM. You should not use it directly.
303
+	 * This method returns the status of the TDBMObject.
304
+	 * This is one of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
305
+	 * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
306
+	 * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
307
+	 * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
308
+	 *
309
+	 * @return string
310
+	 */
311
+	public function _getStatus()
312
+	{
313
+		return $this->status;
314
+	}
315
+
316
+	/**
317
+	 * Override the native php clone function for TDBMObjects.
318
+	 */
319
+	public function __clone()
320
+	{
321
+		// Let's load the row (before we lose the ID!)
322
+		$this->_dbLoadIfNotLoaded();
323
+
324
+		//Let's set the status to detached
325
+		$this->status = TDBMObjectStateEnum::STATE_DETACHED;
326
+
327
+		$this->primaryKeys = [];
328
+
329
+		//Now unset the PK from the row
330
+		if ($this->tdbmService) {
331
+			$pk_array = $this->tdbmService->getPrimaryKeyColumns($this->dbTableName);
332
+			foreach ($pk_array as $pk) {
333
+				$this->dbRow[$pk] = null;
334
+			}
335
+		}
336
+	}
337
+
338
+	/**
339
+	 * Returns raw database row.
340
+	 *
341
+	 * @return array
342
+	 */
343
+	public function _getDbRow()
344
+	{
345
+		// Let's merge $dbRow and $references
346
+		$dbRow = $this->dbRow;
347
+
348
+		foreach ($this->references as $foreignKeyName => $reference) {
349
+			// Let's match the name of the columns to the primary key values
350
+			$fk = $this->tdbmService->_getForeignKeyByName($this->dbTableName, $foreignKeyName);
351
+			$refDbRows = $reference->_getDbRows();
352
+			$firstRefDbRow = reset($refDbRows);
353
+			$pkValues = array_values($firstRefDbRow->_getPrimaryKeys());
354
+			$localColumns = $fk->getLocalColumns();
355
+
356
+			for ($i = 0, $count = count($localColumns); $i < $count; ++$i) {
357
+				$dbRow[$localColumns[$i]] = $pkValues[$i];
358
+			}
359
+		}
360
+
361
+		return $dbRow;
362
+	}
363
+
364
+	/**
365
+	 * Returns references array.
366
+	 *
367
+	 * @return AbstractTDBMObject[]
368
+	 */
369
+	public function _getReferences()
370
+	{
371
+		return $this->references;
372
+	}
373
+
374
+	/**
375
+	 * Returns the values of the primary key.
376
+	 * This is set when the object is in "loaded" state.
377
+	 *
378
+	 * @return array
379
+	 */
380
+	public function _getPrimaryKeys()
381
+	{
382
+		return $this->primaryKeys;
383
+	}
384
+
385
+	/**
386
+	 * Sets the values of the primary key.
387
+	 * This is set when the object is in "loaded" state.
388
+	 *
389
+	 * @param array $primaryKeys
390
+	 */
391
+	public function _setPrimaryKeys(array $primaryKeys)
392
+	{
393
+		$this->primaryKeys = $primaryKeys;
394
+		foreach ($this->primaryKeys as $column => $value) {
395
+			$this->dbRow[$column] = $value;
396
+		}
397
+	}
398
+
399
+	/**
400
+	 * Returns the TDBMObject this bean is associated to.
401
+	 *
402
+	 * @return AbstractTDBMObject
403
+	 */
404
+	public function getTDBMObject()
405
+	{
406
+		return $this->object;
407
+	}
408
+
409
+	/**
410
+	 * Sets the TDBMObject this bean is associated to.
411
+	 * Only used when cloning.
412
+	 *
413
+	 * @param AbstractTDBMObject $object
414
+	 */
415
+	public function setTDBMObject(AbstractTDBMObject $object)
416
+	{
417
+		$this->object = $object;
418
+	}
419 419
 }
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/MapIterator.php 1 patch
Indentation   +71 added lines, -71 removed lines patch added patch discarded remove patch
@@ -9,86 +9,86 @@
 block discarded – undo
9 9
  */
10 10
 class MapIterator implements Iterator
11 11
 {
12
-    /**
13
-     * @var Iterator
14
-     */
15
-    protected $iterator;
12
+	/**
13
+	 * @var Iterator
14
+	 */
15
+	protected $iterator;
16 16
 
17
-    /**
18
-     * @var callable Modifies the current item in iterator
19
-     */
20
-    protected $callable;
17
+	/**
18
+	 * @var callable Modifies the current item in iterator
19
+	 */
20
+	protected $callable;
21 21
 
22
-    /**
23
-     * @param $iterator Iterator|array
24
-     * @param $callable callable This can have two parameters
25
-     *
26
-     * @throws TDBMException
27
-     */
28
-    public function __construct($iterator, callable $callable)
29
-    {
30
-        if (is_array($iterator)) {
31
-            $this->iterator = new \ArrayIterator($iterator);
32
-        } elseif (!($iterator instanceof Iterator)) {
33
-            throw new TDBMException("\$iterator parameter must be an instance of Iterator");
34
-        } else {
35
-            $this->iterator = $iterator;
36
-        }
22
+	/**
23
+	 * @param $iterator Iterator|array
24
+	 * @param $callable callable This can have two parameters
25
+	 *
26
+	 * @throws TDBMException
27
+	 */
28
+	public function __construct($iterator, callable $callable)
29
+	{
30
+		if (is_array($iterator)) {
31
+			$this->iterator = new \ArrayIterator($iterator);
32
+		} elseif (!($iterator instanceof Iterator)) {
33
+			throw new TDBMException("\$iterator parameter must be an instance of Iterator");
34
+		} else {
35
+			$this->iterator = $iterator;
36
+		}
37 37
 
38
-        if ($callable instanceof \Closure) {
39
-            // make sure there's one argument
40
-            $reflection = new \ReflectionObject($callable);
41
-            if ($reflection->hasMethod('__invoke')) {
42
-                $method = $reflection->getMethod('__invoke');
43
-                if ($method->getNumberOfParameters() !== 1) {
44
-                    throw new TDBMException("\$callable must accept one and only one parameter.");
45
-                }
46
-            }
47
-        }
38
+		if ($callable instanceof \Closure) {
39
+			// make sure there's one argument
40
+			$reflection = new \ReflectionObject($callable);
41
+			if ($reflection->hasMethod('__invoke')) {
42
+				$method = $reflection->getMethod('__invoke');
43
+				if ($method->getNumberOfParameters() !== 1) {
44
+					throw new TDBMException("\$callable must accept one and only one parameter.");
45
+				}
46
+			}
47
+		}
48 48
 
49
-        $this->callable = $callable;
50
-    }
49
+		$this->callable = $callable;
50
+	}
51 51
 
52
-    /**
53
-     * Alters the current item with $this->callable and returns a new item.
54
-     * Be careful with your types as we can't do static type checking here!
55
-     *
56
-     * @return mixed
57
-     */
58
-    public function current()
59
-    {
60
-        $callable = $this->callable;
52
+	/**
53
+	 * Alters the current item with $this->callable and returns a new item.
54
+	 * Be careful with your types as we can't do static type checking here!
55
+	 *
56
+	 * @return mixed
57
+	 */
58
+	public function current()
59
+	{
60
+		$callable = $this->callable;
61 61
 
62
-        return $callable($this->iterator->current());
63
-    }
62
+		return $callable($this->iterator->current());
63
+	}
64 64
 
65
-    public function next()
66
-    {
67
-        $this->iterator->next();
68
-    }
65
+	public function next()
66
+	{
67
+		$this->iterator->next();
68
+	}
69 69
 
70
-    public function key()
71
-    {
72
-        return $this->iterator->key();
73
-    }
70
+	public function key()
71
+	{
72
+		return $this->iterator->key();
73
+	}
74 74
 
75
-    public function valid()
76
-    {
77
-        return $this->iterator->valid();
78
-    }
75
+	public function valid()
76
+	{
77
+		return $this->iterator->valid();
78
+	}
79 79
 
80
-    public function rewind()
81
-    {
82
-        $this->iterator->rewind();
83
-    }
80
+	public function rewind()
81
+	{
82
+		$this->iterator->rewind();
83
+	}
84 84
 
85
-    /**
86
-     * Casts the iterator to a PHP array.
87
-     *
88
-     * @return array
89
-     */
90
-    public function toArray()
91
-    {
92
-        return iterator_to_array($this);
93
-    }
85
+	/**
86
+	 * Casts the iterator to a PHP array.
87
+	 *
88
+	 * @return array
89
+	 */
90
+	public function toArray()
91
+	{
92
+		return iterator_to_array($this);
93
+	}
94 94
 }
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/StandardObjectStorage.php 1 patch
Indentation   +69 added lines, -69 removed lines patch added patch discarded remove patch
@@ -30,78 +30,78 @@
 block discarded – undo
30 30
  */
31 31
 class StandardObjectStorage
32 32
 {
33
-    /**
34
-     * An array of fetched object, accessible via table name and primary key.
35
-     * If the primary key is split on several columns, access is done by an array of columns, serialized.
36
-     *
37
-     * @var array<string, array<string, TDBMObject>>
38
-     */
39
-    private $objects = array();
33
+	/**
34
+	 * An array of fetched object, accessible via table name and primary key.
35
+	 * If the primary key is split on several columns, access is done by an array of columns, serialized.
36
+	 *
37
+	 * @var array<string, array<string, TDBMObject>>
38
+	 */
39
+	private $objects = array();
40 40
 
41
-    /**
42
-     * Sets an object in the storage.
43
-     *
44
-     * @param string     $tableName
45
-     * @param string     $id
46
-     * @param TDBMObject $dbRow
47
-     */
48
-    public function set($tableName, $id, DbRow $dbRow)
49
-    {
50
-        $this->objects[$tableName][$id] = $dbRow;
51
-    }
41
+	/**
42
+	 * Sets an object in the storage.
43
+	 *
44
+	 * @param string     $tableName
45
+	 * @param string     $id
46
+	 * @param TDBMObject $dbRow
47
+	 */
48
+	public function set($tableName, $id, DbRow $dbRow)
49
+	{
50
+		$this->objects[$tableName][$id] = $dbRow;
51
+	}
52 52
 
53
-    /**
54
-     * Checks if an object is in the storage.
55
-     *
56
-     * @param string $tableName
57
-     * @param string $id
58
-     *
59
-     * @return bool
60
-     */
61
-    public function has($tableName, $id)
62
-    {
63
-        return isset($this->objects[$tableName][$id]);
64
-    }
53
+	/**
54
+	 * Checks if an object is in the storage.
55
+	 *
56
+	 * @param string $tableName
57
+	 * @param string $id
58
+	 *
59
+	 * @return bool
60
+	 */
61
+	public function has($tableName, $id)
62
+	{
63
+		return isset($this->objects[$tableName][$id]);
64
+	}
65 65
 
66
-    /**
67
-     * Returns an object from the storage (or null if no object is set).
68
-     *
69
-     * @param string $tableName
70
-     * @param string $id
71
-     *
72
-     * @return DbRow
73
-     */
74
-    public function get($tableName, $id)
75
-    {
76
-        if (isset($this->objects[$tableName][$id])) {
77
-            return $this->objects[$tableName][$id];
78
-        } else {
79
-            return;
80
-        }
81
-    }
66
+	/**
67
+	 * Returns an object from the storage (or null if no object is set).
68
+	 *
69
+	 * @param string $tableName
70
+	 * @param string $id
71
+	 *
72
+	 * @return DbRow
73
+	 */
74
+	public function get($tableName, $id)
75
+	{
76
+		if (isset($this->objects[$tableName][$id])) {
77
+			return $this->objects[$tableName][$id];
78
+		} else {
79
+			return;
80
+		}
81
+	}
82 82
 
83
-    /**
84
-     * Removes an object from the storage.
85
-     *
86
-     * @param string $tableName
87
-     * @param string $id
88
-     */
89
-    public function remove($tableName, $id)
90
-    {
91
-        unset($this->objects[$tableName][$id]);
92
-    }
83
+	/**
84
+	 * Removes an object from the storage.
85
+	 *
86
+	 * @param string $tableName
87
+	 * @param string $id
88
+	 */
89
+	public function remove($tableName, $id)
90
+	{
91
+		unset($this->objects[$tableName][$id]);
92
+	}
93 93
 
94
-    /**
95
-     * Applies the callback to all objects.
96
-     *
97
-     * @param callable $callback
98
-     */
99
-    public function apply(callable $callback)
100
-    {
101
-        foreach ($this->objects as $tableName => $table) {
102
-            foreach ($table as $id => $obj) {
103
-                $callback($obj, $tableName, $id);
104
-            }
105
-        }
106
-    }
94
+	/**
95
+	 * Applies the callback to all objects.
96
+	 *
97
+	 * @param callable $callback
98
+	 */
99
+	public function apply(callable $callback)
100
+	{
101
+		foreach ($this->objects as $tableName => $table) {
102
+			foreach ($table as $id => $obj) {
103
+				$callback($obj, $tableName, $id);
104
+			}
105
+		}
106
+	}
107 107
 }
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/PageIterator.php 2 patches
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -112,7 +112,7 @@  discard block
 block discarded – undo
112 112
      */
113 113
     public function getCurrentPage()
114 114
     {
115
-        return floor($this->offset / $this->limit) + 1;
115
+        return floor($this->offset/$this->limit)+1;
116 116
     }
117 117
 
118 118
     /**
@@ -251,7 +251,7 @@  discard block
 block discarded – undo
251 251
      */
252 252
     public function jsonSerialize()
253 253
     {
254
-        return array_map(function (AbstractTDBMObject $item) {
254
+        return array_map(function(AbstractTDBMObject $item) {
255 255
             return $item->jsonSerialize();
256 256
         }, $this->toArray());
257 257
     }
Please login to merge, or discard this patch.
Indentation   +206 added lines, -206 removed lines patch added patch discarded remove patch
@@ -29,232 +29,232 @@
 block discarded – undo
29 29
  */
30 30
 class PageIterator implements Page, \ArrayAccess, \JsonSerializable
31 31
 {
32
-    /**
33
-     * @var Statement
34
-     */
35
-    protected $statement;
32
+	/**
33
+	 * @var Statement
34
+	 */
35
+	protected $statement;
36 36
 
37
-    protected $fetchStarted = false;
38
-    private $objectStorage;
39
-    private $className;
37
+	protected $fetchStarted = false;
38
+	private $objectStorage;
39
+	private $className;
40 40
 
41
-    private $parentResult;
42
-    private $tdbmService;
43
-    private $magicSql;
44
-    private $parameters;
45
-    private $limit;
46
-    private $offset;
47
-    private $columnDescriptors;
48
-    private $magicQuery;
41
+	private $parentResult;
42
+	private $tdbmService;
43
+	private $magicSql;
44
+	private $parameters;
45
+	private $limit;
46
+	private $offset;
47
+	private $columnDescriptors;
48
+	private $magicQuery;
49 49
 
50
-    /**
51
-     * The key of the current retrieved object.
52
-     *
53
-     * @var int
54
-     */
55
-    protected $key = -1;
50
+	/**
51
+	 * The key of the current retrieved object.
52
+	 *
53
+	 * @var int
54
+	 */
55
+	protected $key = -1;
56 56
 
57
-    protected $current = null;
57
+	protected $current = null;
58 58
 
59
-    private $databasePlatform;
59
+	private $databasePlatform;
60 60
 
61
-    private $innerResultIterator;
61
+	private $innerResultIterator;
62 62
 
63
-    private $mode;
63
+	private $mode;
64 64
 
65
-    public function __construct(ResultIterator $parentResult, $magicSql, array $parameters, $limit, $offset, array $columnDescriptors, $objectStorage, $className, TDBMService $tdbmService, MagicQuery $magicQuery, $mode)
66
-    {
67
-        $this->parentResult = $parentResult;
68
-        $this->magicSql = $magicSql;
69
-        $this->objectStorage = $objectStorage;
70
-        $this->className = $className;
71
-        $this->tdbmService = $tdbmService;
72
-        $this->parameters = $parameters;
73
-        $this->limit = $limit;
74
-        $this->offset = $offset;
75
-        $this->columnDescriptors = $columnDescriptors;
76
-        $this->magicQuery = $magicQuery;
77
-        $this->databasePlatform = $this->tdbmService->getConnection()->getDatabasePlatform();
78
-        $this->mode = $mode;
79
-    }
65
+	public function __construct(ResultIterator $parentResult, $magicSql, array $parameters, $limit, $offset, array $columnDescriptors, $objectStorage, $className, TDBMService $tdbmService, MagicQuery $magicQuery, $mode)
66
+	{
67
+		$this->parentResult = $parentResult;
68
+		$this->magicSql = $magicSql;
69
+		$this->objectStorage = $objectStorage;
70
+		$this->className = $className;
71
+		$this->tdbmService = $tdbmService;
72
+		$this->parameters = $parameters;
73
+		$this->limit = $limit;
74
+		$this->offset = $offset;
75
+		$this->columnDescriptors = $columnDescriptors;
76
+		$this->magicQuery = $magicQuery;
77
+		$this->databasePlatform = $this->tdbmService->getConnection()->getDatabasePlatform();
78
+		$this->mode = $mode;
79
+	}
80 80
 
81
-    /**
82
-     * Retrieve an external iterator.
83
-     *
84
-     * @link http://php.net/manual/en/iteratoraggregate.getiterator.php
85
-     *
86
-     * @return InnerResultIterator An instance of an object implementing <b>Iterator</b> or
87
-     *                             <b>Traversable</b>
88
-     *
89
-     * @since 5.0.0
90
-     */
91
-    public function getIterator()
92
-    {
93
-        if ($this->innerResultIterator === null) {
94
-            if ($this->mode === TDBMService::MODE_CURSOR) {
95
-                $this->innerResultIterator = new InnerResultIterator($this->magicSql, $this->parameters, $this->limit, $this->offset, $this->columnDescriptors, $this->objectStorage, $this->className, $this->tdbmService, $this->magicQuery);
96
-            } else {
97
-                $this->innerResultIterator = new InnerResultArray($this->magicSql, $this->parameters, $this->limit, $this->offset, $this->columnDescriptors, $this->objectStorage, $this->className, $this->tdbmService, $this->magicQuery);
98
-            }
99
-        }
81
+	/**
82
+	 * Retrieve an external iterator.
83
+	 *
84
+	 * @link http://php.net/manual/en/iteratoraggregate.getiterator.php
85
+	 *
86
+	 * @return InnerResultIterator An instance of an object implementing <b>Iterator</b> or
87
+	 *                             <b>Traversable</b>
88
+	 *
89
+	 * @since 5.0.0
90
+	 */
91
+	public function getIterator()
92
+	{
93
+		if ($this->innerResultIterator === null) {
94
+			if ($this->mode === TDBMService::MODE_CURSOR) {
95
+				$this->innerResultIterator = new InnerResultIterator($this->magicSql, $this->parameters, $this->limit, $this->offset, $this->columnDescriptors, $this->objectStorage, $this->className, $this->tdbmService, $this->magicQuery);
96
+			} else {
97
+				$this->innerResultIterator = new InnerResultArray($this->magicSql, $this->parameters, $this->limit, $this->offset, $this->columnDescriptors, $this->objectStorage, $this->className, $this->tdbmService, $this->magicQuery);
98
+			}
99
+		}
100 100
 
101
-        return $this->innerResultIterator;
102
-    }
101
+		return $this->innerResultIterator;
102
+	}
103 103
 
104
-    /**
105
-     * @return int
106
-     */
107
-    public function getCurrentOffset()
108
-    {
109
-        return $this->offset;
110
-    }
104
+	/**
105
+	 * @return int
106
+	 */
107
+	public function getCurrentOffset()
108
+	{
109
+		return $this->offset;
110
+	}
111 111
 
112
-    /**
113
-     * @return int
114
-     */
115
-    public function getCurrentPage()
116
-    {
117
-        return floor($this->offset / $this->limit) + 1;
118
-    }
112
+	/**
113
+	 * @return int
114
+	 */
115
+	public function getCurrentPage()
116
+	{
117
+		return floor($this->offset / $this->limit) + 1;
118
+	}
119 119
 
120
-    /**
121
-     * @return int
122
-     */
123
-    public function getCurrentLimit()
124
-    {
125
-        return $this->limit;
126
-    }
120
+	/**
121
+	 * @return int
122
+	 */
123
+	public function getCurrentLimit()
124
+	{
125
+		return $this->limit;
126
+	}
127 127
 
128
-    /**
129
-     * Return the number of results on the current page of the {@link Result}.
130
-     *
131
-     * @return int
132
-     */
133
-    public function count()
134
-    {
135
-        return $this->getIterator()->count();
136
-    }
128
+	/**
129
+	 * Return the number of results on the current page of the {@link Result}.
130
+	 *
131
+	 * @return int
132
+	 */
133
+	public function count()
134
+	{
135
+		return $this->getIterator()->count();
136
+	}
137 137
 
138
-    /**
139
-     * Return the number of ALL results in the paginatable of {@link Result}.
140
-     *
141
-     * @return int
142
-     */
143
-    public function totalCount()
144
-    {
145
-        return $this->parentResult->count();
146
-    }
138
+	/**
139
+	 * Return the number of ALL results in the paginatable of {@link Result}.
140
+	 *
141
+	 * @return int
142
+	 */
143
+	public function totalCount()
144
+	{
145
+		return $this->parentResult->count();
146
+	}
147 147
 
148
-    /**
149
-     * Casts the result set to a PHP array.
150
-     *
151
-     * @return array
152
-     */
153
-    public function toArray()
154
-    {
155
-        return iterator_to_array($this->getIterator());
156
-    }
148
+	/**
149
+	 * Casts the result set to a PHP array.
150
+	 *
151
+	 * @return array
152
+	 */
153
+	public function toArray()
154
+	{
155
+		return iterator_to_array($this->getIterator());
156
+	}
157 157
 
158
-    /**
159
-     * Returns a new iterator mapping any call using the $callable function.
160
-     *
161
-     * @param callable $callable
162
-     *
163
-     * @return MapIterator
164
-     */
165
-    public function map(callable $callable)
166
-    {
167
-        return new MapIterator($this->getIterator(), $callable);
168
-    }
158
+	/**
159
+	 * Returns a new iterator mapping any call using the $callable function.
160
+	 *
161
+	 * @param callable $callable
162
+	 *
163
+	 * @return MapIterator
164
+	 */
165
+	public function map(callable $callable)
166
+	{
167
+		return new MapIterator($this->getIterator(), $callable);
168
+	}
169 169
 
170
-    /**
171
-     * Whether a offset exists.
172
-     *
173
-     * @link http://php.net/manual/en/arrayaccess.offsetexists.php
174
-     *
175
-     * @param mixed $offset <p>
176
-     *                      An offset to check for.
177
-     *                      </p>
178
-     *
179
-     * @return bool true on success or false on failure.
180
-     *              </p>
181
-     *              <p>
182
-     *              The return value will be casted to boolean if non-boolean was returned.
183
-     *
184
-     * @since 5.0.0
185
-     */
186
-    public function offsetExists($offset)
187
-    {
188
-        return $this->getIterator()->offsetExists($offset);
189
-    }
170
+	/**
171
+	 * Whether a offset exists.
172
+	 *
173
+	 * @link http://php.net/manual/en/arrayaccess.offsetexists.php
174
+	 *
175
+	 * @param mixed $offset <p>
176
+	 *                      An offset to check for.
177
+	 *                      </p>
178
+	 *
179
+	 * @return bool true on success or false on failure.
180
+	 *              </p>
181
+	 *              <p>
182
+	 *              The return value will be casted to boolean if non-boolean was returned.
183
+	 *
184
+	 * @since 5.0.0
185
+	 */
186
+	public function offsetExists($offset)
187
+	{
188
+		return $this->getIterator()->offsetExists($offset);
189
+	}
190 190
 
191
-    /**
192
-     * Offset to retrieve.
193
-     *
194
-     * @link http://php.net/manual/en/arrayaccess.offsetget.php
195
-     *
196
-     * @param mixed $offset <p>
197
-     *                      The offset to retrieve.
198
-     *                      </p>
199
-     *
200
-     * @return mixed Can return all value types.
201
-     *
202
-     * @since 5.0.0
203
-     */
204
-    public function offsetGet($offset)
205
-    {
206
-        return $this->getIterator()->offsetGet($offset);
207
-    }
191
+	/**
192
+	 * Offset to retrieve.
193
+	 *
194
+	 * @link http://php.net/manual/en/arrayaccess.offsetget.php
195
+	 *
196
+	 * @param mixed $offset <p>
197
+	 *                      The offset to retrieve.
198
+	 *                      </p>
199
+	 *
200
+	 * @return mixed Can return all value types.
201
+	 *
202
+	 * @since 5.0.0
203
+	 */
204
+	public function offsetGet($offset)
205
+	{
206
+		return $this->getIterator()->offsetGet($offset);
207
+	}
208 208
 
209
-    /**
210
-     * Offset to set.
211
-     *
212
-     * @link http://php.net/manual/en/arrayaccess.offsetset.php
213
-     *
214
-     * @param mixed $offset <p>
215
-     *                      The offset to assign the value to.
216
-     *                      </p>
217
-     * @param mixed $value  <p>
218
-     *                      The value to set.
219
-     *                      </p>
220
-     *
221
-     * @since 5.0.0
222
-     */
223
-    public function offsetSet($offset, $value)
224
-    {
225
-        return $this->getIterator()->offsetSet($offset, $value);
226
-    }
209
+	/**
210
+	 * Offset to set.
211
+	 *
212
+	 * @link http://php.net/manual/en/arrayaccess.offsetset.php
213
+	 *
214
+	 * @param mixed $offset <p>
215
+	 *                      The offset to assign the value to.
216
+	 *                      </p>
217
+	 * @param mixed $value  <p>
218
+	 *                      The value to set.
219
+	 *                      </p>
220
+	 *
221
+	 * @since 5.0.0
222
+	 */
223
+	public function offsetSet($offset, $value)
224
+	{
225
+		return $this->getIterator()->offsetSet($offset, $value);
226
+	}
227 227
 
228
-    /**
229
-     * Offset to unset.
230
-     *
231
-     * @link http://php.net/manual/en/arrayaccess.offsetunset.php
232
-     *
233
-     * @param mixed $offset <p>
234
-     *                      The offset to unset.
235
-     *                      </p>
236
-     *
237
-     * @since 5.0.0
238
-     */
239
-    public function offsetUnset($offset)
240
-    {
241
-        return $this->getIterator()->offsetUnset($offset);
242
-    }
228
+	/**
229
+	 * Offset to unset.
230
+	 *
231
+	 * @link http://php.net/manual/en/arrayaccess.offsetunset.php
232
+	 *
233
+	 * @param mixed $offset <p>
234
+	 *                      The offset to unset.
235
+	 *                      </p>
236
+	 *
237
+	 * @since 5.0.0
238
+	 */
239
+	public function offsetUnset($offset)
240
+	{
241
+		return $this->getIterator()->offsetUnset($offset);
242
+	}
243 243
 
244
-    /**
245
-     * Specify data which should be serialized to JSON.
246
-     *
247
-     * @link http://php.net/manual/en/jsonserializable.jsonserialize.php
248
-     *
249
-     * @return mixed data which can be serialized by <b>json_encode</b>,
250
-     *               which is a value of any type other than a resource.
251
-     *
252
-     * @since 5.4.0
253
-     */
254
-    public function jsonSerialize()
255
-    {
256
-        return array_map(function (AbstractTDBMObject $item) {
257
-            return $item->jsonSerialize();
258
-        }, $this->toArray());
259
-    }
244
+	/**
245
+	 * Specify data which should be serialized to JSON.
246
+	 *
247
+	 * @link http://php.net/manual/en/jsonserializable.jsonserialize.php
248
+	 *
249
+	 * @return mixed data which can be serialized by <b>json_encode</b>,
250
+	 *               which is a value of any type other than a resource.
251
+	 *
252
+	 * @since 5.4.0
253
+	 */
254
+	public function jsonSerialize()
255
+	{
256
+		return array_map(function (AbstractTDBMObject $item) {
257
+			return $item->jsonSerialize();
258
+		}, $this->toArray());
259
+	}
260 260
 }
Please login to merge, or discard this patch.
src/views/tdbmGenerate.php 1 patch
Indentation   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -8,7 +8,7 @@
 block discarded – undo
8 8
 <input type="hidden" id="selfedit" name="selfedit" value="<?php echo plainstring_to_htmlprotected($this->selfedit) ?>" />
9 9
 
10 10
 <?php if (!$this->autoloadDetected) {
11
-    ?>
11
+	?>
12 12
 <div class="alert">Warning! TDBM could not detect the autoload section of your composer.json file.
13 13
 Unless you are developing your own autoload system, you should configure <strong>composer.json</strong> to <a href="http://getcomposer.org/doc/01-basic-usage.md#autoloading" target="_blank">define a source directory and a root namespace using PSR-0</a>.</div>
14 14
 <?php 
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/Controllers/TdbmInstallController.php 2 patches
Doc Comments   +3 added lines patch added patch discarded remove patch
@@ -181,6 +181,9 @@
 block discarded – undo
181 181
 
182 182
     protected $errorMsg;
183 183
 
184
+    /**
185
+     * @param string $msg
186
+     */
184 187
     private function displayErrorMsg($msg)
185 188
     {
186 189
         $this->errorMsg = $msg;
Please login to merge, or discard this patch.
Indentation   +172 added lines, -172 removed lines patch added patch discarded remove patch
@@ -15,176 +15,176 @@
 block discarded – undo
15 15
  */
16 16
 class TdbmInstallController extends Controller
17 17
 {
18
-    /**
19
-     * @var HtmlBlock
20
-     */
21
-    public $content;
22
-
23
-    public $selfedit;
24
-
25
-    /**
26
-     * The active MoufManager to be edited/viewed.
27
-     *
28
-     * @var MoufManager
29
-     */
30
-    public $moufManager;
31
-
32
-    /**
33
-     * The template used by the main page for mouf.
34
-     *
35
-     * @Property
36
-     * @Compulsory
37
-     *
38
-     * @var TemplateInterface
39
-     */
40
-    public $template;
41
-
42
-    /**
43
-     * Displays the first install screen.
44
-     *
45
-     * @Action
46
-     * @Logged
47
-     *
48
-     * @param string $selfedit If true, the name of the component must be a component from the Mouf framework itself (internal use only)
49
-     */
50
-    public function defaultAction($selfedit = 'false')
51
-    {
52
-        $this->selfedit = $selfedit;
53
-
54
-        if ($selfedit == 'true') {
55
-            $this->moufManager = MoufManager::getMoufManager();
56
-        } else {
57
-            $this->moufManager = MoufManager::getMoufManagerHiddenInstance();
58
-        }
59
-
60
-        $this->content->addFile(dirname(__FILE__).'/../../../../views/installStep1.php', $this);
61
-        $this->template->toHtml();
62
-    }
63
-
64
-    /**
65
-     * Skips the install process.
66
-     *
67
-     * @Action
68
-     * @Logged
69
-     *
70
-     * @param string $selfedit If true, the name of the component must be a component from the Mouf framework itself (internal use only)
71
-     */
72
-    public function skip($selfedit = 'false')
73
-    {
74
-        InstallUtils::continueInstall($selfedit == 'true');
75
-    }
76
-
77
-    protected $daoNamespace;
78
-    protected $beanNamespace;
79
-    protected $autoloadDetected;
80
-    protected $storeInUtc;
81
-
82
-    /**
83
-     * Displays the second install screen.
84
-     *
85
-     * @Action
86
-     * @Logged
87
-     *
88
-     * @param string $selfedit If true, the name of the component must be a component from the Mouf framework itself (internal use only)
89
-     */
90
-    public function configure($selfedit = 'false')
91
-    {
92
-        $this->selfedit = $selfedit;
93
-
94
-        if ($selfedit == 'true') {
95
-            $this->moufManager = MoufManager::getMoufManager();
96
-        } else {
97
-            $this->moufManager = MoufManager::getMoufManagerHiddenInstance();
98
-        }
99
-
100
-        // Let's start by performing basic checks about the instances we assume to exist.
101
-        if (!$this->moufManager->instanceExists('dbalConnection')) {
102
-            $this->displayErrorMsg("The TDBM install process assumes your database connection instance is already created, and that the name of this instance is 'dbalConnection'. Could not find the 'dbalConnection' instance.");
103
-
104
-            return;
105
-        }
106
-
107
-        if (!$this->moufManager->instanceExists('noCacheService')) {
108
-            $this->displayErrorMsg("The TDBM install process assumes that a cache instance named 'noCacheService' exists. Could not find the 'noCacheService' instance.");
109
-
110
-            return;
111
-        }
112
-
113
-        $this->daoNamespace = $this->moufManager->getVariable('tdbmDefaultDaoNamespace_tdbmService');
114
-        $this->beanNamespace = $this->moufManager->getVariable('tdbmDefaultBeanNamespace_tdbmService');
115
-
116
-        if ($this->daoNamespace == null && $this->beanNamespace == null) {
117
-            $classNameMapper = ClassNameMapper::createFromComposerFile(__DIR__.'/../../../../../../../../composer.json');
118
-
119
-            $autoloadNamespaces = $classNameMapper->getManagedNamespaces();
120
-            if ($autoloadNamespaces) {
121
-                $this->autoloadDetected = true;
122
-                $rootNamespace = $autoloadNamespaces[0];
123
-                $this->daoNamespace = $rootNamespace.'Dao';
124
-                $this->beanNamespace = $rootNamespace.'Dao\\Bean';
125
-            } else {
126
-                $this->autoloadDetected = false;
127
-                $this->daoNamespace = 'YourApplication\\Dao';
128
-                $this->beanNamespace = 'YourApplication\\Dao\\Bean';
129
-            }
130
-        } else {
131
-            $this->autoloadDetected = true;
132
-        }
133
-
134
-        $this->castDatesToDateTime = true;
135
-
136
-        $this->content->addFile(dirname(__FILE__).'/../../../../views/installStep2.php', $this);
137
-        $this->template->toHtml();
138
-    }
139
-
140
-    /**
141
-     * This action generates the TDBM instance, then the DAOs and Beans.
142
-     *
143
-     * @Action
144
-     *
145
-     * @param string $daonamespace
146
-     * @param string $beannamespace
147
-     * @param int    $storeInUtc
148
-     * @param string $selfedit
149
-     *
150
-     * @throws \Mouf\MoufException
151
-     */
152
-    public function generate($daonamespace, $beannamespace, $storeInUtc = 0, $selfedit = 'false')
153
-    {
154
-        $this->selfedit = $selfedit;
155
-
156
-        if ($selfedit == 'true') {
157
-            $this->moufManager = MoufManager::getMoufManager();
158
-        } else {
159
-            $this->moufManager = MoufManager::getMoufManagerHiddenInstance();
160
-        }
161
-
162
-        if (!$this->moufManager->instanceExists('doctrineApcCache')) {
163
-            $doctrineApcCache = $this->moufManager->createInstance('Doctrine\\Common\\Cache\\ApcCache')->setName('doctrineApcCache');
164
-            // TODO: set namespace
165
-        } else {
166
-            $doctrineApcCache = $this->moufManager->getInstanceDescriptor('doctrineApcCache');
167
-        }
168
-
169
-        if (!$this->moufManager->instanceExists('tdbmService')) {
170
-            $tdbmService = $this->moufManager->createInstance('Mouf\\Database\\TDBM\\TDBMService')->setName('tdbmService');
171
-            $tdbmService->getConstructorArgumentProperty('connection')->setValue($this->moufManager->getInstanceDescriptor('dbalConnection'));
172
-            $tdbmService->getConstructorArgumentProperty('cache')->setValue($doctrineApcCache);
173
-        }
174
-
175
-        $this->moufManager->rewriteMouf();
176
-
177
-        TdbmController::generateDaos($this->moufManager, 'tdbmService', $daonamespace, $beannamespace, 'DaoFactory', 'daoFactory', $selfedit, $storeInUtc);
178
-
179
-        InstallUtils::continueInstall($selfedit == 'true');
180
-    }
181
-
182
-    protected $errorMsg;
183
-
184
-    private function displayErrorMsg($msg)
185
-    {
186
-        $this->errorMsg = $msg;
187
-        $this->content->addFile(dirname(__FILE__).'/../../../../views/installError.php', $this);
188
-        $this->template->toHtml();
189
-    }
18
+	/**
19
+	 * @var HtmlBlock
20
+	 */
21
+	public $content;
22
+
23
+	public $selfedit;
24
+
25
+	/**
26
+	 * The active MoufManager to be edited/viewed.
27
+	 *
28
+	 * @var MoufManager
29
+	 */
30
+	public $moufManager;
31
+
32
+	/**
33
+	 * The template used by the main page for mouf.
34
+	 *
35
+	 * @Property
36
+	 * @Compulsory
37
+	 *
38
+	 * @var TemplateInterface
39
+	 */
40
+	public $template;
41
+
42
+	/**
43
+	 * Displays the first install screen.
44
+	 *
45
+	 * @Action
46
+	 * @Logged
47
+	 *
48
+	 * @param string $selfedit If true, the name of the component must be a component from the Mouf framework itself (internal use only)
49
+	 */
50
+	public function defaultAction($selfedit = 'false')
51
+	{
52
+		$this->selfedit = $selfedit;
53
+
54
+		if ($selfedit == 'true') {
55
+			$this->moufManager = MoufManager::getMoufManager();
56
+		} else {
57
+			$this->moufManager = MoufManager::getMoufManagerHiddenInstance();
58
+		}
59
+
60
+		$this->content->addFile(dirname(__FILE__).'/../../../../views/installStep1.php', $this);
61
+		$this->template->toHtml();
62
+	}
63
+
64
+	/**
65
+	 * Skips the install process.
66
+	 *
67
+	 * @Action
68
+	 * @Logged
69
+	 *
70
+	 * @param string $selfedit If true, the name of the component must be a component from the Mouf framework itself (internal use only)
71
+	 */
72
+	public function skip($selfedit = 'false')
73
+	{
74
+		InstallUtils::continueInstall($selfedit == 'true');
75
+	}
76
+
77
+	protected $daoNamespace;
78
+	protected $beanNamespace;
79
+	protected $autoloadDetected;
80
+	protected $storeInUtc;
81
+
82
+	/**
83
+	 * Displays the second install screen.
84
+	 *
85
+	 * @Action
86
+	 * @Logged
87
+	 *
88
+	 * @param string $selfedit If true, the name of the component must be a component from the Mouf framework itself (internal use only)
89
+	 */
90
+	public function configure($selfedit = 'false')
91
+	{
92
+		$this->selfedit = $selfedit;
93
+
94
+		if ($selfedit == 'true') {
95
+			$this->moufManager = MoufManager::getMoufManager();
96
+		} else {
97
+			$this->moufManager = MoufManager::getMoufManagerHiddenInstance();
98
+		}
99
+
100
+		// Let's start by performing basic checks about the instances we assume to exist.
101
+		if (!$this->moufManager->instanceExists('dbalConnection')) {
102
+			$this->displayErrorMsg("The TDBM install process assumes your database connection instance is already created, and that the name of this instance is 'dbalConnection'. Could not find the 'dbalConnection' instance.");
103
+
104
+			return;
105
+		}
106
+
107
+		if (!$this->moufManager->instanceExists('noCacheService')) {
108
+			$this->displayErrorMsg("The TDBM install process assumes that a cache instance named 'noCacheService' exists. Could not find the 'noCacheService' instance.");
109
+
110
+			return;
111
+		}
112
+
113
+		$this->daoNamespace = $this->moufManager->getVariable('tdbmDefaultDaoNamespace_tdbmService');
114
+		$this->beanNamespace = $this->moufManager->getVariable('tdbmDefaultBeanNamespace_tdbmService');
115
+
116
+		if ($this->daoNamespace == null && $this->beanNamespace == null) {
117
+			$classNameMapper = ClassNameMapper::createFromComposerFile(__DIR__.'/../../../../../../../../composer.json');
118
+
119
+			$autoloadNamespaces = $classNameMapper->getManagedNamespaces();
120
+			if ($autoloadNamespaces) {
121
+				$this->autoloadDetected = true;
122
+				$rootNamespace = $autoloadNamespaces[0];
123
+				$this->daoNamespace = $rootNamespace.'Dao';
124
+				$this->beanNamespace = $rootNamespace.'Dao\\Bean';
125
+			} else {
126
+				$this->autoloadDetected = false;
127
+				$this->daoNamespace = 'YourApplication\\Dao';
128
+				$this->beanNamespace = 'YourApplication\\Dao\\Bean';
129
+			}
130
+		} else {
131
+			$this->autoloadDetected = true;
132
+		}
133
+
134
+		$this->castDatesToDateTime = true;
135
+
136
+		$this->content->addFile(dirname(__FILE__).'/../../../../views/installStep2.php', $this);
137
+		$this->template->toHtml();
138
+	}
139
+
140
+	/**
141
+	 * This action generates the TDBM instance, then the DAOs and Beans.
142
+	 *
143
+	 * @Action
144
+	 *
145
+	 * @param string $daonamespace
146
+	 * @param string $beannamespace
147
+	 * @param int    $storeInUtc
148
+	 * @param string $selfedit
149
+	 *
150
+	 * @throws \Mouf\MoufException
151
+	 */
152
+	public function generate($daonamespace, $beannamespace, $storeInUtc = 0, $selfedit = 'false')
153
+	{
154
+		$this->selfedit = $selfedit;
155
+
156
+		if ($selfedit == 'true') {
157
+			$this->moufManager = MoufManager::getMoufManager();
158
+		} else {
159
+			$this->moufManager = MoufManager::getMoufManagerHiddenInstance();
160
+		}
161
+
162
+		if (!$this->moufManager->instanceExists('doctrineApcCache')) {
163
+			$doctrineApcCache = $this->moufManager->createInstance('Doctrine\\Common\\Cache\\ApcCache')->setName('doctrineApcCache');
164
+			// TODO: set namespace
165
+		} else {
166
+			$doctrineApcCache = $this->moufManager->getInstanceDescriptor('doctrineApcCache');
167
+		}
168
+
169
+		if (!$this->moufManager->instanceExists('tdbmService')) {
170
+			$tdbmService = $this->moufManager->createInstance('Mouf\\Database\\TDBM\\TDBMService')->setName('tdbmService');
171
+			$tdbmService->getConstructorArgumentProperty('connection')->setValue($this->moufManager->getInstanceDescriptor('dbalConnection'));
172
+			$tdbmService->getConstructorArgumentProperty('cache')->setValue($doctrineApcCache);
173
+		}
174
+
175
+		$this->moufManager->rewriteMouf();
176
+
177
+		TdbmController::generateDaos($this->moufManager, 'tdbmService', $daonamespace, $beannamespace, 'DaoFactory', 'daoFactory', $selfedit, $storeInUtc);
178
+
179
+		InstallUtils::continueInstall($selfedit == 'true');
180
+	}
181
+
182
+	protected $errorMsg;
183
+
184
+	private function displayErrorMsg($msg)
185
+	{
186
+		$this->errorMsg = $msg;
187
+		$this->content->addFile(dirname(__FILE__).'/../../../../views/installError.php', $this);
188
+		$this->template->toHtml();
189
+	}
190 190
 }
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/InnerResultIterator.php 1 patch
Indentation   +242 added lines, -242 removed lines patch added patch discarded remove patch
@@ -28,246 +28,246 @@
 block discarded – undo
28 28
  */
29 29
 class InnerResultIterator implements \Iterator, \Countable, \ArrayAccess
30 30
 {
31
-    /**
32
-     * @var Statement
33
-     */
34
-    protected $statement;
35
-
36
-    protected $fetchStarted = false;
37
-    private $objectStorage;
38
-    private $className;
39
-
40
-    private $tdbmService;
41
-    private $magicSql;
42
-    private $parameters;
43
-    private $limit;
44
-    private $offset;
45
-    private $columnDescriptors;
46
-    private $magicQuery;
47
-
48
-    /**
49
-     * The key of the current retrieved object.
50
-     *
51
-     * @var int
52
-     */
53
-    protected $key = -1;
54
-
55
-    protected $current = null;
56
-
57
-    private $databasePlatform;
58
-
59
-    public function __construct($magicSql, array $parameters, $limit, $offset, array $columnDescriptors, $objectStorage, $className, TDBMService $tdbmService, MagicQuery $magicQuery)
60
-    {
61
-        $this->magicSql = $magicSql;
62
-        $this->objectStorage = $objectStorage;
63
-        $this->className = $className;
64
-        $this->tdbmService = $tdbmService;
65
-        $this->parameters = $parameters;
66
-        $this->limit = $limit;
67
-        $this->offset = $offset;
68
-        $this->columnDescriptors = $columnDescriptors;
69
-        $this->magicQuery = $magicQuery;
70
-        $this->databasePlatform = $this->tdbmService->getConnection()->getDatabasePlatform();
71
-    }
72
-
73
-    protected function executeQuery()
74
-    {
75
-        $sql = $this->magicQuery->build($this->magicSql, $this->parameters);
76
-        $sql = $this->tdbmService->getConnection()->getDatabasePlatform()->modifyLimitQuery($sql, $this->limit, $this->offset);
77
-
78
-        $this->statement = $this->tdbmService->getConnection()->executeQuery($sql, $this->parameters);
79
-
80
-        $this->fetchStarted = true;
81
-    }
82
-
83
-    /**
84
-     * Counts found records (this is the number of records fetched, taking into account the LIMIT and OFFSET settings).
85
-     *
86
-     * @return int
87
-     */
88
-    public function count()
89
-    {
90
-        if (!$this->fetchStarted) {
91
-            $this->executeQuery();
92
-        }
93
-
94
-        return $this->statement->rowCount();
95
-    }
96
-
97
-    /**
98
-     * Fetches record at current cursor.
99
-     *
100
-     * @return AbstractTDBMObject|null
101
-     */
102
-    public function current()
103
-    {
104
-        return $this->current;
105
-    }
106
-
107
-    /**
108
-     * Returns the current result's key.
109
-     *
110
-     * @return int
111
-     */
112
-    public function key()
113
-    {
114
-        return $this->key;
115
-    }
116
-
117
-    /**
118
-     * Advances the cursor to the next result.
119
-     * Casts the database result into one (or several) beans.
120
-     */
121
-    public function next()
122
-    {
123
-        $row = $this->statement->fetch(\PDO::FETCH_NUM);
124
-        if ($row) {
125
-
126
-            // array<tablegroup, array<table, array<column, value>>>
127
-            $beansData = [];
128
-            foreach ($row as $i => $value) {
129
-                $columnDescriptor = $this->columnDescriptors[$i];
130
-                // Let's cast the value according to its type
131
-                $value = $columnDescriptor['type']->convertToPHPValue($value, $this->databasePlatform);
132
-
133
-                $beansData[$columnDescriptor['tableGroup']][$columnDescriptor['table']][$columnDescriptor['column']] = $value;
134
-            }
135
-
136
-            $reflectionClassCache = [];
137
-            $firstBean = true;
138
-            foreach ($beansData as $beanData) {
139
-
140
-                // Let's find the bean class name associated to the bean.
141
-
142
-                list($actualClassName, $mainBeanTableName) = $this->tdbmService->_getClassNameFromBeanData($beanData);
143
-
144
-                if ($this->className !== null) {
145
-                    $actualClassName = $this->className;
146
-                }
147
-
148
-                // Must we create the bean? Let's see in the cache if we have a mapping DbRow?
149
-                // Let's get the first object mapping a row:
150
-                // We do this loop only for the first table
151
-
152
-                $primaryKeys = $this->tdbmService->_getPrimaryKeysFromObjectData($mainBeanTableName, $beanData[$mainBeanTableName]);
153
-                $hash = $this->tdbmService->getObjectHash($primaryKeys);
154
-
155
-                if ($this->objectStorage->has($mainBeanTableName, $hash)) {
156
-                    $dbRow = $this->objectStorage->get($mainBeanTableName, $hash);
157
-                    $bean = $dbRow->getTDBMObject();
158
-                } else {
159
-                    // Let's construct the bean
160
-                    if (!isset($reflectionClassCache[$actualClassName])) {
161
-                        $reflectionClassCache[$actualClassName] = new \ReflectionClass($actualClassName);
162
-                    }
163
-                    // Let's bypass the constructor when creating the bean!
164
-                    $bean = $reflectionClassCache[$actualClassName]->newInstanceWithoutConstructor();
165
-                    $bean->_constructFromData($beanData, $this->tdbmService);
166
-                }
167
-
168
-                // The first bean is the one containing the main table.
169
-                if ($firstBean) {
170
-                    $firstBean = false;
171
-                    $this->current = $bean;
172
-                }
173
-            }
174
-
175
-            ++$this->key;
176
-        } else {
177
-            $this->current = null;
178
-        }
179
-    }
180
-
181
-    /**
182
-     * Moves the cursor to the beginning of the result set.
183
-     */
184
-    public function rewind()
185
-    {
186
-        $this->executeQuery();
187
-        $this->key = -1;
188
-        $this->next();
189
-    }
190
-    /**
191
-     * Checks if the cursor is reading a valid result.
192
-     *
193
-     * @return bool
194
-     */
195
-    public function valid()
196
-    {
197
-        return $this->current !== null;
198
-    }
199
-
200
-    /**
201
-     * Whether a offset exists.
202
-     *
203
-     * @link http://php.net/manual/en/arrayaccess.offsetexists.php
204
-     *
205
-     * @param mixed $offset <p>
206
-     *                      An offset to check for.
207
-     *                      </p>
208
-     *
209
-     * @return bool true on success or false on failure.
210
-     *              </p>
211
-     *              <p>
212
-     *              The return value will be casted to boolean if non-boolean was returned.
213
-     *
214
-     * @since 5.0.0
215
-     */
216
-    public function offsetExists($offset)
217
-    {
218
-        throw new TDBMInvalidOperationException('You cannot access this result set via index because it was fetched in CURSOR mode. Use ARRAY_MODE instead.');
219
-    }
220
-
221
-    /**
222
-     * Offset to retrieve.
223
-     *
224
-     * @link http://php.net/manual/en/arrayaccess.offsetget.php
225
-     *
226
-     * @param mixed $offset <p>
227
-     *                      The offset to retrieve.
228
-     *                      </p>
229
-     *
230
-     * @return mixed Can return all value types.
231
-     *
232
-     * @since 5.0.0
233
-     */
234
-    public function offsetGet($offset)
235
-    {
236
-        throw new TDBMInvalidOperationException('You cannot access this result set via index because it was fetched in CURSOR mode. Use ARRAY_MODE instead.');
237
-    }
238
-
239
-    /**
240
-     * Offset to set.
241
-     *
242
-     * @link http://php.net/manual/en/arrayaccess.offsetset.php
243
-     *
244
-     * @param mixed $offset <p>
245
-     *                      The offset to assign the value to.
246
-     *                      </p>
247
-     * @param mixed $value  <p>
248
-     *                      The value to set.
249
-     *                      </p>
250
-     *
251
-     * @since 5.0.0
252
-     */
253
-    public function offsetSet($offset, $value)
254
-    {
255
-        throw new TDBMInvalidOperationException('You can set values in a TDBM result set.');
256
-    }
257
-
258
-    /**
259
-     * Offset to unset.
260
-     *
261
-     * @link http://php.net/manual/en/arrayaccess.offsetunset.php
262
-     *
263
-     * @param mixed $offset <p>
264
-     *                      The offset to unset.
265
-     *                      </p>
266
-     *
267
-     * @since 5.0.0
268
-     */
269
-    public function offsetUnset($offset)
270
-    {
271
-        throw new TDBMInvalidOperationException('You can unset values in a TDBM result set.');
272
-    }
31
+	/**
32
+	 * @var Statement
33
+	 */
34
+	protected $statement;
35
+
36
+	protected $fetchStarted = false;
37
+	private $objectStorage;
38
+	private $className;
39
+
40
+	private $tdbmService;
41
+	private $magicSql;
42
+	private $parameters;
43
+	private $limit;
44
+	private $offset;
45
+	private $columnDescriptors;
46
+	private $magicQuery;
47
+
48
+	/**
49
+	 * The key of the current retrieved object.
50
+	 *
51
+	 * @var int
52
+	 */
53
+	protected $key = -1;
54
+
55
+	protected $current = null;
56
+
57
+	private $databasePlatform;
58
+
59
+	public function __construct($magicSql, array $parameters, $limit, $offset, array $columnDescriptors, $objectStorage, $className, TDBMService $tdbmService, MagicQuery $magicQuery)
60
+	{
61
+		$this->magicSql = $magicSql;
62
+		$this->objectStorage = $objectStorage;
63
+		$this->className = $className;
64
+		$this->tdbmService = $tdbmService;
65
+		$this->parameters = $parameters;
66
+		$this->limit = $limit;
67
+		$this->offset = $offset;
68
+		$this->columnDescriptors = $columnDescriptors;
69
+		$this->magicQuery = $magicQuery;
70
+		$this->databasePlatform = $this->tdbmService->getConnection()->getDatabasePlatform();
71
+	}
72
+
73
+	protected function executeQuery()
74
+	{
75
+		$sql = $this->magicQuery->build($this->magicSql, $this->parameters);
76
+		$sql = $this->tdbmService->getConnection()->getDatabasePlatform()->modifyLimitQuery($sql, $this->limit, $this->offset);
77
+
78
+		$this->statement = $this->tdbmService->getConnection()->executeQuery($sql, $this->parameters);
79
+
80
+		$this->fetchStarted = true;
81
+	}
82
+
83
+	/**
84
+	 * Counts found records (this is the number of records fetched, taking into account the LIMIT and OFFSET settings).
85
+	 *
86
+	 * @return int
87
+	 */
88
+	public function count()
89
+	{
90
+		if (!$this->fetchStarted) {
91
+			$this->executeQuery();
92
+		}
93
+
94
+		return $this->statement->rowCount();
95
+	}
96
+
97
+	/**
98
+	 * Fetches record at current cursor.
99
+	 *
100
+	 * @return AbstractTDBMObject|null
101
+	 */
102
+	public function current()
103
+	{
104
+		return $this->current;
105
+	}
106
+
107
+	/**
108
+	 * Returns the current result's key.
109
+	 *
110
+	 * @return int
111
+	 */
112
+	public function key()
113
+	{
114
+		return $this->key;
115
+	}
116
+
117
+	/**
118
+	 * Advances the cursor to the next result.
119
+	 * Casts the database result into one (or several) beans.
120
+	 */
121
+	public function next()
122
+	{
123
+		$row = $this->statement->fetch(\PDO::FETCH_NUM);
124
+		if ($row) {
125
+
126
+			// array<tablegroup, array<table, array<column, value>>>
127
+			$beansData = [];
128
+			foreach ($row as $i => $value) {
129
+				$columnDescriptor = $this->columnDescriptors[$i];
130
+				// Let's cast the value according to its type
131
+				$value = $columnDescriptor['type']->convertToPHPValue($value, $this->databasePlatform);
132
+
133
+				$beansData[$columnDescriptor['tableGroup']][$columnDescriptor['table']][$columnDescriptor['column']] = $value;
134
+			}
135
+
136
+			$reflectionClassCache = [];
137
+			$firstBean = true;
138
+			foreach ($beansData as $beanData) {
139
+
140
+				// Let's find the bean class name associated to the bean.
141
+
142
+				list($actualClassName, $mainBeanTableName) = $this->tdbmService->_getClassNameFromBeanData($beanData);
143
+
144
+				if ($this->className !== null) {
145
+					$actualClassName = $this->className;
146
+				}
147
+
148
+				// Must we create the bean? Let's see in the cache if we have a mapping DbRow?
149
+				// Let's get the first object mapping a row:
150
+				// We do this loop only for the first table
151
+
152
+				$primaryKeys = $this->tdbmService->_getPrimaryKeysFromObjectData($mainBeanTableName, $beanData[$mainBeanTableName]);
153
+				$hash = $this->tdbmService->getObjectHash($primaryKeys);
154
+
155
+				if ($this->objectStorage->has($mainBeanTableName, $hash)) {
156
+					$dbRow = $this->objectStorage->get($mainBeanTableName, $hash);
157
+					$bean = $dbRow->getTDBMObject();
158
+				} else {
159
+					// Let's construct the bean
160
+					if (!isset($reflectionClassCache[$actualClassName])) {
161
+						$reflectionClassCache[$actualClassName] = new \ReflectionClass($actualClassName);
162
+					}
163
+					// Let's bypass the constructor when creating the bean!
164
+					$bean = $reflectionClassCache[$actualClassName]->newInstanceWithoutConstructor();
165
+					$bean->_constructFromData($beanData, $this->tdbmService);
166
+				}
167
+
168
+				// The first bean is the one containing the main table.
169
+				if ($firstBean) {
170
+					$firstBean = false;
171
+					$this->current = $bean;
172
+				}
173
+			}
174
+
175
+			++$this->key;
176
+		} else {
177
+			$this->current = null;
178
+		}
179
+	}
180
+
181
+	/**
182
+	 * Moves the cursor to the beginning of the result set.
183
+	 */
184
+	public function rewind()
185
+	{
186
+		$this->executeQuery();
187
+		$this->key = -1;
188
+		$this->next();
189
+	}
190
+	/**
191
+	 * Checks if the cursor is reading a valid result.
192
+	 *
193
+	 * @return bool
194
+	 */
195
+	public function valid()
196
+	{
197
+		return $this->current !== null;
198
+	}
199
+
200
+	/**
201
+	 * Whether a offset exists.
202
+	 *
203
+	 * @link http://php.net/manual/en/arrayaccess.offsetexists.php
204
+	 *
205
+	 * @param mixed $offset <p>
206
+	 *                      An offset to check for.
207
+	 *                      </p>
208
+	 *
209
+	 * @return bool true on success or false on failure.
210
+	 *              </p>
211
+	 *              <p>
212
+	 *              The return value will be casted to boolean if non-boolean was returned.
213
+	 *
214
+	 * @since 5.0.0
215
+	 */
216
+	public function offsetExists($offset)
217
+	{
218
+		throw new TDBMInvalidOperationException('You cannot access this result set via index because it was fetched in CURSOR mode. Use ARRAY_MODE instead.');
219
+	}
220
+
221
+	/**
222
+	 * Offset to retrieve.
223
+	 *
224
+	 * @link http://php.net/manual/en/arrayaccess.offsetget.php
225
+	 *
226
+	 * @param mixed $offset <p>
227
+	 *                      The offset to retrieve.
228
+	 *                      </p>
229
+	 *
230
+	 * @return mixed Can return all value types.
231
+	 *
232
+	 * @since 5.0.0
233
+	 */
234
+	public function offsetGet($offset)
235
+	{
236
+		throw new TDBMInvalidOperationException('You cannot access this result set via index because it was fetched in CURSOR mode. Use ARRAY_MODE instead.');
237
+	}
238
+
239
+	/**
240
+	 * Offset to set.
241
+	 *
242
+	 * @link http://php.net/manual/en/arrayaccess.offsetset.php
243
+	 *
244
+	 * @param mixed $offset <p>
245
+	 *                      The offset to assign the value to.
246
+	 *                      </p>
247
+	 * @param mixed $value  <p>
248
+	 *                      The value to set.
249
+	 *                      </p>
250
+	 *
251
+	 * @since 5.0.0
252
+	 */
253
+	public function offsetSet($offset, $value)
254
+	{
255
+		throw new TDBMInvalidOperationException('You can set values in a TDBM result set.');
256
+	}
257
+
258
+	/**
259
+	 * Offset to unset.
260
+	 *
261
+	 * @link http://php.net/manual/en/arrayaccess.offsetunset.php
262
+	 *
263
+	 * @param mixed $offset <p>
264
+	 *                      The offset to unset.
265
+	 *                      </p>
266
+	 *
267
+	 * @since 5.0.0
268
+	 */
269
+	public function offsetUnset($offset)
270
+	{
271
+		throw new TDBMInvalidOperationException('You can unset values in a TDBM result set.');
272
+	}
273 273
 }
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/TDBMObject.php 1 patch
Indentation   +24 added lines, -24 removed lines patch added patch discarded remove patch
@@ -33,28 +33,28 @@
 block discarded – undo
33 33
  */
34 34
 class TDBMObject extends AbstractTDBMObject
35 35
 {
36
-    public function getProperty($var, $tableName = null)
37
-    {
38
-        return $this->get($var, $tableName);
39
-    }
40
-
41
-    public function setProperty($var, $value, $tableName = null)
42
-    {
43
-        $this->set($var, $value, $tableName);
44
-    }
45
-
46
-    /**
47
-     * Specify data which should be serialized to JSON.
48
-     *
49
-     * @link http://php.net/manual/en/jsonserializable.jsonserialize.php
50
-     *
51
-     * @return mixed data which can be serialized by <b>json_encode</b>,
52
-     *               which is a value of any type other than a resource.
53
-     *
54
-     * @since 5.4.0
55
-     */
56
-    public function jsonSerialize()
57
-    {
58
-        throw new TDBMException('Json serialization is only implemented for generated beans.');
59
-    }
36
+	public function getProperty($var, $tableName = null)
37
+	{
38
+		return $this->get($var, $tableName);
39
+	}
40
+
41
+	public function setProperty($var, $value, $tableName = null)
42
+	{
43
+		$this->set($var, $value, $tableName);
44
+	}
45
+
46
+	/**
47
+	 * Specify data which should be serialized to JSON.
48
+	 *
49
+	 * @link http://php.net/manual/en/jsonserializable.jsonserialize.php
50
+	 *
51
+	 * @return mixed data which can be serialized by <b>json_encode</b>,
52
+	 *               which is a value of any type other than a resource.
53
+	 *
54
+	 * @since 5.4.0
55
+	 */
56
+	public function jsonSerialize()
57
+	{
58
+		throw new TDBMException('Json serialization is only implemented for generated beans.');
59
+	}
60 60
 }
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/AbstractTDBMObject.php 2 patches
Indentation   +483 added lines, -483 removed lines patch added patch discarded remove patch
@@ -31,492 +31,492 @@
 block discarded – undo
31 31
  */
32 32
 abstract class AbstractTDBMObject implements JsonSerializable
33 33
 {
34
-    /**
35
-     * The service this object is bound to.
36
-     *
37
-     * @var TDBMService
38
-     */
39
-    protected $tdbmService;
40
-
41
-    /**
42
-     * An array of DbRow, indexed by table name.
43
-     *
44
-     * @var DbRow[]
45
-     */
46
-    protected $dbRows = array();
47
-
48
-    /**
49
-     * One of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
50
-     * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
51
-     * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
52
-     * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
53
-     *
54
-     * @var string
55
-     */
56
-    private $status;
57
-
58
-    /**
59
-     * Array storing beans related via many to many relationships (pivot tables).
60
-     *
61
-     * @var \SplObjectStorage[] Key: pivot table name, value: SplObjectStorage
62
-     */
63
-    private $relationships = [];
64
-
65
-    /**
66
-     * @var bool[] Key: pivot table name, value: whether a query was performed to load the data.
67
-     */
68
-    private $loadedRelationships = [];
69
-
70
-    /**
71
-     * Used with $primaryKeys when we want to retrieve an existing object
72
-     * and $primaryKeys=[] if we want a new object.
73
-     *
74
-     * @param string      $tableName
75
-     * @param array       $primaryKeys
76
-     * @param TDBMService $tdbmService
77
-     *
78
-     * @throws TDBMException
79
-     * @throws TDBMInvalidOperationException
80
-     */
81
-    public function __construct($tableName = null, array $primaryKeys = array(), TDBMService $tdbmService = null)
82
-    {
83
-        // FIXME: lazy loading should be forbidden on tables with inheritance and dynamic type assignation...
84
-        if (!empty($tableName)) {
85
-            $this->dbRows[$tableName] = new DbRow($this, $tableName, $primaryKeys, $tdbmService);
86
-        }
87
-
88
-        if ($tdbmService === null) {
89
-            $this->_setStatus(TDBMObjectStateEnum::STATE_DETACHED);
90
-        } else {
91
-            $this->_attach($tdbmService);
92
-            if (!empty($primaryKeys)) {
93
-                $this->_setStatus(TDBMObjectStateEnum::STATE_NOT_LOADED);
94
-            } else {
95
-                $this->_setStatus(TDBMObjectStateEnum::STATE_NEW);
96
-            }
97
-        }
98
-    }
99
-
100
-    /**
101
-     * Alternative constructor called when data is fetched from database via a SELECT.
102
-     *
103
-     * @param array       $beanData    array<table, array<column, value>>
104
-     * @param TDBMService $tdbmService
105
-     */
106
-    public function _constructFromData(array $beanData, TDBMService $tdbmService)
107
-    {
108
-        $this->tdbmService = $tdbmService;
109
-
110
-        foreach ($beanData as $table => $columns) {
111
-            $this->dbRows[$table] = new DbRow($this, $table, $tdbmService->_getPrimaryKeysFromObjectData($table, $columns), $tdbmService, $columns);
112
-        }
113
-
114
-        $this->status = TDBMObjectStateEnum::STATE_LOADED;
115
-    }
116
-
117
-    /**
118
-     * Alternative constructor called when bean is lazily loaded.
119
-     *
120
-     * @param string      $tableName
121
-     * @param array       $primaryKeys
122
-     * @param TDBMService $tdbmService
123
-     */
124
-    public function _constructLazy($tableName, array $primaryKeys, TDBMService $tdbmService)
125
-    {
126
-        $this->tdbmService = $tdbmService;
127
-
128
-        $this->dbRows[$tableName] = new DbRow($this, $tableName, $primaryKeys, $tdbmService);
129
-
130
-        $this->status = TDBMObjectStateEnum::STATE_NOT_LOADED;
131
-    }
132
-
133
-    public function _attach(TDBMService $tdbmService)
134
-    {
135
-        if ($this->status !== TDBMObjectStateEnum::STATE_DETACHED) {
136
-            throw new TDBMInvalidOperationException('Cannot attach an object that is already attached to TDBM.');
137
-        }
138
-        $this->tdbmService = $tdbmService;
139
-
140
-        // If we attach this object, we must work to make sure the tables are in ascending order (from low level to top level)
141
-        $tableNames = array_keys($this->dbRows);
142
-        $tableNames = $this->tdbmService->_getLinkBetweenInheritedTables($tableNames);
143
-        $tableNames = array_reverse($tableNames);
144
-
145
-        $newDbRows = [];
146
-
147
-        foreach ($tableNames as $table) {
148
-            if (!isset($this->dbRows[$table])) {
149
-                $this->registerTable($table);
150
-            }
151
-            $newDbRows[$table] = $this->dbRows[$table];
152
-        }
153
-        $this->dbRows = $newDbRows;
154
-
155
-        $this->status = TDBMObjectStateEnum::STATE_NEW;
156
-        foreach ($this->dbRows as $dbRow) {
157
-            $dbRow->_attach($tdbmService);
158
-        }
159
-    }
160
-
161
-    /**
162
-     * Sets the state of the TDBM Object
163
-     * One of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
164
-     * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
165
-     * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
166
-     * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
167
-     *
168
-     * @param string $state
169
-     */
170
-    public function _setStatus($state)
171
-    {
172
-        $this->status = $state;
173
-
174
-        // TODO: we might ignore the loaded => dirty state here! dirty status comes from the db_row itself.
175
-        foreach ($this->dbRows as $dbRow) {
176
-            $dbRow->_setStatus($state);
177
-        }
178
-    }
179
-
180
-    /**
181
-     * Checks that $tableName is ok, or returns the only possible table name if "$tableName = null"
182
-     * or throws an error.
183
-     *
184
-     * @param string $tableName
185
-     * @return string
186
-     */
187
-    private function checkTableName($tableName = null) {
188
-        if ($tableName === null) {
189
-            if (count($this->dbRows) > 1) {
190
-                throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
191
-            } elseif (count($this->dbRows) === 1) {
192
-                $tableName = array_keys($this->dbRows)[0];
193
-            }
194
-        }
195
-
196
-        if (!isset($this->dbRows[$tableName])) {
197
-            if (count($this->dbRows[$tableName] === 0)) {
198
-                throw new TDBMException('Object is not yet bound to any table.');
199
-            } else {
200
-                throw new TDBMException('Unknown table "'.$tableName.'"" in object.');
201
-            }
202
-        }
203
-        return $tableName;
204
-    }
205
-
206
-    protected function get($var, $tableName = null)
207
-    {
208
-        $tableName = $this->checkTableName($tableName);
209
-
210
-        return $this->dbRows[$tableName]->get($var);
211
-    }
212
-
213
-    protected function set($var, $value, $tableName = null)
214
-    {
215
-        if ($tableName === null) {
216
-            if (count($this->dbRows) > 1) {
217
-                throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
218
-            } elseif (count($this->dbRows) === 1) {
219
-                $tableName = array_keys($this->dbRows)[0];
220
-            } else {
221
-                throw new TDBMException('Please specify a table for this object.');
222
-            }
223
-        }
224
-
225
-        if (!isset($this->dbRows[$tableName])) {
226
-            $this->registerTable($tableName);
227
-        }
228
-
229
-        $this->dbRows[$tableName]->set($var, $value);
230
-        if ($this->dbRows[$tableName]->_getStatus() === TDBMObjectStateEnum::STATE_DIRTY) {
231
-            $this->status = TDBMObjectStateEnum::STATE_DIRTY;
232
-        }
233
-    }
234
-
235
-    /**
236
-     * @param string             $foreignKeyName
237
-     * @param AbstractTDBMObject $bean
238
-     */
239
-    protected function setRef($foreignKeyName, AbstractTDBMObject $bean, $tableName = null)
240
-    {
241
-        if ($tableName === null) {
242
-            if (count($this->dbRows) > 1) {
243
-                throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
244
-            } elseif (count($this->dbRows) === 1) {
245
-                $tableName = array_keys($this->dbRows)[0];
246
-            } else {
247
-                throw new TDBMException('Please specify a table for this object.');
248
-            }
249
-        }
250
-
251
-        if (!isset($this->dbRows[$tableName])) {
252
-            $this->registerTable($tableName);
253
-        }
254
-
255
-        $this->dbRows[$tableName]->setRef($foreignKeyName, $bean);
256
-        if ($this->dbRows[$tableName]->_getStatus() === TDBMObjectStateEnum::STATE_DIRTY) {
257
-            $this->status = TDBMObjectStateEnum::STATE_DIRTY;
258
-        }
259
-    }
260
-
261
-    /**
262
-     * @param string $foreignKeyName A unique name for this reference
263
-     *
264
-     * @return AbstractTDBMObject|null
265
-     */
266
-    protected function getRef($foreignKeyName, $tableName = null)
267
-    {
268
-        $tableName = $this->checkTableName($tableName);
269
-
270
-        return $this->dbRows[$tableName]->getRef($foreignKeyName);
271
-    }
272
-
273
-    /**
274
-     * Adds a many to many relationship to this bean.
275
-     *
276
-     * @param string             $pivotTableName
277
-     * @param AbstractTDBMObject $remoteBean
278
-     */
279
-    protected function addRelationship($pivotTableName, AbstractTDBMObject $remoteBean)
280
-    {
281
-        $this->setRelationship($pivotTableName, $remoteBean, 'new');
282
-    }
283
-
284
-    /**
285
-     * Returns true if there is a relationship to this bean.
286
-     *
287
-     * @param string             $pivotTableName
288
-     * @param AbstractTDBMObject $remoteBean
289
-     *
290
-     * @return bool
291
-     */
292
-    protected function hasRelationship($pivotTableName, AbstractTDBMObject $remoteBean)
293
-    {
294
-        $storage = $this->retrieveRelationshipsStorage($pivotTableName);
295
-
296
-        if ($storage->contains($remoteBean)) {
297
-            if ($storage[$remoteBean]['status'] !== 'delete') {
298
-                return true;
299
-            }
300
-        }
301
-
302
-        return false;
303
-    }
304
-
305
-    /**
306
-     * Internal TDBM method. Removes a many to many relationship from this bean.
307
-     *
308
-     * @param string             $pivotTableName
309
-     * @param AbstractTDBMObject $remoteBean
310
-     */
311
-    public function _removeRelationship($pivotTableName, AbstractTDBMObject $remoteBean)
312
-    {
313
-        if (isset($this->relationships[$pivotTableName][$remoteBean]) && $this->relationships[$pivotTableName][$remoteBean]['status'] === 'new') {
314
-            unset($this->relationships[$pivotTableName][$remoteBean]);
315
-            unset($remoteBean->relationships[$pivotTableName][$this]);
316
-        } else {
317
-            $this->setRelationship($pivotTableName, $remoteBean, 'delete');
318
-        }
319
-    }
320
-
321
-    /**
322
-     * Returns the list of objects linked to this bean via $pivotTableName.
323
-     *
324
-     * @param $pivotTableName
325
-     *
326
-     * @return \SplObjectStorage
327
-     */
328
-    private function retrieveRelationshipsStorage($pivotTableName)
329
-    {
330
-        $storage = $this->getRelationshipStorage($pivotTableName);
331
-        if ($this->status === TDBMObjectStateEnum::STATE_DETACHED || $this->status === TDBMObjectStateEnum::STATE_NEW || isset($this->loadedRelationships[$pivotTableName]) && $this->loadedRelationships[$pivotTableName]) {
332
-            return $storage;
333
-        }
334
-
335
-        $beans = $this->tdbmService->_getRelatedBeans($pivotTableName, $this);
336
-        $this->loadedRelationships[$pivotTableName] = true;
337
-
338
-        foreach ($beans as $bean) {
339
-            if (isset($storage[$bean])) {
340
-                $oldStatus = $storage[$bean]['status'];
341
-                if ($oldStatus === 'delete') {
342
-                    // Keep deleted things deleted
343
-                    continue;
344
-                }
345
-            }
346
-            $this->setRelationship($pivotTableName, $bean, 'loaded');
347
-        }
348
-
349
-        return $storage;
350
-    }
351
-
352
-    /**
353
-     * Internal TDBM method. Returns the list of objects linked to this bean via $pivotTableName.
354
-     *
355
-     * @param $pivotTableName
356
-     *
357
-     * @return AbstractTDBMObject[]
358
-     */
359
-    public function _getRelationships($pivotTableName)
360
-    {
361
-        return $this->relationshipStorageToArray($this->retrieveRelationshipsStorage($pivotTableName));
362
-    }
363
-
364
-    private function relationshipStorageToArray(\SplObjectStorage $storage)
365
-    {
366
-        $beans = [];
367
-        foreach ($storage as $bean) {
368
-            $statusArr = $storage[$bean];
369
-            if ($statusArr['status'] !== 'delete') {
370
-                $beans[] = $bean;
371
-            }
372
-        }
373
-
374
-        return $beans;
375
-    }
376
-
377
-    /**
378
-     * Declares a relationship between.
379
-     *
380
-     * @param string             $pivotTableName
381
-     * @param AbstractTDBMObject $remoteBean
382
-     * @param string             $status
383
-     */
384
-    private function setRelationship($pivotTableName, AbstractTDBMObject $remoteBean, $status)
385
-    {
386
-        $storage = $this->getRelationshipStorage($pivotTableName);
387
-        $storage->attach($remoteBean, ['status' => $status, 'reverse' => false]);
388
-        if ($this->status === TDBMObjectStateEnum::STATE_LOADED) {
389
-            $this->_setStatus(TDBMObjectStateEnum::STATE_DIRTY);
390
-        }
391
-
392
-        $remoteStorage = $remoteBean->getRelationshipStorage($pivotTableName);
393
-        $remoteStorage->attach($this, ['status' => $status, 'reverse' => true]);
394
-    }
395
-
396
-    /**
397
-     * Returns the SplObjectStorage associated to this relationship (creates it if it does not exists).
398
-     *
399
-     * @param $pivotTableName
400
-     *
401
-     * @return \SplObjectStorage
402
-     */
403
-    private function getRelationshipStorage($pivotTableName)
404
-    {
405
-        if (isset($this->relationships[$pivotTableName])) {
406
-            $storage = $this->relationships[$pivotTableName];
407
-        } else {
408
-            $storage = new \SplObjectStorage();
409
-            $this->relationships[$pivotTableName] = $storage;
410
-        }
411
-
412
-        return $storage;
413
-    }
414
-
415
-    /**
416
-     * Reverts any changes made to the object and resumes it to its DB state.
417
-     * This can only be called on objects that come from database and that have not been deleted.
418
-     * Otherwise, this will throw an exception.
419
-     *
420
-     * @throws TDBMException
421
-     */
422
-    public function discardChanges()
423
-    {
424
-        if ($this->status === TDBMObjectStateEnum::STATE_NEW || $this->status === TDBMObjectStateEnum::STATE_DETACHED) {
425
-            throw new TDBMException("You cannot call discardChanges() on an object that has been created with the 'new' keyword and that has not yet been saved.");
426
-        }
427
-
428
-        if ($this->status === TDBMObjectStateEnum::STATE_DELETED) {
429
-            throw new TDBMException('You cannot call discardChanges() on an object that has been deleted.');
430
-        }
431
-
432
-        $this->_setStatus(TDBMObjectStateEnum::STATE_NOT_LOADED);
433
-    }
434
-
435
-    /**
436
-     * Method used internally by TDBM. You should not use it directly.
437
-     * This method returns the status of the TDBMObject.
438
-     * This is one of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
439
-     * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
440
-     * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
441
-     * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
442
-     *
443
-     * @return string
444
-     */
445
-    public function _getStatus()
446
-    {
447
-        return $this->status;
448
-    }
449
-
450
-    /**
451
-     * Override the native php clone function for TDBMObjects.
452
-     */
453
-    public function __clone()
454
-    {
455
-        // Let's clone the many to many relationships
456
-        if ($this->status === TDBMObjectStateEnum::STATE_DETACHED) {
457
-            $pivotTableList = array_keys($this->relationships);
458
-        } else {
459
-            $pivotTableList = $this->tdbmService->_getPivotTablesLinkedToBean($this);
460
-        }
461
-
462
-        foreach ($pivotTableList as $pivotTable) {
463
-            $storage = $this->retrieveRelationshipsStorage($pivotTable);
464
-
465
-            // Let's duplicate the reverse side of the relationship // This is useless: already done by "retrieveRelationshipsStorage"!!!
466
-            /*foreach ($storage as $remoteBean) {
34
+	/**
35
+	 * The service this object is bound to.
36
+	 *
37
+	 * @var TDBMService
38
+	 */
39
+	protected $tdbmService;
40
+
41
+	/**
42
+	 * An array of DbRow, indexed by table name.
43
+	 *
44
+	 * @var DbRow[]
45
+	 */
46
+	protected $dbRows = array();
47
+
48
+	/**
49
+	 * One of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
50
+	 * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
51
+	 * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
52
+	 * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
53
+	 *
54
+	 * @var string
55
+	 */
56
+	private $status;
57
+
58
+	/**
59
+	 * Array storing beans related via many to many relationships (pivot tables).
60
+	 *
61
+	 * @var \SplObjectStorage[] Key: pivot table name, value: SplObjectStorage
62
+	 */
63
+	private $relationships = [];
64
+
65
+	/**
66
+	 * @var bool[] Key: pivot table name, value: whether a query was performed to load the data.
67
+	 */
68
+	private $loadedRelationships = [];
69
+
70
+	/**
71
+	 * Used with $primaryKeys when we want to retrieve an existing object
72
+	 * and $primaryKeys=[] if we want a new object.
73
+	 *
74
+	 * @param string      $tableName
75
+	 * @param array       $primaryKeys
76
+	 * @param TDBMService $tdbmService
77
+	 *
78
+	 * @throws TDBMException
79
+	 * @throws TDBMInvalidOperationException
80
+	 */
81
+	public function __construct($tableName = null, array $primaryKeys = array(), TDBMService $tdbmService = null)
82
+	{
83
+		// FIXME: lazy loading should be forbidden on tables with inheritance and dynamic type assignation...
84
+		if (!empty($tableName)) {
85
+			$this->dbRows[$tableName] = new DbRow($this, $tableName, $primaryKeys, $tdbmService);
86
+		}
87
+
88
+		if ($tdbmService === null) {
89
+			$this->_setStatus(TDBMObjectStateEnum::STATE_DETACHED);
90
+		} else {
91
+			$this->_attach($tdbmService);
92
+			if (!empty($primaryKeys)) {
93
+				$this->_setStatus(TDBMObjectStateEnum::STATE_NOT_LOADED);
94
+			} else {
95
+				$this->_setStatus(TDBMObjectStateEnum::STATE_NEW);
96
+			}
97
+		}
98
+	}
99
+
100
+	/**
101
+	 * Alternative constructor called when data is fetched from database via a SELECT.
102
+	 *
103
+	 * @param array       $beanData    array<table, array<column, value>>
104
+	 * @param TDBMService $tdbmService
105
+	 */
106
+	public function _constructFromData(array $beanData, TDBMService $tdbmService)
107
+	{
108
+		$this->tdbmService = $tdbmService;
109
+
110
+		foreach ($beanData as $table => $columns) {
111
+			$this->dbRows[$table] = new DbRow($this, $table, $tdbmService->_getPrimaryKeysFromObjectData($table, $columns), $tdbmService, $columns);
112
+		}
113
+
114
+		$this->status = TDBMObjectStateEnum::STATE_LOADED;
115
+	}
116
+
117
+	/**
118
+	 * Alternative constructor called when bean is lazily loaded.
119
+	 *
120
+	 * @param string      $tableName
121
+	 * @param array       $primaryKeys
122
+	 * @param TDBMService $tdbmService
123
+	 */
124
+	public function _constructLazy($tableName, array $primaryKeys, TDBMService $tdbmService)
125
+	{
126
+		$this->tdbmService = $tdbmService;
127
+
128
+		$this->dbRows[$tableName] = new DbRow($this, $tableName, $primaryKeys, $tdbmService);
129
+
130
+		$this->status = TDBMObjectStateEnum::STATE_NOT_LOADED;
131
+	}
132
+
133
+	public function _attach(TDBMService $tdbmService)
134
+	{
135
+		if ($this->status !== TDBMObjectStateEnum::STATE_DETACHED) {
136
+			throw new TDBMInvalidOperationException('Cannot attach an object that is already attached to TDBM.');
137
+		}
138
+		$this->tdbmService = $tdbmService;
139
+
140
+		// If we attach this object, we must work to make sure the tables are in ascending order (from low level to top level)
141
+		$tableNames = array_keys($this->dbRows);
142
+		$tableNames = $this->tdbmService->_getLinkBetweenInheritedTables($tableNames);
143
+		$tableNames = array_reverse($tableNames);
144
+
145
+		$newDbRows = [];
146
+
147
+		foreach ($tableNames as $table) {
148
+			if (!isset($this->dbRows[$table])) {
149
+				$this->registerTable($table);
150
+			}
151
+			$newDbRows[$table] = $this->dbRows[$table];
152
+		}
153
+		$this->dbRows = $newDbRows;
154
+
155
+		$this->status = TDBMObjectStateEnum::STATE_NEW;
156
+		foreach ($this->dbRows as $dbRow) {
157
+			$dbRow->_attach($tdbmService);
158
+		}
159
+	}
160
+
161
+	/**
162
+	 * Sets the state of the TDBM Object
163
+	 * One of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
164
+	 * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
165
+	 * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
166
+	 * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
167
+	 *
168
+	 * @param string $state
169
+	 */
170
+	public function _setStatus($state)
171
+	{
172
+		$this->status = $state;
173
+
174
+		// TODO: we might ignore the loaded => dirty state here! dirty status comes from the db_row itself.
175
+		foreach ($this->dbRows as $dbRow) {
176
+			$dbRow->_setStatus($state);
177
+		}
178
+	}
179
+
180
+	/**
181
+	 * Checks that $tableName is ok, or returns the only possible table name if "$tableName = null"
182
+	 * or throws an error.
183
+	 *
184
+	 * @param string $tableName
185
+	 * @return string
186
+	 */
187
+	private function checkTableName($tableName = null) {
188
+		if ($tableName === null) {
189
+			if (count($this->dbRows) > 1) {
190
+				throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
191
+			} elseif (count($this->dbRows) === 1) {
192
+				$tableName = array_keys($this->dbRows)[0];
193
+			}
194
+		}
195
+
196
+		if (!isset($this->dbRows[$tableName])) {
197
+			if (count($this->dbRows[$tableName] === 0)) {
198
+				throw new TDBMException('Object is not yet bound to any table.');
199
+			} else {
200
+				throw new TDBMException('Unknown table "'.$tableName.'"" in object.');
201
+			}
202
+		}
203
+		return $tableName;
204
+	}
205
+
206
+	protected function get($var, $tableName = null)
207
+	{
208
+		$tableName = $this->checkTableName($tableName);
209
+
210
+		return $this->dbRows[$tableName]->get($var);
211
+	}
212
+
213
+	protected function set($var, $value, $tableName = null)
214
+	{
215
+		if ($tableName === null) {
216
+			if (count($this->dbRows) > 1) {
217
+				throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
218
+			} elseif (count($this->dbRows) === 1) {
219
+				$tableName = array_keys($this->dbRows)[0];
220
+			} else {
221
+				throw new TDBMException('Please specify a table for this object.');
222
+			}
223
+		}
224
+
225
+		if (!isset($this->dbRows[$tableName])) {
226
+			$this->registerTable($tableName);
227
+		}
228
+
229
+		$this->dbRows[$tableName]->set($var, $value);
230
+		if ($this->dbRows[$tableName]->_getStatus() === TDBMObjectStateEnum::STATE_DIRTY) {
231
+			$this->status = TDBMObjectStateEnum::STATE_DIRTY;
232
+		}
233
+	}
234
+
235
+	/**
236
+	 * @param string             $foreignKeyName
237
+	 * @param AbstractTDBMObject $bean
238
+	 */
239
+	protected function setRef($foreignKeyName, AbstractTDBMObject $bean, $tableName = null)
240
+	{
241
+		if ($tableName === null) {
242
+			if (count($this->dbRows) > 1) {
243
+				throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
244
+			} elseif (count($this->dbRows) === 1) {
245
+				$tableName = array_keys($this->dbRows)[0];
246
+			} else {
247
+				throw new TDBMException('Please specify a table for this object.');
248
+			}
249
+		}
250
+
251
+		if (!isset($this->dbRows[$tableName])) {
252
+			$this->registerTable($tableName);
253
+		}
254
+
255
+		$this->dbRows[$tableName]->setRef($foreignKeyName, $bean);
256
+		if ($this->dbRows[$tableName]->_getStatus() === TDBMObjectStateEnum::STATE_DIRTY) {
257
+			$this->status = TDBMObjectStateEnum::STATE_DIRTY;
258
+		}
259
+	}
260
+
261
+	/**
262
+	 * @param string $foreignKeyName A unique name for this reference
263
+	 *
264
+	 * @return AbstractTDBMObject|null
265
+	 */
266
+	protected function getRef($foreignKeyName, $tableName = null)
267
+	{
268
+		$tableName = $this->checkTableName($tableName);
269
+
270
+		return $this->dbRows[$tableName]->getRef($foreignKeyName);
271
+	}
272
+
273
+	/**
274
+	 * Adds a many to many relationship to this bean.
275
+	 *
276
+	 * @param string             $pivotTableName
277
+	 * @param AbstractTDBMObject $remoteBean
278
+	 */
279
+	protected function addRelationship($pivotTableName, AbstractTDBMObject $remoteBean)
280
+	{
281
+		$this->setRelationship($pivotTableName, $remoteBean, 'new');
282
+	}
283
+
284
+	/**
285
+	 * Returns true if there is a relationship to this bean.
286
+	 *
287
+	 * @param string             $pivotTableName
288
+	 * @param AbstractTDBMObject $remoteBean
289
+	 *
290
+	 * @return bool
291
+	 */
292
+	protected function hasRelationship($pivotTableName, AbstractTDBMObject $remoteBean)
293
+	{
294
+		$storage = $this->retrieveRelationshipsStorage($pivotTableName);
295
+
296
+		if ($storage->contains($remoteBean)) {
297
+			if ($storage[$remoteBean]['status'] !== 'delete') {
298
+				return true;
299
+			}
300
+		}
301
+
302
+		return false;
303
+	}
304
+
305
+	/**
306
+	 * Internal TDBM method. Removes a many to many relationship from this bean.
307
+	 *
308
+	 * @param string             $pivotTableName
309
+	 * @param AbstractTDBMObject $remoteBean
310
+	 */
311
+	public function _removeRelationship($pivotTableName, AbstractTDBMObject $remoteBean)
312
+	{
313
+		if (isset($this->relationships[$pivotTableName][$remoteBean]) && $this->relationships[$pivotTableName][$remoteBean]['status'] === 'new') {
314
+			unset($this->relationships[$pivotTableName][$remoteBean]);
315
+			unset($remoteBean->relationships[$pivotTableName][$this]);
316
+		} else {
317
+			$this->setRelationship($pivotTableName, $remoteBean, 'delete');
318
+		}
319
+	}
320
+
321
+	/**
322
+	 * Returns the list of objects linked to this bean via $pivotTableName.
323
+	 *
324
+	 * @param $pivotTableName
325
+	 *
326
+	 * @return \SplObjectStorage
327
+	 */
328
+	private function retrieveRelationshipsStorage($pivotTableName)
329
+	{
330
+		$storage = $this->getRelationshipStorage($pivotTableName);
331
+		if ($this->status === TDBMObjectStateEnum::STATE_DETACHED || $this->status === TDBMObjectStateEnum::STATE_NEW || isset($this->loadedRelationships[$pivotTableName]) && $this->loadedRelationships[$pivotTableName]) {
332
+			return $storage;
333
+		}
334
+
335
+		$beans = $this->tdbmService->_getRelatedBeans($pivotTableName, $this);
336
+		$this->loadedRelationships[$pivotTableName] = true;
337
+
338
+		foreach ($beans as $bean) {
339
+			if (isset($storage[$bean])) {
340
+				$oldStatus = $storage[$bean]['status'];
341
+				if ($oldStatus === 'delete') {
342
+					// Keep deleted things deleted
343
+					continue;
344
+				}
345
+			}
346
+			$this->setRelationship($pivotTableName, $bean, 'loaded');
347
+		}
348
+
349
+		return $storage;
350
+	}
351
+
352
+	/**
353
+	 * Internal TDBM method. Returns the list of objects linked to this bean via $pivotTableName.
354
+	 *
355
+	 * @param $pivotTableName
356
+	 *
357
+	 * @return AbstractTDBMObject[]
358
+	 */
359
+	public function _getRelationships($pivotTableName)
360
+	{
361
+		return $this->relationshipStorageToArray($this->retrieveRelationshipsStorage($pivotTableName));
362
+	}
363
+
364
+	private function relationshipStorageToArray(\SplObjectStorage $storage)
365
+	{
366
+		$beans = [];
367
+		foreach ($storage as $bean) {
368
+			$statusArr = $storage[$bean];
369
+			if ($statusArr['status'] !== 'delete') {
370
+				$beans[] = $bean;
371
+			}
372
+		}
373
+
374
+		return $beans;
375
+	}
376
+
377
+	/**
378
+	 * Declares a relationship between.
379
+	 *
380
+	 * @param string             $pivotTableName
381
+	 * @param AbstractTDBMObject $remoteBean
382
+	 * @param string             $status
383
+	 */
384
+	private function setRelationship($pivotTableName, AbstractTDBMObject $remoteBean, $status)
385
+	{
386
+		$storage = $this->getRelationshipStorage($pivotTableName);
387
+		$storage->attach($remoteBean, ['status' => $status, 'reverse' => false]);
388
+		if ($this->status === TDBMObjectStateEnum::STATE_LOADED) {
389
+			$this->_setStatus(TDBMObjectStateEnum::STATE_DIRTY);
390
+		}
391
+
392
+		$remoteStorage = $remoteBean->getRelationshipStorage($pivotTableName);
393
+		$remoteStorage->attach($this, ['status' => $status, 'reverse' => true]);
394
+	}
395
+
396
+	/**
397
+	 * Returns the SplObjectStorage associated to this relationship (creates it if it does not exists).
398
+	 *
399
+	 * @param $pivotTableName
400
+	 *
401
+	 * @return \SplObjectStorage
402
+	 */
403
+	private function getRelationshipStorage($pivotTableName)
404
+	{
405
+		if (isset($this->relationships[$pivotTableName])) {
406
+			$storage = $this->relationships[$pivotTableName];
407
+		} else {
408
+			$storage = new \SplObjectStorage();
409
+			$this->relationships[$pivotTableName] = $storage;
410
+		}
411
+
412
+		return $storage;
413
+	}
414
+
415
+	/**
416
+	 * Reverts any changes made to the object and resumes it to its DB state.
417
+	 * This can only be called on objects that come from database and that have not been deleted.
418
+	 * Otherwise, this will throw an exception.
419
+	 *
420
+	 * @throws TDBMException
421
+	 */
422
+	public function discardChanges()
423
+	{
424
+		if ($this->status === TDBMObjectStateEnum::STATE_NEW || $this->status === TDBMObjectStateEnum::STATE_DETACHED) {
425
+			throw new TDBMException("You cannot call discardChanges() on an object that has been created with the 'new' keyword and that has not yet been saved.");
426
+		}
427
+
428
+		if ($this->status === TDBMObjectStateEnum::STATE_DELETED) {
429
+			throw new TDBMException('You cannot call discardChanges() on an object that has been deleted.');
430
+		}
431
+
432
+		$this->_setStatus(TDBMObjectStateEnum::STATE_NOT_LOADED);
433
+	}
434
+
435
+	/**
436
+	 * Method used internally by TDBM. You should not use it directly.
437
+	 * This method returns the status of the TDBMObject.
438
+	 * This is one of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
439
+	 * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
440
+	 * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
441
+	 * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
442
+	 *
443
+	 * @return string
444
+	 */
445
+	public function _getStatus()
446
+	{
447
+		return $this->status;
448
+	}
449
+
450
+	/**
451
+	 * Override the native php clone function for TDBMObjects.
452
+	 */
453
+	public function __clone()
454
+	{
455
+		// Let's clone the many to many relationships
456
+		if ($this->status === TDBMObjectStateEnum::STATE_DETACHED) {
457
+			$pivotTableList = array_keys($this->relationships);
458
+		} else {
459
+			$pivotTableList = $this->tdbmService->_getPivotTablesLinkedToBean($this);
460
+		}
461
+
462
+		foreach ($pivotTableList as $pivotTable) {
463
+			$storage = $this->retrieveRelationshipsStorage($pivotTable);
464
+
465
+			// Let's duplicate the reverse side of the relationship // This is useless: already done by "retrieveRelationshipsStorage"!!!
466
+			/*foreach ($storage as $remoteBean) {
467 467
                 $metadata = $storage[$remoteBean];
468 468
 
469 469
                 $remoteStorage = $remoteBean->getRelationshipStorage($pivotTable);
470 470
                 $remoteStorage->attach($this, ['status' => $metadata['status'], 'reverse' => !$metadata['reverse']]);
471 471
             }*/
472
-        }
473
-
474
-        // Let's clone each row
475
-        foreach ($this->dbRows as $key => &$dbRow) {
476
-            $dbRow = clone $dbRow;
477
-            $dbRow->setTDBMObject($this);
478
-        }
479
-
480
-        // Let's set the status to new (to enter the save function)
481
-        $this->status = TDBMObjectStateEnum::STATE_DETACHED;
482
-    }
483
-
484
-    /**
485
-     * Returns raw database rows.
486
-     *
487
-     * @return DbRow[] Key: table name, Value: DbRow object
488
-     */
489
-    public function _getDbRows()
490
-    {
491
-        return $this->dbRows;
492
-    }
493
-
494
-    private function registerTable($tableName)
495
-    {
496
-        $dbRow = new DbRow($this, $tableName);
497
-
498
-        if (in_array($this->status, [TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DIRTY])) {
499
-            // Let's get the primary key for the new table
500
-            $anotherDbRow = array_values($this->dbRows)[0];
501
-            /* @var $anotherDbRow DbRow */
502
-            $indexedPrimaryKeys = array_values($anotherDbRow->_getPrimaryKeys());
503
-            $primaryKeys = $this->tdbmService->_getPrimaryKeysFromIndexedPrimaryKeys($tableName, $indexedPrimaryKeys);
504
-            $dbRow->_setPrimaryKeys($primaryKeys);
505
-        }
506
-
507
-        $dbRow->_setStatus($this->status);
508
-
509
-        $this->dbRows[$tableName] = $dbRow;
510
-        // TODO: look at status (if not new)=> get primary key from tdbmservice
511
-    }
512
-
513
-    /**
514
-     * Internal function: return the list of relationships.
515
-     *
516
-     * @return \SplObjectStorage[]
517
-     */
518
-    public function _getCachedRelationships()
519
-    {
520
-        return $this->relationships;
521
-    }
472
+		}
473
+
474
+		// Let's clone each row
475
+		foreach ($this->dbRows as $key => &$dbRow) {
476
+			$dbRow = clone $dbRow;
477
+			$dbRow->setTDBMObject($this);
478
+		}
479
+
480
+		// Let's set the status to new (to enter the save function)
481
+		$this->status = TDBMObjectStateEnum::STATE_DETACHED;
482
+	}
483
+
484
+	/**
485
+	 * Returns raw database rows.
486
+	 *
487
+	 * @return DbRow[] Key: table name, Value: DbRow object
488
+	 */
489
+	public function _getDbRows()
490
+	{
491
+		return $this->dbRows;
492
+	}
493
+
494
+	private function registerTable($tableName)
495
+	{
496
+		$dbRow = new DbRow($this, $tableName);
497
+
498
+		if (in_array($this->status, [TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DIRTY])) {
499
+			// Let's get the primary key for the new table
500
+			$anotherDbRow = array_values($this->dbRows)[0];
501
+			/* @var $anotherDbRow DbRow */
502
+			$indexedPrimaryKeys = array_values($anotherDbRow->_getPrimaryKeys());
503
+			$primaryKeys = $this->tdbmService->_getPrimaryKeysFromIndexedPrimaryKeys($tableName, $indexedPrimaryKeys);
504
+			$dbRow->_setPrimaryKeys($primaryKeys);
505
+		}
506
+
507
+		$dbRow->_setStatus($this->status);
508
+
509
+		$this->dbRows[$tableName] = $dbRow;
510
+		// TODO: look at status (if not new)=> get primary key from tdbmservice
511
+	}
512
+
513
+	/**
514
+	 * Internal function: return the list of relationships.
515
+	 *
516
+	 * @return \SplObjectStorage[]
517
+	 */
518
+	public function _getCachedRelationships()
519
+	{
520
+		return $this->relationships;
521
+	}
522 522
 }
Please login to merge, or discard this patch.
Spacing   +3 added lines, -3 removed lines patch added patch discarded remove patch
@@ -186,7 +186,7 @@  discard block
 block discarded – undo
186 186
      */
187 187
     private function checkTableName($tableName = null) {
188 188
         if ($tableName === null) {
189
-            if (count($this->dbRows) > 1) {
189
+            if (count($this->dbRows)>1) {
190 190
                 throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
191 191
             } elseif (count($this->dbRows) === 1) {
192 192
                 $tableName = array_keys($this->dbRows)[0];
@@ -213,7 +213,7 @@  discard block
 block discarded – undo
213 213
     protected function set($var, $value, $tableName = null)
214 214
     {
215 215
         if ($tableName === null) {
216
-            if (count($this->dbRows) > 1) {
216
+            if (count($this->dbRows)>1) {
217 217
                 throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
218 218
             } elseif (count($this->dbRows) === 1) {
219 219
                 $tableName = array_keys($this->dbRows)[0];
@@ -239,7 +239,7 @@  discard block
 block discarded – undo
239 239
     protected function setRef($foreignKeyName, AbstractTDBMObject $bean, $tableName = null)
240 240
     {
241 241
         if ($tableName === null) {
242
-            if (count($this->dbRows) > 1) {
242
+            if (count($this->dbRows)>1) {
243 243
                 throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
244 244
             } elseif (count($this->dbRows) === 1) {
245 245
                 $tableName = array_keys($this->dbRows)[0];
Please login to merge, or discard this patch.