DatabaseController.php in Devel 8

Namespace

Drupal\webprofiler\Controller

File

webprofiler/src/Controller/DatabaseController.php

<?php

namespace Drupal\webprofiler\Controller;

use Drupal\Core\Controller\ControllerBase;
use Drupal\Core\Database\Connection;
use Drupal\webprofiler\DataCollector\DatabaseDataCollector;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
use Symfony\Component\HttpKernel\Profiler\Profile;
use Symfony\Component\HttpKernel\Profiler\Profiler;

/**
 * Class DatabaseController
 */
class DatabaseController extends ControllerBase {

  /**
   * @var \Symfony\Component\HttpKernel\Profiler\Profiler
   */
  private $profiler;

  /**
   * @var \Drupal\Core\Database\Connection
   */
  private $database;

  /**
   * {@inheritdoc}
   */
  public static function create(ContainerInterface $container) {
    return new static($container
      ->get('profiler'), $container
      ->get('database'));
  }

  /**
   * Constructs a new WebprofilerController.
   *
   * @param \Symfony\Component\HttpKernel\Profiler\Profiler $profiler
   * @param \Drupal\Core\Database\Connection $database
   */
  public function __construct(Profiler $profiler, Connection $database) {
    $this->profiler = $profiler;
    $this->database = $database;
  }

  /**
   * @param Profile $profile
   * @param int $qid
   *
   * @return JsonResponse
   */
  public function explainAction(Profile $profile, $qid) {
    $query = $this
      ->getQuery($profile, $qid);
    $data = [];
    $result = $this->database
      ->query('EXPLAIN ' . $query['query'], (array) $query['args'])
      ->fetchAllAssoc('table');
    $i = 1;
    foreach ($result as $row) {
      foreach ($row as $key => $value) {
        $data[$i][$key] = $value;
      }
      $i++;
    }
    return new JsonResponse([
      'data' => $data,
    ]);
  }

  /**
   * @param $profile ->getToken()
   * @param int $qid
   *
   * @return array
   */
  private function getQuery(Profile $profile, $qid) {
    $this->profiler
      ->disable();
    $token = $profile
      ->getToken();
    if (!($profile = $this->profiler
      ->loadProfile($token))) {
      throw new NotFoundHttpException($this
        ->t('Token @token does not exist.', [
        '@token' => $token,
      ]));
    }

    /** @var DatabaseDataCollector $databaseCollector */
    $databaseCollector = $profile
      ->getCollector('database');
    $queries = $databaseCollector
      ->getQueries();
    $query = $queries[$qid];
    return $query;
  }

}

Classes

Name	Description
DatabaseController	Class DatabaseController