Symfony2 – Ouvir eventos do Doctrine

Neste ProTip vou mostrar como ouvir eventos do Doctrine para que voc√™ possa acompanhar sempre que seu aplicativo interage com o banco de dados. Pode ser √ļtil se voc√™ deseja criar um fluxo de trabalho de log personalizado.

Em primeiro lugar, vamos registrar um serviço. Adicione o seguinte exemplo a services.yml do seu pacote. (Vendor / ExampleBundle / Resources / config / services.yml) Neste exemplo, enviarei 2 eventos.

# Listen Doctrine events
vendor
.example_bundle.listener.doctrine:
class: VendorExampleBundleServiceDoctrineListenerService
arguments
: ['@service_container']
tags
:
- { name: doctrine.event_listener, event: postUpdate }
- { name: doctrine.event_listener, event: postPersist }

E agora estamos criando a classe de ouvinte

namespace VendorExampleBundleService;

use DoctrineCommonEventSubscriber;
use DoctrineORMEventLifecycleEventArgs;
use SymfonyComponentDependencyInjectionContainerInterface;

class DoctrineListenerService implements EventSubscriber
{

protected $container;

public function __construct(ContainerInterface $container)
{
$this
->container = $container;
}

public function getSubscribedEvents()
{
return array(
'postPersist',
'postUpdate',
);
}

/**
* This method will called on Doctrine postPersist event

*/

public function postPersist(LifecycleEventArgs $args)
{
# Avoid to log the logging process
if (!$args->getEntity() instanceof Log)
# Handle the log creation
$this
->createLog($args, 'persist');
}

/**
* This method will called on Doctrine postUpdate event

*/

public function postUpdate(LifecycleEventArgs $args)
{
# Handle the log creation
$this
->createLog($args, 'update');
}

/**
* Handle the log creation

*/

public function createLog(LifecycleEventArgs $args, $action)
{
# Entity manager
$em
= $args->getEntityManager();
$entity
= $args->getEntity();

# Set DateTime()
$dateTime
= new DateTime();

# Get user
if (method_exists($this->container->get('security.context'), 'getUser')):

# Get current user
$user
= $this->container->get('security.context')->getToken()->getUser();

# ... Do some logging action

endif
;
}

}

Aqui estão os eventos que você também pode enviar

  • prePersist
  • preRemove
  • preFlush
  • onFlush
  • postFlush
  • preUpdate
  • postUpdate
  • postRemove
  • postPersist
  • postLoad