|
|
|
@ -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);
|
|
|
|
|