| @@ 87-107 (lines=21) @@ | ||
| 84 | * @expectedException \Exception |
|
| 85 | * @expectedExceptionMessage can't commit again |
|
| 86 | */ |
|
| 87 | public function testCommitAgain() |
|
| 88 | { |
|
| 89 | $dbDiff = $this->buildMock(); |
|
| 90 | ||
| 91 | $json = '{ |
|
| 92 | "rowCount": 0, |
|
| 93 | "executeStatus": 100, |
|
| 94 | "diff": { |
|
| 95 | "' . self::$tableUser . '": [ |
|
| 96 | { |
|
| 97 | "mode": "Whatever", |
|
| 98 | "pk": [], |
|
| 99 | "column": [] |
|
| 100 | } |
|
| 101 | ] |
|
| 102 | } |
|
| 103 | }'; |
|
| 104 | ||
| 105 | $dbDiff->import($json); |
|
| 106 | $dbDiff->commit(); |
|
| 107 | } |
|
| 108 | ||
| 109 | ||
| 110 | /** |
|
| @@ 155-175 (lines=21) @@ | ||
| 152 | * @expectedException \Exception |
|
| 153 | * @expectedExceptionMessage Invalid mode |
|
| 154 | */ |
|
| 155 | public function testCommitWithInvalidMode() |
|
| 156 | { |
|
| 157 | $dbDiff = $this->buildMock(); |
|
| 158 | ||
| 159 | $json = '{ |
|
| 160 | "rowCount": 0, |
|
| 161 | "executeStatus": 0, |
|
| 162 | "diff": { |
|
| 163 | "' . self::$tableUser . '": [ |
|
| 164 | { |
|
| 165 | "mode": "InvalidMode", |
|
| 166 | "pk": [], |
|
| 167 | "column": [] |
|
| 168 | } |
|
| 169 | ] |
|
| 170 | } |
|
| 171 | }'; |
|
| 172 | ||
| 173 | $dbDiff->import($json); |
|
| 174 | $dbDiff->commit(); |
|
| 175 | } |
|
| 176 | ||
| 177 | ||
| 178 | /** |
|
| @@ 353-373 (lines=21) @@ | ||
| 350 | * @expectedException \Exception |
|
| 351 | * @expectedExceptionMessage can't execute again |
|
| 352 | */ |
|
| 353 | public function testExecuteAgain() |
|
| 354 | { |
|
| 355 | $dbDiff = $this->buildMock(); |
|
| 356 | ||
| 357 | $json = '{ |
|
| 358 | "rowCount": 0, |
|
| 359 | "executeStatus": 100, |
|
| 360 | "diff": { |
|
| 361 | "' . self::$tableUser . '": [ |
|
| 362 | { |
|
| 363 | "mode": "Whatever", |
|
| 364 | "pk": [], |
|
| 365 | "column": [] |
|
| 366 | } |
|
| 367 | ] |
|
| 368 | } |
|
| 369 | }'; |
|
| 370 | ||
| 371 | $dbDiff->import($json); |
|
| 372 | $dbDiff->execute(); |
|
| 373 | } |
|
| 374 | ||
| 375 | ||
| 376 | public function testExecuteInsertThenRollback() |
|
| @@ 475-495 (lines=21) @@ | ||
| 472 | * @expectedException \Exception |
|
| 473 | * @expectedExceptionMessage can't rollback again |
|
| 474 | */ |
|
| 475 | public function testRollbackAgain() |
|
| 476 | { |
|
| 477 | $dbDiff = $this->buildMock(); |
|
| 478 | ||
| 479 | $json = '{ |
|
| 480 | "rowCount": 0, |
|
| 481 | "executeStatus": -100, |
|
| 482 | "diff": { |
|
| 483 | "' . self::$tableUser . '": [ |
|
| 484 | { |
|
| 485 | "mode": "Whatever", |
|
| 486 | "pk": [], |
|
| 487 | "column": [] |
|
| 488 | } |
|
| 489 | ] |
|
| 490 | } |
|
| 491 | }'; |
|
| 492 | ||
| 493 | $dbDiff->import($json); |
|
| 494 | $dbDiff->rollback(); |
|
| 495 | } |
|
| 496 | ||
| 497 | ||
| 498 | /** |
|
| @@ 543-563 (lines=21) @@ | ||
| 540 | * @expectedException \Exception |
|
| 541 | * @expectedExceptionMessage Invalid mode |
|
| 542 | */ |
|
| 543 | public function testRollbackWithInvalidMode() |
|
| 544 | { |
|
| 545 | $dbDiff = $this->buildMock(); |
|
| 546 | ||
| 547 | $json = '{ |
|
| 548 | "rowCount": 0, |
|
| 549 | "executeStatus": 0, |
|
| 550 | "diff": { |
|
| 551 | "' . self::$tableUser . '": [ |
|
| 552 | { |
|
| 553 | "mode": "InvalidMode", |
|
| 554 | "pk": [], |
|
| 555 | "column": [] |
|
| 556 | } |
|
| 557 | ] |
|
| 558 | } |
|
| 559 | }'; |
|
| 560 | ||
| 561 | $dbDiff->import($json); |
|
| 562 | $dbDiff->rollback(); |
|
| 563 | } |
|
| 564 | ||
| 565 | ||
| 566 | /** |
|