vendor/symfony/doctrine-bridge/Middleware/Debug/DBAL3/Statement.php line 78

Open in your IDE?
  1. <?php
  3. /*
  4. * This file is part of the Symfony package.
  5. *
  6. * (c) Fabien Potencier <fabien@symfony.com>
  7. *
  8. * For the full copyright and license information, please view the LICENSE
  9. * file that was distributed with this source code.
  10. */
  12. namespace Symfony\Bridge\Doctrine\Middleware\Debug\DBAL3;
  14. use Doctrine\DBAL\Driver\Middleware\AbstractStatementMiddleware;
  15. use Doctrine\DBAL\Driver\Result as ResultInterface;
  16. use Doctrine\DBAL\Driver\Statement as StatementInterface;
  17. use Doctrine\DBAL\ParameterType;
  18. use Symfony\Bridge\Doctrine\Middleware\Debug\DebugDataHolder;
  19. use Symfony\Bridge\Doctrine\Middleware\Debug\Query;
  20. use Symfony\Component\Stopwatch\Stopwatch;
  22. /**
  23. * @author Laurent VOULLEMIER <laurent.voullemier@gmail.com>
  24. *
  25. * @internal
  26. */
  27. final class Statement extends AbstractStatementMiddleware
  28. {
  29. private $query;
  30. private $debugDataHolder;
  31. private $connectionName;
  32. private $stopwatch;
  34. public function __construct(
  35. StatementInterface $statement,
  36. DebugDataHolder $debugDataHolder,
  37. string $connectionName,
  38. string $sql,
  39. ?Stopwatch $stopwatch = null
  40. ) {
  41. $this->stopwatch = $stopwatch;
  42. $this->connectionName = $connectionName;
  43. $this->debugDataHolder = $debugDataHolder;
  44. $this->query = new Query($sql);
  46. parent::__construct($statement);
  47. }
  49. public function bindParam($param, &$variable, $type = ParameterType::STRING, $length = null): bool
  50. {
  51. $this->query->setParam($param, $variable, $type);
  53. return parent::bindParam($param, $variable, $type, ...\array_slice(\func_get_args(), 3));
  54. }
  56. public function bindValue($param, $value, $type = ParameterType::STRING): bool
  57. {
  58. $this->query->setValue($param, $value, $type);
  60. return parent::bindValue($param, $value, $type);
  61. }
  63. public function execute($params = null): ResultInterface
  64. {
  65. if (null !== $params) {
  66. $this->query->setValues($params);
  67. }
  69. // clone to prevent variables by reference to change
  70. $this->debugDataHolder->addQuery($this->connectionName, $query = clone $this->query);
  72. if ($this->stopwatch) {
  73. $this->stopwatch->start('doctrine', 'doctrine');
  74. }
  75. $query->start();
  77. try {
  78. return parent::execute($params);
  79. } finally {
  80. $query->stop();
  81. if ($this->stopwatch) {
  82. $this->stopwatch->stop('doctrine');
  83. }
  84. }
  85. }
  86. }