@@ -92,7 +92,7 @@ |
||
| 92 | 92 | $this->_tableName, $this->_sequenceName, $this->_allocationSize |
| 93 | 93 | ); |
| 94 | 94 | |
| 95 | - if ($conn->executeUpdate($updateSql, array(1 => $currentLevel, 2 => $currentLevel+1)) !== 1) { |
|
| 95 | + if ($conn->executeUpdate($updateSql, array(1 => $currentLevel, 2 => $currentLevel + 1)) !== 1) { |
|
| 96 | 96 | // no affected rows, concurrency issue, throw exception |
| 97 | 97 | } |
| 98 | 98 | } else { |
@@ -95,15 +95,15 @@ |
||
| 95 | 95 | $expressionList[] = $this->dispatch($child); |
| 96 | 96 | } |
| 97 | 97 | |
| 98 | - switch($expr->getType()) { |
|
| 98 | + switch ($expr->getType()) { |
|
| 99 | 99 | case CompositeExpression::TYPE_AND: |
| 100 | - return '(' . implode(' AND ', $expressionList) . ')'; |
|
| 100 | + return '('.implode(' AND ', $expressionList).')'; |
|
| 101 | 101 | |
| 102 | 102 | case CompositeExpression::TYPE_OR: |
| 103 | - return '(' . implode(' OR ', $expressionList) . ')'; |
|
| 103 | + return '('.implode(' OR ', $expressionList).')'; |
|
| 104 | 104 | |
| 105 | 105 | default: |
| 106 | - throw new \RuntimeException("Unknown composite " . $expr->getType()); |
|
| 106 | + throw new \RuntimeException("Unknown composite ".$expr->getType()); |
|
| 107 | 107 | } |
| 108 | 108 | } |
| 109 | 109 | |
@@ -29,7 +29,7 @@ |
||
| 29 | 29 | static public function matchingAssocationFieldRequiresObject($class, $associationName) |
| 30 | 30 | { |
| 31 | 31 | return new self(sprintf( |
| 32 | - "Cannot match on %s::%s with a non-object value. Matching objects by id is " . |
|
| 32 | + "Cannot match on %s::%s with a non-object value. Matching objects by id is ". |
|
| 33 | 33 | "not compatible with matching on an in-memory collection, which compares objects by reference.", |
| 34 | 34 | $class, $associationName |
| 35 | 35 | )); |
@@ -132,7 +132,7 @@ discard block |
||
| 132 | 132 | foreach ($joinColumns as $joinColumn) { |
| 133 | 133 | $columnName = $this->quoteStrategy->getJoinColumnName($joinColumn, $sourceClass, $this->platform); |
| 134 | 134 | $referencedName = $joinColumn['referencedColumnName']; |
| 135 | - $conditions[] = 't.' . $columnName . ' = ?'; |
|
| 135 | + $conditions[] = 't.'.$columnName.' = ?'; |
|
| 136 | 136 | $params[] = $id[$sourceClass->getFieldForColumn($referencedName)]; |
| 137 | 137 | $types[] = PersisterHelper::getTypeOfColumn($referencedName, $sourceClass, $this->em); |
| 138 | 138 | } |
@@ -161,9 +161,9 @@ discard block |
||
| 161 | 161 | }*/ |
| 162 | 162 | |
| 163 | 163 | $sql = 'SELECT COUNT(*)' |
| 164 | - . ' FROM ' . $joinTableName . ' t' |
|
| 164 | + . ' FROM '.$joinTableName.' t' |
|
| 165 | 165 | . $joinTargetEntitySQL |
| 166 | - . ' WHERE ' . implode(' AND ', $conditions); |
|
| 166 | + . ' WHERE '.implode(' AND ', $conditions); |
|
| 167 | 167 | |
| 168 | 168 | return $this->conn->fetchColumn($sql, $params, 0, $types); |
| 169 | 169 | } |
@@ -191,7 +191,7 @@ discard block |
||
| 191 | 191 | |
| 192 | 192 | list($quotedJoinTable, $whereClauses, $params, $types) = $this->getJoinTableRestrictionsWithKey($collection, $key, true); |
| 193 | 193 | |
| 194 | - $sql = 'SELECT 1 FROM ' . $quotedJoinTable . ' WHERE ' . implode(' AND ', $whereClauses); |
|
| 194 | + $sql = 'SELECT 1 FROM '.$quotedJoinTable.' WHERE '.implode(' AND ', $whereClauses); |
|
| 195 | 195 | |
| 196 | 196 | return (bool) $this->conn->fetchColumn($sql, $params, 0, $types); |
| 197 | 197 | } |
@@ -207,7 +207,7 @@ discard block |
||
| 207 | 207 | |
| 208 | 208 | list($quotedJoinTable, $whereClauses, $params, $types) = $this->getJoinTableRestrictions($collection, $element, true); |
| 209 | 209 | |
| 210 | - $sql = 'SELECT 1 FROM ' . $quotedJoinTable . ' WHERE ' . implode(' AND ', $whereClauses); |
|
| 210 | + $sql = 'SELECT 1 FROM '.$quotedJoinTable.' WHERE '.implode(' AND ', $whereClauses); |
|
| 211 | 211 | |
| 212 | 212 | return (bool) $this->conn->fetchColumn($sql, $params, 0, $types); |
| 213 | 213 | } |
@@ -223,7 +223,7 @@ discard block |
||
| 223 | 223 | |
| 224 | 224 | list($quotedJoinTable, $whereClauses, $params, $types) = $this->getJoinTableRestrictions($collection, $element, false); |
| 225 | 225 | |
| 226 | - $sql = 'DELETE FROM ' . $quotedJoinTable . ' WHERE ' . implode(' AND ', $whereClauses); |
|
| 226 | + $sql = 'DELETE FROM '.$quotedJoinTable.' WHERE '.implode(' AND ', $whereClauses); |
|
| 227 | 227 | |
| 228 | 228 | return (bool) $this->conn->executeUpdate($sql, $params, $types); |
| 229 | 229 | } |
@@ -260,11 +260,11 @@ discard block |
||
| 260 | 260 | $rsm = new Query\ResultSetMappingBuilder($this->em); |
| 261 | 261 | $rsm->addRootEntityFromClassMetadata($mapping['targetEntity'], 'te'); |
| 262 | 262 | |
| 263 | - $sql = 'SELECT ' . $rsm->generateSelectClause() |
|
| 264 | - . ' FROM ' . $tableName . ' te' |
|
| 265 | - . ' JOIN ' . $joinTable . ' t ON' |
|
| 263 | + $sql = 'SELECT '.$rsm->generateSelectClause() |
|
| 264 | + . ' FROM '.$tableName.' te' |
|
| 265 | + . ' JOIN '.$joinTable.' t ON' |
|
| 266 | 266 | . implode(' AND ', $onConditions) |
| 267 | - . ' WHERE ' . implode(' AND ', $whereClauses); |
|
| 267 | + . ' WHERE '.implode(' AND ', $whereClauses); |
|
| 268 | 268 | |
| 269 | 269 | $stmt = $this->conn->executeQuery($sql, $params); |
| 270 | 270 | |
@@ -301,8 +301,8 @@ discard block |
||
| 301 | 301 | |
| 302 | 302 | // A join is needed if there is filtering on the target entity |
| 303 | 303 | $tableName = $this->quoteStrategy->getTableName($rootClass, $this->platform); |
| 304 | - $joinSql = ' JOIN ' . $tableName . ' te' |
|
| 305 | - . ' ON' . implode(' AND ', $this->getOnConditionSQL($mapping)); |
|
| 304 | + $joinSql = ' JOIN '.$tableName.' te' |
|
| 305 | + . ' ON'.implode(' AND ', $this->getOnConditionSQL($mapping)); |
|
| 306 | 306 | |
| 307 | 307 | return array($joinSql, $filterSql); |
| 308 | 308 | } |
@@ -321,12 +321,12 @@ discard block |
||
| 321 | 321 | |
| 322 | 322 | foreach ($this->em->getFilters()->getEnabledFilters() as $filter) { |
| 323 | 323 | if ($filterExpr = $filter->addFilterConstraint($targetEntity, $targetTableAlias)) { |
| 324 | - $filterClauses[] = '(' . $filterExpr . ')'; |
|
| 324 | + $filterClauses[] = '('.$filterExpr.')'; |
|
| 325 | 325 | } |
| 326 | 326 | } |
| 327 | 327 | |
| 328 | 328 | return $filterClauses |
| 329 | - ? '(' . implode(' AND ', $filterClauses) . ')' |
|
| 329 | + ? '('.implode(' AND ', $filterClauses).')' |
|
| 330 | 330 | : ''; |
| 331 | 331 | } |
| 332 | 332 | |
@@ -354,7 +354,7 @@ discard block |
||
| 354 | 354 | $joinColumnName = $this->quoteStrategy->getJoinColumnName($joinColumn, $targetClass, $this->platform); |
| 355 | 355 | $refColumnName = $this->quoteStrategy->getReferencedJoinColumnName($joinColumn, $targetClass, $this->platform); |
| 356 | 356 | |
| 357 | - $conditions[] = ' t.' . $joinColumnName . ' = ' . 'te.' . $refColumnName; |
|
| 357 | + $conditions[] = ' t.'.$joinColumnName.' = '.'te.'.$refColumnName; |
|
| 358 | 358 | } |
| 359 | 359 | |
| 360 | 360 | return $conditions; |
@@ -376,8 +376,8 @@ discard block |
||
| 376 | 376 | $columns[] = $this->quoteStrategy->getJoinColumnName($joinColumn, $class, $this->platform); |
| 377 | 377 | } |
| 378 | 378 | |
| 379 | - return 'DELETE FROM ' . $joinTable |
|
| 380 | - . ' WHERE ' . implode(' = ? AND ', $columns) . ' = ?'; |
|
| 379 | + return 'DELETE FROM '.$joinTable |
|
| 380 | + . ' WHERE '.implode(' = ? AND ', $columns).' = ?'; |
|
| 381 | 381 | } |
| 382 | 382 | |
| 383 | 383 | /** |
@@ -436,8 +436,8 @@ discard block |
||
| 436 | 436 | } |
| 437 | 437 | |
| 438 | 438 | return array( |
| 439 | - 'DELETE FROM ' . $this->quoteStrategy->getJoinTableName($mapping, $class, $this->platform) |
|
| 440 | - . ' WHERE ' . implode(' = ? AND ', $columns) . ' = ?', |
|
| 439 | + 'DELETE FROM '.$this->quoteStrategy->getJoinTableName($mapping, $class, $this->platform) |
|
| 440 | + . ' WHERE '.implode(' = ? AND ', $columns).' = ?', |
|
| 441 | 441 | $types, |
| 442 | 442 | ); |
| 443 | 443 | } |
@@ -485,10 +485,10 @@ discard block |
||
| 485 | 485 | } |
| 486 | 486 | |
| 487 | 487 | return array( |
| 488 | - 'INSERT INTO ' . $this->quoteStrategy->getJoinTableName($mapping, $class, $this->platform) |
|
| 489 | - . ' (' . implode(', ', $columns) . ')' |
|
| 488 | + 'INSERT INTO '.$this->quoteStrategy->getJoinTableName($mapping, $class, $this->platform) |
|
| 489 | + . ' ('.implode(', ', $columns).')' |
|
| 490 | 490 | . ' VALUES' |
| 491 | - . ' (' . implode(', ', array_fill(0, count($columns), '?')) . ')', |
|
| 491 | + . ' ('.implode(', ', array_fill(0, count($columns), '?')).')', |
|
| 492 | 492 | $types, |
| 493 | 493 | ); |
| 494 | 494 | } |
@@ -573,7 +573,7 @@ discard block |
||
| 573 | 573 | $sourceClass = $this->em->getClassMetadata($mapping['sourceEntity']); |
| 574 | 574 | $targetClass = $this->em->getClassMetadata($mapping['targetEntity']); |
| 575 | 575 | |
| 576 | - if (! $mapping['isOwningSide']) { |
|
| 576 | + if ( ! $mapping['isOwningSide']) { |
|
| 577 | 577 | $associationSourceClass = $this->em->getClassMetadata($mapping['targetEntity']); |
| 578 | 578 | $mapping = $associationSourceClass->associationMappings[$mapping['mappedBy']]; |
| 579 | 579 | $joinColumns = $mapping['joinTable']['joinColumns']; |
@@ -586,7 +586,7 @@ discard block |
||
| 586 | 586 | $targetRelationMode = 'relationToTargetKeyColumns'; |
| 587 | 587 | } |
| 588 | 588 | |
| 589 | - $quotedJoinTable = $this->quoteStrategy->getJoinTableName($mapping, $associationSourceClass, $this->platform). ' t'; |
|
| 589 | + $quotedJoinTable = $this->quoteStrategy->getJoinTableName($mapping, $associationSourceClass, $this->platform).' t'; |
|
| 590 | 590 | $whereClauses = array(); |
| 591 | 591 | $params = array(); |
| 592 | 592 | $types = array(); |
@@ -597,14 +597,14 @@ discard block |
||
| 597 | 597 | $joinConditions = array(); |
| 598 | 598 | |
| 599 | 599 | foreach ($joinColumns as $joinTableColumn) { |
| 600 | - $joinConditions[] = 't.' . $joinTableColumn['name'] . ' = tr.' . $joinTableColumn['referencedColumnName']; |
|
| 600 | + $joinConditions[] = 't.'.$joinTableColumn['name'].' = tr.'.$joinTableColumn['referencedColumnName']; |
|
| 601 | 601 | } |
| 602 | 602 | |
| 603 | 603 | $tableName = $this->quoteStrategy->getTableName($targetClass, $this->platform); |
| 604 | - $quotedJoinTable .= ' JOIN ' . $tableName . ' tr ON ' . implode(' AND ', $joinConditions); |
|
| 604 | + $quotedJoinTable .= ' JOIN '.$tableName.' tr ON '.implode(' AND ', $joinConditions); |
|
| 605 | 605 | $columnName = $targetClass->getColumnName($indexBy); |
| 606 | 606 | |
| 607 | - $whereClauses[] = 'tr.' . $columnName . ' = ?'; |
|
| 607 | + $whereClauses[] = 'tr.'.$columnName.' = ?'; |
|
| 608 | 608 | $params[] = $key; |
| 609 | 609 | $types[] = PersisterHelper::getTypeOfColumn($columnName, $targetClass, $this->em); |
| 610 | 610 | } |
@@ -612,7 +612,7 @@ discard block |
||
| 612 | 612 | foreach ($mapping['joinTableColumns'] as $joinTableColumn) { |
| 613 | 613 | if (isset($mapping[$sourceRelationMode][$joinTableColumn])) { |
| 614 | 614 | $column = $mapping[$sourceRelationMode][$joinTableColumn]; |
| 615 | - $whereClauses[] = 't.' . $joinTableColumn . ' = ?'; |
|
| 615 | + $whereClauses[] = 't.'.$joinTableColumn.' = ?'; |
|
| 616 | 616 | $params[] = $sourceClass->containsForeignIdentifier |
| 617 | 617 | ? $id[$sourceClass->getFieldForColumn($column)] |
| 618 | 618 | : $id[$sourceClass->fieldNames[$column]]; |
@@ -620,7 +620,7 @@ discard block |
||
| 620 | 620 | } elseif ( ! $joinNeeded) { |
| 621 | 621 | $column = $mapping[$targetRelationMode][$joinTableColumn]; |
| 622 | 622 | |
| 623 | - $whereClauses[] = 't.' . $joinTableColumn . ' = ?'; |
|
| 623 | + $whereClauses[] = 't.'.$joinTableColumn.' = ?'; |
|
| 624 | 624 | $params[] = $key; |
| 625 | 625 | $types[] = PersisterHelper::getTypeOfColumn($column, $targetClass, $this->em); |
| 626 | 626 | } |
@@ -630,7 +630,7 @@ discard block |
||
| 630 | 630 | list($joinTargetEntitySQL, $filterSql) = $this->getFilterSql($filterMapping); |
| 631 | 631 | |
| 632 | 632 | if ($filterSql) { |
| 633 | - $quotedJoinTable .= ' ' . $joinTargetEntitySQL; |
|
| 633 | + $quotedJoinTable .= ' '.$joinTargetEntitySQL; |
|
| 634 | 634 | $whereClauses[] = $filterSql; |
| 635 | 635 | } |
| 636 | 636 | } |
@@ -674,7 +674,7 @@ discard block |
||
| 674 | 674 | $types = array(); |
| 675 | 675 | |
| 676 | 676 | foreach ($mapping['joinTableColumns'] as $joinTableColumn) { |
| 677 | - $whereClauses[] = ($addFilters ? 't.' : '') . $joinTableColumn . ' = ?'; |
|
| 677 | + $whereClauses[] = ($addFilters ? 't.' : '').$joinTableColumn.' = ?'; |
|
| 678 | 678 | |
| 679 | 679 | if (isset($mapping['relationToTargetKeyColumns'][$joinTableColumn])) { |
| 680 | 680 | $targetColumn = $mapping['relationToTargetKeyColumns'][$joinTableColumn]; |
@@ -696,7 +696,7 @@ discard block |
||
| 696 | 696 | list($joinTargetEntitySQL, $filterSql) = $this->getFilterSql($filterMapping); |
| 697 | 697 | |
| 698 | 698 | if ($filterSql) { |
| 699 | - $quotedJoinTable .= ' ' . $joinTargetEntitySQL; |
|
| 699 | + $quotedJoinTable .= ' '.$joinTargetEntitySQL; |
|
| 700 | 700 | $whereClauses[] = $filterSql; |
| 701 | 701 | } |
| 702 | 702 | } |
@@ -147,9 +147,9 @@ |
||
| 147 | 147 | return (bool) $persister->count($criteria); |
| 148 | 148 | } |
| 149 | 149 | |
| 150 | - /** |
|
| 151 | - * {@inheritdoc} |
|
| 152 | - */ |
|
| 150 | + /** |
|
| 151 | + * {@inheritdoc} |
|
| 152 | + */ |
|
| 153 | 153 | public function contains(PersistentCollection $collection, $element) |
| 154 | 154 | { |
| 155 | 155 | if ( ! $this->isValidEntityState($element)) { |
@@ -39,7 +39,7 @@ |
||
| 39 | 39 | /** |
| 40 | 40 | * @var array |
| 41 | 41 | */ |
| 42 | - private $types = array(); |
|
| 42 | + private $types = array(); |
|
| 43 | 43 | |
| 44 | 44 | /** |
| 45 | 45 | * Converts a comparison expression into the target query language output. |
@@ -339,8 +339,8 @@ discard block |
||
| 339 | 339 | |
| 340 | 340 | // FIXME: Order with composite keys might not be correct |
| 341 | 341 | $sql = 'SELECT ' . $columnName |
| 342 | - . ' FROM ' . $tableName |
|
| 343 | - . ' WHERE ' . implode(' = ? AND ', $identifier) . ' = ?'; |
|
| 342 | + . ' FROM ' . $tableName |
|
| 343 | + . ' WHERE ' . implode(' = ? AND ', $identifier) . ' = ?'; |
|
| 344 | 344 | |
| 345 | 345 | $flatId = $this->identifierFlattener->flattenIdentifier($versionedClass, $id); |
| 346 | 346 | |
@@ -474,8 +474,8 @@ discard block |
||
| 474 | 474 | } |
| 475 | 475 | |
| 476 | 476 | $sql = 'UPDATE ' . $quotedTableName |
| 477 | - . ' SET ' . implode(', ', $set) |
|
| 478 | - . ' WHERE ' . implode(' = ? AND ', $where) . ' = ?'; |
|
| 477 | + . ' SET ' . implode(', ', $set) |
|
| 478 | + . ' WHERE ' . implode(' = ? AND ', $where) . ' = ?'; |
|
| 479 | 479 | |
| 480 | 480 | $result = $this->conn->executeUpdate($sql, $params, $types); |
| 481 | 481 | |
@@ -1528,9 +1528,9 @@ discard block |
||
| 1528 | 1528 | $lock = $this->getLockTablesSql($lockMode); |
| 1529 | 1529 | $where = ($conditionSql ? ' WHERE ' . $conditionSql : '') . ' '; |
| 1530 | 1530 | $sql = 'SELECT 1 ' |
| 1531 | - . $lock |
|
| 1532 | - . $where |
|
| 1533 | - . $lockSql; |
|
| 1531 | + . $lock |
|
| 1532 | + . $where |
|
| 1533 | + . $lockSql; |
|
| 1534 | 1534 | |
| 1535 | 1535 | list($params, $types) = $this->expandParameters($criteria); |
| 1536 | 1536 | |
@@ -1981,8 +1981,8 @@ discard block |
||
| 1981 | 1981 | $alias = $this->getSQLTableAlias($this->class->name); |
| 1982 | 1982 | |
| 1983 | 1983 | $sql = 'SELECT 1 ' |
| 1984 | - . $this->getLockTablesSql(null) |
|
| 1985 | - . ' WHERE ' . $this->getSelectConditionSQL($criteria); |
|
| 1984 | + . $this->getLockTablesSql(null) |
|
| 1985 | + . ' WHERE ' . $this->getSelectConditionSQL($criteria); |
|
| 1986 | 1986 | |
| 1987 | 1987 | list($params, $types) = $this->expandParameters($criteria); |
| 1988 | 1988 | |
@@ -2012,9 +2012,9 @@ discard block |
||
| 2012 | 2012 | { |
| 2013 | 2013 | // if one of the join columns is nullable, return left join |
| 2014 | 2014 | foreach ($joinColumns as $joinColumn) { |
| 2015 | - if ( ! isset($joinColumn['nullable']) || $joinColumn['nullable']) { |
|
| 2016 | - return 'LEFT JOIN'; |
|
| 2017 | - } |
|
| 2015 | + if ( ! isset($joinColumn['nullable']) || $joinColumn['nullable']) { |
|
| 2016 | + return 'LEFT JOIN'; |
|
| 2017 | + } |
|
| 2018 | 2018 | } |
| 2019 | 2019 | |
| 2020 | 2020 | return 'INNER JOIN'; |
@@ -337,9 +337,9 @@ discard block |
||
| 337 | 337 | $columnName = $this->quoteStrategy->getColumnName($versionField, $versionedClass, $this->platform); |
| 338 | 338 | |
| 339 | 339 | // FIXME: Order with composite keys might not be correct |
| 340 | - $sql = 'SELECT ' . $columnName |
|
| 341 | - . ' FROM ' . $tableName |
|
| 342 | - . ' WHERE ' . implode(' = ? AND ', $identifier) . ' = ?'; |
|
| 340 | + $sql = 'SELECT '.$columnName |
|
| 341 | + . ' FROM '.$tableName |
|
| 342 | + . ' WHERE '.implode(' = ? AND ', $identifier).' = ?'; |
|
| 343 | 343 | |
| 344 | 344 | $flatId = $this->identifierFlattener->flattenIdentifier($versionedClass, $id); |
| 345 | 345 | |
@@ -415,7 +415,7 @@ discard block |
||
| 415 | 415 | } |
| 416 | 416 | |
| 417 | 417 | $params[] = $value; |
| 418 | - $set[] = $column . ' = ' . $placeholder; |
|
| 418 | + $set[] = $column.' = '.$placeholder; |
|
| 419 | 419 | $types[] = $this->columnTypes[$columnName]; |
| 420 | 420 | } |
| 421 | 421 | |
@@ -464,18 +464,18 @@ discard block |
||
| 464 | 464 | case Type::SMALLINT: |
| 465 | 465 | case Type::INTEGER: |
| 466 | 466 | case Type::BIGINT: |
| 467 | - $set[] = $versionColumn . ' = ' . $versionColumn . ' + 1'; |
|
| 467 | + $set[] = $versionColumn.' = '.$versionColumn.' + 1'; |
|
| 468 | 468 | break; |
| 469 | 469 | |
| 470 | 470 | case Type::DATETIME: |
| 471 | - $set[] = $versionColumn . ' = CURRENT_TIMESTAMP'; |
|
| 471 | + $set[] = $versionColumn.' = CURRENT_TIMESTAMP'; |
|
| 472 | 472 | break; |
| 473 | 473 | } |
| 474 | 474 | } |
| 475 | 475 | |
| 476 | - $sql = 'UPDATE ' . $quotedTableName |
|
| 477 | - . ' SET ' . implode(', ', $set) |
|
| 478 | - . ' WHERE ' . implode(' = ? AND ', $where) . ' = ?'; |
|
| 476 | + $sql = 'UPDATE '.$quotedTableName |
|
| 477 | + . ' SET '.implode(', ', $set) |
|
| 478 | + . ' WHERE '.implode(' = ? AND ', $where).' = ?'; |
|
| 479 | 479 | |
| 480 | 480 | $result = $this->conn->executeUpdate($sql, $params, $types); |
| 481 | 481 | |
@@ -518,7 +518,7 @@ discard block |
||
| 518 | 518 | |
| 519 | 519 | |
| 520 | 520 | if ($selfReferential) { |
| 521 | - $otherColumns = (! $mapping['isOwningSide']) |
|
| 521 | + $otherColumns = ( ! $mapping['isOwningSide']) |
|
| 522 | 522 | ? $association['joinTable']['joinColumns'] |
| 523 | 523 | : $association['joinTable']['inverseJoinColumns']; |
| 524 | 524 | } |
@@ -555,7 +555,7 @@ discard block |
||
| 555 | 555 | $tableName = $this->quoteStrategy->getTableName($class, $this->platform); |
| 556 | 556 | $idColumns = $this->quoteStrategy->getIdentifierColumnNames($class, $this->platform); |
| 557 | 557 | $id = array_combine($idColumns, $identifier); |
| 558 | - $types = array_map(function ($identifier) use ($class) { |
|
| 558 | + $types = array_map(function($identifier) use ($class) { |
|
| 559 | 559 | |
| 560 | 560 | if (isset($class->fieldMappings[$identifier])) { |
| 561 | 561 | return $class->fieldMappings[$identifier]['type']; |
@@ -781,7 +781,7 @@ discard block |
||
| 781 | 781 | |
| 782 | 782 | // unset the old value and set the new sql aliased value here. By definition |
| 783 | 783 | // unset($identifier[$targetKeyColumn] works here with how UnitOfWork::createEntity() calls this method. |
| 784 | - $identifier[$this->getSQLTableAlias($targetClass->name) . "." . $targetKeyColumn] = |
|
| 784 | + $identifier[$this->getSQLTableAlias($targetClass->name).".".$targetKeyColumn] = |
|
| 785 | 785 | $sourceClass->reflFields[$sourceClass->fieldNames[$sourceKeyColumn]]->getValue($sourceEntity); |
| 786 | 786 | |
| 787 | 787 | unset($identifier[$targetKeyColumn]); |
@@ -1016,7 +1016,7 @@ discard block |
||
| 1016 | 1016 | ); |
| 1017 | 1017 | } |
| 1018 | 1018 | |
| 1019 | - $criteria[$quotedJoinTable . '.' . $quotedKeyColumn] = $value; |
|
| 1019 | + $criteria[$quotedJoinTable.'.'.$quotedKeyColumn] = $value; |
|
| 1020 | 1020 | $parameters[] = array( |
| 1021 | 1021 | 'value' => $value, |
| 1022 | 1022 | 'field' => $field, |
@@ -1059,11 +1059,11 @@ discard block |
||
| 1059 | 1059 | |
| 1060 | 1060 | switch ($lockMode) { |
| 1061 | 1061 | case LockMode::PESSIMISTIC_READ: |
| 1062 | - $lockSql = ' ' . $this->platform->getReadLockSql(); |
|
| 1062 | + $lockSql = ' '.$this->platform->getReadLockSql(); |
|
| 1063 | 1063 | break; |
| 1064 | 1064 | |
| 1065 | 1065 | case LockMode::PESSIMISTIC_WRITE: |
| 1066 | - $lockSql = ' ' . $this->platform->getWriteLockSql(); |
|
| 1066 | + $lockSql = ' '.$this->platform->getWriteLockSql(); |
|
| 1067 | 1067 | break; |
| 1068 | 1068 | } |
| 1069 | 1069 | |
@@ -1074,14 +1074,14 @@ discard block |
||
| 1074 | 1074 | |
| 1075 | 1075 | if ('' !== $filterSql) { |
| 1076 | 1076 | $conditionSql = $conditionSql |
| 1077 | - ? $conditionSql . ' AND ' . $filterSql |
|
| 1077 | + ? $conditionSql.' AND '.$filterSql |
|
| 1078 | 1078 | : $filterSql; |
| 1079 | 1079 | } |
| 1080 | 1080 | |
| 1081 | - $select = 'SELECT ' . $columnList; |
|
| 1082 | - $from = ' FROM ' . $tableName . ' '. $tableAlias; |
|
| 1083 | - $join = $this->currentPersisterContext->selectJoinSql . $joinSql; |
|
| 1084 | - $where = ($conditionSql ? ' WHERE ' . $conditionSql : ''); |
|
| 1081 | + $select = 'SELECT '.$columnList; |
|
| 1082 | + $from = ' FROM '.$tableName.' '.$tableAlias; |
|
| 1083 | + $join = $this->currentPersisterContext->selectJoinSql.$joinSql; |
|
| 1084 | + $where = ($conditionSql ? ' WHERE '.$conditionSql : ''); |
|
| 1085 | 1085 | $lock = $this->platform->appendLockHint($from, $lockMode); |
| 1086 | 1086 | $query = $select |
| 1087 | 1087 | . $lock |
@@ -1089,7 +1089,7 @@ discard block |
||
| 1089 | 1089 | . $where |
| 1090 | 1090 | . $orderBySql; |
| 1091 | 1091 | |
| 1092 | - return $this->platform->modifyLimitQuery($query, $limit, $offset) . $lockSql; |
|
| 1092 | + return $this->platform->modifyLimitQuery($query, $limit, $offset).$lockSql; |
|
| 1093 | 1093 | } |
| 1094 | 1094 | |
| 1095 | 1095 | /** |
@@ -1108,13 +1108,13 @@ discard block |
||
| 1108 | 1108 | |
| 1109 | 1109 | if ('' !== $filterSql) { |
| 1110 | 1110 | $conditionSql = $conditionSql |
| 1111 | - ? $conditionSql . ' AND ' . $filterSql |
|
| 1111 | + ? $conditionSql.' AND '.$filterSql |
|
| 1112 | 1112 | : $filterSql; |
| 1113 | 1113 | } |
| 1114 | 1114 | |
| 1115 | 1115 | $sql = 'SELECT COUNT(*) ' |
| 1116 | - . 'FROM ' . $tableName . ' ' . $tableAlias |
|
| 1117 | - . (empty($conditionSql) ? '' : ' WHERE ' . $conditionSql); |
|
| 1116 | + . 'FROM '.$tableName.' '.$tableAlias |
|
| 1117 | + . (empty($conditionSql) ? '' : ' WHERE '.$conditionSql); |
|
| 1118 | 1118 | |
| 1119 | 1119 | return $sql; |
| 1120 | 1120 | } |
@@ -1147,7 +1147,7 @@ discard block |
||
| 1147 | 1147 | : $baseTableAlias; |
| 1148 | 1148 | |
| 1149 | 1149 | $columnName = $this->quoteStrategy->getColumnName($fieldName, $this->class, $this->platform); |
| 1150 | - $orderByList[] = $tableAlias . '.' . $columnName . ' ' . $orientation; |
|
| 1150 | + $orderByList[] = $tableAlias.'.'.$columnName.' '.$orientation; |
|
| 1151 | 1151 | |
| 1152 | 1152 | continue; |
| 1153 | 1153 | } |
@@ -1164,7 +1164,7 @@ discard block |
||
| 1164 | 1164 | |
| 1165 | 1165 | foreach ($this->class->associationMappings[$fieldName]['joinColumns'] as $joinColumn) { |
| 1166 | 1166 | $columnName = $this->quoteStrategy->getJoinColumnName($joinColumn, $this->class, $this->platform); |
| 1167 | - $orderByList[] = $tableAlias . '.' . $columnName . ' ' . $orientation; |
|
| 1167 | + $orderByList[] = $tableAlias.'.'.$columnName.' '.$orientation; |
|
| 1168 | 1168 | } |
| 1169 | 1169 | |
| 1170 | 1170 | continue; |
@@ -1173,7 +1173,7 @@ discard block |
||
| 1173 | 1173 | throw ORMException::unrecognizedField($fieldName); |
| 1174 | 1174 | } |
| 1175 | 1175 | |
| 1176 | - return ' ORDER BY ' . implode(', ', $orderByList); |
|
| 1176 | + return ' ORDER BY '.implode(', ', $orderByList); |
|
| 1177 | 1177 | } |
| 1178 | 1178 | |
| 1179 | 1179 | /** |
@@ -1201,8 +1201,8 @@ discard block |
||
| 1201 | 1201 | $columnList[] = $this->getSelectColumnSQL($field, $this->class); |
| 1202 | 1202 | } |
| 1203 | 1203 | |
| 1204 | - $this->currentPersisterContext->selectJoinSql = ''; |
|
| 1205 | - $eagerAliasCounter = 0; |
|
| 1204 | + $this->currentPersisterContext->selectJoinSql = ''; |
|
| 1205 | + $eagerAliasCounter = 0; |
|
| 1206 | 1206 | |
| 1207 | 1207 | foreach ($this->class->associationMappings as $assocField => $assoc) { |
| 1208 | 1208 | $assocColumnSQL = $this->getSelectColumnAssociationSQL($assocField, $assoc, $this->class); |
@@ -1228,7 +1228,7 @@ discard block |
||
| 1228 | 1228 | continue; // now this is why you shouldn't use inheritance |
| 1229 | 1229 | } |
| 1230 | 1230 | |
| 1231 | - $assocAlias = 'e' . ($eagerAliasCounter++); |
|
| 1231 | + $assocAlias = 'e'.($eagerAliasCounter++); |
|
| 1232 | 1232 | $this->currentPersisterContext->rsm->addJoinedEntityResult($assoc['targetEntity'], $assocAlias, 'r', $assocField); |
| 1233 | 1233 | |
| 1234 | 1234 | foreach ($eagerEntity->fieldNames as $field) { |
@@ -1261,14 +1261,14 @@ discard block |
||
| 1261 | 1261 | $joinTableName = $this->quoteStrategy->getTableName($eagerEntity, $this->platform); |
| 1262 | 1262 | |
| 1263 | 1263 | if ($assoc['isOwningSide']) { |
| 1264 | - $tableAlias = $this->getSQLTableAlias($association['targetEntity'], $assocAlias); |
|
| 1265 | - $this->currentPersisterContext->selectJoinSql .= ' ' . $this->getJoinSQLForJoinColumns($association['joinColumns']); |
|
| 1264 | + $tableAlias = $this->getSQLTableAlias($association['targetEntity'], $assocAlias); |
|
| 1265 | + $this->currentPersisterContext->selectJoinSql .= ' '.$this->getJoinSQLForJoinColumns($association['joinColumns']); |
|
| 1266 | 1266 | |
| 1267 | 1267 | foreach ($association['joinColumns'] as $joinColumn) { |
| 1268 | 1268 | $sourceCol = $this->quoteStrategy->getJoinColumnName($joinColumn, $this->class, $this->platform); |
| 1269 | 1269 | $targetCol = $this->quoteStrategy->getReferencedJoinColumnName($joinColumn, $this->class, $this->platform); |
| 1270 | 1270 | $joinCondition[] = $this->getSQLTableAlias($association['sourceEntity']) |
| 1271 | - . '.' . $sourceCol . ' = ' . $tableAlias . '.' . $targetCol; |
|
| 1271 | + . '.'.$sourceCol.' = '.$tableAlias.'.'.$targetCol; |
|
| 1272 | 1272 | } |
| 1273 | 1273 | |
| 1274 | 1274 | // Add filter SQL |
@@ -1284,12 +1284,12 @@ discard block |
||
| 1284 | 1284 | $sourceCol = $this->quoteStrategy->getJoinColumnName($joinColumn, $this->class, $this->platform); |
| 1285 | 1285 | $targetCol = $this->quoteStrategy->getReferencedJoinColumnName($joinColumn, $this->class, $this->platform); |
| 1286 | 1286 | |
| 1287 | - $joinCondition[] = $this->getSQLTableAlias($association['sourceEntity'], $assocAlias) . '.' . $sourceCol . ' = ' |
|
| 1288 | - . $this->getSQLTableAlias($association['targetEntity']) . '.' . $targetCol; |
|
| 1287 | + $joinCondition[] = $this->getSQLTableAlias($association['sourceEntity'], $assocAlias).'.'.$sourceCol.' = ' |
|
| 1288 | + . $this->getSQLTableAlias($association['targetEntity']).'.'.$targetCol; |
|
| 1289 | 1289 | } |
| 1290 | 1290 | } |
| 1291 | 1291 | |
| 1292 | - $this->currentPersisterContext->selectJoinSql .= ' ' . $joinTableName . ' ' . $joinTableAlias . ' ON '; |
|
| 1292 | + $this->currentPersisterContext->selectJoinSql .= ' '.$joinTableName.' '.$joinTableAlias.' ON '; |
|
| 1293 | 1293 | $this->currentPersisterContext->selectJoinSql .= implode(' AND ', $joinCondition); |
| 1294 | 1294 | } |
| 1295 | 1295 | |
@@ -1310,7 +1310,7 @@ discard block |
||
| 1310 | 1310 | */ |
| 1311 | 1311 | protected function getSelectColumnAssociationSQL($field, $assoc, ClassMetadata $class, $alias = 'r') |
| 1312 | 1312 | { |
| 1313 | - if ( ! ($assoc['isOwningSide'] && $assoc['type'] & ClassMetadata::TO_ONE) ) { |
|
| 1313 | + if ( ! ($assoc['isOwningSide'] && $assoc['type'] & ClassMetadata::TO_ONE)) { |
|
| 1314 | 1314 | return ''; |
| 1315 | 1315 | } |
| 1316 | 1316 | |
@@ -1322,8 +1322,8 @@ discard block |
||
| 1322 | 1322 | $isIdentifier = isset($assoc['id']) && $assoc['id'] === true; |
| 1323 | 1323 | $quotedColumn = $this->quoteStrategy->getJoinColumnName($joinColumn, $this->class, $this->platform); |
| 1324 | 1324 | $resultColumnName = $this->getSQLColumnAlias($joinColumn['name']); |
| 1325 | - $columnList[] = $this->getSQLTableAlias($class->name, ($alias == 'r' ? '' : $alias) ) |
|
| 1326 | - . '.' . $quotedColumn . ' AS ' . $resultColumnName; |
|
| 1325 | + $columnList[] = $this->getSQLTableAlias($class->name, ($alias == 'r' ? '' : $alias)) |
|
| 1326 | + . '.'.$quotedColumn.' AS '.$resultColumnName; |
|
| 1327 | 1327 | $type = PersisterHelper::getTypeOfColumn($joinColumn['referencedColumnName'], $targetClass, $this->em); |
| 1328 | 1328 | |
| 1329 | 1329 | $this->currentPersisterContext->rsm->addMetaResult($alias, $resultColumnName, $quotedColumn, $isIdentifier, $type); |
@@ -1359,10 +1359,10 @@ discard block |
||
| 1359 | 1359 | foreach ($joinColumns as $joinColumn) { |
| 1360 | 1360 | $quotedSourceColumn = $this->quoteStrategy->getJoinColumnName($joinColumn, $this->class, $this->platform); |
| 1361 | 1361 | $quotedTargetColumn = $this->quoteStrategy->getReferencedJoinColumnName($joinColumn, $this->class, $this->platform); |
| 1362 | - $conditions[] = $sourceTableAlias . '.' . $quotedTargetColumn . ' = ' . $joinTableName . '.' . $quotedSourceColumn; |
|
| 1362 | + $conditions[] = $sourceTableAlias.'.'.$quotedTargetColumn.' = '.$joinTableName.'.'.$quotedSourceColumn; |
|
| 1363 | 1363 | } |
| 1364 | 1364 | |
| 1365 | - return ' INNER JOIN ' . $joinTableName . ' ON ' . implode(' AND ', $conditions); |
|
| 1365 | + return ' INNER JOIN '.$joinTableName.' ON '.implode(' AND ', $conditions); |
|
| 1366 | 1366 | } |
| 1367 | 1367 | |
| 1368 | 1368 | /** |
@@ -1462,10 +1462,10 @@ discard block |
||
| 1462 | 1462 | */ |
| 1463 | 1463 | protected function getSelectColumnSQL($field, ClassMetadata $class, $alias = 'r') |
| 1464 | 1464 | { |
| 1465 | - $root = $alias == 'r' ? '' : $alias ; |
|
| 1465 | + $root = $alias == 'r' ? '' : $alias; |
|
| 1466 | 1466 | $tableAlias = $this->getSQLTableAlias($class->name, $root); |
| 1467 | 1467 | $columnName = $this->quoteStrategy->getColumnName($field, $class, $this->platform); |
| 1468 | - $sql = $tableAlias . '.' . $columnName; |
|
| 1468 | + $sql = $tableAlias.'.'.$columnName; |
|
| 1469 | 1469 | $columnAlias = $this->getSQLColumnAlias($class->columnNames[$field]); |
| 1470 | 1470 | |
| 1471 | 1471 | $this->currentPersisterContext->rsm->addFieldResult($alias, $columnAlias, $field); |
@@ -1475,7 +1475,7 @@ discard block |
||
| 1475 | 1475 | $sql = $type->convertToPHPValueSQL($sql, $this->platform); |
| 1476 | 1476 | } |
| 1477 | 1477 | |
| 1478 | - return $sql . ' AS ' . $columnAlias; |
|
| 1478 | + return $sql.' AS '.$columnAlias; |
|
| 1479 | 1479 | } |
| 1480 | 1480 | |
| 1481 | 1481 | /** |
@@ -1491,14 +1491,14 @@ discard block |
||
| 1491 | 1491 | protected function getSQLTableAlias($className, $assocName = '') |
| 1492 | 1492 | { |
| 1493 | 1493 | if ($assocName) { |
| 1494 | - $className .= '#' . $assocName; |
|
| 1494 | + $className .= '#'.$assocName; |
|
| 1495 | 1495 | } |
| 1496 | 1496 | |
| 1497 | 1497 | if (isset($this->currentPersisterContext->sqlTableAliases[$className])) { |
| 1498 | 1498 | return $this->currentPersisterContext->sqlTableAliases[$className]; |
| 1499 | 1499 | } |
| 1500 | 1500 | |
| 1501 | - $tableAlias = 't' . $this->currentPersisterContext->sqlAliasCounter++; |
|
| 1501 | + $tableAlias = 't'.$this->currentPersisterContext->sqlAliasCounter++; |
|
| 1502 | 1502 | |
| 1503 | 1503 | $this->currentPersisterContext->sqlTableAliases[$className] = $tableAlias; |
| 1504 | 1504 | |
@@ -1525,7 +1525,7 @@ discard block |
||
| 1525 | 1525 | } |
| 1526 | 1526 | |
| 1527 | 1527 | $lock = $this->getLockTablesSql($lockMode); |
| 1528 | - $where = ($conditionSql ? ' WHERE ' . $conditionSql : '') . ' '; |
|
| 1528 | + $where = ($conditionSql ? ' WHERE '.$conditionSql : '').' '; |
|
| 1529 | 1529 | $sql = 'SELECT 1 ' |
| 1530 | 1530 | . $lock |
| 1531 | 1531 | . $where |
@@ -1547,7 +1547,7 @@ discard block |
||
| 1547 | 1547 | { |
| 1548 | 1548 | return $this->platform->appendLockHint( |
| 1549 | 1549 | 'FROM ' |
| 1550 | - . $this->quoteStrategy->getTableName($this->class, $this->platform) . ' ' |
|
| 1550 | + . $this->quoteStrategy->getTableName($this->class, $this->platform).' ' |
|
| 1551 | 1551 | . $this->getSQLTableAlias($this->class->name), |
| 1552 | 1552 | $lockMode |
| 1553 | 1553 | ); |
@@ -1598,17 +1598,17 @@ discard block |
||
| 1598 | 1598 | |
| 1599 | 1599 | if (null !== $comparison) { |
| 1600 | 1600 | // special case null value handling |
| 1601 | - if (($comparison === Comparison::EQ || $comparison === Comparison::IS) && null ===$value) { |
|
| 1602 | - $selectedColumns[] = $column . ' IS NULL'; |
|
| 1601 | + if (($comparison === Comparison::EQ || $comparison === Comparison::IS) && null === $value) { |
|
| 1602 | + $selectedColumns[] = $column.' IS NULL'; |
|
| 1603 | 1603 | continue; |
| 1604 | 1604 | } |
| 1605 | 1605 | |
| 1606 | 1606 | if ($comparison === Comparison::NEQ && null === $value) { |
| 1607 | - $selectedColumns[] = $column . ' IS NOT NULL'; |
|
| 1607 | + $selectedColumns[] = $column.' IS NOT NULL'; |
|
| 1608 | 1608 | continue; |
| 1609 | 1609 | } |
| 1610 | 1610 | |
| 1611 | - $selectedColumns[] = $column . ' ' . sprintf(self::$comparisonMap[$comparison], $placeholder); |
|
| 1611 | + $selectedColumns[] = $column.' '.sprintf(self::$comparisonMap[$comparison], $placeholder); |
|
| 1612 | 1612 | continue; |
| 1613 | 1613 | } |
| 1614 | 1614 | |
@@ -1652,7 +1652,7 @@ discard block |
||
| 1652 | 1652 | ? $this->class->fieldMappings[$field]['inherited'] |
| 1653 | 1653 | : $this->class->name; |
| 1654 | 1654 | |
| 1655 | - return array($this->getSQLTableAlias($className) . '.' . $this->quoteStrategy->getColumnName($field, $this->class, $this->platform)); |
|
| 1655 | + return array($this->getSQLTableAlias($className).'.'.$this->quoteStrategy->getColumnName($field, $this->class, $this->platform)); |
|
| 1656 | 1656 | } |
| 1657 | 1657 | |
| 1658 | 1658 | if (isset($this->class->associationMappings[$field])) { |
@@ -1673,7 +1673,7 @@ discard block |
||
| 1673 | 1673 | |
| 1674 | 1674 | |
| 1675 | 1675 | foreach ($joinColumns as $joinColumn) { |
| 1676 | - $columns[] = $joinTableName . '.' . $this->quoteStrategy->getJoinColumnName($joinColumn, $class, $this->platform); |
|
| 1676 | + $columns[] = $joinTableName.'.'.$this->quoteStrategy->getJoinColumnName($joinColumn, $class, $this->platform); |
|
| 1677 | 1677 | } |
| 1678 | 1678 | |
| 1679 | 1679 | } else { |
@@ -1682,12 +1682,12 @@ discard block |
||
| 1682 | 1682 | throw ORMException::invalidFindByInverseAssociation($this->class->name, $field); |
| 1683 | 1683 | } |
| 1684 | 1684 | |
| 1685 | - $className = (isset($association['inherited'])) |
|
| 1685 | + $className = (isset($association['inherited'])) |
|
| 1686 | 1686 | ? $association['inherited'] |
| 1687 | 1687 | : $this->class->name; |
| 1688 | 1688 | |
| 1689 | 1689 | foreach ($association['joinColumns'] as $joinColumn) { |
| 1690 | - $columns[] = $this->getSQLTableAlias($className) . '.' . $this->quoteStrategy->getJoinColumnName($joinColumn, $this->class, $this->platform); |
|
| 1690 | + $columns[] = $this->getSQLTableAlias($className).'.'.$this->quoteStrategy->getJoinColumnName($joinColumn, $this->class, $this->platform); |
|
| 1691 | 1691 | } |
| 1692 | 1692 | } |
| 1693 | 1693 | return $columns; |
@@ -1780,7 +1780,7 @@ discard block |
||
| 1780 | 1780 | $value = $value[$this->em->getClassMetadata($sourceClass->associationMappings[$field]['targetEntity'])->identifier[0]]; |
| 1781 | 1781 | } |
| 1782 | 1782 | |
| 1783 | - $criteria[$tableAlias . "." . $targetKeyColumn] = $value; |
|
| 1783 | + $criteria[$tableAlias.".".$targetKeyColumn] = $value; |
|
| 1784 | 1784 | $parameters[] = array( |
| 1785 | 1785 | 'value' => $value, |
| 1786 | 1786 | 'field' => $field, |
@@ -1793,7 +1793,7 @@ discard block |
||
| 1793 | 1793 | $field = $sourceClass->fieldNames[$sourceKeyColumn]; |
| 1794 | 1794 | $value = $sourceClass->reflFields[$field]->getValue($sourceEntity); |
| 1795 | 1795 | |
| 1796 | - $criteria[$tableAlias . "." . $targetKeyColumn] = $value; |
|
| 1796 | + $criteria[$tableAlias.".".$targetKeyColumn] = $value; |
|
| 1797 | 1797 | $parameters[] = array( |
| 1798 | 1798 | 'value' => $value, |
| 1799 | 1799 | 'field' => $field, |
@@ -1880,7 +1880,7 @@ discard block |
||
| 1880 | 1880 | $assoc = $class->associationMappings[$field]; |
| 1881 | 1881 | $class = $this->em->getClassMetadata($assoc['targetEntity']); |
| 1882 | 1882 | |
| 1883 | - if (! $assoc['isOwningSide']) { |
|
| 1883 | + if ( ! $assoc['isOwningSide']) { |
|
| 1884 | 1884 | $assoc = $class->associationMappings[$assoc['mappedBy']]; |
| 1885 | 1885 | $class = $this->em->getClassMetadata($assoc['targetEntity']); |
| 1886 | 1886 | } |
@@ -1889,7 +1889,7 @@ discard block |
||
| 1889 | 1889 | ? $assoc['relationToTargetKeyColumns'] |
| 1890 | 1890 | : $assoc['sourceToTargetKeyColumns']; |
| 1891 | 1891 | |
| 1892 | - foreach ($columns as $column){ |
|
| 1892 | + foreach ($columns as $column) { |
|
| 1893 | 1893 | $types[] = PersisterHelper::getTypeOfColumn($column, $class, $this->em); |
| 1894 | 1894 | } |
| 1895 | 1895 | break; |
@@ -1901,7 +1901,7 @@ discard block |
||
| 1901 | 1901 | |
| 1902 | 1902 | if (is_array($value)) { |
| 1903 | 1903 | return array_map( |
| 1904 | - function ($type) { |
|
| 1904 | + function($type) { |
|
| 1905 | 1905 | return Type::getType($type)->getBindingType() + Connection::ARRAY_PARAM_OFFSET; |
| 1906 | 1906 | }, |
| 1907 | 1907 | $types |
@@ -1977,12 +1977,12 @@ discard block |
||
| 1977 | 1977 | |
| 1978 | 1978 | $sql = 'SELECT 1 ' |
| 1979 | 1979 | . $this->getLockTablesSql(null) |
| 1980 | - . ' WHERE ' . $this->getSelectConditionSQL($criteria); |
|
| 1980 | + . ' WHERE '.$this->getSelectConditionSQL($criteria); |
|
| 1981 | 1981 | |
| 1982 | 1982 | list($params, $types) = $this->expandParameters($criteria); |
| 1983 | 1983 | |
| 1984 | 1984 | if (null !== $extraConditions) { |
| 1985 | - $sql .= ' AND ' . $this->getSelectConditionCriteriaSQL($extraConditions); |
|
| 1985 | + $sql .= ' AND '.$this->getSelectConditionCriteriaSQL($extraConditions); |
|
| 1986 | 1986 | list($criteriaParams, $criteriaTypes) = $this->expandCriteriaParameters($extraConditions); |
| 1987 | 1987 | |
| 1988 | 1988 | $params = array_merge($params, $criteriaParams); |
@@ -1990,7 +1990,7 @@ discard block |
||
| 1990 | 1990 | } |
| 1991 | 1991 | |
| 1992 | 1992 | if ($filterSql = $this->generateFilterConditionSQL($this->class, $alias)) { |
| 1993 | - $sql .= ' AND ' . $filterSql; |
|
| 1993 | + $sql .= ' AND '.$filterSql; |
|
| 1994 | 1994 | } |
| 1995 | 1995 | |
| 1996 | 1996 | return (bool) $this->conn->fetchColumn($sql, $params, 0, $types); |
@@ -2037,12 +2037,12 @@ discard block |
||
| 2037 | 2037 | |
| 2038 | 2038 | foreach ($this->em->getFilters()->getEnabledFilters() as $filter) { |
| 2039 | 2039 | if ('' !== $filterExpr = $filter->addFilterConstraint($targetEntity, $targetTableAlias)) { |
| 2040 | - $filterClauses[] = '(' . $filterExpr . ')'; |
|
| 2040 | + $filterClauses[] = '('.$filterExpr.')'; |
|
| 2041 | 2041 | } |
| 2042 | 2042 | } |
| 2043 | 2043 | |
| 2044 | 2044 | $sql = implode(' AND ', $filterClauses); |
| 2045 | - return $sql ? "(" . $sql . ")" : ""; // Wrap again to avoid "X or Y and FilterConditionSQL" |
|
| 2045 | + return $sql ? "(".$sql.")" : ""; // Wrap again to avoid "X or Y and FilterConditionSQL" |
|
| 2046 | 2046 | } |
| 2047 | 2047 | |
| 2048 | 2048 | /** |
@@ -47,17 +47,17 @@ |
||
| 47 | 47 | * Get all queued inserts. |
| 48 | 48 | * |
| 49 | 49 | * @return array |
| 50 | - */ |
|
| 50 | + */ |
|
| 51 | 51 | public function getInserts(); |
| 52 | 52 | |
| 53 | - /** |
|
| 54 | - * @TODO - It should not be here. |
|
| 55 | - * But its necessary since JoinedSubclassPersister#executeInserts invoke the root persister. |
|
| 56 | - * |
|
| 57 | - * Gets the INSERT SQL used by the persister to persist a new entity. |
|
| 58 | - * |
|
| 59 | - * @return string |
|
| 60 | - */ |
|
| 53 | + /** |
|
| 54 | + * @TODO - It should not be here. |
|
| 55 | + * But its necessary since JoinedSubclassPersister#executeInserts invoke the root persister. |
|
| 56 | + * |
|
| 57 | + * Gets the INSERT SQL used by the persister to persist a new entity. |
|
| 58 | + * |
|
| 59 | + * @return string |
|
| 60 | + */ |
|
| 61 | 61 | public function getInsertSQL(); |
| 62 | 62 | |
| 63 | 63 | /** |
@@ -33,6 +33,6 @@ |
||
| 33 | 33 | */ |
| 34 | 34 | public static function noDispatchForNode($node) |
| 35 | 35 | { |
| 36 | - return new self("Double-dispatch for node " . get_class($node) . " is not supported."); |
|
| 36 | + return new self("Double-dispatch for node ".get_class($node)." is not supported."); |
|
| 37 | 37 | } |
| 38 | 38 | } |