pdo_017.phpt 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475
  1. --TEST--
  2. PDO Common: transactions
  3. --EXTENSIONS--
  4. pdo
  5. --SKIPIF--
  6. <?php
  7. $dir = getenv('REDIR_TEST_DIR');
  8. if (false == $dir) die('skip no driver');
  9. require_once $dir . 'pdo_test.inc';
  10. PDOTest::skip();
  11. $db = PDOTest::factory();
  12. try {
  13. $db->beginTransaction();
  14. } catch (PDOException $e) {
  15. die('skip no working transactions: ' . $e->getMessage());
  16. }
  17. if ($db->getAttribute(PDO::ATTR_DRIVER_NAME) == 'mysql') {
  18. require_once(__DIR__ . DIRECTORY_SEPARATOR . '../../pdo_mysql/tests/mysql_pdo_test.inc');
  19. if (false === MySQLPDOTest::detect_transactional_mysql_engine($db)) {
  20. die('skip your mysql configuration does not support working transactions');
  21. }
  22. }
  23. ?>
  24. --FILE--
  25. <?php
  26. if (getenv('REDIR_TEST_DIR') === false) putenv('REDIR_TEST_DIR='.__DIR__ . '/../../pdo/tests/');
  27. require_once getenv('REDIR_TEST_DIR') . 'pdo_test.inc';
  28. $db = PDOTest::factory();
  29. if ($db->getAttribute(PDO::ATTR_DRIVER_NAME) == 'mysql') {
  30. require_once(__DIR__ . DIRECTORY_SEPARATOR . '../../pdo_mysql/tests/mysql_pdo_test.inc');
  31. $suf = ' ENGINE=' . MySQLPDOTest::detect_transactional_mysql_engine($db);
  32. } else {
  33. $suf = '';
  34. }
  35. $db->exec('CREATE TABLE test(id INT NOT NULL PRIMARY KEY, val VARCHAR(10))'.$suf);
  36. $db->exec("INSERT INTO test VALUES(1, 'A')");
  37. $db->exec("INSERT INTO test VALUES(2, 'B')");
  38. $db->exec("INSERT INTO test VALUES(3, 'C')");
  39. $delete = $db->prepare('DELETE FROM test');
  40. function countRows($action) {
  41. global $db;
  42. $select = $db->prepare('SELECT COUNT(*) FROM test');
  43. $select->execute();
  44. $res = $select->fetchColumn();
  45. return "Counted $res rows after $action.\n";
  46. }
  47. echo countRows('insert');
  48. $db->beginTransaction();
  49. $delete->execute();
  50. echo countRows('delete');
  51. $db->rollBack();
  52. echo countRows('rollback');
  53. $db->beginTransaction();
  54. $delete->execute();
  55. echo countRows('delete');
  56. $db->commit();
  57. echo countRows('commit');
  58. ?>
  59. --EXPECT--
  60. Counted 3 rows after insert.
  61. Counted 0 rows after delete.
  62. Counted 3 rows after rollback.
  63. Counted 0 rows after delete.
  64. Counted 0 rows after commit.