使用 preRemove/postRemove 事件来获取哪些查询可以执行，哪些不能执行

我在脑海中思考这个问题有一段时间了，现在我需要一些关于 preRemove/postRemove 事件的建议，因为我将执行的查询基本上是DELETE但这也应该适用于 prePersist/postPersist 和 preUpdate/postUpdate （不知道那些最新的是否真的存在）。

我有两种可能的情况在多个实体中执行 DELETE （请参阅foreach loop):

// First approach
$itemsRemoved = $itemsNonRemoved = [];
foreach($someVar as $item) {
    $item = $em->getRepository('someEntity')->find($item['value']);
    try {
        $em->remove($item);
        $em->flush();
        array_push($itemsRemoved, $item['value']);
    } catch (Exception $e) {
        dump($e->getMessage());
        array_push($itemsNonRemoved, $item['value']);
    }
}

// Second approach
$itemsRemoved = $itemsNonRemoved = [];
foreach($someVar as $item) {
    $item = $em->getRepository('someEntity')->find($item['value']);
    $em->remove($item);
}

$em->flush();

不推荐第一种方法，也可以@acontell用户说this https://stackoverflow.com/questions/27988758/difference-between-call-flush-inside-foreach-loop-or-outside-it-which-one-to回答执行flush()是一种反模式，也会影响应用程序性能，因为每次都需要执行多个查询，但使用这种方法我可以知道哪个查询被插入，哪个查询没有插入。

使用第二种方法，我将避免反模式并提高性能，但我如何知道哪个项目已插入，哪个没有插入？另外，如果默认情况下任何查询失败，Doctrine 都会进行回滚，因此不会插入任何查询。

那么，我可以使用 preRemove/postRemove 事件来获取哪些查询可以执行，哪些查询不能意味着插入或不插入哪些值吗？

这个问题与this https://stackoverflow.com/questions/27988758/difference-between-call-flush-inside-foreach-loop-or-outside-it-which-one-to and this https://stackoverflow.com/questions/28079661/delete-row-from-related-entity-in-many-to-many-relationship-in-doctrine2 ones.

现实生活中的例子

Since @acontell给我另一个很好的答案，我需要一些建议来看看我是否得到了全部内容，或者我仍然迷失了所以这里是一个现实生活中的例子：

        foreach ($request->request->get( 'items' ) as $item) {
            $relacion = $this->get( 'database_connection' )->fetchColumn(
                'SELECT COUNT(fabricante_producto_solicitud_id) AS cnt FROM negocio.fabricante_modelo_marca_producto WHERE fabricante_producto_solicitud_id = ?',
                array( $item['value'] )
            );               

            if ($relacion === 0) {
                $entFabricanteProductoSolicitud = $em->getRepository(
                    "AppBundle:FabricanteProductoSolicitud"
                )->find( $item['value'] );

                try {
                    $em->remove( $entFabricanteProductoSolicitud );
                    $em->flush();
                    array_push( $itemsRemoved, $item['value'] );

                    $response['success'] = true;
                    $status              = 200;
                } catch ( \Exception $e ) {
                    $status = 400;
                    dump( $e->getMessage() );

                    return new JsonResponse( $response, $status ?: 200 );
                }
            }

            $response['itemsRemoved'] = $itemsRemoved;
        }
    }

如果我得到它，那么LifeCycleCallbacks应该进去AppBundle:FabricanteProductoSolicitud在哪里执行 DELETE，是吗？

EDIT: 另外，我想知道在多个实体上使用代码的最佳方法，因为我在大多数实体中都会有这种行为，那么为此目的定义一个 Trait 应该没问题吗？应该被定义为任何其他特征吗？

这已得到答复here https://stackoverflow.com/a/28111353/719427我自己使用用户评论作为输入，希望它可以帮助其他人

由 @acontell 对代码执行一些测试

这就是我的代码此时的样子：

public function eliminarNormasAction(Request $request)
{
    if ($request->isXmlHttpRequest()) {
        $em = $this->getDoctrine()->getManager();
        $response['success']  = false;
        $entProducto = $em->getRepository('AppBundle:Producto')->find($request->request->get('producto'));
        $response['success']  = false;
        $status = null;

        $ids = [];
        foreach($request->request->get( 'items' ) as $item) {
            array_push( $ids, $item['value'] );
        }

        $qb = $em->createQueryBuilder();
        $entNorma = $qb
            ->select("q")
            ->from('AppBundle:Norma', 'q')
            ->add('where', $qb->expr()->in('q.id', ':ids'))
            ->setParameter('ids', $ids)
            ->getQuery()
            ->getResult();

        // Initialize arrays (useful to reset them also)
        Entity\Producto::prepareArrays();

        foreach($entNorma as $norma) {
            // here entities are persisted since rows there is not more at DB
            $entProducto->removeProductoNorma( $norma );  
        }

        try {
            $em->flush();
            $response['success'] = true;
        } catch (\Exception $e) {
            $status = 400;
        }

        $response['itemsRemoved']    = Entity\Producto::getDeletedEntities();
        $response['itemsNonRemoved'] = Entity\Producto::getNotDeletedEntities();
    } else {
        $response['error'] = $this->get('translator')->trans('mensajes.msgPeticionXMLHttpRequestInvalida');
    }

    return new JsonResponse($response, $status ?: 200);
}

问题Entity\Producto::getDeletedEntities()返回一个没有删除值的空数组，为什么？

我就是这样做的。我并不是说这是最好的方法，如果有人知道更简单或更好的东西，我将是第一个有兴趣学习它的人。

首先，这些是教义事件 http://docs.doctrine-project.org/projects/doctrine-orm/en/latest/reference/events.html#lifecycle-events您可以使用。为了简单起见，我将解释如何进行删除。另外为了简单起见，我将使用静态数组（可以通过其他方式完成，我喜欢这个）并且生命周期回调 http://symfony.com/doc/current/book/doctrine.html#lifecycle-callbacks。在这种情况下，回调将是非常简单的方法（这就是为什么可以使用它们而不是实现听众或订阅者 http://symfony.com/doc/current/cookbook/doctrine/event_listeners_subscribers.html).

假设我们有这个实体：

Acme\MyBundle\Entity\Car:
    type: entity
    table: cars
    id:
        id:
            type: integer
            id: true
            generator:
                strategy: AUTO
    fields:
        name:
            type: string
            length: '25'
            unique: true
        color:
            type: string
            length: '64'
    lifecycleCallbacks:
        preRemove: [entityDueToDeletion]
        postRemove: [entityDeleted]

如您所见，我定义了两个将由 preRemove 事件和 postRemove 事件触发的回调。

preRemove - 给定实体的 preRemove 事件发生在 执行该实体的相应 EntityManager 删除操作。 DQL DELETE 语句不会调用它。

postRemove - postRemove 事件发生在实体 实体已被删除。数据库删除后会调用 运营。 DQL DELETE 语句不会调用它。

然后实体的php代码：

class Car {

    // Getters & setters and so on, not going to copy them here for simplicity

    private static $preDeletedEntities;// static array that will contain entities due to deletion.
    private static $deletedEntities;// static array that will contain entities that were deleted (well, at least the SQL was thrown).

    public function entityDueToDeletion() {// This callback will be called on the preRemove event
        self::$preDeletedEntities[] = $this->getId();// This entity is due to be deleted though not deleted yet.
    }

    public function entityDeleted() {// This callback will be called in the postRemove event
        self::$deletedEntities[] = $this->getId();// The SQL to delete the entity has been issued. Could fail and trigger the rollback in which case the id doesn't get stored in the array.
    }

    public static function getDeletedEntities() {
        return array_slice(self::$preDeletedEntities, 0, count(self::$deletedEntities));
    }

    public static function getNotDeletedEntities() {
        return array_slice(self::$preDeletedEntities, count(self::$deletedEntities)+1, count(self::$preDeletedEntities));
    }

    public static function getFailedToDeleteEntity() {
        if(count(self::$preDeletedEntities) == count(self::$deletedEntities)) {
            return NULL; // Everything went ok
        }
        return self::$preDeletedEntities[count(self::$deletedEntities)]; // We return the id of the entity that failed.
    }

    public static function prepareArrays() {
        self::$preDeletedEntities = array();
        self::$deletedEntities = array();
    }
}

请注意回调以及静态数组和方法。每次通过 a 调用删除Car实体，即preRemove回调会将实体的 id 存储在数组中$preDeletedEntities。当实体被删除时，postRemove事件会将 id 存储在$entityDeleted. The preRemove事件很重要，因为我们想知道哪个实体导致交易失败。

现在，在控制器中我们可以这样做：

use Acme\MyBundle\Entity\Car;

$qb = $em->createQueryBuilder();
$ret = $qb
        ->select("c")
        ->from('AcmeMyBundle:Car', 'c')
        ->add('where', $qb->expr()->in('c.id', ':ids'))
        ->setParameter('ids', $arrayOfIds)
        ->getQuery()
        ->getResult();

Car::prepareArrays();// Initialize arrays (useful to reset them also)
foreach ($ret as $car) {// Second approach
    $em->remove($car);
}

try {
    $em->flush();
} catch (\Exception $e) {
    $couldBeDeleted = Car::getDeletedEntities();
    $entityThatFailed = Car::getFailedToDeleteEntity();
    $notDeletedCars = Car::getNotDeletedEntities();

    // Do what you please, you can delete those entities that didn't fail though you'll have to reset the entitymanager (it'll be closed by now due to the exception).

    return $this->render('AcmeMyBundle:Car:errors.html.twig', array(// I'm going to respond with the ids that could've succeded, the id that failed and those entities that we don't know whether they could've succeeded or not.
                'deletedCars' => $couldBeDeleted,
                'failToDeleteCar' => $entityThatFailed,
                'notDeletedCars' => $notDeletedCars,
    ));
}

希望能帮助到你。它的实现比第一种方法要麻烦一些，但在性能方面要好得多。

UPDATE

我将尝试更多地解释一下内部发生的事情catch block:

至此，交易失败。由于无法删除某些实体（例如由于 fk 约束），因此引发了异常。

事务已回滚，并且实际上没有从数据库中删除任何实体。

$deletedCars是一个变量，其中包含那些本来可以被删除（它们没有引发任何异常）但没有（因为回滚）的实体的 id。

$failToDeleteCar包含其删除引发异常的实体的 ID。

$notDeletedCars包含事务中的其余实体 ID，但我们不知道是否会成功。

此时，您可以重置实体管理器（它已关闭），使用不会导致问题的 id 启动另一个查询并删除它们（如果您愿意），然后发回一条消息，让用户知道您删除了这些实体，并且$failToDeleteCar失败且未被删除$notDeletedCars也没有被删除。由您决定要做什么。

我无法重现你提到的问题Entity::getDeletedEntities()，这里工作正常。

您可以优化代码，以便不需要将此方法添加到实体（甚至不需要生命周期回调）。例如，您可以利用订阅者来捕获事件，并使用具有静态方法的特殊类来跟踪那些未失败的实体、失败的实体以及那些没有机会被删除的实体/更新/插入。我建议您参考我提供的文档。这比听起来要复杂一些，无法在几行代码中为您提供通用答案，抱歉，您必须进一步调查。

我的建议是您尝试使用我提供的假实体代码并进行一些测试以完全理解它是如何工作的。然后您可以尝试将其应用到您的实体中。

祝你好运！