Completed
Push — 4.0 ( d3558c...243a2b )
by David
32:03
created
src/Mouf/Database/TDBM/TDBMService.php 4 patches
Unused Use Statements   -5 removed lines patch added patch discarded remove patch
@@ -22,16 +22,11 @@
 block discarded – undo
22 22
 use Doctrine\Common\Cache\Cache;
23 23
 use Doctrine\Common\Cache\VoidCache;
24 24
 use Doctrine\DBAL\Connection;
25
-use Doctrine\DBAL\DBALException;
26
-use Doctrine\DBAL\Schema\Column;
27 25
 use Doctrine\DBAL\Schema\ForeignKeyConstraint;
28
-use Doctrine\DBAL\Schema\Schema;
29 26
 use Mouf\Database\MagicQuery;
30 27
 use Mouf\Database\SchemaAnalyzer\SchemaAnalyzer;
31 28
 use Mouf\Database\TDBM\Filters\OrderBySQLString;
32 29
 use Mouf\Database\TDBM\Utils\TDBMDaoGenerator;
33
-use Mouf\Utils\Cache\CacheInterface;
34
-use SQLParser\Node\ColRef;
35 30
 
36 31
 /**
37 32
  * The TDBMService class is the main TDBM class. It provides methods to retrieve TDBMObject instances
Please login to merge, or discard this patch.
Spacing   +11 added lines, -11 removed lines patch added patch discarded remove patch
@@ -699,9 +699,9 @@  discard block
 block discarded – undo
699 699
 		// 4-2, let's take all the objects out of the orderby bag, and let's make objects from them
700 700
 		$orderby_bag2 = array();
701 701
 		foreach ($orderby_bag as $thing) {
702
-			if (is_a($thing,'Mouf\\Database\\TDBM\\Filters\\OrderBySQLString')) {
702
+			if (is_a($thing, 'Mouf\\Database\\TDBM\\Filters\\OrderBySQLString')) {
703 703
 				$orderby_bag2[] = $thing;
704
-			} elseif (is_a($thing,'Mouf\\Database\\TDBM\\Filters\\OrderByColumn')) {
704
+			} elseif (is_a($thing, 'Mouf\\Database\\TDBM\\Filters\\OrderByColumn')) {
705 705
 				$orderby_bag2[] = $thing;
706 706
 			} elseif (is_string($thing)) {
707 707
 				$orderby_bag2[] = new OrderBySQLString($thing);
@@ -1204,7 +1204,7 @@  discard block
 block discarded – undo
1204 1204
 		$schemaAnalyzer = $this->schemaAnalyzer;
1205 1205
 
1206 1206
 		foreach ($tables as $currentTable) {
1207
-			$allParents = [ $currentTable ];
1207
+			$allParents = [$currentTable];
1208 1208
 			$currentFk = null;
1209 1209
 			while ($currentFk = $schemaAnalyzer->getParentRelationship($currentTable)) {
1210 1210
 				$currentTable = $currentFk->getForeignTableName();
@@ -1246,7 +1246,7 @@  discard block
 block discarded – undo
1246 1246
 		// Let's scan the parent tables
1247 1247
 		$currentTable = $table;
1248 1248
 
1249
-		$parentTables = [ ];
1249
+		$parentTables = [];
1250 1250
 
1251 1251
 		// Get parent relationship
1252 1252
 		while ($currentFk = $schemaAnalyzer->getParentRelationship($currentTable)) {
@@ -1336,7 +1336,7 @@  discard block
 block discarded – undo
1336 1336
 	 * @return ResultIterator An object representing an array of results.
1337 1337
 	 * @throws TDBMException
1338 1338
 	 */
1339
-	public function findObjects($mainTable, $filter=null, array $parameters = array(), $orderString=null, array $additionalTablesFetch = array(), $mode = null, $className=null) {
1339
+	public function findObjects($mainTable, $filter = null, array $parameters = array(), $orderString = null, array $additionalTablesFetch = array(), $mode = null, $className = null) {
1340 1340
 		// $mainTable is not secured in MagicJoin, let's add a bit of security to avoid SQL injection.
1341 1341
 		if (!preg_match('/^[a-zA-Z_][a-zA-Z0-9_]*$/', $mainTable)) {
1342 1342
 			throw new TDBMException(sprintf("Invalid table name: '%s'", $mainTable));
@@ -1405,7 +1405,7 @@  discard block
 block discarded – undo
1405 1405
 			throw new TDBMException("Unknown fetch mode: '".$this->mode."'");
1406 1406
 		}
1407 1407
 
1408
-		$mode = $mode?:$this->mode;
1408
+		$mode = $mode ?: $this->mode;
1409 1409
 
1410 1410
 		return new ResultIterator($sql, $countSql, $parameters, $columnDescList, $this->objectStorage, $className, $this, $this->magicQuery, $mode);
1411 1411
 	}
@@ -1419,7 +1419,7 @@  discard block
 block discarded – undo
1419 1419
 	 * @return AbstractTDBMObject
1420 1420
 	 * @throws TDBMException
1421 1421
 	 */
1422
-	public function findObjectByPk($table, array $primaryKeys, array $additionalTablesFetch = array(), $lazy = false, $className=null) {
1422
+	public function findObjectByPk($table, array $primaryKeys, array $additionalTablesFetch = array(), $lazy = false, $className = null) {
1423 1423
 		$primaryKeys = $this->_getPrimaryKeysFromObjectData($table, $primaryKeys);
1424 1424
 		$hash = $this->getObjectHash($primaryKeys);
1425 1425
 
@@ -1439,7 +1439,7 @@  discard block
 block discarded – undo
1439 1439
 			// Only allowed if no inheritance.
1440 1440
 			if (count($tables) === 1) {
1441 1441
 				if ($className === null) {
1442
-					$className = isset($this->tableToBeanMap[$table])?$this->tableToBeanMap[$table]:"Mouf\\Database\\TDBM\\TDBMObject";
1442
+					$className = isset($this->tableToBeanMap[$table]) ? $this->tableToBeanMap[$table] : "Mouf\\Database\\TDBM\\TDBMObject";
1443 1443
 				}
1444 1444
 
1445 1445
 				// Let's construct the bean
@@ -1468,11 +1468,11 @@  discard block
 block discarded – undo
1468 1468
 	 * @return AbstractTDBMObject|null The object we want, or null if no object matches the filters.
1469 1469
 	 * @throws TDBMException
1470 1470
 	 */
1471
-	public function findObject($mainTable, $filterString=null, array $parameters = array(), array $additionalTablesFetch = array(), $className = null) {
1471
+	public function findObject($mainTable, $filterString = null, array $parameters = array(), array $additionalTablesFetch = array(), $className = null) {
1472 1472
 		$objects = $this->findObjects($mainTable, $filterString, $parameters, null, $additionalTablesFetch, self::MODE_ARRAY, $className);
1473 1473
 		$page = $objects->take(0, 2);
1474 1474
 		$count = $page->count();
1475
-		if ($count > 1) {
1475
+		if ($count>1) {
1476 1476
 			throw new DuplicateRowException("Error while querying an object for table '$mainTable': More than 1 row have been returned, but we should have received at most one.");
1477 1477
 		} elseif ($count === 0) {
1478 1478
 			return null;
@@ -1492,7 +1492,7 @@  discard block
 block discarded – undo
1492 1492
 	 * @return AbstractTDBMObject The object we want
1493 1493
 	 * @throws TDBMException
1494 1494
 	 */
1495
-	public function findObjectOrFail($mainTable, $filterString=null, array $parameters = array(), array $additionalTablesFetch = array(), $className = null) {
1495
+	public function findObjectOrFail($mainTable, $filterString = null, array $parameters = array(), array $additionalTablesFetch = array(), $className = null) {
1496 1496
 		$bean = $this->findObject($mainTable, $filterString, $parameters, $additionalTablesFetch, $className);
1497 1497
 		if ($bean === null) {
1498 1498
 			throw new NoBeanFoundException("No result found for query on table '".$mainTable."'");
Please login to merge, or discard this patch.
Braces   +3 added lines, -2 removed lines patch added patch discarded remove patch
@@ -693,8 +693,9 @@
 block discarded – undo
693 693
 		// Fourth, let's apply the same steps to the orderby_bag
694 694
 		// 4-1 orderby_bag should be an array, if it is a singleton, let's put it in an array.
695 695
 
696
-		if (!is_array($orderby_bag))
697
-		$orderby_bag = array($orderby_bag);
696
+		if (!is_array($orderby_bag)) {
697
+				$orderby_bag = array($orderby_bag);
698
+		}
698 699
 
699 700
 		// 4-2, let's take all the objects out of the orderby bag, and let's make objects from them
700 701
 		$orderby_bag2 = array();
Please login to merge, or discard this patch.
Indentation   +150 added lines, -150 removed lines patch added patch discarded remove patch
@@ -360,7 +360,7 @@  discard block
 block discarded – undo
360 360
 			case TDBMObjectStateEnum::STATE_DETACHED:
361 361
 				throw new TDBMInvalidOperationException('Cannot delete a detached object');
362 362
 			case TDBMObjectStateEnum::STATE_NEW:
363
-                $this->deleteManyToManyRelationships($object);
363
+				$this->deleteManyToManyRelationships($object);
364 364
 				foreach ($object->_getDbRows() as $dbRow) {
365 365
 					$this->removeFromToSaveObjectList($dbRow);
366 366
 				}
@@ -371,7 +371,7 @@  discard block
 block discarded – undo
371 371
 				}
372 372
 			case TDBMObjectStateEnum::STATE_NOT_LOADED:
373 373
 			case TDBMObjectStateEnum::STATE_LOADED:
374
-                $this->deleteManyToManyRelationships($object);
374
+				$this->deleteManyToManyRelationships($object);
375 375
 				// Let's delete db rows, in reverse order.
376 376
 				foreach (array_reverse($object->_getDbRows()) as $dbRow) {
377 377
 					$tableName = $dbRow->_getDbTableName();
@@ -389,44 +389,44 @@  discard block
 block discarded – undo
389 389
 		$object->_setStatus(TDBMObjectStateEnum::STATE_DELETED);
390 390
 	}
391 391
 
392
-    /**
393
-     * Removes all many to many relationships for this object.
394
-     * @param AbstractTDBMObject $object
395
-     */
396
-    private function deleteManyToManyRelationships(AbstractTDBMObject $object) {
397
-        foreach ($object->_getDbRows() as $tableName => $dbRow) {
398
-            $pivotTables = $this->tdbmSchemaAnalyzer->getPivotTableLinkedToTable($tableName);
399
-            foreach ($pivotTables as $pivotTable) {
400
-                $remoteBeans = $object->_getRelationships($pivotTable);
401
-                foreach ($remoteBeans as $remoteBean) {
402
-                    $object->_removeRelationship($pivotTable, $remoteBean);
403
-                }
404
-            }
405
-        }
406
-        $this->persistManyToManyRelationships($object);
407
-    }
408
-
409
-
410
-    /**
411
-     * This function removes the given object from the database. It will also remove all objects relied to the one given
412
-     * by parameter before all.
413
-     *
414
-     * Notice: if the object has a multiple primary key, the function will not work.
415
-     *
416
-     * @param AbstractTDBMObject $objToDelete
417
-     */
418
-    public function deleteCascade(AbstractTDBMObject $objToDelete) {
419
-        $this->deleteAllConstraintWithThisObject($objToDelete);
420
-        $this->delete($objToDelete);
421
-    }
422
-
423
-    /**
424
-     * This function is used only in TDBMService (private function)
425
-     * It will call deleteCascade function foreach object relied with a foreign key to the object given by parameter
426
-     *
427
-     * @param AbstractTDBMObject $obj
428
-     */
429
-    private function deleteAllConstraintWithThisObject(AbstractTDBMObject $obj) {
392
+	/**
393
+	 * Removes all many to many relationships for this object.
394
+	 * @param AbstractTDBMObject $object
395
+	 */
396
+	private function deleteManyToManyRelationships(AbstractTDBMObject $object) {
397
+		foreach ($object->_getDbRows() as $tableName => $dbRow) {
398
+			$pivotTables = $this->tdbmSchemaAnalyzer->getPivotTableLinkedToTable($tableName);
399
+			foreach ($pivotTables as $pivotTable) {
400
+				$remoteBeans = $object->_getRelationships($pivotTable);
401
+				foreach ($remoteBeans as $remoteBean) {
402
+					$object->_removeRelationship($pivotTable, $remoteBean);
403
+				}
404
+			}
405
+		}
406
+		$this->persistManyToManyRelationships($object);
407
+	}
408
+
409
+
410
+	/**
411
+	 * This function removes the given object from the database. It will also remove all objects relied to the one given
412
+	 * by parameter before all.
413
+	 *
414
+	 * Notice: if the object has a multiple primary key, the function will not work.
415
+	 *
416
+	 * @param AbstractTDBMObject $objToDelete
417
+	 */
418
+	public function deleteCascade(AbstractTDBMObject $objToDelete) {
419
+		$this->deleteAllConstraintWithThisObject($objToDelete);
420
+		$this->delete($objToDelete);
421
+	}
422
+
423
+	/**
424
+	 * This function is used only in TDBMService (private function)
425
+	 * It will call deleteCascade function foreach object relied with a foreign key to the object given by parameter
426
+	 *
427
+	 * @param AbstractTDBMObject $obj
428
+	 */
429
+	private function deleteAllConstraintWithThisObject(AbstractTDBMObject $obj) {
430 430
 		$dbRows = $obj->_getDbRows();
431 431
 		foreach ($dbRows as $dbRow) {
432 432
 			$tableName = $dbRow->_getDbTableName();
@@ -445,7 +445,7 @@  discard block
 block discarded – undo
445 445
 				}
446 446
 			}
447 447
 		}
448
-    }
448
+	}
449 449
 
450 450
 	/**
451 451
 	 * This function performs a save() of all the objects that have been modified.
@@ -774,8 +774,8 @@  discard block
 block discarded – undo
774 774
 	}
775 775
 
776 776
 	/**
777
- 	* @param array<string, string> $tableToBeanMap
778
- 	*/
777
+	 * @param array<string, string> $tableToBeanMap
778
+	 */
779 779
 	public function setTableToBeanMap(array $tableToBeanMap) {
780 780
 		$this->tableToBeanMap = $tableToBeanMap;
781 781
 	}
@@ -821,7 +821,7 @@  discard block
 block discarded – undo
821 821
 
822 822
 				// Let's save all references in NEW or DETACHED state (we need their primary key)
823 823
 				foreach ($references as $fkName => $reference) {
824
-                    $refStatus = $reference->_getStatus();
824
+					$refStatus = $reference->_getStatus();
825 825
 					if ($refStatus === TDBMObjectStateEnum::STATE_NEW || $refStatus === TDBMObjectStateEnum::STATE_DETACHED) {
826 826
 						$this->save($reference);
827 827
 					}
@@ -980,94 +980,94 @@  discard block
 block discarded – undo
980 980
 			throw new TDBMInvalidOperationException("This object has been deleted. It cannot be saved.");
981 981
 		}
982 982
 
983
-        // Finally, let's save all the many to many relationships to this bean.
984
-        $this->persistManyToManyRelationships($object);
983
+		// Finally, let's save all the many to many relationships to this bean.
984
+		$this->persistManyToManyRelationships($object);
985 985
 	}
986 986
 
987
-    private function persistManyToManyRelationships(AbstractTDBMObject $object) {
988
-        foreach ($object->_getCachedRelationships() as $pivotTableName => $storage) {
989
-            $tableDescriptor = $this->tdbmSchemaAnalyzer->getSchema()->getTable($pivotTableName);
990
-            list($localFk, $remoteFk) = $this->getPivotTableForeignKeys($pivotTableName, $object);
991
-
992
-            foreach ($storage as $remoteBean) {
993
-                /* @var $remoteBean AbstractTDBMObject */
994
-                $statusArr = $storage[$remoteBean];
995
-                $status = $statusArr['status'];
996
-                $reverse = $statusArr['reverse'];
997
-                if ($reverse) {
998
-                    continue;
999
-                }
1000
-
1001
-                if ($status === 'new') {
1002
-                    $remoteBeanStatus = $remoteBean->_getStatus();
1003
-                    if ($remoteBeanStatus === TDBMObjectStateEnum::STATE_NEW || $remoteBeanStatus === TDBMObjectStateEnum::STATE_DETACHED) {
1004
-                        // Let's save remote bean if needed.
1005
-                        $this->save($remoteBean);
1006
-                    }
987
+	private function persistManyToManyRelationships(AbstractTDBMObject $object) {
988
+		foreach ($object->_getCachedRelationships() as $pivotTableName => $storage) {
989
+			$tableDescriptor = $this->tdbmSchemaAnalyzer->getSchema()->getTable($pivotTableName);
990
+			list($localFk, $remoteFk) = $this->getPivotTableForeignKeys($pivotTableName, $object);
991
+
992
+			foreach ($storage as $remoteBean) {
993
+				/* @var $remoteBean AbstractTDBMObject */
994
+				$statusArr = $storage[$remoteBean];
995
+				$status = $statusArr['status'];
996
+				$reverse = $statusArr['reverse'];
997
+				if ($reverse) {
998
+					continue;
999
+				}
1007 1000
 
1008
-                    $filters = $this->getPivotFilters($object, $remoteBean, $localFk, $remoteFk);
1001
+				if ($status === 'new') {
1002
+					$remoteBeanStatus = $remoteBean->_getStatus();
1003
+					if ($remoteBeanStatus === TDBMObjectStateEnum::STATE_NEW || $remoteBeanStatus === TDBMObjectStateEnum::STATE_DETACHED) {
1004
+						// Let's save remote bean if needed.
1005
+						$this->save($remoteBean);
1006
+					}
1009 1007
 
1010
-                    $types = [];
1008
+					$filters = $this->getPivotFilters($object, $remoteBean, $localFk, $remoteFk);
1011 1009
 
1012
-                    foreach ($filters as $columnName => $value) {
1013
-                        $columnDescriptor = $tableDescriptor->getColumn($columnName);
1014
-                        $types[] = $columnDescriptor->getType();
1015
-                    }
1010
+					$types = [];
1016 1011
 
1017
-                    $this->connection->insert($pivotTableName, $filters, $types);
1012
+					foreach ($filters as $columnName => $value) {
1013
+						$columnDescriptor = $tableDescriptor->getColumn($columnName);
1014
+						$types[] = $columnDescriptor->getType();
1015
+					}
1018 1016
 
1019
-                    // Finally, let's mark relationships as saved.
1020
-                    $statusArr['status'] = 'loaded';
1021
-                    $storage[$remoteBean] = $statusArr;
1022
-                    $remoteStorage = $remoteBean->_getCachedRelationships()[$pivotTableName];
1023
-                    $remoteStatusArr = $remoteStorage[$object];
1024
-                    $remoteStatusArr['status'] = 'loaded';
1025
-                    $remoteStorage[$object] = $remoteStatusArr;
1017
+					$this->connection->insert($pivotTableName, $filters, $types);
1026 1018
 
1027
-                } elseif ($status === 'delete') {
1028
-                    $filters = $this->getPivotFilters($object, $remoteBean, $localFk, $remoteFk);
1019
+					// Finally, let's mark relationships as saved.
1020
+					$statusArr['status'] = 'loaded';
1021
+					$storage[$remoteBean] = $statusArr;
1022
+					$remoteStorage = $remoteBean->_getCachedRelationships()[$pivotTableName];
1023
+					$remoteStatusArr = $remoteStorage[$object];
1024
+					$remoteStatusArr['status'] = 'loaded';
1025
+					$remoteStorage[$object] = $remoteStatusArr;
1029 1026
 
1030
-                    $types = [];
1027
+				} elseif ($status === 'delete') {
1028
+					$filters = $this->getPivotFilters($object, $remoteBean, $localFk, $remoteFk);
1031 1029
 
1032
-                    foreach ($filters as $columnName => $value) {
1033
-                        $columnDescriptor = $tableDescriptor->getColumn($columnName);
1034
-                        $types[] = $columnDescriptor->getType();
1035
-                    }
1030
+					$types = [];
1036 1031
 
1037
-                    $this->connection->delete($pivotTableName, $filters, $types);
1038
-
1039
-                    // Finally, let's remove relationships completely from bean.
1040
-                    $storage->detach($remoteBean);
1041
-                    $remoteBean->_getCachedRelationships()[$pivotTableName]->detach($object);
1042
-                }
1043
-            }
1044
-        }
1045
-    }
1046
-
1047
-    private function getPivotFilters(AbstractTDBMObject $localBean, AbstractTDBMObject $remoteBean, ForeignKeyConstraint $localFk, ForeignKeyConstraint $remoteFk) {
1048
-        $localBeanPk = $this->getPrimaryKeyValues($localBean);
1049
-        $remoteBeanPk = $this->getPrimaryKeyValues($remoteBean);
1050
-        $localColumns = $localFk->getLocalColumns();
1051
-        $remoteColumns = $remoteFk->getLocalColumns();
1052
-
1053
-        $localFilters = array_combine($localColumns, $localBeanPk);
1054
-        $remoteFilters = array_combine($remoteColumns, $remoteBeanPk);
1055
-
1056
-        return array_merge($localFilters, $remoteFilters);
1057
-    }
1058
-
1059
-    /**
1060
-     * Returns the "values" of the primary key.
1061
-     * This returns the primary key from the $primaryKey attribute, not the one stored in the columns.
1062
-     *
1063
-     * @param AbstractTDBMObject $bean
1064
-     * @return array numerically indexed array of values.
1065
-     */
1066
-    private function getPrimaryKeyValues(AbstractTDBMObject $bean) {
1067
-        $dbRows = $bean->_getDbRows();
1068
-        $dbRow = reset($dbRows);
1069
-        return array_values($dbRow->_getPrimaryKeys());
1070
-    }
1032
+					foreach ($filters as $columnName => $value) {
1033
+						$columnDescriptor = $tableDescriptor->getColumn($columnName);
1034
+						$types[] = $columnDescriptor->getType();
1035
+					}
1036
+
1037
+					$this->connection->delete($pivotTableName, $filters, $types);
1038
+
1039
+					// Finally, let's remove relationships completely from bean.
1040
+					$storage->detach($remoteBean);
1041
+					$remoteBean->_getCachedRelationships()[$pivotTableName]->detach($object);
1042
+				}
1043
+			}
1044
+		}
1045
+	}
1046
+
1047
+	private function getPivotFilters(AbstractTDBMObject $localBean, AbstractTDBMObject $remoteBean, ForeignKeyConstraint $localFk, ForeignKeyConstraint $remoteFk) {
1048
+		$localBeanPk = $this->getPrimaryKeyValues($localBean);
1049
+		$remoteBeanPk = $this->getPrimaryKeyValues($remoteBean);
1050
+		$localColumns = $localFk->getLocalColumns();
1051
+		$remoteColumns = $remoteFk->getLocalColumns();
1052
+
1053
+		$localFilters = array_combine($localColumns, $localBeanPk);
1054
+		$remoteFilters = array_combine($remoteColumns, $remoteBeanPk);
1055
+
1056
+		return array_merge($localFilters, $remoteFilters);
1057
+	}
1058
+
1059
+	/**
1060
+	 * Returns the "values" of the primary key.
1061
+	 * This returns the primary key from the $primaryKey attribute, not the one stored in the columns.
1062
+	 *
1063
+	 * @param AbstractTDBMObject $bean
1064
+	 * @return array numerically indexed array of values.
1065
+	 */
1066
+	private function getPrimaryKeyValues(AbstractTDBMObject $bean) {
1067
+		$dbRows = $bean->_getDbRows();
1068
+		$dbRow = reset($dbRows);
1069
+		return array_values($dbRow->_getPrimaryKeys());
1070
+	}
1071 1071
 
1072 1072
 	/**
1073 1073
 	 * Returns a unique hash used to store the object based on its primary key.
@@ -1549,41 +1549,41 @@  discard block
 block discarded – undo
1549 1549
 	 */
1550 1550
 	public function _getRelatedBeans($pivotTableName, AbstractTDBMObject $bean) {
1551 1551
 
1552
-        list($localFk, $remoteFk) = $this->getPivotTableForeignKeys($pivotTableName, $bean);
1553
-        /* @var $localFk ForeignKeyConstraint */
1554
-        /* @var $remoteFk ForeignKeyConstraint */
1555
-        $remoteTable = $remoteFk->getForeignTableName();
1552
+		list($localFk, $remoteFk) = $this->getPivotTableForeignKeys($pivotTableName, $bean);
1553
+		/* @var $localFk ForeignKeyConstraint */
1554
+		/* @var $remoteFk ForeignKeyConstraint */
1555
+		$remoteTable = $remoteFk->getForeignTableName();
1556 1556
 
1557 1557
 
1558
-        $primaryKeys = $this->getPrimaryKeyValues($bean);
1559
-        $columnNames = array_map(function($name) use ($pivotTableName) { return $pivotTableName.'.'.$name; }, $localFk->getLocalColumns());
1558
+		$primaryKeys = $this->getPrimaryKeyValues($bean);
1559
+		$columnNames = array_map(function($name) use ($pivotTableName) { return $pivotTableName.'.'.$name; }, $localFk->getLocalColumns());
1560 1560
 
1561
-        $filter = array_combine($columnNames, $primaryKeys);
1561
+		$filter = array_combine($columnNames, $primaryKeys);
1562 1562
 
1563
-        return $this->findObjects($remoteTable, $filter);
1563
+		return $this->findObjects($remoteTable, $filter);
1564 1564
 	}
1565 1565
 
1566
-    /**
1567
-     * @param $pivotTableName
1568
-     * @param AbstractTDBMObject $bean The LOCAL bean
1569
-     * @return ForeignKeyConstraint[] First item: the LOCAL bean, second item: the REMOTE bean.
1570
-     * @throws TDBMException
1571
-     */
1572
-    private function getPivotTableForeignKeys($pivotTableName, AbstractTDBMObject $bean) {
1573
-        $fks = array_values($this->tdbmSchemaAnalyzer->getSchema()->getTable($pivotTableName)->getForeignKeys());
1574
-        $table1 = $fks[0]->getForeignTableName();
1575
-        $table2 = $fks[1]->getForeignTableName();
1576
-
1577
-        $beanTables = array_map(function(DbRow $dbRow) { return $dbRow->_getDbTableName(); }, $bean->_getDbRows());
1578
-
1579
-        if (in_array($table1, $beanTables)) {
1580
-            return [$fks[0], $fks[1]];
1581
-        } elseif (in_array($table2, $beanTables)) {
1582
-            return [$fks[1], $fks[0]];
1583
-        } else {
1584
-            throw new TDBMException("Unexpected bean type in getPivotTableForeignKeys. Awaiting beans from table {$table1} and {$table2} for pivot table {$pivotTableName}");
1585
-        }
1586
-    }
1566
+	/**
1567
+	 * @param $pivotTableName
1568
+	 * @param AbstractTDBMObject $bean The LOCAL bean
1569
+	 * @return ForeignKeyConstraint[] First item: the LOCAL bean, second item: the REMOTE bean.
1570
+	 * @throws TDBMException
1571
+	 */
1572
+	private function getPivotTableForeignKeys($pivotTableName, AbstractTDBMObject $bean) {
1573
+		$fks = array_values($this->tdbmSchemaAnalyzer->getSchema()->getTable($pivotTableName)->getForeignKeys());
1574
+		$table1 = $fks[0]->getForeignTableName();
1575
+		$table2 = $fks[1]->getForeignTableName();
1576
+
1577
+		$beanTables = array_map(function(DbRow $dbRow) { return $dbRow->_getDbTableName(); }, $bean->_getDbRows());
1578
+
1579
+		if (in_array($table1, $beanTables)) {
1580
+			return [$fks[0], $fks[1]];
1581
+		} elseif (in_array($table2, $beanTables)) {
1582
+			return [$fks[1], $fks[0]];
1583
+		} else {
1584
+			throw new TDBMException("Unexpected bean type in getPivotTableForeignKeys. Awaiting beans from table {$table1} and {$table2} for pivot table {$pivotTableName}");
1585
+		}
1586
+	}
1587 1587
 
1588 1588
 	/**
1589 1589
 	 * Returns a list of pivot tables linked to $bean.
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/Utils/TDBMDaoGenerator.php 2 patches
Doc Comments   +10 added lines, -5 removed lines patch added patch discarded remove patch
@@ -47,7 +47,6 @@  discard block
 block discarded – undo
47 47
     /**
48 48
      * Constructor.
49 49
      *
50
-     * @param Connection $dbConnection The connection to the database.
51 50
      */
52 51
     public function __construct(SchemaAnalyzer $schemaAnalyzer, Schema $schema, TDBMSchemaAnalyzer $tdbmSchemaAnalyzer) {
53 52
         $this->schemaAnalyzer = $schemaAnalyzer;
@@ -100,6 +99,9 @@  discard block
 block discarded – undo
100 99
      * Generates in one method call the daos and the beans for one table.
101 100
      * 
102 101
      * @param $tableName
102
+     * @param string $daonamespace
103
+     * @param string $beannamespace
104
+     * @param boolean $storeInUtc
103 105
      */
104 106
     public function generateDaoAndBean(Table $table, $daonamespace, $beannamespace, ClassNameMapper $classNameMapper, $storeInUtc) {
105 107
 		$tableName = $table->getName();
@@ -135,7 +137,7 @@  discard block
 block discarded – undo
135 137
     /**
136 138
      * Returns the name of the base bean class from the table name.
137 139
      * 
138
-     * @param $tableName
140
+     * @param string $tableName
139 141
      * @return string
140 142
      */
141 143
     public static function getBaseBeanNameFromTableName($tableName) {
@@ -145,7 +147,7 @@  discard block
 block discarded – undo
145 147
     /**
146 148
      * Returns the name of the base DAO class from the table name.
147 149
      *
148
-     * @param $tableName
150
+     * @param string $tableName
149 151
      * @return string
150 152
      */
151 153
     public static function getBaseDaoNameFromTableName($tableName) {
@@ -215,9 +217,10 @@  discard block
 block discarded – undo
215 217
     /**
216 218
      * Writes the PHP bean DAO with simple functions to create/get/save objects.
217 219
      *
218
-     * @param string $fileName The file that will be written (without the directory)
219 220
      * @param string $className The name of the class
220
-     * @param string $tableName The name of the table
221
+     * @param string $table The name of the table
222
+     * @param string $baseClassName
223
+     * @param string $beanClassName
221 224
      */
222 225
     public function generateDao($className, $baseClassName, $beanClassName, Table $table, $daonamespace, $beannamespace, ClassNameMapper $classNameMapper) {
223 226
         $tableName = $table->getName();
@@ -461,6 +464,8 @@  discard block
 block discarded – undo
461 464
      * Generates the factory bean.
462 465
      * 
463 466
      * @param Table[] $tableList
467
+     * @param string $daoFactoryClassName
468
+     * @param string $daoNamespace
464 469
      */
465 470
     private function generateFactory(array $tableList, $daoFactoryClassName, $daoNamespace, ClassNameMapper $classNameMapper) {
466 471
         // For each table, let's write a property.
Please login to merge, or discard this patch.
Indentation   +373 added lines, -373 removed lines patch added patch discarded remove patch
@@ -20,178 +20,178 @@  discard block
 block discarded – undo
20 20
  */
21 21
 class TDBMDaoGenerator {
22 22
 
23
-    /**
24
-     * 
25
-     * @var SchemaAnalyzer
26
-     */
27
-    private $schemaAnalyzer;
28
-
29
-    /**
30
-     *
31
-     * @var Schema
32
-     */
33
-    private $schema;
34
-
35
-    /**
36
-     * The root directory of the project.
37
-     *
38
-     * @var string
39
-     */
40
-    private $rootPath;
41
-
42
-    /**
43
-     * @var TDBMSchemaAnalyzer
44
-     */
45
-    private $tdbmSchemaAnalyzer;
46
-
47
-    /**
48
-     * Constructor.
49
-     *
50
-     * @param Connection $dbConnection The connection to the database.
51
-     */
52
-    public function __construct(SchemaAnalyzer $schemaAnalyzer, Schema $schema, TDBMSchemaAnalyzer $tdbmSchemaAnalyzer) {
53
-        $this->schemaAnalyzer = $schemaAnalyzer;
54
-        $this->schema = $schema;
55
-        $this->tdbmSchemaAnalyzer = $tdbmSchemaAnalyzer;
56
-        $this->rootPath = __DIR__."/../../../../../../../../";
57
-    }
58
-
59
-    /**
60
-     * Generates all the daos and beans.
61
-     *
62
-     * @param string $daoFactoryClassName The classe name of the DAO factory
63
-     * @param string $daonamespace The namespace for the DAOs, without trailing \
64
-     * @param string $beannamespace The Namespace for the beans, without trailing \
65
-     * @param bool $storeInUtc If the generated daos should store the date in UTC timezone instead of user's timezone.
66
-     * @return \string[] the list of tables
67
-     * @throws TDBMException
68
-     */
69
-    public function generateAllDaosAndBeans($daoFactoryClassName, $daonamespace, $beannamespace, $storeInUtc) {
70
-        // TODO: extract ClassNameMapper in its own package!
71
-        $classNameMapper = ClassNameMapper::createFromComposerFile($this->rootPath.'composer.json');
72
-
73
-        // TODO: check that no class name ends with "Base". Otherwise, there will be name clash.
74
-
75
-        $tableList = $this->schema->getTables();
76
-
77
-        // Remove all beans and daos from junction tables
78
-        $junctionTables = $this->schemaAnalyzer->detectJunctionTables();
79
-        $junctionTableNames = array_map(function(Table $table) {
80
-            return $table->getName();
81
-        }, $junctionTables);
82
-
83
-        $tableList = array_filter($tableList, function(Table $table) use ($junctionTableNames) {
84
-            return !in_array($table->getName(), $junctionTableNames);
85
-        });
86
-
87
-        foreach ($tableList as $table) {
88
-            $this->generateDaoAndBean($table, $daonamespace, $beannamespace, $classNameMapper, $storeInUtc);
89
-        }
23
+	/**
24
+	 * 
25
+	 * @var SchemaAnalyzer
26
+	 */
27
+	private $schemaAnalyzer;
28
+
29
+	/**
30
+	 *
31
+	 * @var Schema
32
+	 */
33
+	private $schema;
34
+
35
+	/**
36
+	 * The root directory of the project.
37
+	 *
38
+	 * @var string
39
+	 */
40
+	private $rootPath;
41
+
42
+	/**
43
+	 * @var TDBMSchemaAnalyzer
44
+	 */
45
+	private $tdbmSchemaAnalyzer;
46
+
47
+	/**
48
+	 * Constructor.
49
+	 *
50
+	 * @param Connection $dbConnection The connection to the database.
51
+	 */
52
+	public function __construct(SchemaAnalyzer $schemaAnalyzer, Schema $schema, TDBMSchemaAnalyzer $tdbmSchemaAnalyzer) {
53
+		$this->schemaAnalyzer = $schemaAnalyzer;
54
+		$this->schema = $schema;
55
+		$this->tdbmSchemaAnalyzer = $tdbmSchemaAnalyzer;
56
+		$this->rootPath = __DIR__."/../../../../../../../../";
57
+	}
58
+
59
+	/**
60
+	 * Generates all the daos and beans.
61
+	 *
62
+	 * @param string $daoFactoryClassName The classe name of the DAO factory
63
+	 * @param string $daonamespace The namespace for the DAOs, without trailing \
64
+	 * @param string $beannamespace The Namespace for the beans, without trailing \
65
+	 * @param bool $storeInUtc If the generated daos should store the date in UTC timezone instead of user's timezone.
66
+	 * @return \string[] the list of tables
67
+	 * @throws TDBMException
68
+	 */
69
+	public function generateAllDaosAndBeans($daoFactoryClassName, $daonamespace, $beannamespace, $storeInUtc) {
70
+		// TODO: extract ClassNameMapper in its own package!
71
+		$classNameMapper = ClassNameMapper::createFromComposerFile($this->rootPath.'composer.json');
72
+
73
+		// TODO: check that no class name ends with "Base". Otherwise, there will be name clash.
74
+
75
+		$tableList = $this->schema->getTables();
76
+
77
+		// Remove all beans and daos from junction tables
78
+		$junctionTables = $this->schemaAnalyzer->detectJunctionTables();
79
+		$junctionTableNames = array_map(function(Table $table) {
80
+			return $table->getName();
81
+		}, $junctionTables);
82
+
83
+		$tableList = array_filter($tableList, function(Table $table) use ($junctionTableNames) {
84
+			return !in_array($table->getName(), $junctionTableNames);
85
+		});
86
+
87
+		foreach ($tableList as $table) {
88
+			$this->generateDaoAndBean($table, $daonamespace, $beannamespace, $classNameMapper, $storeInUtc);
89
+		}
90 90
         
91
-        $this->generateFactory($tableList, $daoFactoryClassName, $daonamespace, $classNameMapper);
91
+		$this->generateFactory($tableList, $daoFactoryClassName, $daonamespace, $classNameMapper);
92 92
 
93
-        // Ok, let's return the list of all tables.
94
-        // These will be used by the calling script to create Mouf instances.
93
+		// Ok, let's return the list of all tables.
94
+		// These will be used by the calling script to create Mouf instances.
95 95
         
96
-        return array_map(function(Table $table) { return $table->getName(); },$tableList);
97
-    }
96
+		return array_map(function(Table $table) { return $table->getName(); },$tableList);
97
+	}
98 98
     
99
-    /**
100
-     * Generates in one method call the daos and the beans for one table.
101
-     * 
102
-     * @param $tableName
103
-     */
104
-    public function generateDaoAndBean(Table $table, $daonamespace, $beannamespace, ClassNameMapper $classNameMapper, $storeInUtc) {
99
+	/**
100
+	 * Generates in one method call the daos and the beans for one table.
101
+	 * 
102
+	 * @param $tableName
103
+	 */
104
+	public function generateDaoAndBean(Table $table, $daonamespace, $beannamespace, ClassNameMapper $classNameMapper, $storeInUtc) {
105 105
 		$tableName = $table->getName();
106
-        $daoName = $this->getDaoNameFromTableName($tableName);
107
-        $beanName = $this->getBeanNameFromTableName($tableName);
108
-        $baseBeanName = $this->getBaseBeanNameFromTableName($tableName);
109
-        $baseDaoName = $this->getBaseDaoNameFromTableName($tableName);
110
-
111
-        $this->generateBean($beanName, $baseBeanName, $table, $beannamespace, $classNameMapper, $storeInUtc);
112
-        $this->generateDao($daoName, $baseDaoName, $beanName, $table, $daonamespace, $beannamespace, $classNameMapper);
113
-    }
106
+		$daoName = $this->getDaoNameFromTableName($tableName);
107
+		$beanName = $this->getBeanNameFromTableName($tableName);
108
+		$baseBeanName = $this->getBaseBeanNameFromTableName($tableName);
109
+		$baseDaoName = $this->getBaseDaoNameFromTableName($tableName);
110
+
111
+		$this->generateBean($beanName, $baseBeanName, $table, $beannamespace, $classNameMapper, $storeInUtc);
112
+		$this->generateDao($daoName, $baseDaoName, $beanName, $table, $daonamespace, $beannamespace, $classNameMapper);
113
+	}
114 114
     
115
-    /**
116
-     * Returns the name of the bean class from the table name.
117
-     * 
118
-     * @param $tableName
119
-     * @return string
120
-     */
121
-    public static function getBeanNameFromTableName($tableName) {
122
-        return TDBMDaoGenerator::toSingular(TDBMDaoGenerator::toCamelCase($tableName))."Bean";
123
-    }
115
+	/**
116
+	 * Returns the name of the bean class from the table name.
117
+	 * 
118
+	 * @param $tableName
119
+	 * @return string
120
+	 */
121
+	public static function getBeanNameFromTableName($tableName) {
122
+		return TDBMDaoGenerator::toSingular(TDBMDaoGenerator::toCamelCase($tableName))."Bean";
123
+	}
124 124
     
125
-    /**
126
-     * Returns the name of the DAO class from the table name.
127
-     * 
128
-     * @param $tableName
129
-     * @return string
130
-     */
131
-    public static function getDaoNameFromTableName($tableName) {
132
-        return TDBMDaoGenerator::toSingular(TDBMDaoGenerator::toCamelCase($tableName))."Dao";
133
-    }
125
+	/**
126
+	 * Returns the name of the DAO class from the table name.
127
+	 * 
128
+	 * @param $tableName
129
+	 * @return string
130
+	 */
131
+	public static function getDaoNameFromTableName($tableName) {
132
+		return TDBMDaoGenerator::toSingular(TDBMDaoGenerator::toCamelCase($tableName))."Dao";
133
+	}
134 134
     
135
-    /**
136
-     * Returns the name of the base bean class from the table name.
137
-     * 
138
-     * @param $tableName
139
-     * @return string
140
-     */
141
-    public static function getBaseBeanNameFromTableName($tableName) {
142
-        return TDBMDaoGenerator::toSingular(TDBMDaoGenerator::toCamelCase($tableName))."BaseBean";
143
-    }
144
-
145
-    /**
146
-     * Returns the name of the base DAO class from the table name.
147
-     *
148
-     * @param $tableName
149
-     * @return string
150
-     */
151
-    public static function getBaseDaoNameFromTableName($tableName) {
152
-        return TDBMDaoGenerator::toSingular(TDBMDaoGenerator::toCamelCase($tableName))."BaseDao";
153
-    }
154
-
155
-    /**
156
-     * Writes the PHP bean file with all getters and setters from the table passed in parameter.
157
-     *
158
-     * @param string $className The name of the class
159
-     * @param string $baseClassName The name of the base class which will be extended (name only, no directory)
160
-     * @param Table $table The table
161
-     * @param string $beannamespace The namespace of the bean
162
-     * @param ClassNameMapper $classNameMapper
163
-     * @throws TDBMException
164
-     */
165
-    public function generateBean($className, $baseClassName, Table $table, $beannamespace, ClassNameMapper $classNameMapper, $storeInUtc) {
166
-
167
-        $beanDescriptor = new BeanDescriptor($table, $this->schemaAnalyzer, $this->schema, $this->tdbmSchemaAnalyzer);
168
-
169
-        $str = $beanDescriptor->generatePhpCode($beannamespace);
170
-
171
-        $possibleBaseFileNames = $classNameMapper->getPossibleFileNames($beannamespace."\\".$baseClassName);
172
-        if (!$possibleBaseFileNames) {
173
-            throw new TDBMException('Sorry, autoload namespace issue. The class "'.$beannamespace."\\".$baseClassName.'" is not autoloadable.');
174
-        }
175
-        $possibleBaseFileName = $this->rootPath.$possibleBaseFileNames[0];
176
-
177
-        $this->ensureDirectoryExist($possibleBaseFileName);
178
-        file_put_contents($possibleBaseFileName, $str);
179
-        @chmod($possibleBaseFileName, 0664);
180
-
181
-
182
-
183
-        $possibleFileNames = $classNameMapper->getPossibleFileNames($beannamespace."\\".$className);
184
-        if (!$possibleFileNames) {
185
-            // @codeCoverageIgnoreStart
186
-            throw new TDBMException('Sorry, autoload namespace issue. The class "'.$beannamespace."\\".$className.'" is not autoloadable.');
187
-            // @codeCoverageIgnoreEnd
188
-        }
189
-        $possibleFileName = $this->rootPath.$possibleFileNames[0];
190
-
191
-        if (!file_exists($possibleFileName)) {
192
-            $tableName = $table->getName();
193
-
194
-            $str = "<?php
135
+	/**
136
+	 * Returns the name of the base bean class from the table name.
137
+	 * 
138
+	 * @param $tableName
139
+	 * @return string
140
+	 */
141
+	public static function getBaseBeanNameFromTableName($tableName) {
142
+		return TDBMDaoGenerator::toSingular(TDBMDaoGenerator::toCamelCase($tableName))."BaseBean";
143
+	}
144
+
145
+	/**
146
+	 * Returns the name of the base DAO class from the table name.
147
+	 *
148
+	 * @param $tableName
149
+	 * @return string
150
+	 */
151
+	public static function getBaseDaoNameFromTableName($tableName) {
152
+		return TDBMDaoGenerator::toSingular(TDBMDaoGenerator::toCamelCase($tableName))."BaseDao";
153
+	}
154
+
155
+	/**
156
+	 * Writes the PHP bean file with all getters and setters from the table passed in parameter.
157
+	 *
158
+	 * @param string $className The name of the class
159
+	 * @param string $baseClassName The name of the base class which will be extended (name only, no directory)
160
+	 * @param Table $table The table
161
+	 * @param string $beannamespace The namespace of the bean
162
+	 * @param ClassNameMapper $classNameMapper
163
+	 * @throws TDBMException
164
+	 */
165
+	public function generateBean($className, $baseClassName, Table $table, $beannamespace, ClassNameMapper $classNameMapper, $storeInUtc) {
166
+
167
+		$beanDescriptor = new BeanDescriptor($table, $this->schemaAnalyzer, $this->schema, $this->tdbmSchemaAnalyzer);
168
+
169
+		$str = $beanDescriptor->generatePhpCode($beannamespace);
170
+
171
+		$possibleBaseFileNames = $classNameMapper->getPossibleFileNames($beannamespace."\\".$baseClassName);
172
+		if (!$possibleBaseFileNames) {
173
+			throw new TDBMException('Sorry, autoload namespace issue. The class "'.$beannamespace."\\".$baseClassName.'" is not autoloadable.');
174
+		}
175
+		$possibleBaseFileName = $this->rootPath.$possibleBaseFileNames[0];
176
+
177
+		$this->ensureDirectoryExist($possibleBaseFileName);
178
+		file_put_contents($possibleBaseFileName, $str);
179
+		@chmod($possibleBaseFileName, 0664);
180
+
181
+
182
+
183
+		$possibleFileNames = $classNameMapper->getPossibleFileNames($beannamespace."\\".$className);
184
+		if (!$possibleFileNames) {
185
+			// @codeCoverageIgnoreStart
186
+			throw new TDBMException('Sorry, autoload namespace issue. The class "'.$beannamespace."\\".$className.'" is not autoloadable.');
187
+			// @codeCoverageIgnoreEnd
188
+		}
189
+		$possibleFileName = $this->rootPath.$possibleFileNames[0];
190
+
191
+		if (!file_exists($possibleFileName)) {
192
+			$tableName = $table->getName();
193
+
194
+			$str = "<?php
195 195
 /*
196 196
  * This file has been automatically generated by TDBM.
197 197
  * You can edit this file as it will not be overwritten.
@@ -206,44 +206,44 @@  discard block
 block discarded – undo
206 206
 {
207 207
 
208 208
 }";
209
-            $this->ensureDirectoryExist($possibleFileName);
210
-            file_put_contents($possibleFileName ,$str);
211
-            @chmod($possibleFileName, 0664);
212
-        }
213
-    }
214
-
215
-    /**
216
-     * Writes the PHP bean DAO with simple functions to create/get/save objects.
217
-     *
218
-     * @param string $fileName The file that will be written (without the directory)
219
-     * @param string $className The name of the class
220
-     * @param string $tableName The name of the table
221
-     */
222
-    public function generateDao($className, $baseClassName, $beanClassName, Table $table, $daonamespace, $beannamespace, ClassNameMapper $classNameMapper) {
223
-        $tableName = $table->getName();
224
-        $primaryKeyColumns = $table->getPrimaryKeyColumns();
225
-
226
-        $defaultSort = null;
227
-        foreach ($table->getColumns() as $column) {
228
-            $comments = $column->getComment();
229
-            $matches = array();
230
-            if (preg_match('/@defaultSort(\((desc|asc)\))*/', $comments, $matches) != 0){
231
-                $defaultSort = $data['column_name'];
232
-                if (count($matches == 3)){
233
-                    $defaultSortDirection = $matches[2];
234
-                }else{
235
-                    $defaultSortDirection = 'ASC';
236
-                }
237
-            }
238
-        }
209
+			$this->ensureDirectoryExist($possibleFileName);
210
+			file_put_contents($possibleFileName ,$str);
211
+			@chmod($possibleFileName, 0664);
212
+		}
213
+	}
214
+
215
+	/**
216
+	 * Writes the PHP bean DAO with simple functions to create/get/save objects.
217
+	 *
218
+	 * @param string $fileName The file that will be written (without the directory)
219
+	 * @param string $className The name of the class
220
+	 * @param string $tableName The name of the table
221
+	 */
222
+	public function generateDao($className, $baseClassName, $beanClassName, Table $table, $daonamespace, $beannamespace, ClassNameMapper $classNameMapper) {
223
+		$tableName = $table->getName();
224
+		$primaryKeyColumns = $table->getPrimaryKeyColumns();
225
+
226
+		$defaultSort = null;
227
+		foreach ($table->getColumns() as $column) {
228
+			$comments = $column->getComment();
229
+			$matches = array();
230
+			if (preg_match('/@defaultSort(\((desc|asc)\))*/', $comments, $matches) != 0){
231
+				$defaultSort = $data['column_name'];
232
+				if (count($matches == 3)){
233
+					$defaultSortDirection = $matches[2];
234
+				}else{
235
+					$defaultSortDirection = 'ASC';
236
+				}
237
+			}
238
+		}
239 239
 
240
-        // FIXME: lowercase tables with _ in the name should work!
241
-        $tableCamel = self::toSingular(self::toCamelCase($tableName));
240
+		// FIXME: lowercase tables with _ in the name should work!
241
+		$tableCamel = self::toSingular(self::toCamelCase($tableName));
242 242
         
243
-        $beanClassWithoutNameSpace = $beanClassName;
244
-        $beanClassName = $beannamespace."\\".$beanClassName;
243
+		$beanClassWithoutNameSpace = $beanClassName;
244
+		$beanClassName = $beannamespace."\\".$beanClassName;
245 245
         
246
-        $str = "<?php
246
+		$str = "<?php
247 247
 
248 248
 /*
249 249
  * This file has been automatically generated by TDBM.
@@ -330,9 +330,9 @@  discard block
 block discarded – undo
330 330
     }
331 331
     ";
332 332
 
333
-        if (count($primaryKeyColumns) === 1) {
334
-            $primaryKeyColumn = $primaryKeyColumns[0];
335
-            $str .= "
333
+		if (count($primaryKeyColumns) === 1) {
334
+			$primaryKeyColumn = $primaryKeyColumns[0];
335
+			$str .= "
336 336
     /**
337 337
      * Get $beanClassWithoutNameSpace specified by its ID (its primary key)
338 338
      * If the primary key does not exist, an exception is thrown.
@@ -347,8 +347,8 @@  discard block
 block discarded – undo
347 347
         return \$this->tdbmService->findObjectByPk('$tableName', ['$primaryKeyColumn' => \$id], [], \$lazyLoading);
348 348
     }
349 349
     ";
350
-        }
351
-        $str .= "
350
+		}
351
+		$str .= "
352 352
     /**
353 353
      * Deletes the $beanClassWithoutNameSpace passed in parameter.
354 354
      *
@@ -410,29 +410,29 @@  discard block
 block discarded – undo
410 410
 }
411 411
 ";
412 412
 
413
-        $possibleBaseFileNames = $classNameMapper->getPossibleFileNames($daonamespace."\\".$baseClassName);
414
-        if (!$possibleBaseFileNames) {
415
-            // @codeCoverageIgnoreStart
416
-            throw new TDBMException('Sorry, autoload namespace issue. The class "'.$baseClassName.'" is not autoloadable.');
417
-            // @codeCoverageIgnoreEnd
418
-        }
419
-        $possibleBaseFileName = $this->rootPath.$possibleBaseFileNames[0];
420
-
421
-        $this->ensureDirectoryExist($possibleBaseFileName);
422
-        file_put_contents($possibleBaseFileName ,$str);
423
-        @chmod($possibleBaseFileName, 0664);
424
-
425
-        $possibleFileNames = $classNameMapper->getPossibleFileNames($daonamespace."\\".$className);
426
-        if (!$possibleFileNames) {
427
-            // @codeCoverageIgnoreStart
428
-            throw new TDBMException('Sorry, autoload namespace issue. The class "'.$className.'" is not autoloadable.');
429
-            // @codeCoverageIgnoreEnd
430
-        }
431
-        $possibleFileName = $this->rootPath.$possibleFileNames[0];
413
+		$possibleBaseFileNames = $classNameMapper->getPossibleFileNames($daonamespace."\\".$baseClassName);
414
+		if (!$possibleBaseFileNames) {
415
+			// @codeCoverageIgnoreStart
416
+			throw new TDBMException('Sorry, autoload namespace issue. The class "'.$baseClassName.'" is not autoloadable.');
417
+			// @codeCoverageIgnoreEnd
418
+		}
419
+		$possibleBaseFileName = $this->rootPath.$possibleBaseFileNames[0];
420
+
421
+		$this->ensureDirectoryExist($possibleBaseFileName);
422
+		file_put_contents($possibleBaseFileName ,$str);
423
+		@chmod($possibleBaseFileName, 0664);
424
+
425
+		$possibleFileNames = $classNameMapper->getPossibleFileNames($daonamespace."\\".$className);
426
+		if (!$possibleFileNames) {
427
+			// @codeCoverageIgnoreStart
428
+			throw new TDBMException('Sorry, autoload namespace issue. The class "'.$className.'" is not autoloadable.');
429
+			// @codeCoverageIgnoreEnd
430
+		}
431
+		$possibleFileName = $this->rootPath.$possibleFileNames[0];
432 432
         
433
-        // Now, let's generate the "editable" class
434
-        if (!file_exists($possibleFileName)) {
435
-            $str = "<?php
433
+		// Now, let's generate the "editable" class
434
+		if (!file_exists($possibleFileName)) {
435
+			$str = "<?php
436 436
 
437 437
 /*
438 438
  * This file has been automatically generated by TDBM.
@@ -449,23 +449,23 @@  discard block
 block discarded – undo
449 449
 
450 450
 }
451 451
 ";
452
-            $this->ensureDirectoryExist($possibleFileName);
453
-            file_put_contents($possibleFileName ,$str);
454
-            @chmod($possibleFileName, 0664);
455
-        }
456
-    }
452
+			$this->ensureDirectoryExist($possibleFileName);
453
+			file_put_contents($possibleFileName ,$str);
454
+			@chmod($possibleFileName, 0664);
455
+		}
456
+	}
457 457
 
458 458
 
459 459
 
460
-    /**
461
-     * Generates the factory bean.
462
-     * 
463
-     * @param Table[] $tableList
464
-     */
465
-    private function generateFactory(array $tableList, $daoFactoryClassName, $daoNamespace, ClassNameMapper $classNameMapper) {
466
-        // For each table, let's write a property.
460
+	/**
461
+	 * Generates the factory bean.
462
+	 * 
463
+	 * @param Table[] $tableList
464
+	 */
465
+	private function generateFactory(array $tableList, $daoFactoryClassName, $daoNamespace, ClassNameMapper $classNameMapper) {
466
+		// For each table, let's write a property.
467 467
         
468
-        $str = "<?php
468
+		$str = "<?php
469 469
 
470 470
 /*
471 471
  * This file has been automatically generated by TDBM.
@@ -482,12 +482,12 @@  discard block
 block discarded – undo
482 482
 {
483 483
 ";
484 484
 
485
-        foreach ($tableList as $table) {
486
-            $tableName = $table->getName();
487
-            $daoClassName = $this->getDaoNameFromTableName($tableName);
488
-            $daoInstanceName = self::toVariableName($daoClassName);
485
+		foreach ($tableList as $table) {
486
+			$tableName = $table->getName();
487
+			$daoClassName = $this->getDaoNameFromTableName($tableName);
488
+			$daoInstanceName = self::toVariableName($daoClassName);
489 489
             
490
-            $str .= '    /**
490
+			$str .= '    /**
491 491
      * @var '.$daoClassName.'
492 492
      */
493 493
     private $'.$daoInstanceName.';
@@ -512,142 +512,142 @@  discard block
 block discarded – undo
512 512
     }
513 513
     
514 514
 ';
515
-        }
515
+		}
516 516
         
517 517
         
518
-        $str .= '
518
+		$str .= '
519 519
 }
520 520
 ';
521 521
 
522
-        $possibleFileNames = $classNameMapper->getPossibleFileNames($daoNamespace."\\".$daoFactoryClassName);
523
-        if (!$possibleFileNames) {
524
-            throw new TDBMException('Sorry, autoload namespace issue. The class "'.$daoNamespace."\\".$daoFactoryClassName.'" is not autoloadable.');
525
-        }
526
-        $possibleFileName = $this->rootPath.$possibleFileNames[0];
527
-
528
-        $this->ensureDirectoryExist($possibleFileName);
529
-        file_put_contents($possibleFileName ,$str);
530
-        @chmod($possibleFileName, 0664);
531
-    }
532
-
533
-    /**
534
-     * Transforms a string to camelCase (except the first letter will be uppercase too).
535
-     * Underscores and spaces are removed and the first letter after the underscore is uppercased.
536
-     * 
537
-     * @param $str string
538
-     * @return string
539
-     */
540
-    public static function toCamelCase($str) {
541
-        $str = strtoupper(substr($str,0,1)).substr($str,1);
542
-        while (true) {
543
-            if (strpos($str, "_") === false && strpos($str, " ") === false) {
544
-                break;
522
+		$possibleFileNames = $classNameMapper->getPossibleFileNames($daoNamespace."\\".$daoFactoryClassName);
523
+		if (!$possibleFileNames) {
524
+			throw new TDBMException('Sorry, autoload namespace issue. The class "'.$daoNamespace."\\".$daoFactoryClassName.'" is not autoloadable.');
525
+		}
526
+		$possibleFileName = $this->rootPath.$possibleFileNames[0];
527
+
528
+		$this->ensureDirectoryExist($possibleFileName);
529
+		file_put_contents($possibleFileName ,$str);
530
+		@chmod($possibleFileName, 0664);
531
+	}
532
+
533
+	/**
534
+	 * Transforms a string to camelCase (except the first letter will be uppercase too).
535
+	 * Underscores and spaces are removed and the first letter after the underscore is uppercased.
536
+	 * 
537
+	 * @param $str string
538
+	 * @return string
539
+	 */
540
+	public static function toCamelCase($str) {
541
+		$str = strtoupper(substr($str,0,1)).substr($str,1);
542
+		while (true) {
543
+			if (strpos($str, "_") === false && strpos($str, " ") === false) {
544
+				break;
545 545
 			}
546 546
                 
547
-            $pos = strpos($str, "_");
548
-            if ($pos === false) {
549
-                $pos = strpos($str, " ");
550
-            }
551
-            $before = substr($str,0,$pos);
552
-            $after = substr($str,$pos+1);
553
-            $str = $before.strtoupper(substr($after,0,1)).substr($after,1);
554
-        }
555
-        return $str;
556
-    }
547
+			$pos = strpos($str, "_");
548
+			if ($pos === false) {
549
+				$pos = strpos($str, " ");
550
+			}
551
+			$before = substr($str,0,$pos);
552
+			$after = substr($str,$pos+1);
553
+			$str = $before.strtoupper(substr($after,0,1)).substr($after,1);
554
+		}
555
+		return $str;
556
+	}
557 557
     
558
-    /**
559
-     * Tries to put string to the singular form (if it is plural).
560
-     * We assume the table names are in english.
561
-     *
562
-     * @param $str string
563
-     * @return string
564
-     */
565
-    public static function toSingular($str) {
566
-        return Inflector::singularize($str);
567
-    }
558
+	/**
559
+	 * Tries to put string to the singular form (if it is plural).
560
+	 * We assume the table names are in english.
561
+	 *
562
+	 * @param $str string
563
+	 * @return string
564
+	 */
565
+	public static function toSingular($str) {
566
+		return Inflector::singularize($str);
567
+	}
568 568
     
569
-    /**
570
-     * Put the first letter of the string in lower case.
571
-     * Very useful to transform a class name into a variable name.
572
-     * 
573
-     * @param $str string
574
-     * @return string
575
-     */
576
-    public static function toVariableName($str) {
577
-        return strtolower(substr($str, 0, 1)).substr($str, 1);
578
-    }
579
-
580
-    /**
581
-     * Ensures the file passed in parameter can be written in its directory.
582
-     * @param string $fileName
583
-     * @throws TDBMException
584
-     */
585
-    private function ensureDirectoryExist($fileName) {
586
-        $dirName = dirname($fileName);
587
-        if (!file_exists($dirName)) {
588
-            $old = umask(0);
589
-            $result = mkdir($dirName, 0775, true);
590
-            umask($old);
591
-            if ($result === false) {
592
-                throw new TDBMException("Unable to create directory: '".$dirName."'.");
593
-            }
594
-        }
595
-    }
596
-
597
-    /**
598
-     * @param string $rootPath
599
-     */
600
-    public function setRootPath($rootPath)
601
-    {
602
-        $this->rootPath = $rootPath;
603
-    }
604
-
605
-    /**
606
-     * Transforms a DBAL type into a PHP type (for PHPDoc purpose)
607
-     *
608
-     * @param Type $type The DBAL type
609
-     * @return string The PHP type
610
-     */
611
-    public static function dbalTypeToPhpType(Type $type) {
612
-        $map = [
613
-            Type::TARRAY => 'array',
614
-            Type::SIMPLE_ARRAY => 'array',
615
-            Type::JSON_ARRAY => 'array',
616
-            Type::BIGINT => 'string',
617
-            Type::BOOLEAN => 'bool',
618
-            Type::DATETIME => '\DateTimeInterface',
619
-            Type::DATETIMETZ => '\DateTimeInterface',
620
-            Type::DATE => '\DateTimeInterface',
621
-            Type::TIME => '\DateTimeInterface',
622
-            Type::DECIMAL => 'float',
623
-            Type::INTEGER => 'int',
624
-            Type::OBJECT => 'string',
625
-            Type::SMALLINT => 'int',
626
-            Type::STRING => 'string',
627
-            Type::TEXT => 'string',
628
-            Type::BINARY => 'string',
629
-            Type::BLOB => 'string',
630
-            Type::FLOAT => 'float',
631
-            Type::GUID => 'string'
632
-        ];
633
-
634
-        return isset($map[$type->getName()])?$map[$type->getName()]:$type->getName();
635
-    }
636
-
637
-    /**
638
-     *
639
-     * @param string $beanNamespace
640
-     * @return \string[] Returns a map mapping table name to beans name
641
-     */
642
-    public function buildTableToBeanMap($beanNamespace) {
643
-        $tableToBeanMap = [];
644
-
645
-        $tables = $this->schema->getTables();
646
-
647
-        foreach ($tables as $table) {
648
-            $tableName = $table->getName();
649
-            $tableToBeanMap[$tableName] = $beanNamespace . "\\" . self::getBeanNameFromTableName($tableName);
650
-        }
651
-        return $tableToBeanMap;
652
-    }
569
+	/**
570
+	 * Put the first letter of the string in lower case.
571
+	 * Very useful to transform a class name into a variable name.
572
+	 * 
573
+	 * @param $str string
574
+	 * @return string
575
+	 */
576
+	public static function toVariableName($str) {
577
+		return strtolower(substr($str, 0, 1)).substr($str, 1);
578
+	}
579
+
580
+	/**
581
+	 * Ensures the file passed in parameter can be written in its directory.
582
+	 * @param string $fileName
583
+	 * @throws TDBMException
584
+	 */
585
+	private function ensureDirectoryExist($fileName) {
586
+		$dirName = dirname($fileName);
587
+		if (!file_exists($dirName)) {
588
+			$old = umask(0);
589
+			$result = mkdir($dirName, 0775, true);
590
+			umask($old);
591
+			if ($result === false) {
592
+				throw new TDBMException("Unable to create directory: '".$dirName."'.");
593
+			}
594
+		}
595
+	}
596
+
597
+	/**
598
+	 * @param string $rootPath
599
+	 */
600
+	public function setRootPath($rootPath)
601
+	{
602
+		$this->rootPath = $rootPath;
603
+	}
604
+
605
+	/**
606
+	 * Transforms a DBAL type into a PHP type (for PHPDoc purpose)
607
+	 *
608
+	 * @param Type $type The DBAL type
609
+	 * @return string The PHP type
610
+	 */
611
+	public static function dbalTypeToPhpType(Type $type) {
612
+		$map = [
613
+			Type::TARRAY => 'array',
614
+			Type::SIMPLE_ARRAY => 'array',
615
+			Type::JSON_ARRAY => 'array',
616
+			Type::BIGINT => 'string',
617
+			Type::BOOLEAN => 'bool',
618
+			Type::DATETIME => '\DateTimeInterface',
619
+			Type::DATETIMETZ => '\DateTimeInterface',
620
+			Type::DATE => '\DateTimeInterface',
621
+			Type::TIME => '\DateTimeInterface',
622
+			Type::DECIMAL => 'float',
623
+			Type::INTEGER => 'int',
624
+			Type::OBJECT => 'string',
625
+			Type::SMALLINT => 'int',
626
+			Type::STRING => 'string',
627
+			Type::TEXT => 'string',
628
+			Type::BINARY => 'string',
629
+			Type::BLOB => 'string',
630
+			Type::FLOAT => 'float',
631
+			Type::GUID => 'string'
632
+		];
633
+
634
+		return isset($map[$type->getName()])?$map[$type->getName()]:$type->getName();
635
+	}
636
+
637
+	/**
638
+	 *
639
+	 * @param string $beanNamespace
640
+	 * @return \string[] Returns a map mapping table name to beans name
641
+	 */
642
+	public function buildTableToBeanMap($beanNamespace) {
643
+		$tableToBeanMap = [];
644
+
645
+		$tables = $this->schema->getTables();
646
+
647
+		foreach ($tables as $table) {
648
+			$tableName = $table->getName();
649
+			$tableToBeanMap[$tableName] = $beanNamespace . "\\" . self::getBeanNameFromTableName($tableName);
650
+		}
651
+		return $tableToBeanMap;
652
+	}
653 653
 }
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/DbRow.php 2 patches
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch
@@ -94,7 +94,7 @@  discard block
 block discarded – undo
94 94
 	 * @throws TDBMException
95 95
 	 * @throws TDBMInvalidOperationException
96 96
 	 */
97
-	public function __construct(AbstractTDBMObject $object, $table_name, array $primaryKeys=array(), TDBMService $tdbmService=null, array $dbRow = array()) {
97
+	public function __construct(AbstractTDBMObject $object, $table_name, array $primaryKeys = array(), TDBMService $tdbmService = null, array $dbRow = array()) {
98 98
 		$this->object = $object;
99 99
 		$this->dbTableName = $table_name;
100 100
 
@@ -141,7 +141,7 @@  discard block
 block discarded – undo
141 141
 	 * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
142 142
 	 * @param string $state
143 143
 	 */
144
-	public function _setStatus($state){
144
+	public function _setStatus($state) {
145 145
 		$this->status = $state;
146 146
 	}
147 147
 
@@ -163,7 +163,7 @@  discard block
 block discarded – undo
163 163
 			$sql = "SELECT * FROM ".$connection->quoteIdentifier($this->dbTableName)." WHERE ".$sql_where;
164 164
 			$result = $connection->executeQuery($sql, $parameters);
165 165
 
166
-			if ($result->rowCount()==0)
166
+			if ($result->rowCount() == 0)
167 167
 			{
168 168
 				throw new TDBMException("Could not retrieve object from table \"$this->dbTableName\" with ID \"".$this->TDBMObject_id."\".");
169 169
 			}
@@ -326,7 +326,7 @@  discard block
 block discarded – undo
326 326
     /**
327 327
      * Override the native php clone function for TDBMObjects
328 328
      */
329
-    public function __clone(){
329
+    public function __clone() {
330 330
         $this->_dbLoadIfNotLoaded();
331 331
         //First lets set the status to new (to enter the save function)
332 332
         $this->status = TDBMObjectStateEnum::STATE_NEW;
@@ -358,7 +358,7 @@  discard block
 block discarded – undo
358 358
             $pkValues = array_values($firstRefDbRow->_getPrimaryKeys());
359 359
             $localColumns = $fk->getLocalColumns();
360 360
 
361
-            for ($i=0, $count=count($localColumns); $i<$count; $i++) {
361
+            for ($i = 0, $count = count($localColumns); $i<$count; $i++) {
362 362
                 $dbRow[$localColumns[$i]] = $pkValues[$i];
363 363
             }
364 364
         }
Please login to merge, or discard this patch.
Indentation   +52 added lines, -52 removed lines patch added patch discarded remove patch
@@ -247,36 +247,36 @@  discard block
 block discarded – undo
247 247
 	public function setRef($foreignKeyName, AbstractTDBMObject $bean = null) {
248 248
 		$this->references[$foreignKeyName] = $bean;
249 249
 
250
-        if ($this->tdbmService !== null && $this->status === TDBMObjectStateEnum::STATE_LOADED) {
251
-            $this->status = TDBMObjectStateEnum::STATE_DIRTY;
252
-            $this->tdbmService->_addToToSaveObjectList($this);
253
-        }
250
+		if ($this->tdbmService !== null && $this->status === TDBMObjectStateEnum::STATE_LOADED) {
251
+			$this->status = TDBMObjectStateEnum::STATE_DIRTY;
252
+			$this->tdbmService->_addToToSaveObjectList($this);
253
+		}
254 254
 	}
255 255
 
256
-    /**
257
-     * @param string $foreignKeyName A unique name for this reference
258
-     * @return AbstractTDBMObject|null
259
-     */
260
-    public function getRef($foreignKeyName) {
256
+	/**
257
+	 * @param string $foreignKeyName A unique name for this reference
258
+	 * @return AbstractTDBMObject|null
259
+	 */
260
+	public function getRef($foreignKeyName) {
261 261
 		if (isset($this->references[$foreignKeyName])) {
262 262
 			return $this->references[$foreignKeyName];
263 263
 		} elseif ($this->status === TDBMObjectStateEnum::STATE_NEW) {
264
-            // If the object is new and has no property, then it has to be empty.
265
-            return null;
266
-        } else {
267
-            $this->_dbLoadIfNotLoaded();
264
+			// If the object is new and has no property, then it has to be empty.
265
+			return null;
266
+		} else {
267
+			$this->_dbLoadIfNotLoaded();
268 268
 
269
-            // Let's match the name of the columns to the primary key values
270
-            $fk = $this->tdbmService->_getForeignKeyByName($this->dbTableName, $foreignKeyName);
269
+			// Let's match the name of the columns to the primary key values
270
+			$fk = $this->tdbmService->_getForeignKeyByName($this->dbTableName, $foreignKeyName);
271 271
 
272
-            $values = [];
273
-            foreach ($fk->getLocalColumns() as $column) {
274
-                $values[] = $this->dbRow[$column];
275
-            }
272
+			$values = [];
273
+			foreach ($fk->getLocalColumns() as $column) {
274
+				$values[] = $this->dbRow[$column];
275
+			}
276 276
 
277
-            $filter = array_combine($this->tdbmService->getPrimaryKeyColumns($fk->getForeignTableName()), $values);
277
+			$filter = array_combine($this->tdbmService->getPrimaryKeyColumns($fk->getForeignTableName()), $values);
278 278
 
279
-            return $this->tdbmService->findObjectByPk($fk->getForeignTableName(), $filter, [], true);
279
+			return $this->tdbmService->findObjectByPk($fk->getForeignTableName(), $filter, [], true);
280 280
 		}
281 281
 	}
282 282
 
@@ -323,26 +323,26 @@  discard block
 block discarded – undo
323 323
 		return array($this->dbTableName);
324 324
 	}
325 325
 
326
-    /**
327
-     * Override the native php clone function for TDBMObjects
328
-     */
329
-    public function __clone(){
326
+	/**
327
+	 * Override the native php clone function for TDBMObjects
328
+	 */
329
+	public function __clone(){
330 330
 		// Let's load the row (before we lose the ID!)
331 331
 		$this->_dbLoadIfNotLoaded();
332 332
 
333 333
 		//Let's set the status to detached
334
-        $this->status = TDBMObjectStateEnum::STATE_DETACHED;
334
+		$this->status = TDBMObjectStateEnum::STATE_DETACHED;
335 335
 
336 336
 		$this->primaryKeys = null;
337 337
 
338
-        //Now unset the PK from the row
338
+		//Now unset the PK from the row
339 339
 		if ($this->tdbmService) {
340 340
 			$pk_array = $this->tdbmService->getPrimaryKeyColumns($this->dbTableName);
341 341
 			foreach ($pk_array as $pk) {
342 342
 				$this->dbRow[$pk] = null;
343 343
 			}
344 344
 		}
345
-    }
345
+	}
346 346
 
347 347
 	/**
348 348
 	 * Returns raw database row.
@@ -350,35 +350,35 @@  discard block
 block discarded – undo
350 350
 	 * @return array
351 351
 	 */
352 352
 	public function _getDbRow() {
353
-        // Let's merge $dbRow and $references
354
-        $dbRow = $this->dbRow;
355
-
356
-        foreach ($this->references as $foreignKeyName => $reference) {
357
-            // Let's match the name of the columns to the primary key values
358
-            $fk = $this->tdbmService->_getForeignKeyByName($this->dbTableName, $foreignKeyName);
359
-            $refDbRows = $reference->_getDbRows();
360
-            $firstRefDbRow = reset($refDbRows);
361
-            $pkValues = array_values($firstRefDbRow->_getPrimaryKeys());
362
-            $localColumns = $fk->getLocalColumns();
363
-
364
-            for ($i=0, $count=count($localColumns); $i<$count; $i++) {
365
-                $dbRow[$localColumns[$i]] = $pkValues[$i];
366
-            }
367
-        }
353
+		// Let's merge $dbRow and $references
354
+		$dbRow = $this->dbRow;
355
+
356
+		foreach ($this->references as $foreignKeyName => $reference) {
357
+			// Let's match the name of the columns to the primary key values
358
+			$fk = $this->tdbmService->_getForeignKeyByName($this->dbTableName, $foreignKeyName);
359
+			$refDbRows = $reference->_getDbRows();
360
+			$firstRefDbRow = reset($refDbRows);
361
+			$pkValues = array_values($firstRefDbRow->_getPrimaryKeys());
362
+			$localColumns = $fk->getLocalColumns();
363
+
364
+			for ($i=0, $count=count($localColumns); $i<$count; $i++) {
365
+				$dbRow[$localColumns[$i]] = $pkValues[$i];
366
+			}
367
+		}
368 368
 
369 369
 		return $dbRow;
370 370
 	}
371 371
 
372
-    /**
373
-     * Returns references array.
374
-     *
375
-     * @return AbstractTDBMObject[]
376
-     */
377
-    public function _getReferences() {
378
-        return $this->references;
379
-    }
372
+	/**
373
+	 * Returns references array.
374
+	 *
375
+	 * @return AbstractTDBMObject[]
376
+	 */
377
+	public function _getReferences() {
378
+		return $this->references;
379
+	}
380 380
 
381
-    /**
381
+	/**
382 382
 	 * @return array
383 383
 	 */
384 384
 	public function _getPrimaryKeys()
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/Utils/ObjectBeanPropertyDescriptor.php 1 patch
Indentation   +128 added lines, -128 removed lines patch added patch discarded remove patch
@@ -14,122 +14,122 @@  discard block
 block discarded – undo
14 14
 class ObjectBeanPropertyDescriptor extends AbstractBeanPropertyDescriptor
15 15
 {
16 16
 
17
-    /**
18
-     * @var ForeignKeyConstraint
19
-     */
20
-    private $foreignKey;
21
-
22
-    /**
23
-     * @var SchemaAnalyzer
24
-     */
25
-    private $schemaAnalyzer;
26
-
27
-    public function __construct(Table $table, ForeignKeyConstraint $foreignKey, SchemaAnalyzer $schemaAnalyzer) {
28
-        parent::__construct($table);
29
-        $this->foreignKey = $foreignKey;
30
-        $this->schemaAnalyzer = $schemaAnalyzer;
31
-    }
32
-
33
-
34
-
35
-    /**
36
-     * Returns the foreignkey the column is part of, if any. null otherwise.
37
-     *
38
-     * @return ForeignKeyConstraint|null
39
-     */
40
-    public function getForeignKey() {
41
-        return $this->foreignKey;
42
-    }
43
-
44
-    /**
45
-     * Returns the name of the class linked to this property or null if this is not a foreign key
46
-     * @return null|string
47
-     */
48
-    public function getClassName() {
49
-        return TDBMDaoGenerator::getBeanNameFromTableName($this->foreignKey->getForeignTableName());
50
-    }
51
-
52
-    /**
53
-     * Returns the param annotation for this property (useful for constructor).
54
-     *
55
-     * @return string
56
-     */
57
-    public function getParamAnnotation() {
58
-        $str = "     * @param %s %s";
59
-        return sprintf($str, $this->getClassName(), $this->getVariableName());
60
-    }
61
-
62
-    public function getUpperCamelCaseName() {
63
-        // First, are there many column or only one?
64
-        // If one column, we name the setter after it. Otherwise, we name the setter after the table name
65
-        if (count($this->foreignKey->getLocalColumns()) > 1) {
66
-            $name = TDBMDaoGenerator::toSingular(TDBMDaoGenerator::toCamelCase($this->foreignKey->getForeignTableName()));
67
-            if ($this->alternativeName) {
68
-                $camelizedColumns = array_map(['Mouf\\Database\\TDBM\\Utils\\TDBMDaoGenerator', 'toCamelCase'], $this->foreignKey->getLocalColumns());
69
-
70
-                $name .= 'By'.implode('And', $camelizedColumns);
71
-            }
72
-        } else {
73
-            $column = $this->foreignKey->getLocalColumns()[0];
74
-            // Let's remove any _id or id_.
75
-            if (strpos(strtolower($column), "id_") === 0) {
76
-                $column = substr($column, 3);
77
-            }
78
-            if (strrpos(strtolower($column), "_id") === strlen($column)-3) {
79
-                $column = substr($column, 0, strlen($column)-3);
80
-            }
81
-            $name = TDBMDaoGenerator::toCamelCase($column);
82
-            if ($this->alternativeName) {
83
-                $name .= 'Object';
84
-            }
85
-        }
86
-        return $name;
87
-    }
88
-
89
-    /**
90
-     * Returns true if the property is compulsory (and therefore should be fetched in the constructor).
91
-     * @return bool
92
-     */
93
-    public function isCompulsory() {
94
-        // Are all columns nullable?
95
-        $localColumnNames = $this->foreignKey->getLocalColumns();
96
-
97
-        foreach ($localColumnNames as $name) {
98
-            $column = $this->table->getColumn($name);
99
-            if ($column->getNotnull()) {
100
-                return true;
101
-            }
102
-        }
103
-
104
-        return false;
105
-    }
106
-
107
-    /**
108
-     * Returns true if the property is the primary key
109
-     * @return bool
110
-     */
111
-    public function isPrimaryKey() {
112
-        $fkColumns = $this->foreignKey->getLocalColumns();
113
-        sort($fkColumns);
114
-
115
-        $pkColumns = $this->table->getPrimaryKeyColumns();
116
-        sort($pkColumns);
117
-
118
-        return $fkColumns == $pkColumns;
119
-    }
120
-
121
-    /**
122
-     * Returns the PHP code for getters and setters
123
-     * @return string
124
-     */
125
-    public function getGetterSetterCode() {
126
-        $tableName = $this->table->getName();
127
-        $getterName = $this->getGetterName();
128
-        $setterName = $this->getSetterName();
129
-
130
-        $referencedBeanName = TDBMDaoGenerator::getBeanNameFromTableName($this->foreignKey->getForeignTableName());
131
-
132
-        $str = '    /**
17
+	/**
18
+	 * @var ForeignKeyConstraint
19
+	 */
20
+	private $foreignKey;
21
+
22
+	/**
23
+	 * @var SchemaAnalyzer
24
+	 */
25
+	private $schemaAnalyzer;
26
+
27
+	public function __construct(Table $table, ForeignKeyConstraint $foreignKey, SchemaAnalyzer $schemaAnalyzer) {
28
+		parent::__construct($table);
29
+		$this->foreignKey = $foreignKey;
30
+		$this->schemaAnalyzer = $schemaAnalyzer;
31
+	}
32
+
33
+
34
+
35
+	/**
36
+	 * Returns the foreignkey the column is part of, if any. null otherwise.
37
+	 *
38
+	 * @return ForeignKeyConstraint|null
39
+	 */
40
+	public function getForeignKey() {
41
+		return $this->foreignKey;
42
+	}
43
+
44
+	/**
45
+	 * Returns the name of the class linked to this property or null if this is not a foreign key
46
+	 * @return null|string
47
+	 */
48
+	public function getClassName() {
49
+		return TDBMDaoGenerator::getBeanNameFromTableName($this->foreignKey->getForeignTableName());
50
+	}
51
+
52
+	/**
53
+	 * Returns the param annotation for this property (useful for constructor).
54
+	 *
55
+	 * @return string
56
+	 */
57
+	public function getParamAnnotation() {
58
+		$str = "     * @param %s %s";
59
+		return sprintf($str, $this->getClassName(), $this->getVariableName());
60
+	}
61
+
62
+	public function getUpperCamelCaseName() {
63
+		// First, are there many column or only one?
64
+		// If one column, we name the setter after it. Otherwise, we name the setter after the table name
65
+		if (count($this->foreignKey->getLocalColumns()) > 1) {
66
+			$name = TDBMDaoGenerator::toSingular(TDBMDaoGenerator::toCamelCase($this->foreignKey->getForeignTableName()));
67
+			if ($this->alternativeName) {
68
+				$camelizedColumns = array_map(['Mouf\\Database\\TDBM\\Utils\\TDBMDaoGenerator', 'toCamelCase'], $this->foreignKey->getLocalColumns());
69
+
70
+				$name .= 'By'.implode('And', $camelizedColumns);
71
+			}
72
+		} else {
73
+			$column = $this->foreignKey->getLocalColumns()[0];
74
+			// Let's remove any _id or id_.
75
+			if (strpos(strtolower($column), "id_") === 0) {
76
+				$column = substr($column, 3);
77
+			}
78
+			if (strrpos(strtolower($column), "_id") === strlen($column)-3) {
79
+				$column = substr($column, 0, strlen($column)-3);
80
+			}
81
+			$name = TDBMDaoGenerator::toCamelCase($column);
82
+			if ($this->alternativeName) {
83
+				$name .= 'Object';
84
+			}
85
+		}
86
+		return $name;
87
+	}
88
+
89
+	/**
90
+	 * Returns true if the property is compulsory (and therefore should be fetched in the constructor).
91
+	 * @return bool
92
+	 */
93
+	public function isCompulsory() {
94
+		// Are all columns nullable?
95
+		$localColumnNames = $this->foreignKey->getLocalColumns();
96
+
97
+		foreach ($localColumnNames as $name) {
98
+			$column = $this->table->getColumn($name);
99
+			if ($column->getNotnull()) {
100
+				return true;
101
+			}
102
+		}
103
+
104
+		return false;
105
+	}
106
+
107
+	/**
108
+	 * Returns true if the property is the primary key
109
+	 * @return bool
110
+	 */
111
+	public function isPrimaryKey() {
112
+		$fkColumns = $this->foreignKey->getLocalColumns();
113
+		sort($fkColumns);
114
+
115
+		$pkColumns = $this->table->getPrimaryKeyColumns();
116
+		sort($pkColumns);
117
+
118
+		return $fkColumns == $pkColumns;
119
+	}
120
+
121
+	/**
122
+	 * Returns the PHP code for getters and setters
123
+	 * @return string
124
+	 */
125
+	public function getGetterSetterCode() {
126
+		$tableName = $this->table->getName();
127
+		$getterName = $this->getGetterName();
128
+		$setterName = $this->getSetterName();
129
+
130
+		$referencedBeanName = TDBMDaoGenerator::getBeanNameFromTableName($this->foreignKey->getForeignTableName());
131
+
132
+		$str = '    /**
133 133
      * Returns the '.$referencedBeanName.' object bound to this object via the '.implode(" and ", $this->foreignKey->getLocalColumns()).' column.
134 134
      *
135 135
      * @return '.$referencedBeanName.'
@@ -148,19 +148,19 @@  discard block
 block discarded – undo
148 148
     }
149 149
 
150 150
 ';
151
-        return $str;
152
-    }
153
-
154
-    /**
155
-     * Returns the part of code useful when doing json serialization.
156
-     *
157
-     * @return string
158
-     */
159
-    public function getJsonSerializeCode()
160
-    {
161
-        return '        if (!$stopRecursion) {
151
+		return $str;
152
+	}
153
+
154
+	/**
155
+	 * Returns the part of code useful when doing json serialization.
156
+	 *
157
+	 * @return string
158
+	 */
159
+	public function getJsonSerializeCode()
160
+	{
161
+		return '        if (!$stopRecursion) {
162 162
             $array['.var_export($this->getLowerCamelCaseName(), true).'] = $this->'.$this->getGetterName().'()->jsonSerialize(true);
163 163
         }
164 164
 ';
165
-    }
165
+	}
166 166
 }
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/Utils/ScalarBeanPropertyDescriptor.php 1 patch
Indentation   +118 added lines, -118 removed lines patch added patch discarded remove patch
@@ -12,88 +12,88 @@  discard block
 block discarded – undo
12 12
  */
13 13
 class ScalarBeanPropertyDescriptor extends AbstractBeanPropertyDescriptor
14 14
 {
15
-    /**
16
-     * @var Column
17
-     */
18
-    private $column;
19
-
20
-
21
-    public function __construct(Table $table, Column $column) {
22
-        parent::__construct($table);
23
-        $this->table = $table;
24
-        $this->column = $column;
25
-    }
26
-
27
-    /**
28
-     * Returns the foreignkey the column is part of, if any. null otherwise.
29
-     *
30
-     * @param Column $column
31
-     * @return ForeignKeyConstraint|null
32
-     */
33
-    public function getForeignKey() {
34
-        return false;
35
-    }
36
-
37
-    /**
38
-     * Returns the param annotation for this property (useful for constructor).
39
-     *
40
-     * @return string
41
-     */
42
-    public function getParamAnnotation() {
43
-        $className = $this->getClassName();
44
-        $paramType = $className ?: TDBMDaoGenerator::dbalTypeToPhpType($this->column->getType());
45
-
46
-        $str = "     * @param %s %s";
47
-        return sprintf($str, $paramType, $this->getVariableName());
48
-    }
49
-
50
-    public function getUpperCamelCaseName() {
51
-        return TDBMDaoGenerator::toCamelCase($this->column->getName());
52
-    }
53
-
54
-    /**
55
-     * Returns the name of the class linked to this property or null if this is not a foreign key
56
-     * @return null|string
57
-     */
58
-    public function getClassName() {
59
-        return null;
60
-    }
61
-
62
-    /**
63
-     * Returns true if the property is compulsory (and therefore should be fetched in the constructor).
64
-     * @return bool
65
-     */
66
-    public function isCompulsory() {
67
-        return $this->column->getNotnull() && !$this->column->getAutoincrement();
68
-    }
69
-
70
-    /**
71
-     * Returns true if the property is the primary key
72
-     * @return bool
73
-     */
74
-    public function isPrimaryKey() {
75
-        return in_array($this->column->getName(), $this->table->getPrimaryKeyColumns());
76
-    }
77
-
78
-    /**
79
-     * Returns the PHP code for getters and setters
80
-     * @return string
81
-     */
82
-    public function getGetterSetterCode() {
83
-
84
-        $type = $this->column->getType();
85
-        $normalizedType = TDBMDaoGenerator::dbalTypeToPhpType($type);
86
-
87
-        $columnGetterName = $this->getGetterName();
88
-        $columnSetterName = $this->getSetterName();
89
-
90
-        if ($normalizedType == "\\DateTimeInterface") {
91
-            $castTo = "\\DateTimeInterface ";
92
-        } else {
93
-            $castTo = "";
94
-        }
95
-
96
-        $getterAndSetterCode = '    /**
15
+	/**
16
+	 * @var Column
17
+	 */
18
+	private $column;
19
+
20
+
21
+	public function __construct(Table $table, Column $column) {
22
+		parent::__construct($table);
23
+		$this->table = $table;
24
+		$this->column = $column;
25
+	}
26
+
27
+	/**
28
+	 * Returns the foreignkey the column is part of, if any. null otherwise.
29
+	 *
30
+	 * @param Column $column
31
+	 * @return ForeignKeyConstraint|null
32
+	 */
33
+	public function getForeignKey() {
34
+		return false;
35
+	}
36
+
37
+	/**
38
+	 * Returns the param annotation for this property (useful for constructor).
39
+	 *
40
+	 * @return string
41
+	 */
42
+	public function getParamAnnotation() {
43
+		$className = $this->getClassName();
44
+		$paramType = $className ?: TDBMDaoGenerator::dbalTypeToPhpType($this->column->getType());
45
+
46
+		$str = "     * @param %s %s";
47
+		return sprintf($str, $paramType, $this->getVariableName());
48
+	}
49
+
50
+	public function getUpperCamelCaseName() {
51
+		return TDBMDaoGenerator::toCamelCase($this->column->getName());
52
+	}
53
+
54
+	/**
55
+	 * Returns the name of the class linked to this property or null if this is not a foreign key
56
+	 * @return null|string
57
+	 */
58
+	public function getClassName() {
59
+		return null;
60
+	}
61
+
62
+	/**
63
+	 * Returns true if the property is compulsory (and therefore should be fetched in the constructor).
64
+	 * @return bool
65
+	 */
66
+	public function isCompulsory() {
67
+		return $this->column->getNotnull() && !$this->column->getAutoincrement();
68
+	}
69
+
70
+	/**
71
+	 * Returns true if the property is the primary key
72
+	 * @return bool
73
+	 */
74
+	public function isPrimaryKey() {
75
+		return in_array($this->column->getName(), $this->table->getPrimaryKeyColumns());
76
+	}
77
+
78
+	/**
79
+	 * Returns the PHP code for getters and setters
80
+	 * @return string
81
+	 */
82
+	public function getGetterSetterCode() {
83
+
84
+		$type = $this->column->getType();
85
+		$normalizedType = TDBMDaoGenerator::dbalTypeToPhpType($type);
86
+
87
+		$columnGetterName = $this->getGetterName();
88
+		$columnSetterName = $this->getSetterName();
89
+
90
+		if ($normalizedType == "\\DateTimeInterface") {
91
+			$castTo = "\\DateTimeInterface ";
92
+		} else {
93
+			$castTo = "";
94
+		}
95
+
96
+		$getterAndSetterCode = '    /**
97 97
      * The getter for the "%s" column.
98 98
      *
99 99
      * @return %s
@@ -112,40 +112,40 @@  discard block
 block discarded – undo
112 112
     }
113 113
 
114 114
 ';
115
-        return sprintf($getterAndSetterCode,
116
-            // Getter
117
-            $this->column->getName(),
118
-            $normalizedType,
119
-            $columnGetterName,
120
-            var_export($this->column->getName(), true),
121
-            var_export($this->table->getName(), true),
122
-            // Setter
123
-            $this->column->getName(),
124
-            $normalizedType,
125
-            $this->column->getName(),
126
-            $columnSetterName,
127
-            $castTo,
128
-            $this->column->getName(),
129
-            var_export($this->column->getName(), true),
130
-            $this->column->getName(),
131
-            var_export($this->table->getName(), true)
132
-        );
133
-    }
134
-
135
-    /**
136
-     * Returns the part of code useful when doing json serialization.
137
-     *
138
-     * @return string
139
-     */
140
-    public function getJsonSerializeCode()
141
-    {
142
-        $type = $this->column->getType();
143
-        $normalizedType = TDBMDaoGenerator::dbalTypeToPhpType($type);
144
-
145
-        if ($normalizedType == "\\DateTimeInterface") {
146
-            return '        $array['.var_export($this->getLowerCamelCaseName(), true).'] = $this->'.$this->getGetterName()."()->format('c');\n";
147
-        } else {
148
-            return '        $array['.var_export($this->getLowerCamelCaseName(), true).'] = $this->'.$this->getGetterName()."();\n";
149
-        }
150
-    }
115
+		return sprintf($getterAndSetterCode,
116
+			// Getter
117
+			$this->column->getName(),
118
+			$normalizedType,
119
+			$columnGetterName,
120
+			var_export($this->column->getName(), true),
121
+			var_export($this->table->getName(), true),
122
+			// Setter
123
+			$this->column->getName(),
124
+			$normalizedType,
125
+			$this->column->getName(),
126
+			$columnSetterName,
127
+			$castTo,
128
+			$this->column->getName(),
129
+			var_export($this->column->getName(), true),
130
+			$this->column->getName(),
131
+			var_export($this->table->getName(), true)
132
+		);
133
+	}
134
+
135
+	/**
136
+	 * Returns the part of code useful when doing json serialization.
137
+	 *
138
+	 * @return string
139
+	 */
140
+	public function getJsonSerializeCode()
141
+	{
142
+		$type = $this->column->getType();
143
+		$normalizedType = TDBMDaoGenerator::dbalTypeToPhpType($type);
144
+
145
+		if ($normalizedType == "\\DateTimeInterface") {
146
+			return '        $array['.var_export($this->getLowerCamelCaseName(), true).'] = $this->'.$this->getGetterName()."()->format('c');\n";
147
+		} else {
148
+			return '        $array['.var_export($this->getLowerCamelCaseName(), true).'] = $this->'.$this->getGetterName()."();\n";
149
+		}
150
+	}
151 151
 }
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/Utils/AbstractBeanPropertyDescriptor.php 1 patch
Indentation   +100 added lines, -100 removed lines patch added patch discarded remove patch
@@ -13,104 +13,104 @@
 block discarded – undo
13 13
 abstract class AbstractBeanPropertyDescriptor
14 14
 {
15 15
 
16
-    /**
17
-     * @var Table
18
-     */
19
-    protected $table;
20
-
21
-    /**
22
-     * Whether to use the more complex name in case of conflict.
23
-     * @var bool
24
-     */
25
-    protected $alternativeName = false;
26
-
27
-    /**
28
-     * @param Table $table
29
-     */
30
-    public function __construct(Table $table)
31
-    {
32
-        $this->table = $table;
33
-    }
34
-
35
-
36
-    /**
37
-     * Use the more complex name in case of conflict.
38
-     */
39
-    public function useAlternativeName()
40
-    {
41
-        $this->alternativeName = true;
42
-    }
43
-
44
-    /**
45
-     * Returns the name of the class linked to this property or null if this is not a foreign key
46
-     * @return null|string
47
-     */
48
-    abstract public function getClassName();
49
-
50
-    /**
51
-     * Returns the param annotation for this property (useful for constructor).
52
-     *
53
-     * @return string
54
-     */
55
-    abstract public function getParamAnnotation();
56
-
57
-    public function getVariableName() {
58
-        return '$'.$this->getLowerCamelCaseName();
59
-    }
60
-
61
-    public function getLowerCamelCaseName() {
62
-        return TDBMDaoGenerator::toVariableName($this->getUpperCamelCaseName());
63
-    }
64
-
65
-    abstract public function getUpperCamelCaseName();
66
-
67
-    public function getSetterName() {
68
-        return 'set'.$this->getUpperCamelCaseName();
69
-    }
70
-
71
-    public function getGetterName() {
72
-        return 'get'.$this->getUpperCamelCaseName();
73
-    }
74
-
75
-    /**
76
-     * Returns the PHP code used in the ben constructor for this property.
77
-     * @return string
78
-     */
79
-    public function getConstructorAssignCode() {
80
-        $str = '        $this->%s(%s);';
81
-        return sprintf($str, $this->getSetterName(), $this->getVariableName());
82
-    }
83
-
84
-    /**
85
-     * Returns true if the property is compulsory (and therefore should be fetched in the constructor).
86
-     * @return bool
87
-     */
88
-    abstract public function isCompulsory();
89
-
90
-    /**
91
-     * Returns true if the property is the primary key
92
-     * @return bool
93
-     */
94
-    abstract public function isPrimaryKey();
95
-
96
-    /**
97
-     * @return Table
98
-     */
99
-    public function getTable()
100
-    {
101
-        return $this->table;
102
-    }
103
-
104
-    /**
105
-     * Returns the PHP code for getters and setters
106
-     * @return string
107
-     */
108
-    abstract public function getGetterSetterCode();
109
-
110
-    /**
111
-     * Returns the part of code useful when doing json serialization.
112
-     *
113
-     * @return string
114
-     */
115
-    abstract public function getJsonSerializeCode();
16
+	/**
17
+	 * @var Table
18
+	 */
19
+	protected $table;
20
+
21
+	/**
22
+	 * Whether to use the more complex name in case of conflict.
23
+	 * @var bool
24
+	 */
25
+	protected $alternativeName = false;
26
+
27
+	/**
28
+	 * @param Table $table
29
+	 */
30
+	public function __construct(Table $table)
31
+	{
32
+		$this->table = $table;
33
+	}
34
+
35
+
36
+	/**
37
+	 * Use the more complex name in case of conflict.
38
+	 */
39
+	public function useAlternativeName()
40
+	{
41
+		$this->alternativeName = true;
42
+	}
43
+
44
+	/**
45
+	 * Returns the name of the class linked to this property or null if this is not a foreign key
46
+	 * @return null|string
47
+	 */
48
+	abstract public function getClassName();
49
+
50
+	/**
51
+	 * Returns the param annotation for this property (useful for constructor).
52
+	 *
53
+	 * @return string
54
+	 */
55
+	abstract public function getParamAnnotation();
56
+
57
+	public function getVariableName() {
58
+		return '$'.$this->getLowerCamelCaseName();
59
+	}
60
+
61
+	public function getLowerCamelCaseName() {
62
+		return TDBMDaoGenerator::toVariableName($this->getUpperCamelCaseName());
63
+	}
64
+
65
+	abstract public function getUpperCamelCaseName();
66
+
67
+	public function getSetterName() {
68
+		return 'set'.$this->getUpperCamelCaseName();
69
+	}
70
+
71
+	public function getGetterName() {
72
+		return 'get'.$this->getUpperCamelCaseName();
73
+	}
74
+
75
+	/**
76
+	 * Returns the PHP code used in the ben constructor for this property.
77
+	 * @return string
78
+	 */
79
+	public function getConstructorAssignCode() {
80
+		$str = '        $this->%s(%s);';
81
+		return sprintf($str, $this->getSetterName(), $this->getVariableName());
82
+	}
83
+
84
+	/**
85
+	 * Returns true if the property is compulsory (and therefore should be fetched in the constructor).
86
+	 * @return bool
87
+	 */
88
+	abstract public function isCompulsory();
89
+
90
+	/**
91
+	 * Returns true if the property is the primary key
92
+	 * @return bool
93
+	 */
94
+	abstract public function isPrimaryKey();
95
+
96
+	/**
97
+	 * @return Table
98
+	 */
99
+	public function getTable()
100
+	{
101
+		return $this->table;
102
+	}
103
+
104
+	/**
105
+	 * Returns the PHP code for getters and setters
106
+	 * @return string
107
+	 */
108
+	abstract public function getGetterSetterCode();
109
+
110
+	/**
111
+	 * Returns the part of code useful when doing json serialization.
112
+	 *
113
+	 * @return string
114
+	 */
115
+	abstract public function getJsonSerializeCode();
116 116
 }
117 117
\ No newline at end of file
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/AbstractTDBMObject.php 2 patches
Indentation   +6 added lines, -6 removed lines patch added patch discarded remove patch
@@ -537,10 +537,10 @@  discard block
 block discarded – undo
537 537
 		return $sql_where;
538 538
 	}
539 539
 
540
-    /**
541
-     * Override the native php clone function for TDBMObjects
542
-     */
543
-    public function __clone() {
540
+	/**
541
+	 * Override the native php clone function for TDBMObjects
542
+	 */
543
+	public function __clone() {
544 544
 		// Let's clone the many to many relationships
545 545
 		if ($this->status === TDBMObjectStateEnum::STATE_DETACHED) {
546 546
 			$pivotTableList = array_keys($this->relationships);
@@ -566,10 +566,10 @@  discard block
 block discarded – undo
566 566
 		}
567 567
 
568 568
 		// Let's set the status to new (to enter the save function)
569
-        $this->status = TDBMObjectStateEnum::STATE_DETACHED;
569
+		$this->status = TDBMObjectStateEnum::STATE_DETACHED;
570 570
 
571 571
 
572
-    }
572
+	}
573 573
 
574 574
 	/**
575 575
 	 * Returns raw database rows.
Please login to merge, or discard this patch.
Spacing   +11 added lines, -11 removed lines patch added patch discarded remove patch
@@ -75,7 +75,7 @@  discard block
 block discarded – undo
75 75
 	 * @throws TDBMException
76 76
 	 * @throws TDBMInvalidOperationException
77 77
 	 */
78
-	public function __construct($tableName=null, array $primaryKeys=array(), TDBMService $tdbmService=null) {
78
+	public function __construct($tableName = null, array $primaryKeys = array(), TDBMService $tdbmService = null) {
79 79
 		// FIXME: lazy loading should be forbidden on tables with inheritance and dynamic type assignation...
80 80
 		if (!empty($tableName)) {
81 81
 			$this->dbRows[$tableName] = new DbRow($this, $tableName, $primaryKeys, $tdbmService);
@@ -159,7 +159,7 @@  discard block
 block discarded – undo
159 159
 	 * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
160 160
 	 * @param string $state
161 161
 	 */
162
-	public function _setStatus($state){
162
+	public function _setStatus($state) {
163 163
 		$this->status = $state;
164 164
 
165 165
 		// TODO: we might ignore the loaded => dirty state here! dirty status comes from the db_row itself.
@@ -170,7 +170,7 @@  discard block
 block discarded – undo
170 170
 
171 171
 	public function get($var, $tableName = null) {
172 172
 		if ($tableName === null) {
173
-			if (count($this->dbRows) > 1) {
173
+			if (count($this->dbRows)>1) {
174 174
 				throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
175 175
 			} elseif (count($this->dbRows) === 1) {
176 176
 				$tableName = array_keys($this->dbRows)[0];
@@ -196,7 +196,7 @@  discard block
 block discarded – undo
196 196
 	 */
197 197
 	public function has($var, $tableName = null) {
198 198
 		if ($tableName === null) {
199
-			if (count($this->dbRows) > 1) {
199
+			if (count($this->dbRows)>1) {
200 200
 				throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
201 201
 			} elseif (count($this->dbRows) === 1) {
202 202
 				$tableName = array_keys($this->dbRows)[0];
@@ -216,7 +216,7 @@  discard block
 block discarded – undo
216 216
 	
217 217
 	public function set($var, $value, $tableName = null) {
218 218
 		if ($tableName === null) {
219
-			if (count($this->dbRows) > 1) {
219
+			if (count($this->dbRows)>1) {
220 220
 				throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
221 221
 			} elseif (count($this->dbRows) === 1) {
222 222
 				$tableName = array_keys($this->dbRows)[0];
@@ -241,7 +241,7 @@  discard block
 block discarded – undo
241 241
 	 */
242 242
 	public function setRef($foreignKeyName, AbstractTDBMObject $bean, $tableName = null) {
243 243
 		if ($tableName === null) {
244
-			if (count($this->dbRows) > 1) {
244
+			if (count($this->dbRows)>1) {
245 245
 				throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
246 246
 			} elseif (count($this->dbRows) === 1) {
247 247
 				$tableName = array_keys($this->dbRows)[0];
@@ -266,7 +266,7 @@  discard block
 block discarded – undo
266 266
 	 */
267 267
 	public function getRef($foreignKeyName, $tableName = null) {
268 268
 		if ($tableName === null) {
269
-			if (count($this->dbRows) > 1) {
269
+			if (count($this->dbRows)>1) {
270 270
 				throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
271 271
 			} elseif (count($this->dbRows) === 1) {
272 272
 				$tableName = array_keys($this->dbRows)[0];
@@ -382,13 +382,13 @@  discard block
 block discarded – undo
382 382
 	 */
383 383
 	private function setRelationship($pivotTableName, AbstractTDBMObject $remoteBean, $status) {
384 384
 		$storage = $this->getRelationshipStorage($pivotTableName);
385
-		$storage->attach($remoteBean, [ 'status' => $status, 'reverse' => false ]);
385
+		$storage->attach($remoteBean, ['status' => $status, 'reverse' => false]);
386 386
 		if ($this->status === TDBMObjectStateEnum::STATE_LOADED) {
387 387
 			$this->_setStatus(TDBMObjectStateEnum::STATE_DIRTY);
388 388
 		}
389 389
 
390 390
 		$remoteStorage = $remoteBean->getRelationshipStorage($pivotTableName);
391
-		$remoteStorage->attach($this, [ 'status' => $status, 'reverse' => true ]);
391
+		$remoteStorage->attach($this, ['status' => $status, 'reverse' => true]);
392 392
 	}
393 393
 
394 394
 	/**
@@ -458,7 +458,7 @@  discard block
 block discarded – undo
458 458
 				$metadata = $storage[$remoteBean];
459 459
 
460 460
 				$remoteStorage = $remoteBean->getRelationshipStorage($pivotTable);
461
-				$remoteStorage->attach($this, [ 'status' => $metadata['status'], 'reverse' => !$metadata['reverse'] ]);
461
+				$remoteStorage->attach($this, ['status' => $metadata['status'], 'reverse' => !$metadata['reverse']]);
462 462
 			}
463 463
 		}
464 464
 
@@ -485,7 +485,7 @@  discard block
 block discarded – undo
485 485
 	private function registerTable($tableName) {
486 486
 		$dbRow = new DbRow($this, $tableName);
487 487
 
488
-		if (in_array($this->status, [ TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DIRTY ])) {
488
+		if (in_array($this->status, [TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DIRTY])) {
489 489
 			// Let's get the primary key for the new table
490 490
 			$anotherDbRow = array_values($this->dbRows)[0];
491 491
 			/* @var $anotherDbRow DbRow */
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/Utils/BeanDescriptor.php 1 patch
Indentation   +415 added lines, -415 removed lines patch added patch discarded remove patch
@@ -16,206 +16,206 @@  discard block
 block discarded – undo
16 16
  */
17 17
 class BeanDescriptor
18 18
 {
19
-    /**
20
-     * @var Table
21
-     */
22
-    private $table;
23
-
24
-    /**
25
-     * @var SchemaAnalyzer
26
-     */
27
-    private $schemaAnalyzer;
28
-
29
-    /**
30
-     * @var Schema
31
-     */
32
-    private $schema;
33
-
34
-    /**
35
-     * @var AbstractBeanPropertyDescriptor[]
36
-     */
37
-    private $beanPropertyDescriptors = [];
38
-
39
-    /**
40
-     * @var TDBMSchemaAnalyzer
41
-     */
42
-    private $tdbmSchemaAnalyzer;
43
-
44
-    public function __construct(Table $table, SchemaAnalyzer $schemaAnalyzer, Schema $schema, TDBMSchemaAnalyzer $tdbmSchemaAnalyzer) {
45
-        $this->table = $table;
46
-        $this->schemaAnalyzer = $schemaAnalyzer;
47
-        $this->schema = $schema;
48
-        $this->tdbmSchemaAnalyzer = $tdbmSchemaAnalyzer;
49
-        $this->initBeanPropertyDescriptors();
50
-    }
51
-
52
-    private function initBeanPropertyDescriptors() {
53
-        $this->beanPropertyDescriptors = $this->getProperties($this->table);
54
-    }
55
-
56
-    /**
57
-     * Returns the foreignkey the column is part of, if any. null otherwise.
58
-     *
59
-     * @param Table $table
60
-     * @param Column $column
61
-     * @return ForeignKeyConstraint|null
62
-     */
63
-    private function isPartOfForeignKey(Table $table, Column $column) {
64
-        $localColumnName = $column->getName();
65
-        foreach ($table->getForeignKeys() as $foreignKey) {
66
-            foreach ($foreignKey->getColumns() as $columnName) {
67
-                if ($columnName === $localColumnName) {
68
-                    return $foreignKey;
69
-                }
70
-            }
71
-        }
72
-        return null;
73
-    }
74
-
75
-    /**
76
-     * @return AbstractBeanPropertyDescriptor[]
77
-     */
78
-    public function getBeanPropertyDescriptors()
79
-    {
80
-        return $this->beanPropertyDescriptors;
81
-    }
82
-
83
-    /**
84
-     * Returns the list of columns that are not nullable and not autogenerated for a given table and its parent.
85
-     *
86
-     * @return AbstractBeanPropertyDescriptor[]
87
-     */
88
-    public function getConstructorProperties() {
89
-
90
-        $constructorProperties = array_filter($this->beanPropertyDescriptors, function(AbstractBeanPropertyDescriptor $property) {
91
-           return $property->isCompulsory();
92
-        });
93
-
94
-        return $constructorProperties;
95
-    }
96
-
97
-    /**
98
-     * Returns the list of properties exposed as getters and setters in this class.
99
-     *
100
-     * @return AbstractBeanPropertyDescriptor[]
101
-     */
102
-    public function getExposedProperties() {
103
-        $exposedProperties = array_filter($this->beanPropertyDescriptors, function(AbstractBeanPropertyDescriptor $property) {
104
-            return $property->getTable()->getName() == $this->table->getName();
105
-        });
106
-
107
-        return $exposedProperties;
108
-    }
109
-
110
-    /**
111
-     * Returns the list of properties for this table (including parent tables).
112
-     *
113
-     * @param Table $table
114
-     * @return AbstractBeanPropertyDescriptor[]
115
-     */
116
-    private function getProperties(Table $table)
117
-    {
118
-        $parentRelationship = $this->schemaAnalyzer->getParentRelationship($table->getName());
119
-        if ($parentRelationship) {
120
-            $parentTable = $this->schema->getTable($parentRelationship->getForeignTableName());
121
-            $properties = $this->getProperties($parentTable);
122
-            // we merge properties by overriding property names.
123
-            $localProperties = $this->getPropertiesForTable($table);
124
-            foreach ($localProperties as $name => $property) {
125
-                // We do not override properties if this is a primary key!
126
-                if ($property->isPrimaryKey()) {
127
-                    continue;
128
-                }
129
-                $properties[$name] = $property;
130
-            }
131
-            //$properties = array_merge($properties, $localProperties);
132
-
133
-        } else {
134
-            $properties = $this->getPropertiesForTable($table);
135
-        }
136
-
137
-        return $properties;
138
-    }
139
-
140
-        /**
141
-     * Returns the list of properties for this table (ignoring parent tables).
142
-     *
143
-     * @param Table $table
144
-     * @return AbstractBeanPropertyDescriptor[]
145
-     */
146
-    private function getPropertiesForTable(Table $table)
147
-    {
148
-        $parentRelationship = $this->schemaAnalyzer->getParentRelationship($table->getName());
149
-        if ($parentRelationship) {
150
-            $ignoreColumns = $parentRelationship->getLocalColumns();
151
-        } else {
152
-            $ignoreColumns = [];
153
-        }
154
-
155
-        $beanPropertyDescriptors = [];
156
-
157
-        foreach ($table->getColumns() as $column) {
158
-            if (array_search($column->getName(), $ignoreColumns) !== false) {
159
-                continue;
160
-            }
161
-
162
-            $fk = $this->isPartOfForeignKey($table, $column);
163
-            if ($fk !== null) {
164
-                // Check that previously added descriptors are not added on same FK (can happen with multi key FK).
165
-                foreach ($beanPropertyDescriptors as $beanDescriptor) {
166
-                    if ($beanDescriptor instanceof ObjectBeanPropertyDescriptor && $beanDescriptor->getForeignKey() === $fk) {
167
-                        continue 2;
168
-                    }
169
-                }
170
-                // Check that this property is not an inheritance relationship
171
-                $parentRelationship = $this->schemaAnalyzer->getParentRelationship($table->getName());
172
-                if ($parentRelationship === $fk) {
173
-                    continue;
174
-                }
175
-
176
-                $beanPropertyDescriptors[] = new ObjectBeanPropertyDescriptor($table, $fk, $this->schemaAnalyzer);
177
-            } else {
178
-                $beanPropertyDescriptors[] = new ScalarBeanPropertyDescriptor($table, $column);
179
-            }
180
-        }
181
-
182
-        // Now, let's get the name of all properties and let's check there is no duplicate.
183
-        /** @var $names AbstractBeanPropertyDescriptor[] */
184
-        $names = [];
185
-        foreach ($beanPropertyDescriptors as $beanDescriptor) {
186
-            $name = $beanDescriptor->getUpperCamelCaseName();
187
-            if (isset($names[$name])) {
188
-                $names[$name]->useAlternativeName();
189
-                $beanDescriptor->useAlternativeName();
190
-            } else {
191
-                $names[$name] = $beanDescriptor;
192
-            }
193
-        }
194
-
195
-        // Final check (throw exceptions if problem arises)
196
-        $names = [];
197
-        foreach ($beanPropertyDescriptors as $beanDescriptor) {
198
-            $name = $beanDescriptor->getUpperCamelCaseName();
199
-            if (isset($names[$name])) {
200
-                throw new TDBMException("Unsolvable name conflict while generating method name");
201
-            } else {
202
-                $names[$name] = $beanDescriptor;
203
-            }
204
-        }
205
-
206
-        // Last step, let's rebuild the list with a map:
207
-        $beanPropertyDescriptorsMap = [];
208
-        foreach ($beanPropertyDescriptors as $beanDescriptor) {
209
-            $beanPropertyDescriptorsMap[$beanDescriptor->getLowerCamelCaseName()] = $beanDescriptor;
210
-        }
211
-
212
-        return $beanPropertyDescriptorsMap;
213
-    }
214
-
215
-    public function generateBeanConstructor() {
216
-        $constructorProperties = $this->getConstructorProperties();
217
-
218
-        $constructorCode = "    /**
19
+	/**
20
+	 * @var Table
21
+	 */
22
+	private $table;
23
+
24
+	/**
25
+	 * @var SchemaAnalyzer
26
+	 */
27
+	private $schemaAnalyzer;
28
+
29
+	/**
30
+	 * @var Schema
31
+	 */
32
+	private $schema;
33
+
34
+	/**
35
+	 * @var AbstractBeanPropertyDescriptor[]
36
+	 */
37
+	private $beanPropertyDescriptors = [];
38
+
39
+	/**
40
+	 * @var TDBMSchemaAnalyzer
41
+	 */
42
+	private $tdbmSchemaAnalyzer;
43
+
44
+	public function __construct(Table $table, SchemaAnalyzer $schemaAnalyzer, Schema $schema, TDBMSchemaAnalyzer $tdbmSchemaAnalyzer) {
45
+		$this->table = $table;
46
+		$this->schemaAnalyzer = $schemaAnalyzer;
47
+		$this->schema = $schema;
48
+		$this->tdbmSchemaAnalyzer = $tdbmSchemaAnalyzer;
49
+		$this->initBeanPropertyDescriptors();
50
+	}
51
+
52
+	private function initBeanPropertyDescriptors() {
53
+		$this->beanPropertyDescriptors = $this->getProperties($this->table);
54
+	}
55
+
56
+	/**
57
+	 * Returns the foreignkey the column is part of, if any. null otherwise.
58
+	 *
59
+	 * @param Table $table
60
+	 * @param Column $column
61
+	 * @return ForeignKeyConstraint|null
62
+	 */
63
+	private function isPartOfForeignKey(Table $table, Column $column) {
64
+		$localColumnName = $column->getName();
65
+		foreach ($table->getForeignKeys() as $foreignKey) {
66
+			foreach ($foreignKey->getColumns() as $columnName) {
67
+				if ($columnName === $localColumnName) {
68
+					return $foreignKey;
69
+				}
70
+			}
71
+		}
72
+		return null;
73
+	}
74
+
75
+	/**
76
+	 * @return AbstractBeanPropertyDescriptor[]
77
+	 */
78
+	public function getBeanPropertyDescriptors()
79
+	{
80
+		return $this->beanPropertyDescriptors;
81
+	}
82
+
83
+	/**
84
+	 * Returns the list of columns that are not nullable and not autogenerated for a given table and its parent.
85
+	 *
86
+	 * @return AbstractBeanPropertyDescriptor[]
87
+	 */
88
+	public function getConstructorProperties() {
89
+
90
+		$constructorProperties = array_filter($this->beanPropertyDescriptors, function(AbstractBeanPropertyDescriptor $property) {
91
+		   return $property->isCompulsory();
92
+		});
93
+
94
+		return $constructorProperties;
95
+	}
96
+
97
+	/**
98
+	 * Returns the list of properties exposed as getters and setters in this class.
99
+	 *
100
+	 * @return AbstractBeanPropertyDescriptor[]
101
+	 */
102
+	public function getExposedProperties() {
103
+		$exposedProperties = array_filter($this->beanPropertyDescriptors, function(AbstractBeanPropertyDescriptor $property) {
104
+			return $property->getTable()->getName() == $this->table->getName();
105
+		});
106
+
107
+		return $exposedProperties;
108
+	}
109
+
110
+	/**
111
+	 * Returns the list of properties for this table (including parent tables).
112
+	 *
113
+	 * @param Table $table
114
+	 * @return AbstractBeanPropertyDescriptor[]
115
+	 */
116
+	private function getProperties(Table $table)
117
+	{
118
+		$parentRelationship = $this->schemaAnalyzer->getParentRelationship($table->getName());
119
+		if ($parentRelationship) {
120
+			$parentTable = $this->schema->getTable($parentRelationship->getForeignTableName());
121
+			$properties = $this->getProperties($parentTable);
122
+			// we merge properties by overriding property names.
123
+			$localProperties = $this->getPropertiesForTable($table);
124
+			foreach ($localProperties as $name => $property) {
125
+				// We do not override properties if this is a primary key!
126
+				if ($property->isPrimaryKey()) {
127
+					continue;
128
+				}
129
+				$properties[$name] = $property;
130
+			}
131
+			//$properties = array_merge($properties, $localProperties);
132
+
133
+		} else {
134
+			$properties = $this->getPropertiesForTable($table);
135
+		}
136
+
137
+		return $properties;
138
+	}
139
+
140
+		/**
141
+		 * Returns the list of properties for this table (ignoring parent tables).
142
+		 *
143
+		 * @param Table $table
144
+		 * @return AbstractBeanPropertyDescriptor[]
145
+		 */
146
+	private function getPropertiesForTable(Table $table)
147
+	{
148
+		$parentRelationship = $this->schemaAnalyzer->getParentRelationship($table->getName());
149
+		if ($parentRelationship) {
150
+			$ignoreColumns = $parentRelationship->getLocalColumns();
151
+		} else {
152
+			$ignoreColumns = [];
153
+		}
154
+
155
+		$beanPropertyDescriptors = [];
156
+
157
+		foreach ($table->getColumns() as $column) {
158
+			if (array_search($column->getName(), $ignoreColumns) !== false) {
159
+				continue;
160
+			}
161
+
162
+			$fk = $this->isPartOfForeignKey($table, $column);
163
+			if ($fk !== null) {
164
+				// Check that previously added descriptors are not added on same FK (can happen with multi key FK).
165
+				foreach ($beanPropertyDescriptors as $beanDescriptor) {
166
+					if ($beanDescriptor instanceof ObjectBeanPropertyDescriptor && $beanDescriptor->getForeignKey() === $fk) {
167
+						continue 2;
168
+					}
169
+				}
170
+				// Check that this property is not an inheritance relationship
171
+				$parentRelationship = $this->schemaAnalyzer->getParentRelationship($table->getName());
172
+				if ($parentRelationship === $fk) {
173
+					continue;
174
+				}
175
+
176
+				$beanPropertyDescriptors[] = new ObjectBeanPropertyDescriptor($table, $fk, $this->schemaAnalyzer);
177
+			} else {
178
+				$beanPropertyDescriptors[] = new ScalarBeanPropertyDescriptor($table, $column);
179
+			}
180
+		}
181
+
182
+		// Now, let's get the name of all properties and let's check there is no duplicate.
183
+		/** @var $names AbstractBeanPropertyDescriptor[] */
184
+		$names = [];
185
+		foreach ($beanPropertyDescriptors as $beanDescriptor) {
186
+			$name = $beanDescriptor->getUpperCamelCaseName();
187
+			if (isset($names[$name])) {
188
+				$names[$name]->useAlternativeName();
189
+				$beanDescriptor->useAlternativeName();
190
+			} else {
191
+				$names[$name] = $beanDescriptor;
192
+			}
193
+		}
194
+
195
+		// Final check (throw exceptions if problem arises)
196
+		$names = [];
197
+		foreach ($beanPropertyDescriptors as $beanDescriptor) {
198
+			$name = $beanDescriptor->getUpperCamelCaseName();
199
+			if (isset($names[$name])) {
200
+				throw new TDBMException("Unsolvable name conflict while generating method name");
201
+			} else {
202
+				$names[$name] = $beanDescriptor;
203
+			}
204
+		}
205
+
206
+		// Last step, let's rebuild the list with a map:
207
+		$beanPropertyDescriptorsMap = [];
208
+		foreach ($beanPropertyDescriptors as $beanDescriptor) {
209
+			$beanPropertyDescriptorsMap[$beanDescriptor->getLowerCamelCaseName()] = $beanDescriptor;
210
+		}
211
+
212
+		return $beanPropertyDescriptorsMap;
213
+	}
214
+
215
+	public function generateBeanConstructor() {
216
+		$constructorProperties = $this->getConstructorProperties();
217
+
218
+		$constructorCode = "    /**
219 219
      * The constructor takes all compulsory arguments.
220 220
      *
221 221
 %s
@@ -225,64 +225,64 @@  discard block
 block discarded – undo
225 225
     }
226 226
     ";
227 227
 
228
-        $paramAnnotations = [];
229
-        $arguments = [];
230
-        $assigns = [];
231
-        $parentConstructorArguments = [];
232
-
233
-        foreach ($constructorProperties as $property) {
234
-            $className = $property->getClassName();
235
-            if ($className) {
236
-                $arguments[] = $className.' '.$property->getVariableName();
237
-            } else {
238
-                $arguments[] = $property->getVariableName();
239
-            }
240
-            $paramAnnotations[] = $property->getParamAnnotation();
241
-            if ($property->getTable()->getName() === $this->table->getName()) {
242
-                $assigns[] = $property->getConstructorAssignCode();
243
-            } else {
244
-                $parentConstructorArguments[] = $property->getVariableName();
245
-            }
246
-        }
228
+		$paramAnnotations = [];
229
+		$arguments = [];
230
+		$assigns = [];
231
+		$parentConstructorArguments = [];
247 232
 
248
-        $parentConstrutorCode = sprintf("        parent::__construct(%s);\n", implode(', ', $parentConstructorArguments));
233
+		foreach ($constructorProperties as $property) {
234
+			$className = $property->getClassName();
235
+			if ($className) {
236
+				$arguments[] = $className.' '.$property->getVariableName();
237
+			} else {
238
+				$arguments[] = $property->getVariableName();
239
+			}
240
+			$paramAnnotations[] = $property->getParamAnnotation();
241
+			if ($property->getTable()->getName() === $this->table->getName()) {
242
+				$assigns[] = $property->getConstructorAssignCode();
243
+			} else {
244
+				$parentConstructorArguments[] = $property->getVariableName();
245
+			}
246
+		}
249 247
 
250
-        return sprintf($constructorCode, implode("\n", $paramAnnotations), implode(", ", $arguments), $parentConstrutorCode, implode("\n", $assigns));
251
-    }
248
+		$parentConstrutorCode = sprintf("        parent::__construct(%s);\n", implode(', ', $parentConstructorArguments));
252 249
 
253
-    public function generateDirectForeignKeysCode() {
254
-        $fks = $this->tdbmSchemaAnalyzer->getIncomingForeignKeys($this->table->getName());
250
+		return sprintf($constructorCode, implode("\n", $paramAnnotations), implode(", ", $arguments), $parentConstrutorCode, implode("\n", $assigns));
251
+	}
255 252
 
256
-        $fksByTable = [];
253
+	public function generateDirectForeignKeysCode() {
254
+		$fks = $this->tdbmSchemaAnalyzer->getIncomingForeignKeys($this->table->getName());
257 255
 
258
-        foreach ($fks as $fk) {
259
-            $fksByTable[$fk->getLocalTableName()][] = $fk;
260
-        }
256
+		$fksByTable = [];
261 257
 
262
-        /* @var $fksByMethodName ForeignKeyConstraint[] */
263
-        $fksByMethodName = [];
258
+		foreach ($fks as $fk) {
259
+			$fksByTable[$fk->getLocalTableName()][] = $fk;
260
+		}
264 261
 
265
-        foreach ($fksByTable as $tableName => $fksForTable) {
266
-            if (count($fksForTable) > 1) {
267
-                foreach ($fksForTable as $fk) {
268
-                    $methodName = 'get'.TDBMDaoGenerator::toCamelCase($fk->getLocalTableName()).'By';
262
+		/* @var $fksByMethodName ForeignKeyConstraint[] */
263
+		$fksByMethodName = [];
269 264
 
270
-                    $camelizedColumns = array_map(['Mouf\\Database\\TDBM\\Utils\\TDBMDaoGenerator', 'toCamelCase'], $fk->getLocalColumns());
265
+		foreach ($fksByTable as $tableName => $fksForTable) {
266
+			if (count($fksForTable) > 1) {
267
+				foreach ($fksForTable as $fk) {
268
+					$methodName = 'get'.TDBMDaoGenerator::toCamelCase($fk->getLocalTableName()).'By';
271 269
 
272
-                    $methodName .= implode('And', $camelizedColumns);
270
+					$camelizedColumns = array_map(['Mouf\\Database\\TDBM\\Utils\\TDBMDaoGenerator', 'toCamelCase'], $fk->getLocalColumns());
273 271
 
274
-                    $fksByMethodName[$methodName] = $fk;
275
-                }
276
-            } else {
277
-                $methodName = 'get'.TDBMDaoGenerator::toCamelCase($fksForTable[0]->getLocalTableName());
278
-                $fksByMethodName[$methodName] = $fk;
279
-            }
280
-        }
272
+					$methodName .= implode('And', $camelizedColumns);
273
+
274
+					$fksByMethodName[$methodName] = $fk;
275
+				}
276
+			} else {
277
+				$methodName = 'get'.TDBMDaoGenerator::toCamelCase($fksForTable[0]->getLocalTableName());
278
+				$fksByMethodName[$methodName] = $fk;
279
+			}
280
+		}
281 281
 
282
-        $code = '';
282
+		$code = '';
283 283
 
284
-        foreach ($fksByMethodName as $methodName => $fk) {
285
-            $getterCode = '    /**
284
+		foreach ($fksByMethodName as $methodName => $fk) {
285
+			$getterCode = '    /**
286 286
      * Returns the list of %s pointing to this bean via the %s column.
287 287
      *
288 288
      * @return %s[]|ResultIterator
@@ -294,109 +294,109 @@  discard block
 block discarded – undo
294 294
 
295 295
 ';
296 296
 
297
-            list($sql, $parametersCode) = $this->getFilters($fk);
298
-
299
-            $beanClass = TDBMDaoGenerator::getBeanNameFromTableName($fk->getLocalTableName());
300
-            $code .= sprintf($getterCode,
301
-                $beanClass,
302
-                implode(', ', $fk->getColumns()),
303
-                $beanClass,
304
-                $methodName,
305
-                var_export($fk->getLocalTableName(), true),
306
-                $sql,
307
-                $parametersCode
308
-            );
309
-        }
310
-
311
-        return $code;
312
-    }
313
-
314
-    private function getFilters(ForeignKeyConstraint $fk) {
315
-        $sqlParts = [];
316
-        $counter = 0;
317
-        $parameters = [];
318
-
319
-        $pkColumns = $this->table->getPrimaryKeyColumns();
320
-
321
-        foreach ($fk->getLocalColumns() as $columnName) {
322
-            $paramName = "tdbmparam".$counter;
323
-            $sqlParts[] = $fk->getLocalTableName().'.'.$columnName." = :".$paramName;
324
-
325
-            $pkColumn = $pkColumns[$counter];
326
-            $parameters[] = sprintf('%s => $this->get(%s, %s)', var_export($paramName, true), var_export($pkColumn, true), var_export($this->table->getName(), true));
327
-            $counter++;
328
-        }
329
-        $sql = "'".implode(' AND ', $sqlParts)."'";
330
-        $parametersCode = '[ '.implode(', ', $parameters).' ]';
331
-
332
-        return [$sql, $parametersCode];
333
-    }
334
-
335
-    /**
336
-     * Generate code section about pivot tables
337
-     *
338
-     * @return string;
339
-     */
340
-    public function generatePivotTableCode() {
341
-
342
-        $finalDescs = $this->getPivotTableDescriptors();
343
-
344
-        $code = '';
345
-
346
-        foreach ($finalDescs as $desc) {
347
-            $code .= $this->getPivotTableCode($desc['name'], $desc['table'], $desc['localFK'], $desc['remoteFK']);
348
-        }
349
-
350
-        return $code;
351
-    }
352
-
353
-    private function getPivotTableDescriptors() {
354
-        $descs = [];
355
-        foreach ($this->schemaAnalyzer->detectJunctionTables() as $table) {
356
-            // There are exactly 2 FKs since this is a pivot table.
357
-            $fks = array_values($table->getForeignKeys());
358
-
359
-            if ($fks[0]->getForeignTableName() === $this->table->getName()) {
360
-                $localFK = $fks[0];
361
-                $remoteFK = $fks[1];
362
-            } elseif ($fks[1]->getForeignTableName() === $this->table->getName()) {
363
-                $localFK = $fks[1];
364
-                $remoteFK = $fks[0];
365
-            } else {
366
-                continue;
367
-            }
368
-
369
-            $descs[$remoteFK->getForeignTableName()][] = [
370
-                'table' => $table,
371
-                'localFK' => $localFK,
372
-                'remoteFK' => $remoteFK
373
-            ];
374
-
375
-        }
376
-
377
-        $finalDescs = [];
378
-        foreach ($descs as $descArray) {
379
-            if (count($descArray) > 1) {
380
-                foreach ($descArray as $desc) {
381
-                    $desc['name'] = TDBMDaoGenerator::toCamelCase($desc['remoteFK']->getForeignTableName())."By".TDBMDaoGenerator::toCamelCase($desc['table']->getName());
382
-                    $finalDescs[] = $desc;
383
-                }
384
-            } else {
385
-                $desc = $descArray[0];
386
-                $desc['name'] = TDBMDaoGenerator::toCamelCase($desc['remoteFK']->getForeignTableName());
387
-                $finalDescs[] = $desc;
388
-            }
389
-        }
390
-
391
-        return $finalDescs;
392
-    }
393
-
394
-    public function getPivotTableCode($name, Table $table, ForeignKeyConstraint $localFK, ForeignKeyConstraint $remoteFK) {
395
-        $singularName = TDBMDaoGenerator::toSingular($name);
396
-        $remoteBeanName = TDBMDaoGenerator::getBeanNameFromTableName($remoteFK->getForeignTableName());
397
-        $variableName = '$'.TDBMDaoGenerator::toVariableName($remoteBeanName);
398
-
399
-        $str = '    /**
297
+			list($sql, $parametersCode) = $this->getFilters($fk);
298
+
299
+			$beanClass = TDBMDaoGenerator::getBeanNameFromTableName($fk->getLocalTableName());
300
+			$code .= sprintf($getterCode,
301
+				$beanClass,
302
+				implode(', ', $fk->getColumns()),
303
+				$beanClass,
304
+				$methodName,
305
+				var_export($fk->getLocalTableName(), true),
306
+				$sql,
307
+				$parametersCode
308
+			);
309
+		}
310
+
311
+		return $code;
312
+	}
313
+
314
+	private function getFilters(ForeignKeyConstraint $fk) {
315
+		$sqlParts = [];
316
+		$counter = 0;
317
+		$parameters = [];
318
+
319
+		$pkColumns = $this->table->getPrimaryKeyColumns();
320
+
321
+		foreach ($fk->getLocalColumns() as $columnName) {
322
+			$paramName = "tdbmparam".$counter;
323
+			$sqlParts[] = $fk->getLocalTableName().'.'.$columnName." = :".$paramName;
324
+
325
+			$pkColumn = $pkColumns[$counter];
326
+			$parameters[] = sprintf('%s => $this->get(%s, %s)', var_export($paramName, true), var_export($pkColumn, true), var_export($this->table->getName(), true));
327
+			$counter++;
328
+		}
329
+		$sql = "'".implode(' AND ', $sqlParts)."'";
330
+		$parametersCode = '[ '.implode(', ', $parameters).' ]';
331
+
332
+		return [$sql, $parametersCode];
333
+	}
334
+
335
+	/**
336
+	 * Generate code section about pivot tables
337
+	 *
338
+	 * @return string;
339
+	 */
340
+	public function generatePivotTableCode() {
341
+
342
+		$finalDescs = $this->getPivotTableDescriptors();
343
+
344
+		$code = '';
345
+
346
+		foreach ($finalDescs as $desc) {
347
+			$code .= $this->getPivotTableCode($desc['name'], $desc['table'], $desc['localFK'], $desc['remoteFK']);
348
+		}
349
+
350
+		return $code;
351
+	}
352
+
353
+	private function getPivotTableDescriptors() {
354
+		$descs = [];
355
+		foreach ($this->schemaAnalyzer->detectJunctionTables() as $table) {
356
+			// There are exactly 2 FKs since this is a pivot table.
357
+			$fks = array_values($table->getForeignKeys());
358
+
359
+			if ($fks[0]->getForeignTableName() === $this->table->getName()) {
360
+				$localFK = $fks[0];
361
+				$remoteFK = $fks[1];
362
+			} elseif ($fks[1]->getForeignTableName() === $this->table->getName()) {
363
+				$localFK = $fks[1];
364
+				$remoteFK = $fks[0];
365
+			} else {
366
+				continue;
367
+			}
368
+
369
+			$descs[$remoteFK->getForeignTableName()][] = [
370
+				'table' => $table,
371
+				'localFK' => $localFK,
372
+				'remoteFK' => $remoteFK
373
+			];
374
+
375
+		}
376
+
377
+		$finalDescs = [];
378
+		foreach ($descs as $descArray) {
379
+			if (count($descArray) > 1) {
380
+				foreach ($descArray as $desc) {
381
+					$desc['name'] = TDBMDaoGenerator::toCamelCase($desc['remoteFK']->getForeignTableName())."By".TDBMDaoGenerator::toCamelCase($desc['table']->getName());
382
+					$finalDescs[] = $desc;
383
+				}
384
+			} else {
385
+				$desc = $descArray[0];
386
+				$desc['name'] = TDBMDaoGenerator::toCamelCase($desc['remoteFK']->getForeignTableName());
387
+				$finalDescs[] = $desc;
388
+			}
389
+		}
390
+
391
+		return $finalDescs;
392
+	}
393
+
394
+	public function getPivotTableCode($name, Table $table, ForeignKeyConstraint $localFK, ForeignKeyConstraint $remoteFK) {
395
+		$singularName = TDBMDaoGenerator::toSingular($name);
396
+		$remoteBeanName = TDBMDaoGenerator::getBeanNameFromTableName($remoteFK->getForeignTableName());
397
+		$variableName = '$'.TDBMDaoGenerator::toVariableName($remoteBeanName);
398
+
399
+		$str = '    /**
400 400
      * Returns the list of %s associated to this bean via the %s pivot table.
401 401
      *
402 402
      * @return %s[]
@@ -406,9 +406,9 @@  discard block
 block discarded – undo
406 406
     }
407 407
 ';
408 408
 
409
-        $getterCode = sprintf($str, $remoteBeanName, $table->getName(), $remoteBeanName, $name, var_export($remoteFK->getLocalTableName(), true));
409
+		$getterCode = sprintf($str, $remoteBeanName, $table->getName(), $remoteBeanName, $name, var_export($remoteFK->getLocalTableName(), true));
410 410
 
411
-        $str = '    /**
411
+		$str = '    /**
412 412
      * Adds a relationship with %s associated to this bean via the %s pivot table.
413 413
      *
414 414
      * @param %s %s
@@ -418,9 +418,9 @@  discard block
 block discarded – undo
418 418
     }
419 419
 ';
420 420
 
421
-        $adderCode = sprintf($str, $remoteBeanName, $table->getName(), $remoteBeanName, $variableName, $singularName, $remoteBeanName, $variableName, var_export($remoteFK->getLocalTableName(), true), $variableName);
421
+		$adderCode = sprintf($str, $remoteBeanName, $table->getName(), $remoteBeanName, $variableName, $singularName, $remoteBeanName, $variableName, var_export($remoteFK->getLocalTableName(), true), $variableName);
422 422
 
423
-        $str = '    /**
423
+		$str = '    /**
424 424
      * Deletes the relationship with %s associated to this bean via the %s pivot table.
425 425
      *
426 426
      * @param %s %s
@@ -430,9 +430,9 @@  discard block
 block discarded – undo
430 430
     }
431 431
 ';
432 432
 
433
-        $removerCode = sprintf($str, $remoteBeanName, $table->getName(), $remoteBeanName, $variableName, $singularName, $remoteBeanName, $variableName, var_export($remoteFK->getLocalTableName(), true), $variableName);
433
+		$removerCode = sprintf($str, $remoteBeanName, $table->getName(), $remoteBeanName, $variableName, $singularName, $remoteBeanName, $variableName, var_export($remoteFK->getLocalTableName(), true), $variableName);
434 434
 
435
-        $str = '    /**
435
+		$str = '    /**
436 436
      * Returns whether this bean is associated with %s via the %s pivot table.
437 437
      *
438 438
      * @param %s %s
@@ -443,24 +443,24 @@  discard block
 block discarded – undo
443 443
     }
444 444
 ';
445 445
 
446
-        $hasCode = sprintf($str, $remoteBeanName, $table->getName(), $remoteBeanName, $variableName, $singularName, $remoteBeanName, $variableName, var_export($remoteFK->getLocalTableName(), true), $variableName);
446
+		$hasCode = sprintf($str, $remoteBeanName, $table->getName(), $remoteBeanName, $variableName, $singularName, $remoteBeanName, $variableName, var_export($remoteFK->getLocalTableName(), true), $variableName);
447 447
 
448 448
 
449
-        $code = $getterCode.$adderCode.$removerCode.$hasCode;
449
+		$code = $getterCode.$adderCode.$removerCode.$hasCode;
450 450
 
451
-        return $code;
452
-    }
451
+		return $code;
452
+	}
453 453
 
454
-    public function generateJsonSerialize() {
455
-        $tableName = $this->table->getName();
456
-        $parentFk = $this->schemaAnalyzer->getParentRelationship($tableName);
457
-        if ($parentFk !== null) {
458
-            $initializer = '$array = parent::jsonSerialize();';
459
-        } else {
460
-            $initializer = '$array = [];';
461
-        }
454
+	public function generateJsonSerialize() {
455
+		$tableName = $this->table->getName();
456
+		$parentFk = $this->schemaAnalyzer->getParentRelationship($tableName);
457
+		if ($parentFk !== null) {
458
+			$initializer = '$array = parent::jsonSerialize();';
459
+		} else {
460
+			$initializer = '$array = [];';
461
+		}
462 462
 
463
-        $str = '
463
+		$str = '
464 464
     /**
465 465
      * Serializes the object for JSON encoding
466 466
      *
@@ -476,53 +476,53 @@  discard block
 block discarded – undo
476 476
     }
477 477
 ';
478 478
 
479
-        $propertiesCode = '';
480
-        foreach ($this->beanPropertyDescriptors as $beanPropertyDescriptor) {
481
-            $propertiesCode .= $beanPropertyDescriptor->getJsonSerializeCode();
482
-        }
479
+		$propertiesCode = '';
480
+		foreach ($this->beanPropertyDescriptors as $beanPropertyDescriptor) {
481
+			$propertiesCode .= $beanPropertyDescriptor->getJsonSerializeCode();
482
+		}
483 483
 
484
-        // Many to many relationships:
484
+		// Many to many relationships:
485 485
 
486
-        $descs = $this->getPivotTableDescriptors();
486
+		$descs = $this->getPivotTableDescriptors();
487 487
 
488
-        $many2manyCode = '';
488
+		$many2manyCode = '';
489 489
 
490
-        foreach ($descs as $desc) {
491
-            $remoteFK = $desc['remoteFK'];
492
-            $remoteBeanName = TDBMDaoGenerator::getBeanNameFromTableName($remoteFK->getForeignTableName());
493
-            $variableName = '$'.TDBMDaoGenerator::toVariableName($remoteBeanName);
490
+		foreach ($descs as $desc) {
491
+			$remoteFK = $desc['remoteFK'];
492
+			$remoteBeanName = TDBMDaoGenerator::getBeanNameFromTableName($remoteFK->getForeignTableName());
493
+			$variableName = '$'.TDBMDaoGenerator::toVariableName($remoteBeanName);
494 494
 
495
-            $many2manyCode .= '        if (!$stopRecursion) {
495
+			$many2manyCode .= '        if (!$stopRecursion) {
496 496
             $array[\''.lcfirst($desc['name']).'\'] = array_map(function('.$remoteBeanName.' '.$variableName.') {
497 497
                 return '.$variableName.'->jsonSerialize(true);
498 498
             }, $this->get'.$desc['name'].'());
499 499
         }
500 500
         ';
501
-        }
502
-
503
-        return sprintf($str, $initializer, $propertiesCode, $many2manyCode);
504
-    }
505
-
506
-    /**
507
-     * Writes the PHP bean file with all getters and setters from the table passed in parameter.
508
-     *
509
-     * @param string $beannamespace The namespace of the bean
510
-     */
511
-    public function generatePhpCode($beannamespace) {
512
-        $baseClassName = TDBMDaoGenerator::getBaseBeanNameFromTableName($this->table->getName());
513
-        $className = TDBMDaoGenerator::getBeanNameFromTableName($this->table->getName());
514
-        $tableName = $this->table->getName();
515
-
516
-        $parentFk = $this->schemaAnalyzer->getParentRelationship($tableName);
517
-        if ($parentFk !== null) {
518
-            $extends = TDBMDaoGenerator::getBeanNameFromTableName($parentFk->getForeignTableName());
519
-            $use = "";
520
-        } else {
521
-            $extends = "AbstractTDBMObject";
522
-            $use = "use Mouf\\Database\\TDBM\\AbstractTDBMObject;\n\n";
523
-        }
524
-
525
-        $str = "<?php
501
+		}
502
+
503
+		return sprintf($str, $initializer, $propertiesCode, $many2manyCode);
504
+	}
505
+
506
+	/**
507
+	 * Writes the PHP bean file with all getters and setters from the table passed in parameter.
508
+	 *
509
+	 * @param string $beannamespace The namespace of the bean
510
+	 */
511
+	public function generatePhpCode($beannamespace) {
512
+		$baseClassName = TDBMDaoGenerator::getBaseBeanNameFromTableName($this->table->getName());
513
+		$className = TDBMDaoGenerator::getBeanNameFromTableName($this->table->getName());
514
+		$tableName = $this->table->getName();
515
+
516
+		$parentFk = $this->schemaAnalyzer->getParentRelationship($tableName);
517
+		if ($parentFk !== null) {
518
+			$extends = TDBMDaoGenerator::getBeanNameFromTableName($parentFk->getForeignTableName());
519
+			$use = "";
520
+		} else {
521
+			$extends = "AbstractTDBMObject";
522
+			$use = "use Mouf\\Database\\TDBM\\AbstractTDBMObject;\n\n";
523
+		}
524
+
525
+		$str = "<?php
526 526
 namespace {$beannamespace};
527 527
 
528 528
 use Mouf\\Database\\TDBM\\ResultIterator;
@@ -540,20 +540,20 @@  discard block
 block discarded – undo
540 540
 {
541 541
 ";
542 542
 
543
-        $str .= $this->generateBeanConstructor();
543
+		$str .= $this->generateBeanConstructor();
544 544
 
545 545
 
546 546
 
547
-        foreach ($this->getExposedProperties() as $property) {
548
-            $str .= $property->getGetterSetterCode();
549
-        }
547
+		foreach ($this->getExposedProperties() as $property) {
548
+			$str .= $property->getGetterSetterCode();
549
+		}
550 550
 
551
-        $str .= $this->generateDirectForeignKeysCode();
552
-        $str .= $this->generatePivotTableCode();
553
-        $str .= $this->generateJsonSerialize();
551
+		$str .= $this->generateDirectForeignKeysCode();
552
+		$str .= $this->generatePivotTableCode();
553
+		$str .= $this->generateJsonSerialize();
554 554
 
555
-        $str .= "}
555
+		$str .= "}
556 556
 ";
557
-        return $str;
558
-    }
557
+		return $str;
558
+	}
559 559
 }
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/TDBMSchemaAnalyzer.php 1 patch
Indentation   +122 added lines, -122 removed lines patch added patch discarded remove patch
@@ -16,126 +16,126 @@
 block discarded – undo
16 16
 class TDBMSchemaAnalyzer
17 17
 {
18 18
 
19
-    private $connection;
20
-
21
-    /**
22
-     * @var Schema
23
-     */
24
-    private $schema;
25
-
26
-    /**
27
-     * @var string
28
-     */
29
-    private $cachePrefix;
30
-
31
-    /**
32
-     * @var Cache
33
-     */
34
-    private $cache;
35
-
36
-    /**
37
-     * @var SchemaAnalyzer
38
-     */
39
-    private $schemaAnalyzer;
40
-
41
-    /**
42
-     * @param Connection $connection The DBAL DB connection to use
43
-     * @param Cache $cache A cache service to be used
44
-     * @param SchemaAnalyzer $schemaAnalyzer The schema analyzer that will be used to find shortest paths...
45
-     * 										 Will be automatically created if not passed.
46
-     */
47
-    public function __construct(Connection $connection, Cache $cache, SchemaAnalyzer $schemaAnalyzer) {
48
-        $this->connection = $connection;
49
-        $this->cache = $cache;
50
-        $this->schemaAnalyzer = $schemaAnalyzer;
51
-    }
52
-
53
-    /**
54
-     * Returns a unique ID for the current connection. Useful for namespacing cache entries in the current connection.
55
-     * @return string
56
-     */
57
-    public function getCachePrefix() {
58
-        if ($this->cachePrefix === null) {
59
-            $this->cachePrefix = hash('md4', $this->connection->getHost()."-".$this->connection->getPort()."-".$this->connection->getDatabase()."-".$this->connection->getDriver()->getName());
60
-        }
61
-        return $this->cachePrefix;
62
-    }
63
-
64
-    /**
65
-     * Returns the (cached) schema.
66
-     *
67
-     * @return Schema
68
-     */
69
-    public function getSchema() {
70
-        if ($this->schema === null) {
71
-            $cacheKey = $this->getCachePrefix().'_schema';
72
-            if ($this->cache->contains($cacheKey)) {
73
-                $this->schema = $this->cache->fetch($cacheKey);
74
-            } else {
75
-                $this->schema = $this->connection->getSchemaManager()->createSchema();
76
-                $this->cache->save($cacheKey, $this->schema);
77
-            }
78
-        }
79
-        return $this->schema;
80
-    }
81
-
82
-    /**
83
-     * Returns the list of pivot tables linked to table $tableName
84
-     * @param string $tableName
85
-     * @return array|string[]
86
-     */
87
-    public function getPivotTableLinkedToTable($tableName) {
88
-        $cacheKey = $this->getCachePrefix().'_pivottables_link';
89
-        if ($this->cache->contains($cacheKey)) {
90
-            return $this->cache->fetch($cacheKey);
91
-        }
92
-
93
-        $pivotTables = [];
94
-
95
-        $junctionTables = $this->schemaAnalyzer->detectJunctionTables();
96
-        foreach ($junctionTables as $table) {
97
-            $fks = $table->getForeignKeys();
98
-            foreach ($fks as $fk) {
99
-                if ($fk->getForeignTableName() == $tableName) {
100
-                    $pivotTables[] = $table->getName();
101
-                    break;
102
-                }
103
-            }
104
-        }
105
-
106
-        $this->cache->save($cacheKey, $pivotTables);
107
-        return $pivotTables;
108
-    }
109
-
110
-    /**
111
-     * Returns the list of foreign keys pointing to the table represented by this bean, excluding foreign keys
112
-     * from junction tables and from inheritance.
113
-     *
114
-     * @return ForeignKeyConstraint[]
115
-     */
116
-    public function getIncomingForeignKeys($tableName) {
117
-
118
-        $junctionTables = $this->schemaAnalyzer->detectJunctionTables();
119
-        $junctionTableNames = array_map(function(Table $table) { return $table->getName(); }, $junctionTables);
120
-        $childrenRelationships = $this->schemaAnalyzer->getChildrenRelationships($tableName);
121
-
122
-        $fks = [];
123
-        foreach ($this->getSchema()->getTables() as $table) {
124
-            foreach ($table->getForeignKeys() as $fk) {
125
-                if ($fk->getForeignTableName() === $tableName) {
126
-                    if (in_array($fk->getLocalTableName(), $junctionTableNames)) {
127
-                        continue;
128
-                    }
129
-                    foreach ($childrenRelationships as $childFk) {
130
-                        if ($fk->getLocalTableName() === $childFk->getLocalTableName() && $fk->getLocalColumns() === $childFk->getLocalColumns()) {
131
-                            continue 2;
132
-                        }
133
-                    }
134
-                    $fks[] = $fk;
135
-                }
136
-            }
137
-        }
138
-
139
-        return $fks;
140
-    }
19
+	private $connection;
20
+
21
+	/**
22
+	 * @var Schema
23
+	 */
24
+	private $schema;
25
+
26
+	/**
27
+	 * @var string
28
+	 */
29
+	private $cachePrefix;
30
+
31
+	/**
32
+	 * @var Cache
33
+	 */
34
+	private $cache;
35
+
36
+	/**
37
+	 * @var SchemaAnalyzer
38
+	 */
39
+	private $schemaAnalyzer;
40
+
41
+	/**
42
+	 * @param Connection $connection The DBAL DB connection to use
43
+	 * @param Cache $cache A cache service to be used
44
+	 * @param SchemaAnalyzer $schemaAnalyzer The schema analyzer that will be used to find shortest paths...
45
+	 * 										 Will be automatically created if not passed.
46
+	 */
47
+	public function __construct(Connection $connection, Cache $cache, SchemaAnalyzer $schemaAnalyzer) {
48
+		$this->connection = $connection;
49
+		$this->cache = $cache;
50
+		$this->schemaAnalyzer = $schemaAnalyzer;
51
+	}
52
+
53
+	/**
54
+	 * Returns a unique ID for the current connection. Useful for namespacing cache entries in the current connection.
55
+	 * @return string
56
+	 */
57
+	public function getCachePrefix() {
58
+		if ($this->cachePrefix === null) {
59
+			$this->cachePrefix = hash('md4', $this->connection->getHost()."-".$this->connection->getPort()."-".$this->connection->getDatabase()."-".$this->connection->getDriver()->getName());
60
+		}
61
+		return $this->cachePrefix;
62
+	}
63
+
64
+	/**
65
+	 * Returns the (cached) schema.
66
+	 *
67
+	 * @return Schema
68
+	 */
69
+	public function getSchema() {
70
+		if ($this->schema === null) {
71
+			$cacheKey = $this->getCachePrefix().'_schema';
72
+			if ($this->cache->contains($cacheKey)) {
73
+				$this->schema = $this->cache->fetch($cacheKey);
74
+			} else {
75
+				$this->schema = $this->connection->getSchemaManager()->createSchema();
76
+				$this->cache->save($cacheKey, $this->schema);
77
+			}
78
+		}
79
+		return $this->schema;
80
+	}
81
+
82
+	/**
83
+	 * Returns the list of pivot tables linked to table $tableName
84
+	 * @param string $tableName
85
+	 * @return array|string[]
86
+	 */
87
+	public function getPivotTableLinkedToTable($tableName) {
88
+		$cacheKey = $this->getCachePrefix().'_pivottables_link';
89
+		if ($this->cache->contains($cacheKey)) {
90
+			return $this->cache->fetch($cacheKey);
91
+		}
92
+
93
+		$pivotTables = [];
94
+
95
+		$junctionTables = $this->schemaAnalyzer->detectJunctionTables();
96
+		foreach ($junctionTables as $table) {
97
+			$fks = $table->getForeignKeys();
98
+			foreach ($fks as $fk) {
99
+				if ($fk->getForeignTableName() == $tableName) {
100
+					$pivotTables[] = $table->getName();
101
+					break;
102
+				}
103
+			}
104
+		}
105
+
106
+		$this->cache->save($cacheKey, $pivotTables);
107
+		return $pivotTables;
108
+	}
109
+
110
+	/**
111
+	 * Returns the list of foreign keys pointing to the table represented by this bean, excluding foreign keys
112
+	 * from junction tables and from inheritance.
113
+	 *
114
+	 * @return ForeignKeyConstraint[]
115
+	 */
116
+	public function getIncomingForeignKeys($tableName) {
117
+
118
+		$junctionTables = $this->schemaAnalyzer->detectJunctionTables();
119
+		$junctionTableNames = array_map(function(Table $table) { return $table->getName(); }, $junctionTables);
120
+		$childrenRelationships = $this->schemaAnalyzer->getChildrenRelationships($tableName);
121
+
122
+		$fks = [];
123
+		foreach ($this->getSchema()->getTables() as $table) {
124
+			foreach ($table->getForeignKeys() as $fk) {
125
+				if ($fk->getForeignTableName() === $tableName) {
126
+					if (in_array($fk->getLocalTableName(), $junctionTableNames)) {
127
+						continue;
128
+					}
129
+					foreach ($childrenRelationships as $childFk) {
130
+						if ($fk->getLocalTableName() === $childFk->getLocalTableName() && $fk->getLocalColumns() === $childFk->getLocalColumns()) {
131
+							continue 2;
132
+						}
133
+					}
134
+					$fks[] = $fk;
135
+				}
136
+			}
137
+		}
138
+
139
+		return $fks;
140
+	}
141 141
 }
Please login to merge, or discard this patch.