bug57702.phpt 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187
  1. --TEST--
  2. PDO OCI Bug #57702 (Multi-row BLOB fetches)
  3. --EXTENSIONS--
  4. pdo
  5. pdo_oci
  6. --SKIPIF--
  7. <?php
  8. require(__DIR__.'/../../pdo/tests/pdo_test.inc');
  9. PDOTest::skip();
  10. ?>
  11. --FILE--
  12. <?php
  13. require('ext/pdo/tests/pdo_test.inc');
  14. $db = PDOTest::test_factory('ext/pdo_oci/tests/common.phpt');
  15. // Note the PDO test setup sets PDO::ATTR_STRINGIFY_FETCHES to true
  16. // (and sets PDO::ATTR_CASE to PDO::CASE_LOWER)
  17. $query = "begin execute immediate 'drop table bug57702'; exception when others then if sqlcode <> -942 then raise; end if; end;";
  18. $stmt = $db->prepare($query);
  19. $stmt->execute();
  20. $query = "create table bug57702 (id number, data1 blob, data2 blob)";
  21. $stmt = $db->prepare($query);
  22. $stmt->execute();
  23. function do_insert($db, $id, $data1, $data2)
  24. {
  25. $db->beginTransaction();
  26. $stmt = $db->prepare("insert into bug57702 (id, data1, data2) values (:id, empty_blob(), empty_blob()) returning data1, data2 into :blob1, :blob2");
  27. $stmt->bindParam(':id', $id);
  28. $stmt->bindParam(':blob1', $blob1, PDO::PARAM_LOB);
  29. $stmt->bindParam(':blob2', $blob2, PDO::PARAM_LOB);
  30. $blob1 = null;
  31. $blob2 = null;
  32. $stmt->execute();
  33. fwrite($blob1, $data1);
  34. fclose($blob1);
  35. fwrite($blob2, $data2);
  36. fclose($blob2);
  37. $db->commit();
  38. }
  39. do_insert($db, 1, "row 1 col 1", "row 1 col 2");
  40. do_insert($db, 2, "row 2 col 1", "row 2 col 2");
  41. ////////////////////
  42. echo "First Query\n";
  43. // Fetch it back
  44. $stmt = $db->prepare('select data1, data2 from bug57702 order by id');
  45. $stmt->execute();
  46. $row = $stmt->fetch(PDO::FETCH_ASSOC);
  47. var_dump($row['data1']);
  48. var_dump($row['data2']);
  49. $row = $stmt->fetch(PDO::FETCH_ASSOC);
  50. var_dump($row['data1']);
  51. var_dump($row['data2']);
  52. ////////////////////
  53. echo "\nSecond Query\n";
  54. foreach($db->query("select data1 as d1, data2 as d2 from bug57702 order by id") as $row) {
  55. var_dump($row['d1']);
  56. var_dump($row['d2']);
  57. }
  58. ////////////////////
  59. echo "\nThird Query\n";
  60. $stmt = $db->prepare('select data1 as d3_1, data2 as d3_2 from bug57702 order by id');
  61. $rs = $stmt->execute();
  62. $stmt->bindColumn('d3_1' , $clob1, PDO::PARAM_LOB);
  63. $stmt->bindColumn('d3_2' , $clob2, PDO::PARAM_LOB);
  64. while ($stmt->fetch(PDO::FETCH_BOUND)) {
  65. var_dump($clob1);
  66. var_dump($clob2);
  67. }
  68. ////////////////////
  69. echo "\nFourth Query\n";
  70. $a = array();
  71. $i = 0;
  72. foreach($db->query("select data1 as d4_1, data2 as d4_2 from bug57702 order by id") as $row) {
  73. $a[$i][0] = $row['d4_1'];
  74. $a[$i][1] = $row['d4_2'];
  75. $i++;
  76. }
  77. for ($i = 0; $i < count($a); $i++) {
  78. var_dump($a[$i][0]);
  79. var_dump($a[$i][1]);
  80. }
  81. ////////////////////
  82. echo "\nFifth Query\n";
  83. $db->setAttribute(PDO::ATTR_STRINGIFY_FETCHES, false); // Let's use streams
  84. // Since each column only has one lob descriptor, the last row is
  85. // shown twice because the lob descriptor for each column is reused in
  86. // the stream
  87. $a = array();
  88. $i = 0;
  89. foreach($db->query("select data1 as d4_1, data2 as d4_2 from bug57702 order by id") as $row) {
  90. $a[$i][0] = $row['d4_1'];
  91. $a[$i][1] = $row['d4_2'];
  92. $i++;
  93. }
  94. for ($i = 0; $i < count($a); $i++) {
  95. var_dump(stream_get_contents($a[$i][0]));
  96. var_dump(stream_get_contents($a[$i][1]));
  97. }
  98. ////////////////////
  99. echo "\nSixth Query\n";
  100. $db->setAttribute(PDO::ATTR_STRINGIFY_FETCHES, false); // Let's use streams
  101. $a = array();
  102. $i = 0;
  103. foreach($db->query("select data1 as d4_1, data2 as d4_2 from bug57702 order by id") as $row) {
  104. $a[$i][0] = $row['d4_1'];
  105. $a[$i][1] = $row['d4_2'];
  106. var_dump(stream_get_contents($a[$i][0]));
  107. var_dump(stream_get_contents($a[$i][1]));
  108. $i++;
  109. }
  110. // Cleanup
  111. $query = "drop table bug57702";
  112. $stmt = $db->prepare($query);
  113. $stmt->execute();
  114. print "done\n";
  115. ?>
  116. --EXPECT--
  117. First Query
  118. string(11) "row 1 col 1"
  119. string(11) "row 1 col 2"
  120. string(11) "row 2 col 1"
  121. string(11) "row 2 col 2"
  122. Second Query
  123. string(11) "row 1 col 1"
  124. string(11) "row 1 col 2"
  125. string(11) "row 2 col 1"
  126. string(11) "row 2 col 2"
  127. Third Query
  128. string(11) "row 1 col 1"
  129. string(11) "row 1 col 2"
  130. string(11) "row 2 col 1"
  131. string(11) "row 2 col 2"
  132. Fourth Query
  133. string(11) "row 1 col 1"
  134. string(11) "row 1 col 2"
  135. string(11) "row 2 col 1"
  136. string(11) "row 2 col 2"
  137. Fifth Query
  138. string(11) "row 2 col 1"
  139. string(11) "row 2 col 2"
  140. string(11) "row 2 col 1"
  141. string(11) "row 2 col 2"
  142. Sixth Query
  143. string(11) "row 1 col 1"
  144. string(11) "row 1 col 2"
  145. string(11) "row 2 col 1"
  146. string(11) "row 2 col 2"
  147. done