123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121 |
- <?php
- namespace Doctrine\DBAL\Driver;
- use Doctrine\DBAL\ParameterType;
- use PDO;
- use function count;
- use function func_get_args;
- /**
- * PDO implementation of the Connection interface.
- * Used by all PDO-based drivers.
- */
- class PDOConnection extends PDO implements Connection, ServerInfoAwareConnection
- {
- /**
- * @param string $dsn
- * @param string|null $user
- * @param string|null $password
- * @param mixed[]|null $options
- *
- * @throws PDOException In case of an error.
- */
- public function __construct($dsn, $user = null, $password = null, ?array $options = null)
- {
- try {
- parent::__construct($dsn, $user, $password, $options);
- $this->setAttribute(PDO::ATTR_STATEMENT_CLASS, [PDOStatement::class, []]);
- $this->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
- } catch (\PDOException $exception) {
- throw new PDOException($exception);
- }
- }
- /**
- * {@inheritdoc}
- */
- public function exec($statement)
- {
- try {
- return parent::exec($statement);
- } catch (\PDOException $exception) {
- throw new PDOException($exception);
- }
- }
- /**
- * {@inheritdoc}
- */
- public function getServerVersion()
- {
- return PDO::getAttribute(PDO::ATTR_SERVER_VERSION);
- }
- /**
- * {@inheritdoc}
- */
- public function prepare($prepareString, $driverOptions = [])
- {
- try {
- return parent::prepare($prepareString, $driverOptions);
- } catch (\PDOException $exception) {
- throw new PDOException($exception);
- }
- }
- /**
- * {@inheritdoc}
- */
- public function query()
- {
- $args = func_get_args();
- $argsCount = count($args);
- try {
- if ($argsCount === 4) {
- return parent::query($args[0], $args[1], $args[2], $args[3]);
- }
- if ($argsCount === 3) {
- return parent::query($args[0], $args[1], $args[2]);
- }
- if ($argsCount === 2) {
- return parent::query($args[0], $args[1]);
- }
- return parent::query($args[0]);
- } catch (\PDOException $exception) {
- throw new PDOException($exception);
- }
- }
- /**
- * {@inheritdoc}
- */
- public function quote($input, $type = ParameterType::STRING)
- {
- return parent::quote($input, $type);
- }
- /**
- * {@inheritdoc}
- */
- public function lastInsertId($name = null)
- {
- try {
- return parent::lastInsertId($name);
- } catch (\PDOException $exception) {
- throw new PDOException($exception);
- }
- }
- /**
- * {@inheritdoc}
- */
- public function requiresQueryForServerVersion()
- {
- return false;
- }
- }
|