1 | <?php |
||
2 | namespace yentu\database; |
||
3 | |||
4 | class Query extends DatabaseItem implements Commitable, Initializable |
||
5 | { |
||
6 | private string $query; |
||
7 | private array $bindData; |
||
8 | private array $queryData; |
||
9 | |||
10 | |||
11 | public function __construct(string $query, array $bindData = []) |
||
12 | { |
||
13 | $this->query = $query; |
||
14 | $this->bindData = $bindData; |
||
15 | } |
||
16 | |||
17 | #[\Override] |
||
18 | public function initialize(): void |
||
19 | { |
||
20 | $this->queryData = [ |
||
21 | 'query' => $this->query, |
||
22 | 'bind' => $this->bindData |
||
23 | ]; |
||
24 | $this->new = true; |
||
25 | } |
||
26 | |||
27 | public function rollback(string $query, array $bindData = []): DatabaseItem |
||
28 | { |
||
29 | $this->queryData['rollback_query'] = $query; |
||
30 | $this->queryData['rollback_bind'] = $bindData; |
||
31 | $this->new = true; |
||
32 | return $this; |
||
33 | } |
||
34 | |||
35 | #[\Override] |
||
36 | public function commitNew() |
||
37 | { |
||
38 | $this->getChangeLogger()->executeQuery($this->queryData); |
||
0 ignored issues
–
show
Bug
introduced
by
![]() |
|||
39 | } |
||
40 | } |
||
41 |