Changeset 20492 for lang/php/misc/Hermit/src/Hermit/resultset/HermitProcedureResultSet.php

Timestamp:

10/02/08 18:12:10 (3 months ago)

Author:

nowelium

Message:

mysql の procedure サポートは終わり。
General error: 2014 Cannot execute queries while other unbuffered queries are active. とかは、PDOのPDO::MYSQL_ATTR_USE_BUFFERED_QUERY をいくら設定してもダメなので、少し逃げ。一端切断すればなんとかなるけど、Datasource設定とかは管理外なので、やらない。
multi rows は 2次元配列で。

Files:

• lang/php/misc/Hermit/src/Hermit/resultset/HermitProcedureResultSet.php (modified) (2 diffs)

lang/php/misc/Hermit/src/Hermit/resultset/HermitProcedureResultSet.php

@@ -4 +4 @@
  * @author nowelium
  */
-class HermitProcedureResultSet implements HermitResultSet, HermitParameterBind {
+class HermitProcedureResultSet implements HermitResultSet {
     protected $procParameter;
     public function __construct(HermitProcedureParameter $procParameter){
@@ -10 +10 @@
     }
     public function execute(HermitStatement $stmt, HermitValueType $type){
+        if($stmt->columnCount() < 1){
+            $stmt->closeCursor();
+            unset($stmt);
+            return null;
+        }
         $type->apply($stmt);
 
-        if($stmt->columnCount() < 1){
-            return null;
-        }
+//        $rows = array();
+//        while($row = $stmt->fetch()){
+//            $rows[] = $row;
+//        }
+//        if(!$stmt->nextRowset()){
+//            return $rows;
+//        }
+//
+//        $results = array();
+//        $results[] = $rows;
+//        do {
+//            $rows = array();
+//            while($row = $stmt->fetch()){
+//                $rows[] = $row;
+//            }
+//            $results[] = $rows;
+//        } while($stmt->nextRowset());
+//
+//        $stmt->closeCursor();
+//        unset($stmt);
+//        return $results;
 
+        // multiresult so always to array[array]
         $results = array();
         do {
-            $row = $stmt->fetch();
-            if(false === $row){
-                break;
+            $rows = array();
+            while($row = $stmt->fetch()){
+                $rows[] = $row;
             }
-            $results[] = $row;
+            $results[] = $rows;
         } while($stmt->nextRowset());
+        
+        $stmt->closeCursor();
+        unset($stmt);
         return $results;
     }
-    public function bindParameter(PDO $pdo, array $parameter){
-    }
 }