krowinski /
php-mysql-replication
| @@ 177-191 (lines=15) @@ | ||
| 174 | * @throws JsonBinaryDecoderException |
|
| 175 | * @throws MySQLReplicationException |
|
| 176 | */ |
|
| 177 | public function makeWriteRowsDTO() |
|
| 178 | { |
|
| 179 | if (!$this->rowInit()) { |
|
| 180 | return null; |
|
| 181 | } |
|
| 182 | ||
| 183 | $values = $this->getValues(); |
|
| 184 | ||
| 185 | return new WriteRowsDTO( |
|
| 186 | $this->eventInfo, |
|
| 187 | $this->currentTableMap, |
|
| 188 | count($values), |
|
| 189 | $values |
|
| 190 | ); |
|
| 191 | } |
|
| 192 | ||
| 193 | /** |
|
| 194 | * @return bool |
|
| @@ 704-718 (lines=15) @@ | ||
| 701 | * @throws JsonBinaryDecoderException |
|
| 702 | * @throws MySQLReplicationException |
|
| 703 | */ |
|
| 704 | public function makeDeleteRowsDTO() |
|
| 705 | { |
|
| 706 | if (!$this->rowInit()) { |
|
| 707 | return null; |
|
| 708 | } |
|
| 709 | ||
| 710 | $values = $this->getValues(); |
|
| 711 | ||
| 712 | return new DeleteRowsDTO( |
|
| 713 | $this->eventInfo, |
|
| 714 | $this->currentTableMap, |
|
| 715 | count($values), |
|
| 716 | $values |
|
| 717 | ); |
|
| 718 | } |
|
| 719 | ||
| 720 | /** |
|
| 721 | * @return UpdateRowsDTO |
|
