sql >> Base de Datos >  >> RDS >> Mysql

Detener consulta a través de pdo

El principal problema aquí es compartir PID entre su solicitud asíncrona que genera el informe y el script que debería detenerlo.

Puede obtener su PID usando:

    $stmt = $dbh->prepare("SELECT CONNECTION_ID()");
    $stmt->execute();
    $pid = $stmt->fetchColumn();

Y puedes usar algo como php-shared-memory para crear una variable compartida entre sus scripts. Si no está utilizando Composer para las dependencias de su proyecto, esta biblioteca tiene una versión independiente (1.5.0, aquí ).

Ejemplo de implementación:

<?php

if (!include __DIR__ . '/vendor/autoload.php')
{
    die('You must set up the project dependencies.');
}

use Fuz\Component\SharedMemory\SharedMemory;
use Fuz\Component\SharedMemory\Storage\StorageFile;

// your intializations here

$storage = new StorageFile("/tmp/shared.{$user_id}.sync");
$shared = new SharedMemory($storage);

if (!isset($_POST['cancel_request']))
{
    $stmt = $dbh->prepare("SELECT CONNECTION_ID()");
    $stmt->execute();
    $pid = $stmt->fetchColumn();

    $shared->pid = $pid;

    // your long query here

    $shared->destroyStorage();
}
else
{
    // kills pid
    $pid = $shared->pid;
    if (!is_null($pid))
    {
        $dbh->exec("KILL {$pid}");
    }
}