diff --git a/src/Command.php b/src/Command.php index f73ca139..04baaa4a 100644 --- a/src/Command.php +++ b/src/Command.php @@ -60,11 +60,6 @@ public function showDatabases(): array return $this->setSql($sql)->queryColumn(); } - protected function getQueryBuilder(): QueryBuilderInterface - { - return $this->db->getQueryBuilder(); - } - /** * Executes the SQL statement. * @@ -105,43 +100,6 @@ public function execute(): int return $result; } - /** - * @psalm-suppress UnusedClosureParam - * - * @throws Throwable - */ - protected function internalExecute(string|null $rawSql): void - { - $attempt = 0; - - while (true) { - try { - if ( - ++$attempt === 1 - && $this->isolationLevel !== null - && $this->db->getTransaction() === null - ) { - $this->db->transaction( - function () use ($rawSql): void { - $this->internalExecute($rawSql); - }, - $this->isolationLevel, - ); - } else { - $this->pdoStatement?->execute(); - } - break; - } catch (PDOException $e) { - $rawSql = $rawSql ?: $this->getRawSql(); - $e = (new ConvertException($e, $rawSql))->run(); - - if ($this->retryHandler === null || !($this->retryHandler)($e, $attempt)) { - throw $e; - } - } - } - } - /** * Performs the actual DB query of an SQL statement. *