|
|
|
@ -321,7 +321,6 @@ class Connection extends PrimaryReadReplicaConnection { |
|
|
|
public function executeStatement($sql, array $params = [], array $types = []): int { |
|
|
|
$tables = $this->getQueriedTables($sql); |
|
|
|
$this->tableDirtyWrites = array_unique(array_merge($this->tableDirtyWrites, $tables)); |
|
|
|
$this->logger->debug('dirty table writes: ' . $sql, ['tables' => $this->tableDirtyWrites]); |
|
|
|
$sql = $this->replaceTablePrefix($sql); |
|
|
|
$sql = $this->adapter->fixupStatement($sql); |
|
|
|
$this->queriesExecuted++; |
|
|
|
@ -644,16 +643,6 @@ class Connection extends PrimaryReadReplicaConnection { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
protected function performConnect(?string $connectionName = null): bool { |
|
|
|
$before = $this->isConnectedToPrimary(); |
|
|
|
$result = parent::performConnect($connectionName); |
|
|
|
$after = $this->isConnectedToPrimary(); |
|
|
|
if (!$before && $after) { |
|
|
|
$this->logger->debug('Switched to primary database', ['exception' => new \Exception()]); |
|
|
|
} |
|
|
|
return $result; |
|
|
|
} |
|
|
|
|
|
|
|
public function beginTransaction() { |
|
|
|
if (!$this->inTransaction()) { |
|
|
|
$this->transactionActiveSince = microtime(true); |
|
|
|
|