-
-
Notifications
You must be signed in to change notification settings - Fork 35
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'master' into drop-table-params
- Loading branch information
Showing
55 changed files
with
2,099 additions
and
439 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,126 @@ | ||
| <?php | ||
|
|
||
| declare(strict_types=1); | ||
|
|
||
| namespace Yiisoft\Db\Expression; | ||
|
|
||
| use Traversable; | ||
| use Yiisoft\Db\Schema\Column\ColumnSchemaInterface; | ||
|
|
||
| use function array_key_exists; | ||
| use function array_keys; | ||
| use function get_object_vars; | ||
| use function is_object; | ||
| use function iterator_to_array; | ||
|
|
||
| /** | ||
| * Represents a structured type SQL expression. | ||
| * | ||
| * @see https://en.wikipedia.org/wiki/Structured_type | ||
| * | ||
| * For example: | ||
| * | ||
| * ```php | ||
| * new StructuredExpression(['price' => 10, 'currency_code' => 'USD']); | ||
| * ``` | ||
| * | ||
| * Will be encoded to `ROW(10, USD)` in PostgreSQL. | ||
| */ | ||
| final class StructuredExpression implements ExpressionInterface | ||
| { | ||
| /** | ||
| * @param array|object $value The content of the structured type. It can be represented as | ||
| * - an associative `array` of column names and values; | ||
| * - an indexed `array` of column values in the order of structured type columns; | ||
| * - an `iterable` object that can be converted to an `array` using `iterator_to_array()`; | ||
| * - an `object` that can be converted to an `array` using `get_object_vars()`; | ||
| * - an `ExpressionInterface` object that represents a SQL expression. | ||
| * @param string|null $type The structured database type name. Defaults to `null` which means the type is not | ||
| * explicitly specified. Note that in the case where a type is not specified explicitly and DBMS cannot guess it | ||
| * from the context, SQL error will be raised. | ||
| * @param ColumnSchemaInterface[] $columns The structured type columns that are used for value normalization and type | ||
| * casting. | ||
| * | ||
| * @psalm-param array<string, ColumnSchemaInterface> $columns | ||
| */ | ||
| public function __construct( | ||
| private array|object $value, | ||
| private string|null $type = null, | ||
| private array $columns = [], | ||
| ) { | ||
| } | ||
|
|
||
| /** | ||
| * The structured type name. | ||
| * | ||
| * Defaults to `null` which means the type is not explicitly specified. | ||
| * | ||
| * Note that in the case where a type is not specified explicitly and DBMS cannot guess it from the context, | ||
| * SQL error will be raised. | ||
| */ | ||
| public function getType(): string|null | ||
| { | ||
| return $this->type; | ||
| } | ||
|
|
||
| /** | ||
| * The structured type columns that are used for value normalization and type casting. | ||
| * | ||
| * @return ColumnSchemaInterface[] | ||
| */ | ||
| public function getColumns(): array | ||
| { | ||
| return $this->columns; | ||
| } | ||
|
|
||
| /** | ||
| * The content of the structured type. It can be represented as | ||
| * - an associative `array` of column names and values; | ||
| * - an indexed `array` of column values in the order of structured type columns; | ||
| * - an `iterable` object that can be converted to an `array` using `iterator_to_array()`; | ||
| * - an `object` that can be converted to an `array` using `get_object_vars()`; | ||
| * - an `ExpressionInterface` object that represents a SQL expression. | ||
| */ | ||
| public function getValue(): array|object | ||
| { | ||
| return $this->value; | ||
| } | ||
|
|
||
| /** | ||
| * Returns the normalized value of the structured type, where: | ||
| * - values sorted according to the order of structured type columns; | ||
| * - indexed keys are replaced with column names; | ||
| * - missing elements are filled in with default values; | ||
| * - excessive elements are removed. | ||
| * | ||
| * If the structured type columns are not specified or the value is an `ExpressionInterface` object, | ||
| * it will be returned as is. | ||
| */ | ||
| public function getNormalizedValue(): array|object | ||
| { | ||
| $value = $this->value; | ||
|
|
||
| if (empty($this->columns) || $value instanceof ExpressionInterface) { | ||
| return $value; | ||
| } | ||
|
|
||
| if (is_object($value)) { | ||
| $value = $value instanceof Traversable | ||
| ? iterator_to_array($value) | ||
| : get_object_vars($value); | ||
| } | ||
|
|
||
| $normalized = []; | ||
| $columnsNames = array_keys($this->columns); | ||
|
|
||
| foreach ($columnsNames as $i => $columnsName) { | ||
| $normalized[$columnsName] = match (true) { | ||
| array_key_exists($columnsName, $value) => $value[$columnsName], | ||
| array_key_exists($i, $value) => $value[$i], | ||
| default => $this->columns[$columnsName]->getDefaultValue(), | ||
| }; | ||
| } | ||
|
|
||
| return $normalized; | ||
| } | ||
| } |
Oops, something went wrong.