* @link http://www.pradosoft.com/ * @copyright Copyright © 2005-2015 PradoSoft * @license http://www.pradosoft.com/license/ * @package System.Data.SqlMap.Statements */ Prado::using('System.Data.Common.TDbMetaData'); Prado::using('System.Data.Common.TDbCommandBuilder'); /** * TPreparedCommand class. * * @author Wei Zhuo * @package System.Data.SqlMap.Statements * @since 3.1 */ class TPreparedCommand { public function create(TSqlMapManager $manager, $connection, $statement, $parameterObject,$skip=null,$max=null) { $sqlText = $statement->getSQLText(); $prepared = $sqlText->getPreparedStatement($parameterObject); $connection->setActive(true); $sql = $prepared->getPreparedSql(); if($sqlText instanceof TSimpleDynamicSql) $sql = $sqlText->replaceDynamicParameter($sql, $parameterObject); if($max!==null || $skip!==null) { $builder = TDbMetaData::getInstance($connection)->createCommandBuilder(); $sql = $builder->applyLimitOffset($sql,$max,$skip); } $command = $connection->createCommand($sql); $this->applyParameterMap($manager, $command, $prepared, $statement, $parameterObject); return $command; } protected function applyParameterMap($manager,$command,$prepared, $statement, $parameterObject) { $properties = $prepared->getParameterNames(false); //$parameters = $prepared->getParameterValues(); $registry=$manager->getTypeHandlers(); if ($properties) for($i = 0, $k=$properties->getCount(); $i<$k; $i++) { $property = $statement->parameterMap()->getProperty($i); $value = $statement->parameterMap()->getPropertyValue($registry,$property, $parameterObject); $dbType = $property->getDbType(); if($dbType=='') //relies on PHP lax comparison $command->bindValue($i+1,$value, TDbCommandBuilder::getPdoType($value)); else if(strpos($dbType, 'PDO::')===0) $command->bindValue($i+1,$value, constant($property->getDbType())); //assumes PDO types, e.g. PDO::PARAM_INT else $command->bindValue($i+1,$value); } } }