Changeset 20492 for lang/php/misc/Hermit/src/Hermit/creator/HermitProcedureCallSqlCreator.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/creator/HermitProcedureCallSqlCreator.php (modified) (1 diff)

lang/php/misc/Hermit/src/Hermit/creator/HermitProcedureCallSqlCreator.php

@@ -4 +4 @@
  * @author nowelum
  */
-class HermitProcedureCallSqlCreator implements HermitSqlCreator {
+class HermitProcedureCallSqlCreator implements HermitSqlCreator, HermiSetupSqlCreator {
     private $sql;
+    private $setupSql;
     public function initialize(PDO $pdo, ReflectionMethod $method, HermitAnnote $annote){
         $procedureName = $annote->getProcedure($method);
         $dbMeta = HermitDatabaseMetaFactory::get($pdo);
         $info = $dbMeta->getProcedureInfo($procedureName);
-        $parameterNames = $info->getParamNames();
-        $sql = 'CALL';
-        $sql .= ' ';
-        $sql .= $procedureName;
-        $sql .= '(';
-        foreach($parameterNames as $parameterName){
-            $sql .= '/*' . $parameterName . '*/';
-            $sql .= '"' . $parameterName . '"';
-            $sql .= ',';
-        }
-        $sql = substr($sql, 0, -1);
-        $sql .= ')';
-        $this->sql = $sql;
+
+        $this->setupSql = self::generateSetupSql($info);
+        $this->sql = self::generateCallSql($info);
     }
     public function createSql(){
         return $this->sql;
     }
+    public function createSetupSql(){
+        return $this->setupSql;
+    }
+    public function hasSetupSql(){
+        return null !== $this->setupSql;
+    }
+    protected static function generateCallSql(HermitProcedureInfo $info){
+        $parameterNames = $info->getParamNames();
+        $callSql = 'CALL';
+        $callSql .= ' ';
+        $callSql .= $info->getName();
+        $callSql .= '(';
+        foreach($parameterNames as $parameterName){
+            $callSql .= '/*' . $parameterName . '*/';
+            $callSql .= '"' . $parameterName . '"';
+            $callSql .= ',';
+        }
+        $callSql = substr($callSql, 0, -1);
+        $callSql .= ')';
+        return $callSql;
+    }
+    protected static function generateSetupSql(HermitProcedureInfo $info){
+        $begin = false;
+        $parameterNames = $info->getParamNames();
+
+        $setupSql = 'SET';
+        $setupSql .= ' ';
+        foreach($parameterNames as $parameterName){
+            if($info->typeofIn($parameterName)){
+               continue;
+            }
+            $begin = true;
+            $setupSql .= '@' . $parameterName;
+            $setupSql .= ' = ';
+            $setupSql .= '/*' . $parameterName . '*/';
+            $setupSql .= '"' . $parameterName . '"';
+            $setupSql .= ',';
+        }
+        if(!$begin){
+            return null;
+        }
+        return substr($setupSql, 0, -1);
+    }
 }