thecodingmachine /
database.tdbm
Duplicate code is one of the most pungent code smells. A rule that is often used is to re-structure code once it is duplicated in three or more places.
Common duplication problems, and corresponding solutions are:
Complex classes like TDBMService often do a lot of different things. To break such a class down, we need to identify a cohesive component within that class. A common approach to find such a component is to look for fields/methods that share the same prefixes, or suffixes. You can also have a look at the cohesion graph to spot any un-connected, or weakly-connected components.
Once you have determined the fields that belong together, you can apply the Extract Class refactoring. If the component makes sense as a sub-class, Extract Subclass is also a candidate, and is often faster.
While breaking up the class, it is a good idea to analyze how other classes use TDBMService, and based on these observations, apply Extract Interface, too.
| 1 | <?php |
||
| 46 | class TDBMService |
||
| 47 | { |
||
| 48 | const MODE_CURSOR = 1; |
||
| 49 | const MODE_ARRAY = 2; |
||
| 50 | |||
| 51 | /** |
||
| 52 | * The database connection. |
||
| 53 | * |
||
| 54 | * @var Connection |
||
| 55 | */ |
||
| 56 | private $connection; |
||
| 57 | |||
| 58 | /** |
||
| 59 | * @var SchemaAnalyzer |
||
| 60 | */ |
||
| 61 | private $schemaAnalyzer; |
||
| 62 | |||
| 63 | /** |
||
| 64 | * @var MagicQuery |
||
| 65 | */ |
||
| 66 | private $magicQuery; |
||
| 67 | |||
| 68 | /** |
||
| 69 | * @var TDBMSchemaAnalyzer |
||
| 70 | */ |
||
| 71 | private $tdbmSchemaAnalyzer; |
||
| 72 | |||
| 73 | /** |
||
| 74 | * @var string |
||
| 75 | */ |
||
| 76 | private $cachePrefix; |
||
| 77 | |||
| 78 | /** |
||
| 79 | * Cache of table of primary keys. |
||
| 80 | * Primary keys are stored by tables, as an array of column. |
||
| 81 | * For instance $primary_key['my_table'][0] will return the first column of the primary key of table 'my_table'. |
||
| 82 | * |
||
| 83 | * @var string[] |
||
| 84 | */ |
||
| 85 | private $primaryKeysColumns; |
||
| 86 | |||
| 87 | /** |
||
| 88 | * Service storing objects in memory. |
||
| 89 | * Access is done by table name and then by primary key. |
||
| 90 | * If the primary key is split on several columns, access is done by an array of columns, serialized. |
||
| 91 | * |
||
| 92 | * @var StandardObjectStorage|WeakrefObjectStorage |
||
| 93 | */ |
||
| 94 | private $objectStorage; |
||
| 95 | |||
| 96 | /** |
||
| 97 | * The fetch mode of the result sets returned by `getObjects`. |
||
| 98 | * Can be one of: TDBMObjectArray::MODE_CURSOR or TDBMObjectArray::MODE_ARRAY or TDBMObjectArray::MODE_COMPATIBLE_ARRAY. |
||
| 99 | * |
||
| 100 | * In 'MODE_ARRAY' mode (default), the result is an array. Use this mode by default (unless the list returned is very big). |
||
| 101 | * In 'MODE_CURSOR' mode, the result is a Generator which is an iterable collection that can be scanned only once (only one "foreach") on it, |
||
| 102 | * and it cannot be accessed via key. Use this mode for large datasets processed by batch. |
||
| 103 | * In 'MODE_COMPATIBLE_ARRAY' mode, the result is an old TDBMObjectArray (used up to TDBM 3.2). |
||
| 104 | * You can access the array by key, or using foreach, several times. |
||
| 105 | * |
||
| 106 | * @var int |
||
| 107 | */ |
||
| 108 | private $mode = self::MODE_ARRAY; |
||
| 109 | |||
| 110 | /** |
||
| 111 | * Table of new objects not yet inserted in database or objects modified that must be saved. |
||
| 112 | * |
||
| 113 | * @var \SplObjectStorage of DbRow objects |
||
| 114 | */ |
||
| 115 | private $toSaveObjects; |
||
| 116 | |||
| 117 | /** |
||
| 118 | * A cache service to be used. |
||
| 119 | * |
||
| 120 | * @var Cache|null |
||
| 121 | */ |
||
| 122 | private $cache; |
||
| 123 | |||
| 124 | /** |
||
| 125 | * Map associating a table name to a fully qualified Bean class name. |
||
| 126 | * |
||
| 127 | * @var array |
||
| 128 | */ |
||
| 129 | private $tableToBeanMap = []; |
||
| 130 | |||
| 131 | /** |
||
| 132 | * @var \ReflectionClass[] |
||
| 133 | */ |
||
| 134 | private $reflectionClassCache = array(); |
||
| 135 | |||
| 136 | /** |
||
| 137 | * @var LoggerInterface |
||
| 138 | */ |
||
| 139 | private $rootLogger; |
||
| 140 | |||
| 141 | /** |
||
| 142 | * @var MinLogLevelFilter|NullLogger |
||
| 143 | */ |
||
| 144 | private $logger; |
||
| 145 | |||
| 146 | /** |
||
| 147 | * @var OrderByAnalyzer |
||
| 148 | */ |
||
| 149 | private $orderByAnalyzer; |
||
| 150 | |||
| 151 | /** |
||
| 152 | * @param Connection $connection The DBAL DB connection to use |
||
| 153 | * @param Cache|null $cache A cache service to be used |
||
| 154 | * @param SchemaAnalyzer $schemaAnalyzer The schema analyzer that will be used to find shortest paths... |
||
| 155 | * Will be automatically created if not passed |
||
| 156 | */ |
||
| 157 | public function __construct(Connection $connection, Cache $cache = null, SchemaAnalyzer $schemaAnalyzer = null, LoggerInterface $logger = null) |
||
| 191 | |||
| 192 | /** |
||
| 193 | * Returns the object used to connect to the database. |
||
| 194 | * |
||
| 195 | * @return Connection |
||
| 196 | */ |
||
| 197 | public function getConnection() |
||
| 201 | |||
| 202 | /** |
||
| 203 | * Creates a unique cache key for the current connection. |
||
| 204 | * |
||
| 205 | * @return string |
||
| 206 | */ |
||
| 207 | private function getConnectionUniqueId() |
||
| 211 | |||
| 212 | /** |
||
| 213 | * Sets the default fetch mode of the result sets returned by `findObjects`. |
||
| 214 | * Can be one of: TDBMObjectArray::MODE_CURSOR or TDBMObjectArray::MODE_ARRAY. |
||
| 215 | * |
||
| 216 | * In 'MODE_ARRAY' mode (default), the result is a ResultIterator object that behaves like an array. Use this mode by default (unless the list returned is very big). |
||
| 217 | * In 'MODE_CURSOR' mode, the result is a ResultIterator object. If you scan it many times (by calling several time a foreach loop), the query will be run |
||
| 218 | * several times. In cursor mode, you cannot access the result set by key. Use this mode for large datasets processed by batch. |
||
| 219 | * |
||
| 220 | * @param int $mode |
||
| 221 | * |
||
| 222 | * @return $this |
||
| 223 | * |
||
| 224 | * @throws TDBMException |
||
| 225 | */ |
||
| 226 | public function setFetchMode($mode) |
||
| 235 | |||
| 236 | /** |
||
| 237 | * Returns a TDBMObject associated from table "$table_name". |
||
| 238 | * If the $filters parameter is an int/string, the object returned will be the object whose primary key = $filters. |
||
| 239 | * $filters can also be a set of TDBM_Filters (see the findObjects method for more details). |
||
| 240 | * |
||
| 241 | * For instance, if there is a table 'users', with a primary key on column 'user_id' and a column 'user_name', then |
||
| 242 | * $user = $tdbmService->getObject('users',1); |
||
| 243 | * echo $user->name; |
||
| 244 | * will return the name of the user whose user_id is one. |
||
| 245 | * |
||
| 246 | * If a table has a primary key over several columns, you should pass to $id an array containing the the value of the various columns. |
||
| 247 | * For instance: |
||
| 248 | * $group = $tdbmService->getObject('groups',array(1,2)); |
||
| 249 | * |
||
| 250 | * Note that TDBMObject performs caching for you. If you get twice the same object, the reference of the object you will get |
||
| 251 | * will be the same. |
||
| 252 | * |
||
| 253 | * For instance: |
||
| 254 | * $user1 = $tdbmService->getObject('users',1); |
||
| 255 | * $user2 = $tdbmService->getObject('users',1); |
||
| 256 | * $user1->name = 'John Doe'; |
||
| 257 | * echo $user2->name; |
||
| 258 | * will return 'John Doe'. |
||
| 259 | * |
||
| 260 | * You can use filters instead of passing the primary key. For instance: |
||
| 261 | * $user = $tdbmService->getObject('users',new EqualFilter('users', 'login', 'jdoe')); |
||
| 262 | * This will return the user whose login is 'jdoe'. |
||
| 263 | * Please note that if 2 users have the jdoe login in database, the method will throw a TDBM_DuplicateRowException. |
||
| 264 | * |
||
| 265 | * Also, you can specify the return class for the object (provided the return class extends TDBMObject). |
||
| 266 | * For instance: |
||
| 267 | * $user = $tdbmService->getObject('users',1,'User'); |
||
| 268 | * will return an object from the "User" class. The "User" class must extend the "TDBMObject" class. |
||
| 269 | * Please be sure not to override any method or any property unless you perfectly know what you are doing! |
||
| 270 | * |
||
| 271 | * @param string $table_name The name of the table we retrieve an object from |
||
| 272 | * @param mixed $filters If the filter is a string/integer, it will be considered as the id of the object (the value of the primary key). Otherwise, it can be a filter bag (see the filterbag parameter of the findObjects method for more details about filter bags) |
||
| 273 | * @param string $className Optional: The name of the class to instanciate. This class must extend the TDBMObject class. If none is specified, a TDBMObject instance will be returned |
||
| 274 | * @param bool $lazy_loading If set to true, and if the primary key is passed in parameter of getObject, the object will not be queried in database. It will be queried when you first try to access a column. If at that time the object cannot be found in database, an exception will be thrown |
||
| 275 | * |
||
| 276 | * @return TDBMObject |
||
| 277 | */ |
||
| 278 | /* public function getObject($table_name, $filters, $className = null, $lazy_loading = false) { |
||
| 279 | |||
| 280 | if (is_array($filters) || $filters instanceof FilterInterface) { |
||
| 281 | $isFilterBag = false; |
||
| 282 | if (is_array($filters)) { |
||
| 283 | // Is this a multiple primary key or a filter bag? |
||
| 284 | // Let's have a look at the first item of the array to decide. |
||
| 285 | foreach ($filters as $filter) { |
||
| 286 | if (is_array($filter) || $filter instanceof FilterInterface) { |
||
| 287 | $isFilterBag = true; |
||
| 288 | } |
||
| 289 | break; |
||
| 290 | } |
||
| 291 | } else { |
||
| 292 | $isFilterBag = true; |
||
| 293 | } |
||
| 294 | |||
| 295 | if ($isFilterBag == true) { |
||
| 296 | // If a filter bag was passer in parameter, let's perform a findObjects. |
||
| 297 | $objects = $this->findObjects($table_name, $filters, null, null, null, $className); |
||
| 298 | if (count($objects) == 0) { |
||
| 299 | return null; |
||
| 300 | } elseif (count($objects) > 1) { |
||
| 301 | throw new DuplicateRowException("Error while querying an object for table '$table_name': ".count($objects)." rows have been returned, but we should have received at most one."); |
||
| 302 | } |
||
| 303 | // Return the first and only object. |
||
| 304 | if ($objects instanceof \Generator) { |
||
| 305 | return $objects->current(); |
||
| 306 | } else { |
||
| 307 | return $objects[0]; |
||
| 308 | } |
||
| 309 | } |
||
| 310 | } |
||
| 311 | $id = $filters; |
||
| 312 | if ($this->connection == null) { |
||
| 313 | throw new TDBMException("Error while calling TdbmService->getObject(): No connection has been established on the database!"); |
||
| 314 | } |
||
| 315 | $table_name = $this->connection->toStandardcase($table_name); |
||
| 316 | |||
| 317 | // If the ID is null, let's throw an exception |
||
| 318 | if ($id === null) { |
||
| 319 | throw new TDBMException("The ID you passed to TdbmService->getObject is null for the object of type '$table_name'. Objects primary keys cannot be null."); |
||
| 320 | } |
||
| 321 | |||
| 322 | // If the primary key is split over many columns, the IDs are passed in an array. Let's serialize this array to store it. |
||
| 323 | if (is_array($id)) { |
||
| 324 | $id = serialize($id); |
||
| 325 | } |
||
| 326 | |||
| 327 | if ($className === null) { |
||
| 328 | if (isset($this->tableToBeanMap[$table_name])) { |
||
| 329 | $className = $this->tableToBeanMap[$table_name]; |
||
| 330 | } else { |
||
| 331 | $className = "Mouf\\Database\\TDBM\\TDBMObject"; |
||
| 332 | } |
||
| 333 | } |
||
| 334 | |||
| 335 | if ($this->objectStorage->has($table_name, $id)) { |
||
| 336 | $obj = $this->objectStorage->get($table_name, $id); |
||
| 337 | if (is_a($obj, $className)) { |
||
| 338 | return $obj; |
||
| 339 | } else { |
||
| 340 | throw new TDBMException("Error! The object with ID '$id' for table '$table_name' has already been retrieved. The type for this object is '".get_class($obj)."'' which is not a subtype of '$className'"); |
||
| 341 | } |
||
| 342 | } |
||
| 343 | |||
| 344 | if ($className != "Mouf\\Database\\TDBM\\TDBMObject" && !is_subclass_of($className, "Mouf\\Database\\TDBM\\TDBMObject")) { |
||
| 345 | if (!class_exists($className)) { |
||
| 346 | throw new TDBMException("Error while calling TDBMService->getObject: The class ".$className." does not exist."); |
||
| 347 | } else { |
||
| 348 | throw new TDBMException("Error while calling TDBMService->getObject: The class ".$className." should extend TDBMObject."); |
||
| 349 | } |
||
| 350 | } |
||
| 351 | $obj = new $className($this, $table_name, $id); |
||
| 352 | |||
| 353 | if ($lazy_loading == false) { |
||
| 354 | // If we are not doing lazy loading, let's load the object: |
||
| 355 | $obj->_dbLoadIfNotLoaded(); |
||
| 356 | } |
||
| 357 | |||
| 358 | $this->objectStorage->set($table_name, $id, $obj); |
||
| 359 | |||
| 360 | return $obj; |
||
| 361 | }*/ |
||
| 362 | |||
| 363 | /** |
||
| 364 | * Removes the given object from database. |
||
| 365 | * This cannot be called on an object that is not attached to this TDBMService |
||
| 366 | * (will throw a TDBMInvalidOperationException). |
||
| 367 | * |
||
| 368 | * @param AbstractTDBMObject $object the object to delete |
||
| 369 | * |
||
| 370 | * @throws TDBMException |
||
| 371 | * @throws TDBMInvalidOperationException |
||
| 372 | */ |
||
| 373 | public function delete(AbstractTDBMObject $object) |
||
| 411 | |||
| 412 | /** |
||
| 413 | * Removes all many to many relationships for this object. |
||
| 414 | * |
||
| 415 | * @param AbstractTDBMObject $object |
||
| 416 | */ |
||
| 417 | private function deleteManyToManyRelationships(AbstractTDBMObject $object) |
||
| 430 | |||
| 431 | /** |
||
| 432 | * This function removes the given object from the database. It will also remove all objects relied to the one given |
||
| 433 | * by parameter before all. |
||
| 434 | * |
||
| 435 | * Notice: if the object has a multiple primary key, the function will not work. |
||
| 436 | * |
||
| 437 | * @param AbstractTDBMObject $objToDelete |
||
| 438 | */ |
||
| 439 | public function deleteCascade(AbstractTDBMObject $objToDelete) |
||
| 444 | |||
| 445 | /** |
||
| 446 | * This function is used only in TDBMService (private function) |
||
| 447 | * It will call deleteCascade function foreach object relied with a foreign key to the object given by parameter. |
||
| 448 | * |
||
| 449 | * @param AbstractTDBMObject $obj |
||
| 450 | */ |
||
| 451 | private function deleteAllConstraintWithThisObject(AbstractTDBMObject $obj) |
||
| 472 | |||
| 473 | /** |
||
| 474 | * This function performs a save() of all the objects that have been modified. |
||
| 475 | */ |
||
| 476 | public function completeSave() |
||
| 482 | |||
| 483 | /** |
||
| 484 | * Takes in input a filter_bag (which can be about anything from a string to an array of TDBMObjects... see above from documentation), |
||
| 485 | * and gives back a proper Filter object. |
||
| 486 | * |
||
| 487 | * @param mixed $filter_bag |
||
| 488 | * @param int $counter |
||
| 489 | * |
||
| 490 | * @return array First item: filter string, second item: parameters |
||
| 491 | * |
||
| 492 | * @throws TDBMException |
||
| 493 | */ |
||
| 494 | public function buildFilterFromFilterBag($filter_bag, $counter = 1) |
||
| 542 | |||
| 543 | /** |
||
| 544 | * @param string $table |
||
| 545 | * |
||
| 546 | * @return string[] |
||
| 547 | */ |
||
| 548 | public function getPrimaryKeyColumns($table) |
||
| 580 | |||
| 581 | /** |
||
| 582 | * This is an internal function, you should not use it in your application. |
||
| 583 | * This is used internally by TDBM to add an object to the object cache. |
||
| 584 | * |
||
| 585 | * @param DbRow $dbRow |
||
| 586 | */ |
||
| 587 | public function _addToCache(DbRow $dbRow) |
||
| 593 | |||
| 594 | /** |
||
| 595 | * This is an internal function, you should not use it in your application. |
||
| 596 | * This is used internally by TDBM to remove the object from the list of objects that have been |
||
| 597 | * created/updated but not saved yet. |
||
| 598 | * |
||
| 599 | * @param DbRow $myObject |
||
| 600 | */ |
||
| 601 | private function removeFromToSaveObjectList(DbRow $myObject) |
||
| 605 | |||
| 606 | /** |
||
| 607 | * This is an internal function, you should not use it in your application. |
||
| 608 | * This is used internally by TDBM to add an object to the list of objects that have been |
||
| 609 | * created/updated but not saved yet. |
||
| 610 | * |
||
| 611 | * @param AbstractTDBMObject $myObject |
||
| 612 | */ |
||
| 613 | public function _addToToSaveObjectList(DbRow $myObject) |
||
| 617 | |||
| 618 | /** |
||
| 619 | * Generates all the daos and beans. |
||
| 620 | * |
||
| 621 | * @param string $daoFactoryClassName The classe name of the DAO factory |
||
| 622 | * @param string $daonamespace The namespace for the DAOs, without trailing \ |
||
| 623 | * @param string $beannamespace The Namespace for the beans, without trailing \ |
||
| 624 | * @param bool $storeInUtc If the generated daos should store the date in UTC timezone instead of user's timezone |
||
| 625 | * @param string $composerFile If it's set, location of custom Composer file. Relative to project root |
||
| 626 | * |
||
| 627 | * @return \string[] the list of tables |
||
| 628 | */ |
||
| 629 | public function generateAllDaosAndBeans($daoFactoryClassName, $daonamespace, $beannamespace, $storeInUtc, $composerFile = null) |
||
| 641 | |||
| 642 | /** |
||
| 643 | * @param array<string, string> $tableToBeanMap |
||
| 644 | */ |
||
| 645 | public function setTableToBeanMap(array $tableToBeanMap) |
||
| 649 | |||
| 650 | /** |
||
| 651 | * Saves $object by INSERTing or UPDAT(E)ing it in the database. |
||
| 652 | * |
||
| 653 | * @param AbstractTDBMObject $object |
||
| 654 | * |
||
| 655 | * @throws TDBMException |
||
| 656 | */ |
||
| 657 | public function save(AbstractTDBMObject $object) |
||
| 857 | |||
| 858 | private function persistManyToManyRelationships(AbstractTDBMObject $object) |
||
| 928 | |||
| 929 | private function getPivotFilters(AbstractTDBMObject $localBean, AbstractTDBMObject $remoteBean, ForeignKeyConstraint $localFk, ForeignKeyConstraint $remoteFk) |
||
| 941 | |||
| 942 | /** |
||
| 943 | * Returns the "values" of the primary key. |
||
| 944 | * This returns the primary key from the $primaryKey attribute, not the one stored in the columns. |
||
| 945 | * |
||
| 946 | * @param AbstractTDBMObject $bean |
||
| 947 | * |
||
| 948 | * @return array numerically indexed array of values |
||
| 949 | */ |
||
| 950 | private function getPrimaryKeyValues(AbstractTDBMObject $bean) |
||
| 957 | |||
| 958 | /** |
||
| 959 | * Returns a unique hash used to store the object based on its primary key. |
||
| 960 | * If the array contains only one value, then the value is returned. |
||
| 961 | * Otherwise, a hash representing the array is returned. |
||
| 962 | * |
||
| 963 | * @param array $primaryKeys An array of columns => values forming the primary key |
||
| 964 | * |
||
| 965 | * @return string |
||
| 966 | */ |
||
| 967 | public function getObjectHash(array $primaryKeys) |
||
| 977 | |||
| 978 | /** |
||
| 979 | * Returns an array of primary keys from the object. |
||
| 980 | * The primary keys are extracted from the object columns and not from the primary keys stored in the |
||
| 981 | * $primaryKeys variable of the object. |
||
| 982 | * |
||
| 983 | * @param DbRow $dbRow |
||
| 984 | * |
||
| 985 | * @return array Returns an array of column => value |
||
| 986 | */ |
||
| 987 | public function getPrimaryKeysForObjectFromDbRow(DbRow $dbRow) |
||
| 994 | |||
| 995 | /** |
||
| 996 | * Returns an array of primary keys for the given row. |
||
| 997 | * The primary keys are extracted from the object columns. |
||
| 998 | * |
||
| 999 | * @param $table |
||
| 1000 | * @param array $columns |
||
| 1001 | * |
||
| 1002 | * @return array |
||
| 1003 | */ |
||
| 1004 | public function _getPrimaryKeysFromObjectData($table, array $columns) |
||
| 1016 | |||
| 1017 | /** |
||
| 1018 | * Attaches $object to this TDBMService. |
||
| 1019 | * The $object must be in DETACHED state and will pass in NEW state. |
||
| 1020 | * |
||
| 1021 | * @param AbstractTDBMObject $object |
||
| 1022 | * |
||
| 1023 | * @throws TDBMInvalidOperationException |
||
| 1024 | */ |
||
| 1025 | public function attach(AbstractTDBMObject $object) |
||
| 1029 | |||
| 1030 | /** |
||
| 1031 | * Returns an associative array (column => value) for the primary keys from the table name and an |
||
| 1032 | * indexed array of primary key values. |
||
| 1033 | * |
||
| 1034 | * @param string $tableName |
||
| 1035 | * @param array $indexedPrimaryKeys |
||
| 1036 | */ |
||
| 1037 | public function _getPrimaryKeysFromIndexedPrimaryKeys($tableName, array $indexedPrimaryKeys) |
||
| 1048 | |||
| 1049 | /** |
||
| 1050 | * Return the list of tables (from child to parent) joining the tables passed in parameter. |
||
| 1051 | * Tables must be in a single line of inheritance. The method will find missing tables. |
||
| 1052 | * |
||
| 1053 | * Algorithm: one of those tables is the ultimate child. From this child, by recursively getting the parent, |
||
| 1054 | * we must be able to find all other tables. |
||
| 1055 | * |
||
| 1056 | * @param string[] $tables |
||
| 1057 | * |
||
| 1058 | * @return string[] |
||
| 1059 | */ |
||
| 1060 | public function _getLinkBetweenInheritedTables(array $tables) |
||
| 1069 | |||
| 1070 | /** |
||
| 1071 | * Return the list of tables (from child to parent) joining the tables passed in parameter. |
||
| 1072 | * Tables must be in a single line of inheritance. The method will find missing tables. |
||
| 1073 | * |
||
| 1074 | * Algorithm: one of those tables is the ultimate child. From this child, by recursively getting the parent, |
||
| 1075 | * we must be able to find all other tables. |
||
| 1076 | * |
||
| 1077 | * @param string[] $tables |
||
| 1078 | * |
||
| 1079 | * @return string[] |
||
| 1080 | */ |
||
| 1081 | private function _getLinkBetweenInheritedTablesWithoutCache(array $tables) |
||
| 1102 | |||
| 1103 | /** |
||
| 1104 | * Returns the list of tables related to this table (via a parent or child inheritance relationship). |
||
| 1105 | * |
||
| 1106 | * @param string $table |
||
| 1107 | * |
||
| 1108 | * @return string[] |
||
| 1109 | */ |
||
| 1110 | public function _getRelatedTablesByInheritance($table) |
||
| 1116 | |||
| 1117 | /** |
||
| 1118 | * Returns the list of tables related to this table (via a parent or child inheritance relationship). |
||
| 1119 | * |
||
| 1120 | * @param string $table |
||
| 1121 | * |
||
| 1122 | * @return string[] |
||
| 1123 | */ |
||
| 1124 | private function _getRelatedTablesByInheritanceWithoutCache($table) |
||
| 1144 | |||
| 1145 | /** |
||
| 1146 | * Explore all the children and descendant of $table and returns ForeignKeyConstraints on those. |
||
| 1147 | * |
||
| 1148 | * @param string $table |
||
| 1149 | * |
||
| 1150 | * @return string[] |
||
| 1151 | */ |
||
| 1152 | private function exploreChildrenTablesRelationships(SchemaAnalyzer $schemaAnalyzer, $table) |
||
| 1163 | |||
| 1164 | /** |
||
| 1165 | * @param string $tableName |
||
| 1166 | * |
||
| 1167 | * @return ForeignKeyConstraint[] |
||
| 1168 | */ |
||
| 1169 | private function getParentRelationshipForeignKeys($tableName) |
||
| 1175 | |||
| 1176 | /** |
||
| 1177 | * @param string $tableName |
||
| 1178 | * |
||
| 1179 | * @return ForeignKeyConstraint[] |
||
| 1180 | */ |
||
| 1181 | private function getParentRelationshipForeignKeysWithoutCache($tableName) |
||
| 1192 | |||
| 1193 | /** |
||
| 1194 | * @param string $tableName |
||
| 1195 | * |
||
| 1196 | * @return ForeignKeyConstraint[] |
||
| 1197 | */ |
||
| 1198 | private function getChildrenRelationshipForeignKeys($tableName) |
||
| 1204 | |||
| 1205 | /** |
||
| 1206 | * @param string $tableName |
||
| 1207 | * |
||
| 1208 | * @return ForeignKeyConstraint[] |
||
| 1209 | */ |
||
| 1210 | private function getChildrenRelationshipForeignKeysWithoutCache($tableName) |
||
| 1226 | |||
| 1227 | /** |
||
| 1228 | * Casts a foreign key into SQL, assuming table name is used with no alias. |
||
| 1229 | * The returned value does contain only one table. For instance:. |
||
| 1230 | * |
||
| 1231 | * " LEFT JOIN table2 ON table1.id = table2.table1_id" |
||
| 1232 | * |
||
| 1233 | * @param ForeignKeyConstraint $fk |
||
| 1234 | * @param bool $leftTableIsLocal |
||
| 1235 | * |
||
| 1236 | * @return string |
||
| 1237 | */ |
||
| 1238 | /*private function foreignKeyToSql(ForeignKeyConstraint $fk, $leftTableIsLocal) { |
||
| 1239 | $onClauses = []; |
||
| 1240 | $foreignTableName = $this->connection->quoteIdentifier($fk->getForeignTableName()); |
||
| 1241 | $foreignColumns = $fk->getForeignColumns(); |
||
| 1242 | $localTableName = $this->connection->quoteIdentifier($fk->getLocalTableName()); |
||
| 1243 | $localColumns = $fk->getLocalColumns(); |
||
| 1244 | $columnCount = count($localTableName); |
||
| 1245 | |||
| 1246 | for ($i = 0; $i < $columnCount; $i++) { |
||
| 1247 | $onClauses[] = sprintf("%s.%s = %s.%s", |
||
| 1248 | $localTableName, |
||
| 1249 | $this->connection->quoteIdentifier($localColumns[$i]), |
||
| 1250 | $foreignColumns, |
||
| 1251 | $this->connection->quoteIdentifier($foreignColumns[$i]) |
||
| 1252 | ); |
||
| 1253 | } |
||
| 1254 | |||
| 1255 | $onClause = implode(' AND ', $onClauses); |
||
| 1256 | |||
| 1257 | if ($leftTableIsLocal) { |
||
| 1258 | return sprintf(" LEFT JOIN %s ON (%s)", $foreignTableName, $onClause); |
||
| 1259 | } else { |
||
| 1260 | return sprintf(" LEFT JOIN %s ON (%s)", $localTableName, $onClause); |
||
| 1261 | } |
||
| 1262 | }*/ |
||
| 1263 | |||
| 1264 | /** |
||
| 1265 | * Returns an identifier for the group of tables passed in parameter. |
||
| 1266 | * |
||
| 1267 | * @param string[] $relatedTables |
||
| 1268 | * |
||
| 1269 | * @return string |
||
| 1270 | */ |
||
| 1271 | private function getTableGroupName(array $relatedTables) |
||
| 1277 | |||
| 1278 | /** |
||
| 1279 | * Returns a `ResultIterator` object representing filtered records of "$mainTable" . |
||
| 1280 | * |
||
| 1281 | * The findObjects method should be the most used query method in TDBM if you want to query the database for objects. |
||
| 1282 | * (Note: if you want to query the database for an object by its primary key, use the findObjectByPk method). |
||
| 1283 | * |
||
| 1284 | * The findObjects method takes in parameter: |
||
| 1285 | * - mainTable: the kind of bean you want to retrieve. In TDBM, a bean matches a database row, so the |
||
| 1286 | * `$mainTable` parameter should be the name of an existing table in database. |
||
| 1287 | * - filter: The filter is a filter bag. It is what you use to filter your request (the WHERE part in SQL). |
||
| 1288 | * It can be a string (SQL Where clause), or even a bean or an associative array (key = column to filter, value = value to find) |
||
| 1289 | * - parameters: The parameters used in the filter. If you pass a SQL string as a filter, be sure to avoid |
||
| 1290 | * concatenating parameters in the string (this leads to SQL injection and also to poor caching performance). |
||
| 1291 | * Instead, please consider passing parameters (see documentation for more details). |
||
| 1292 | * - additionalTablesFetch: An array of SQL tables names. The beans related to those tables will be fetched along |
||
| 1293 | * the main table. This is useful to avoid hitting the database with numerous subqueries. |
||
| 1294 | * - mode: The fetch mode of the result. See `setFetchMode()` method for more details. |
||
| 1295 | * |
||
| 1296 | * The `findObjects` method will return a `ResultIterator`. A `ResultIterator` is an object that behaves as an array |
||
| 1297 | * (in ARRAY mode) at least. It can be iterated using a `foreach` loop. |
||
| 1298 | * |
||
| 1299 | * Finally, if filter_bag is null, the whole table is returned. |
||
| 1300 | * |
||
| 1301 | * @param string $mainTable The name of the table queried |
||
| 1302 | * @param string|array|null $filter The SQL filters to apply to the query (the WHERE part). All columns must be prefixed by the table name (in the form: table.column) |
||
| 1303 | * @param array $parameters |
||
| 1304 | * @param string|null $orderString The ORDER BY part of the query. All columns must be prefixed by the table name (in the form: table.column) |
||
| 1305 | * @param array $additionalTablesFetch |
||
| 1306 | * @param int $mode |
||
| 1307 | * @param string $className Optional: The name of the class to instantiate. This class must extend the TDBMObject class. If none is specified, a TDBMObject instance will be returned |
||
| 1308 | * |
||
| 1309 | * @return ResultIterator An object representing an array of results |
||
| 1310 | * |
||
| 1311 | * @throws TDBMException |
||
| 1312 | */ |
||
| 1313 | public function findObjects($mainTable, $filter = null, array $parameters = array(), $orderString = null, array $additionalTablesFetch = array(), $mode = null, $className = null) |
||
| 1353 | |||
| 1354 | /** |
||
| 1355 | * @param string $mainTable The name of the table queried |
||
| 1356 | * @param string $from The from sql statement |
||
| 1357 | * @param string|array|null $filter The SQL filters to apply to the query (the WHERE part). All columns must be prefixed by the table name (in the form: table.column) |
||
| 1358 | * @param array $parameters |
||
| 1359 | * @param string|null $orderString The ORDER BY part of the query. All columns must be prefixed by the table name (in the form: table.column) |
||
| 1360 | * @param int $mode |
||
| 1361 | * @param string $className Optional: The name of the class to instantiate. This class must extend the TDBMObject class. If none is specified, a TDBMObject instance will be returned |
||
| 1362 | * |
||
| 1363 | * @return ResultIterator An object representing an array of results |
||
| 1364 | * |
||
| 1365 | * @throws TDBMException |
||
| 1366 | */ |
||
| 1367 | public function findObjectsFromSql(string $mainTable, string $from, $filter = null, array $parameters = array(), string $orderString = null, $mode = null, string $className = null) |
||
| 1462 | |||
| 1463 | /** |
||
| 1464 | * Returns the column list that must be fetched for the SQL request. |
||
| 1465 | * |
||
| 1466 | * Note: MySQL dictates that ORDER BYed columns should appear in the SELECT clause. |
||
| 1467 | * |
||
| 1468 | * @param string $mainTable |
||
| 1469 | * @param array $additionalTablesFetch |
||
| 1470 | * @param string|null $orderBy |
||
| 1471 | * |
||
| 1472 | * @return array |
||
| 1473 | * |
||
| 1474 | * @throws \Doctrine\DBAL\Schema\SchemaException |
||
| 1475 | */ |
||
| 1476 | private function getColumnsList(string $mainTable, array $additionalTablesFetch = array(), string $orderBy = null) |
||
| 1545 | |||
| 1546 | /** |
||
| 1547 | * @param $table |
||
| 1548 | * @param array $primaryKeys |
||
| 1549 | * @param array $additionalTablesFetch |
||
| 1550 | * @param bool $lazy Whether to perform lazy loading on this object or not |
||
| 1551 | * @param string $className |
||
| 1552 | * |
||
| 1553 | * @return AbstractTDBMObject |
||
| 1554 | * |
||
| 1555 | * @throws TDBMException |
||
| 1556 | */ |
||
| 1557 | public function findObjectByPk(string $table, array $primaryKeys, array $additionalTablesFetch = array(), bool $lazy = false, string $className = null) |
||
| 1598 | |||
| 1599 | /** |
||
| 1600 | * Returns a unique bean (or null) according to the filters passed in parameter. |
||
| 1601 | * |
||
| 1602 | * @param string $mainTable The name of the table queried |
||
| 1603 | * @param string|array|null $filter The SQL filters to apply to the query (the WHERE part). All columns must be prefixed by the table name (in the form: table.column) |
||
| 1604 | * @param array $parameters |
||
| 1605 | * @param array $additionalTablesFetch |
||
| 1606 | * @param string $className Optional: The name of the class to instantiate. This class must extend the TDBMObject class. If none is specified, a TDBMObject instance will be returned |
||
| 1607 | * |
||
| 1608 | * @return AbstractTDBMObject|null The object we want, or null if no object matches the filters |
||
| 1609 | * |
||
| 1610 | * @throws TDBMException |
||
| 1611 | */ |
||
| 1612 | View Code Duplication | public function findObject(string $mainTable, $filter = null, array $parameters = array(), array $additionalTablesFetch = array(), string $className = null) |
|
| 1625 | |||
| 1626 | /** |
||
| 1627 | * Returns a unique bean (or null) according to the filters passed in parameter. |
||
| 1628 | * |
||
| 1629 | * @param string $mainTable The name of the table queried |
||
| 1630 | * @param string $from The from sql statement |
||
| 1631 | * @param string|array|null $filter The SQL filters to apply to the query (the WHERE part). All columns must be prefixed by the table name (in the form: table.column) |
||
| 1632 | * @param array $parameters |
||
| 1633 | * @param string $className Optional: The name of the class to instantiate. This class must extend the TDBMObject class. If none is specified, a TDBMObject instance will be returned |
||
| 1634 | * |
||
| 1635 | * @return AbstractTDBMObject|null The object we want, or null if no object matches the filters |
||
| 1636 | * |
||
| 1637 | * @throws TDBMException |
||
| 1638 | */ |
||
| 1639 | View Code Duplication | public function findObjectFromSql($mainTable, $from, $filter = null, array $parameters = array(), $className = null) |
|
| 1652 | |||
| 1653 | /** |
||
| 1654 | * Returns a unique bean according to the filters passed in parameter. |
||
| 1655 | * Throws a NoBeanFoundException if no bean was found for the filter passed in parameter. |
||
| 1656 | * |
||
| 1657 | * @param string $mainTable The name of the table queried |
||
| 1658 | * @param string|array|null $filter The SQL filters to apply to the query (the WHERE part). All columns must be prefixed by the table name (in the form: table.column) |
||
| 1659 | * @param array $parameters |
||
| 1660 | * @param array $additionalTablesFetch |
||
| 1661 | * @param string $className Optional: The name of the class to instantiate. This class must extend the TDBMObject class. If none is specified, a TDBMObject instance will be returned |
||
| 1662 | * |
||
| 1663 | * @return AbstractTDBMObject The object we want |
||
| 1664 | * |
||
| 1665 | * @throws TDBMException |
||
| 1666 | */ |
||
| 1667 | public function findObjectOrFail(string $mainTable, $filter = null, array $parameters = array(), array $additionalTablesFetch = array(), string $className = null) |
||
| 1676 | |||
| 1677 | /** |
||
| 1678 | * @param array $beanData An array of data: array<table, array<column, value>> |
||
| 1679 | * |
||
| 1680 | * @return array an array with first item = class name, second item = table name and third item = list of tables needed |
||
| 1681 | */ |
||
| 1682 | public function _getClassNameFromBeanData(array $beanData) |
||
| 1715 | |||
| 1716 | /** |
||
| 1717 | * Returns an item from cache or computes it using $closure and puts it in cache. |
||
| 1718 | * |
||
| 1719 | * @param string $key |
||
| 1720 | * @param callable $closure |
||
| 1721 | * |
||
| 1722 | * @return mixed |
||
| 1723 | */ |
||
| 1724 | private function fromCache(string $key, callable $closure) |
||
| 1734 | |||
| 1735 | /** |
||
| 1736 | * Returns the foreign key object. |
||
| 1737 | * |
||
| 1738 | * @param string $table |
||
| 1739 | * @param string $fkName |
||
| 1740 | * |
||
| 1741 | * @return ForeignKeyConstraint |
||
| 1742 | */ |
||
| 1743 | public function _getForeignKeyByName(string $table, string $fkName) |
||
| 1747 | |||
| 1748 | /** |
||
| 1749 | * @param $pivotTableName |
||
| 1750 | * @param AbstractTDBMObject $bean |
||
| 1751 | * |
||
| 1752 | * @return AbstractTDBMObject[] |
||
| 1753 | */ |
||
| 1754 | public function _getRelatedBeans(string $pivotTableName, AbstractTDBMObject $bean) |
||
| 1770 | |||
| 1771 | /** |
||
| 1772 | * @param $pivotTableName |
||
| 1773 | * @param AbstractTDBMObject $bean The LOCAL bean |
||
| 1774 | * |
||
| 1775 | * @return ForeignKeyConstraint[] First item: the LOCAL bean, second item: the REMOTE bean |
||
| 1776 | * |
||
| 1777 | * @throws TDBMException |
||
| 1778 | */ |
||
| 1779 | private function getPivotTableForeignKeys(string $pivotTableName, AbstractTDBMObject $bean) |
||
| 1797 | |||
| 1798 | /** |
||
| 1799 | * Returns a list of pivot tables linked to $bean. |
||
| 1800 | * |
||
| 1801 | * @param AbstractTDBMObject $bean |
||
| 1802 | * |
||
| 1803 | * @return string[] |
||
| 1804 | */ |
||
| 1805 | public function _getPivotTablesLinkedToBean(AbstractTDBMObject $bean) |
||
| 1822 | |||
| 1823 | /** |
||
| 1824 | * Array of types for tables. |
||
| 1825 | * Key: table name |
||
| 1826 | * Value: array of types indexed by column. |
||
| 1827 | * |
||
| 1828 | * @var array[] |
||
| 1829 | */ |
||
| 1830 | private $typesForTable = []; |
||
| 1831 | |||
| 1832 | /** |
||
| 1833 | * @internal |
||
| 1834 | * |
||
| 1835 | * @param string $tableName |
||
| 1836 | * |
||
| 1837 | * @return Type[] |
||
| 1838 | */ |
||
| 1839 | public function _getColumnTypesForTable(string $tableName) |
||
| 1850 | |||
| 1851 | /** |
||
| 1852 | * Sets the minimum log level. |
||
| 1853 | * $level must be one of Psr\Log\LogLevel::xxx. |
||
| 1854 | * |
||
| 1855 | * Defaults to LogLevel::WARNING |
||
| 1856 | * |
||
| 1857 | * @param string $level |
||
| 1858 | */ |
||
| 1859 | public function setLogLevel(string $level) |
||
| 1863 | } |
||
| 1864 |
Loading history...
Sometimes obsolete code just ends up commented out instead of removed. In this case it is better to remove the code once you have checked you do not need it.
The code might also have been commented out for debugging purposes. In this case it is vital that someone uncomments it again or your project may behave in very unexpected ways in production.
This check looks for comments that seem to be mostly valid code and reports them.