Cacher is the code snippet organizer for pro developers

<?php

use Behat\Symfony2Extension\Context\KernelAwareInterface;
use Behat\Symfony2Extension\Context\KernelDictionary;
use Behat\MinkExtension\Context\MinkContext;

class MysqlContext extends MinkContext implements KernelAwareInterface
{
    use KernelDictionary;
    
    /**
     * @AfterScenario
     */
    public function killMysqlConnections()
    {
        $connections = $this->kernel->getContainer()->get('doctrine')->getConnections();

        foreach ($connections as $connection) {
            $threads = $connection->query('SHOW FULL PROCESSLIST');

            while ($thread = $threads->fetch()) {
                if ($thread['db'] == $connection->getDatabase() && $thread['Command'] == 'Sleep') {
                    $connection->query(sprintf('KILL %d', $thread['Id']));
                }
            }
        }
    }
}