Changeset 29506

Timestamp:

02/04/09 11:54:01 (4 years ago)

Author:

nowelium

Message:

とりあえず、preparedStatementを利用できるようにbatchMode

Location:

lang/php/misc/Hermit/src

Files:

• Hermit/HermitContext.php (modified) (2 diffs)
• Hermit/annote/HermitAnnote.php (modified) (1 diff)
• Hermit/annote/HermitAnnoteConst.php (modified) (2 diffs)
• Hermit/command/AbstractHermitSqlCommand.php (modified) (1 diff)
• Hermit/command/HermitDeleteCommand.php (modified) (1 diff)
• Hermit/command/HermitDeleteSqlCommandFactory.php (modified) (1 diff)
• Hermit/command/HermitInsertCommand.php (modified) (1 diff)
• Hermit/command/HermitInsertSqlCommandFactory.php (modified) (1 diff)
• Hermit/command/HermitProcedureSqlCommandFactory.php (modified) (1 diff)
• Hermit/command/HermitSelectCommand.php (modified) (1 diff)
• Hermit/command/HermitSelectSqlCommandFactory.php (modified) (1 diff)
• Hermit/command/HermitUpdateCommand.php (modified) (1 diff)
• Hermit/command/HermitUpdateSqlCommandFactory.php (modified) (1 diff)
• Queue/HermitQueueDao.php (modified) (1 diff)

lang/php/misc/Hermit/src/Hermit/HermitContext.php

@@ -6 +6 @@
 class HermitContext {
     protected $reflector;
+    protected $batchMode = false;
     public function __construct(ReflectionClass $reflector){
         $this->reflector = $reflector;
@@ -18 +19 @@
         return $this->reflector;
     }
+    public function setBatchMode($mode){
+        $this->batchMode = $mode;
+    }
+    public function isBatchMode(){
+        return $this->batchMode;
+    }
 }

lang/php/misc/Hermit/src/Hermit/annote/HermitAnnote.php

@@ -17 +17 @@
     public abstract function getQuery(ReflectionMethod $method);
     public abstract function getValueType(ReflectionMethod $method);
+    public abstract function getBatchMode(ReflectionMethod $method);
     public static final function create(ReflectionClass $reflector){
         return new HermitAnnoteConst($reflector);

lang/php/misc/Hermit/src/Hermit/annote/HermitAnnoteConst.php

@@ -14 +14 @@
     const PROCEDURE_SUFFIX = '_PROCEDURE';
     const VALUE_TYPE_SUFFIX = '_VALUE_TYPE';
+    const BATCH_MODE_SUFFIX = '_BATCH_MODE';
     const CHECK_SINGLE_ROW_UPDATE = 'CHECK_SINGLE_ROW_UPDATE';
     
@@ -120 +121 @@
         return $valueType;
     }
+    public function getBatchMode(ReflectionMethod $method){
+        $batchMode = self::getMethodAnnotation($this->reflector, $method, self::BATCH_MODE_SUFFIX);
+        if(null === $batchMode){
+            return self::getClassAnnotation($this->reflector, self::DEFAULT_PREFIX . self::BATCH_MODE_SUFFIX);
+        }
+        return $batchMode;
+    }
     public function getColumns(){
         $columns = $this->reflector->getConstant(self::COLUMNS_KEY);

lang/php/misc/Hermit/src/Hermit/command/AbstractHermitSqlCommand.php

@@ -9 +9 @@
     protected $sqlCreator;
     protected $type;
+    protected $statement;
     public function setContext(HermitContext $ctx){
         $this->context = $ctx;

lang/php/misc/Hermit/src/Hermit/command/HermitDeleteCommand.php

@@ -7 +7 @@
     public function execute(array $parameters){
         $pdo = $this->getConnection(HermitEvent::EVT_DELETE);
-        $builder = new HermitStatementBuilder($this->context->getTargetClass(), $this->method, $this->sqlCreator);
-        $stmt = $builder->build($pdo, $parameters);
-        $stmt->execute($parameters);
+        $genStmt = false;
+        if(null === $this->statement){
+            $genStmt = true;
+        } else {
+            if(!$this->context->isBatchMode()){
+                $genStmt = true;
+            }
+        }
+        if($genStmt){
+            $builder = new HermitStatementBuilder($this->context->getTargetClass(), $this->method, $this->sqlCreator);
+            $this->statement = $builder->build($pdo, $parameters);
+        }
+        $this->statement->execute($parameters);
         $resultset = new HermitUpdateQueryResultSet;
-        return $resultset->execute($stmt, $this->type);
+        return $resultset->execute($this->statement, $this->type);
     }
 }

lang/php/misc/Hermit/src/Hermit/command/HermitDeleteSqlCommandFactory.php

@@ -16 +16 @@
         $valueType = HermitValueTypeFactory::create($this->annote, $this->method);
         
+        $batchMode = $this->annote->getBatchMode($this->method);
+        $context->setBatchMode($batchMode);
+        
         $command = new HermitDeleteCommand;
         $command->setContext($context);

lang/php/misc/Hermit/src/Hermit/command/HermitInsertCommand.php

@@ -7 +7 @@
     public function execute(array $parameters){
         $pdo = $this->getConnection(HermitEvent::EVT_INSERT);
-        $builder = new HermitStatementBuilder($this->context->getTargetClass(), $this->method, $this->sqlCreator);
-        $stmt = $builder->build($pdo, $parameters);
-        $stmt->execute($parameters);
+        $genStmt = false;
+        if(null === $this->statement){
+            $genStmt = true;
+        } else {
+            if(!$this->context->isBatchMode()){
+                $genStmt = true;
+            }
+        }
+        if($genStmt){
+            $builder = new HermitStatementBuilder($this->context->getTargetClass(), $this->method, $this->sqlCreator);
+            $this->statement = $builder->build($pdo, $parameters);
+        }
+        $this->statement->execute($parameters);
+        
         $resultset = new HermitUpdateQueryResultSet;
-        return $resultset->execute($stmt, $this->type);
+        return $resultset->execute($this->statement, $this->type);
     }
 }

lang/php/misc/Hermit/src/Hermit/command/HermitInsertSqlCommandFactory.php

@@ -13 +13 @@
         $valueType = HermitValueTypeFactory::create($this->annote, $this->method);
         
+        $batchMode = $this->annote->getBatchMode($this->method);
+        $context->setBatchMode($batchMode);
+        
         $command = new HermitInsertCommand;
         $command->setContext($context);

lang/php/misc/Hermit/src/Hermit/command/HermitProcedureSqlCommandFactory.php

@@ -18 +18 @@
         $valueType = HermitValueTypeFactory::create($this->annote, $this->method);
 
+        $batchMode = $this->annote->getBatchMode($this->method);
+        $context->setBatchMode($batchMode);
+        
         $command = new HermitProcedureCommand;
         $command->setContext($context);

lang/php/misc/Hermit/src/Hermit/command/HermitSelectCommand.php

@@ -7 +7 @@
     public function execute(array $parameters){
         $pdo = $this->getConnection(HermitEvent::EVT_SELECT);
-        $builder = new HermitStatementBuilder($this->context->getTargetClass(), $this->method, $this->sqlCreator);
-        $stmt = $builder->build($pdo, $parameters);
-        $stmt->execute($parameters);
+        $genStmt = false;
+        if(null === $this->statement){
+            $genStmt = true;
+        } else {
+            if(!$this->context->isBatchMode()){
+                $genStmt = true;
+            }
+        }
+        if($genStmt){
+            $builder = new HermitStatementBuilder($this->context->getTargetClass(), $this->method, $this->sqlCreator);
+            $this->statement = $builder->build($pdo, $parameters);
+        }
+        $this->statement->execute($parameters);
+        
         $resultset = HermitResultSetFactory::create($this->method);
-        return $resultset->execute($stmt, $this->type);
+        return $resultset->execute($this->statement, $this->type);
     }
 }

lang/php/misc/Hermit/src/Hermit/command/HermitSelectSqlCommandFactory.php

@@ -20 +20 @@
         }
         $valueType = HermitValueTypeFactory::create($this->annote, $this->method);
+        
+        $batchMode = $this->annote->getBatchMode($this->method);
+        $context->setBatchMode($batchMode);
         
         $command = new HermitSelectCommand;

lang/php/misc/Hermit/src/Hermit/command/HermitUpdateCommand.php

@@ -7 +7 @@
     public function execute(array $parameters){
         $pdo = $this->getConnection(HermitEvent::EVT_UPDATE);
-        $builder = new HermitStatementBuilder($this->context->getTargetClass(), $this->method, $this->sqlCreator);
-        $stmt = $builder->build($pdo, $parameters);
-        $stmt->execute($parameters);
+        $genStmt = false;
+        if(null === $this->statement){
+            $genStmt = true;
+        } else {
+            if(!$this->context->isBatchMode()){
+                $genStmt = true;
+            }
+        }
+        if($genStmt){
+            $builder = new HermitStatementBuilder($this->context->getTargetClass(), $this->method, $this->sqlCreator);
+            $this->statement = $builder->build($pdo, $parameters);
+        }
+        $this->statement->execute($parameters);
         $resultset = new HermitUpdateQueryResultSet;
-        return $resultset->execute($stmt, $this->type);
+        return $resultset->execute($this->statement, $this->type);
     }
 }

lang/php/misc/Hermit/src/Hermit/command/HermitUpdateSqlCommandFactory.php

@@ -15 +15 @@
         }
         $valueType = HermitValueTypeFactory::create($this->annote, $this->method);
+        $batchMode = $this->annote->getBatchMode($this->method);
+        $context->setBatchMode($batchMode);
         
         $command = new HermitUpdateCommand;

lang/php/misc/Hermit/src/Queue/HermitQueueDao.php

@@ -5 +5 @@
  */
 interface HermitQueueDao {
+    const default_BATCH_MODE = true;
+
     const wait_SQL = 'SELECT queue_wait(/*table*/"table", /*timeout*/5)';
     const wait_VALUE_TYPE = 'NUM';