Skip to content

Commit

Permalink
Merge pull request #4092 from morozov/remove-connection-is-connected
Browse files Browse the repository at this point in the history
Remove Connection::$isConnected
  • Loading branch information
morozov authored Jun 19, 2020
2 parents 1738936 + 2cedd22 commit 334e298
Showing 1 changed file with 5 additions and 16 deletions.
21 changes: 5 additions & 16 deletions lib/Doctrine/DBAL/Connection.php
Original file line number Diff line number Diff line change
Expand Up @@ -98,13 +98,6 @@ class Connection implements DriverConnection
/** @var ExpressionBuilder */
protected $_expr;

/**
* Whether or not a connection has been established.
*
* @var bool
*/
private $isConnected = false;

/**
* The current auto-commit mode of this connection.
*
Expand Down Expand Up @@ -192,8 +185,7 @@ public function __construct(
$this->params = $params;

if (isset($params['pdo'])) {
$this->_conn = $params['pdo'];
$this->isConnected = true;
$this->_conn = $params['pdo'];
unset($this->params['pdo']);
}

Expand Down Expand Up @@ -356,16 +348,15 @@ public function getExpressionBuilder()
*/
public function connect()
{
if ($this->isConnected) {
if ($this->_conn !== null) {
return false;
}

$driverOptions = $this->params['driverOptions'] ?? [];
$user = $this->params['user'] ?? null;
$password = $this->params['password'] ?? null;

$this->_conn = $this->_driver->connect($this->params, $user, $password, $driverOptions);
$this->isConnected = true;
$this->_conn = $this->_driver->connect($this->params, $user, $password, $driverOptions);

$this->transactionNestingLevel = 0;

Expand Down Expand Up @@ -524,7 +515,7 @@ public function setAutoCommit($autoCommit)
$this->autoCommit = $autoCommit;

// Commit all currently active transactions if any when switching auto-commit mode.
if ($this->isConnected !== true || $this->transactionNestingLevel === 0) {
if ($this->_conn === null || $this->transactionNestingLevel === 0) {
return;
}

Expand Down Expand Up @@ -689,7 +680,7 @@ public function fetchOne(string $query, array $params = [], array $types = [])
*/
public function isConnected()
{
return $this->isConnected;
return $this->_conn !== null;
}

/**
Expand Down Expand Up @@ -771,8 +762,6 @@ public function delete($tableExpression, array $identifier, array $types = [])
public function close()
{
$this->_conn = null;

$this->isConnected = false;
}

/**
Expand Down

0 comments on commit 334e298

Please sign in to comment.