Code Coverage |
||||||||||
Classes and Traits |
Functions and Methods |
Lines |
||||||||
| Total | |
0.00% |
0 / 1 |
|
88.89% |
8 / 9 |
CRAP | |
97.78% |
44 / 45 |
| MySQLSelectByCollectionManyStoredProcedure | |
0.00% |
0 / 1 |
|
88.89% |
8 / 9 |
14 | |
97.78% |
44 / 45 |
| __construct | |
100.00% |
1 / 1 |
1 | |
100.00% |
8 / 8 |
|||
| buildElements | |
100.00% |
1 / 1 |
1 | |
100.00% |
6 / 6 |
|||
| buildSignature | |
100.00% |
1 / 1 |
2 | |
100.00% |
5 / 5 |
|||
| buildStatement | |
100.00% |
1 / 1 |
1 | |
100.00% |
6 / 6 |
|||
| getJoinCondition | |
100.00% |
1 / 1 |
2 | |
100.00% |
8 / 8 |
|||
| getWhereCondition | |
100.00% |
1 / 1 |
2 | |
100.00% |
6 / 6 |
|||
| getCorrespondingColumnForPKAttribute | |
0.00% |
0 / 1 |
3.14 | |
75.00% |
3 / 4 |
|||
| buildTableColumn | |
100.00% |
1 / 1 |
1 | |
100.00% |
1 / 1 |
|||
| buildComparision | |
100.00% |
1 / 1 |
1 | |
100.00% |
1 / 1 |
|||
| <?php | |
| declare(strict_types = 1); | |
| namespace Siesta\Driver\MySQL\StoredProcedure; | |
| use Siesta\Database\StoredProcedureNaming; | |
| use Siesta\Model\Attribute; | |
| use Siesta\Model\CollectionMany; | |
| use Siesta\Model\DataModel; | |
| use Siesta\Model\Entity; | |
| use Siesta\Model\Reference; | |
| class MySQLSelectByCollectionManyStoredProcedure extends MySQLStoredProcedureBase | |
| { | |
| const JOIN = "SELECT * FROM %s LEFT JOIN %s ON %s WHERE %s;"; | |
| /** | |
| * @var CollectionMany | |
| */ | |
| protected $collectionMany; | |
| /** | |
| * @var Entity | |
| */ | |
| protected $foreignEntity; | |
| /** | |
| * @var Reference | |
| */ | |
| protected $foreignReference; | |
| /** | |
| * @var Entity | |
| */ | |
| protected $mappingEntity; | |
| /** | |
| * @var Reference | |
| */ | |
| protected $mappinReference; | |
| /** | |
| * | |
| */ | |
| protected $reference; | |
| public function __construct(DataModel $dataModel, Entity $entity, CollectionMany $collectionMany) | |
| { | |
| parent::__construct($dataModel, $entity); | |
| $this->collectionMany = $collectionMany; | |
| $this->foreignEntity = $collectionMany->getForeignEntity(); | |
| $this->foreignReference = $collectionMany->getForeignReference(); | |
| $this->mappingEntity = $collectionMany->getMappingEntity(); | |
| $this->mappinReference = $collectionMany->getMappingReference(); | |
| $this->buildElements(); | |
| } | |
| /** | |
| * | |
| */ | |
| protected function buildElements() | |
| { | |
| $this->modifies = false; | |
| $this->name = StoredProcedureNaming::getSelectByCollectionManyName($this->collectionMany); | |
| $this->determineTableNames(); | |
| $this->buildSignature(); | |
| $this->buildStatement(); | |
| } | |
| /** | |
| * @return void | |
| */ | |
| protected function buildSignature() | |
| { | |
| $parameterList = []; | |
| foreach ($this->entity->getPrimaryKeyAttributeList() as $attribute) { | |
| $parameterList[] = $this->buildSignatureParameter($attribute->getStoredProcedureParameterName(), $attribute->getDbType()); | |
| } | |
| $this->signature = $this->buildSignatureFromList($parameterList); | |
| } | |
| /** | |
| * | |
| */ | |
| protected function buildStatement() | |
| { | |
| $foreignTable = $this->quote($this->foreignEntity->getTableName()); | |
| $mappingTable = $this->quote($this->mappingEntity->getTableName()); | |
| $joinCondition = $this->getJoinCondition(); | |
| $whereStatement = $this->getWhereCondition(); | |
| $this->statement = sprintf(self::JOIN, $foreignTable, $mappingTable, $joinCondition, $whereStatement); | |
| } | |
| /** | |
| * | |
| */ | |
| protected function getJoinCondition() : string | |
| { | |
| $foreignTable = $this->foreignEntity->getTableName(); | |
| $mappingTable = $this->mappingEntity->getTableName(); | |
| $conditionList = []; | |
| foreach ($this->foreignEntity->getPrimaryKeyAttributeList() as $pkAttribute) { | |
| $mappingAttribute = $this->getCorrespondingColumnForPKAttribute($this->foreignReference, $pkAttribute); | |
| $foreignAttribute = $pkAttribute->getDBName(); | |
| $conditionList[] = $this->buildComparision($foreignTable, $foreignAttribute, $mappingTable, $mappingAttribute); | |
| } | |
| return implode(",", $conditionList); | |
| } | |
| /** | |
| * @return string | |
| */ | |
| protected function getWhereCondition() : string | |
| { | |
| $mappingTable = $this->mappingEntity->getTableName(); | |
| $whereList = []; | |
| foreach ($this->entity->getPrimaryKeyAttributeList() as $pkAttribute) { | |
| $mappingAttribute = $this->getCorrespondingColumnForPKAttribute($this->mappinReference, $pkAttribute); | |
| $whereList[] = $this->buildTableColumn($mappingTable, $mappingAttribute) . ' = ' . $pkAttribute->getStoredProcedureParameterName(); | |
| } | |
| return implode(" AND ", $whereList); | |
| } | |
| /** | |
| * @param Reference $reference | |
| * @param Attribute $pkAttribute | |
| * | |
| * @return string | |
| */ | |
| protected function getCorrespondingColumnForPKAttribute(Reference $reference, Attribute $pkAttribute) : string | |
| { | |
| foreach ($reference->getReferenceMappingList() as $referenceMapping) { | |
| if ($referenceMapping->getForeignColumnName() === $pkAttribute->getDBName()) { | |
| return $referenceMapping->getLocalColumnName(); | |
| } | |
| } | |
| } | |
| /** | |
| * @param string $tableName | |
| * @param string $columnName | |
| * | |
| * @return string | |
| */ | |
| protected function buildTableColumn(string $tableName, string $columnName) : string | |
| { | |
| return $this->quote($tableName) . '.' . $this->quote($columnName); | |
| } | |
| /** | |
| * @param string $table1 | |
| * @param string $column1 | |
| * @param string $table2 | |
| * @param string $column2 | |
| * | |
| * @return string | |
| */ | |
| protected function buildComparision(string $table1, string $column1, string $table2, string $column2) : string | |
| { | |
| return $this->buildTableColumn($table1, $column1) . ' = ' . $this->buildTableColumn($table2, $column2); | |
| } | |
| } |