Task/Database/DatabaseUpdaterTask.php
protected function initializeStatement(ProcessState $state)
    {
        $connection = $this->getConnection($state);

        return $connection->executeQuery($this->getOption($state, 'sql'));
    }
protected function initializeStatement(ProcessState $state)
    {
        $connection = $this->getConnection($state);

        return $connection->executeQuery($this->getOption($state, 'sql'));
    }
@param ProcessState $state

@throws \Symfony\Component\OptionsResolver\Exception\ExceptionInterface
@throws \InvalidArgumentException
@throws \Doctrine\DBAL\DBALException

@return \Doctrine\DBAL\Driver\Statement