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 |
|
| @@ 696-710 (lines=15) @@ | ||
| 693 | * @throws JsonBinaryDecoderException |
|
| 694 | * @throws MySQLReplicationException |
|
| 695 | */ |
|
| 696 | public function makeDeleteRowsDTO() |
|
| 697 | { |
|
| 698 | if (!$this->rowInit()) { |
|
| 699 | return null; |
|
| 700 | } |
|
| 701 | ||
| 702 | $values = $this->getValues(); |
|
| 703 | ||
| 704 | return new DeleteRowsDTO( |
|
| 705 | $this->eventInfo, |
|
| 706 | $this->currentTableMap, |
|
| 707 | count($values), |
|
| 708 | $values |
|
| 709 | ); |
|
| 710 | } |
|
| 711 | ||
| 712 | /** |
|
| 713 | * @return UpdateRowsDTO |
|
