Code Coverage for /home/jrf/repos/projom-storage/src/Storage/SQL/Statement/Update.php

1	<?php
2
3	declare(strict_types=1);
4
5	namespace Projom\Storage\SQL\Statement;
6
7	use Stringable;
8
9	use Projom\Storage\SQL\Component\Filter;
10	use Projom\Storage\SQL\Component\Join;
11	use Projom\Storage\SQL\Component\Set;
12	use Projom\Storage\SQL\Component\Table;
13	use Projom\Storage\SQL\Statement\StatementInterface;
14	use Projom\Storage\SQL\QueryObject;
15	use Projom\Storage\SQL\Util;
16
17	class Update implements StatementInterface, Stringable
18	{
19	private readonly Table $table;
20	private readonly Set $set;
21	private readonly Join $join;
22	private readonly Filter $filter;
23
24	public function __construct(QueryObject $queryUpdate)
25	{
26	$this->table = Table::create($queryUpdate->collections);
27	$this->set = Set::create($queryUpdate->fieldsWithValues);
28	$this->join = Join::create($queryUpdate->joins);
29	$this->filter = Filter::create($queryUpdate->filters);
30	}
31
32	public function __toString(): string
33	{
34	[$statement, $params] = $this->statement();
35	return $statement;
36	}
37
38	public static function create(QueryObject $queryUpdate): Update
39	{
40	return new Update($queryUpdate);
41	}
42
43	public function statement(): array
44	{
45	$queryParts[] = "UPDATE {$this->table} SET {$this->set}";
46
47	if (!$this->join->empty())
48	$queryParts[] = "{$this->join}";
49
50	if (!$this->filter->empty())
51	$queryParts[] = "WHERE {$this->filter}";
52
53	$query = Util::join($queryParts, ' ');
54	$params = ($this->set->params() + $this->filter->params()) ?: null;
55
56	return [
57	$query,
58	$params
59	];
60	}
61	}