@@ 59-67 (lines=9) @@ | ||
56 | if (count($allFetchedTables) > 1) { |
|
57 | $joinSql = ''; |
|
58 | $parentFks = $this->getParentRelationshipForeignKeys($this->mainTable); |
|
59 | foreach ($parentFks as $fk) { |
|
60 | $joinSql .= sprintf(' JOIN %s ON (%s.%s = %s.%s)', |
|
61 | $connection->quoteIdentifier($fk->getForeignTableName()), |
|
62 | $connection->quoteIdentifier($fk->getLocalTableName()), |
|
63 | $connection->quoteIdentifier($fk->getLocalColumns()[0]), |
|
64 | $connection->quoteIdentifier($fk->getForeignTableName()), |
|
65 | $connection->quoteIdentifier($fk->getForeignColumns()[0]) |
|
66 | ); |
|
67 | } |
|
68 | ||
69 | $childrenFks = $this->getChildrenRelationshipForeignKeys($this->mainTable); |
|
70 | foreach ($childrenFks as $fk) { |
|
@@ 70-78 (lines=9) @@ | ||
67 | } |
|
68 | ||
69 | $childrenFks = $this->getChildrenRelationshipForeignKeys($this->mainTable); |
|
70 | foreach ($childrenFks as $fk) { |
|
71 | $joinSql .= sprintf(' LEFT JOIN %s ON (%s.%s = %s.%s)', |
|
72 | $connection->quoteIdentifier($fk->getLocalTableName()), |
|
73 | $connection->quoteIdentifier($fk->getForeignTableName()), |
|
74 | $connection->quoteIdentifier($fk->getForeignColumns()[0]), |
|
75 | $connection->quoteIdentifier($fk->getLocalTableName()), |
|
76 | $connection->quoteIdentifier($fk->getLocalColumns()[0]) |
|
77 | ); |
|
78 | } |
|
79 | ||
80 | $sql .= $joinSql; |
|
81 | } |