MySQL查询的Symfony命令

Question

我正在尝试创建一个Symfony命令，其中它运行查询并最终作为Cronjob运行。有人对这个有经验么？到目前为止，这是我的代码。我想知道我应该在哪里创建我的查询。

namespace KCMGivingBundleCommand;
use SymfonyBundleFrameworkBundleCommandContainerAwareCommand;
use SymfonyComponentConsoleInputInputArgument;
use SymfonyComponentConsoleInputInputInterface;
use SymfonyComponentConsoleInputInputOption;
use SymfonyComponentConsoleOutputOutputInterface;


class GivingTranReport extends ContainerAwareCommand
{
    protected function configure()
    {
        $this
            ->setName('giving:report')
            ->setDescriptio('Runs query for giving transactions on hold')
        ;
    }
   protected function execute(InputInterface $input, OutputInterface $output)
   {


   }

Answer 1

做类似：

的事情

protected function execute(InputInterface $input, OutputInterface $output)
{
    $connection = $this->getContainer()->get('doctrine')->getConnection();
    $connection->executeUpdate("UPDATE mytable SET mycol = 1 WHERE id = 1");
}