HeuJung
5f4a733b3b
계측 축이 "목록 SELECT" 하나였고 프로파일 12종이 커맨드 파일에 하드코딩돼 있어 확장이 자기 대상을 추가할 수 없었다. 확장이 설치·제거되는 설치본마다 "실제로 존재하는 대상"이 달라지므로, 대상을 소유자가 선언하고 코어가 수집하도록 뒤집었다. - 선언 지점 두 곳, 스키마 하나: 코어 config/benchmark.php, 확장 getBenchmarkProfiles (모듈/플러그인). 수집은 method_exists 기반이라 인터페이스를 직접 구현한 서드파티 확장이 깨지지 않는다. - 축 4종(목록/화면/쓰기/배치)을 실행기로 분리하고 컨테이너 태그로 주입 — 축이 늘 때 커맨드를 고치지 않는다. - 화면 축은 HTTP 커널로 내부 요청을 처리한다. 라우트만 dispatch 하면 전역 미들웨어를 건너뛰어 화면과 다른 것을 재게 된다. 인증은 프로파일이 선언한 권한만 가진 임시 계정이 기본이며 --as 로 기존 계정을 지목할 수 있다. - 화면/쓰기 축은 계측 계정 생성부터 처리까지 롤백되는 트랜잭션 안에서 실행해 운영 DB 에도 잔여 데이터를 남기지 않는다. 배치 축은 내부 커밋·락 보유 때문에 감싸지 않고 --allow-write 로만 통제한다. - 잘못된 선언은 조용히 버리지 않고 사유를 경고로 남긴다. 버려진 선언이 곧 계측 사각이 되기 때문이다. 전부 건너뛴 실행은 종료 코드 1 로 끝난다. - 리포트는 환경 정보를 함께 적어 저장소 밖(storage/app/benchmarks)에 남긴다. 측정값이 실행 머신에 종속되므로 저장소에 축적하면 비교 불가능한 수치가 섞인다. 작업 중 발견해 함께 고친 것: - 이관 프로파일 3종의 soft_delete 선언이 실제 스키마와 어긋나 있었다 (users/product_inquiries/pages 에 deleted_at 없음). - 주문 목록이 상태 미지정 시 임시 주문 상태를 NOT IN 으로 제외하는데 선언에 빠져 있었다. filters 가 등가 비교만 지원한 것이 근본 원인이라 연산자 형태를 받도록 넓히고, 미허용 연산자는 측정 전에 거부한다. - 댓글 프로파일은 지배적 술어가 상관 서브쿼리라 선언형으로 재현할 수 없어 제거했다. 맨 테이블 스캔은 어느 화면도 내지 않는 수치가 된다. g7:bench:pagination → g7:bench 로 개명(4축을 재므로). 이전 이름은 별칭으로 남겼다. 테스트 61건 통과, 라이브 18종 전건 측정.
103 lines
2.9 KiB
PHP
103 lines
2.9 KiB
PHP
<?php
|
|
|
|
namespace App\Benchmark;
|
|
|
|
use Illuminate\Database\Events\QueryExecuted;
|
|
use Illuminate\Support\Facades\DB;
|
|
|
|
/**
|
|
* 실행 쿼리 수집기 — 화면/쓰기/배치 축의 쿼리 건수·시간·N+1 후보 산출
|
|
*
|
|
* 목록 SELECT 는 빨라도 화면이 느린 대표적 원인이 N+1 이므로, 응답 시간만 재고 끝내면
|
|
* 원인을 못 찾습니다. 이 수집기는 계측 구간에서 실행된 쿼리를 모아 건수·DB 시간과, 같은
|
|
* SQL 이 반복 실행된 그룹(N+1 후보)을 함께 돌려줍니다.
|
|
*
|
|
* `DB::listen` 은 한 번 등록하면 해제할 수 없으므로, 리스너는 인스턴스당 한 번만 등록하고
|
|
* 수집 여부는 플래그로 켰다 끕니다 — 계측 구간 밖의 쿼리가 섞이지 않게 합니다.
|
|
*/
|
|
class QueryCollector
|
|
{
|
|
/**
|
|
* 같은 SQL 이 이 횟수 이상 반복되면 N+1 후보로 본다
|
|
*/
|
|
private const N_PLUS_ONE_THRESHOLD = 5;
|
|
|
|
/**
|
|
* 수집 구간 여부
|
|
*/
|
|
private bool $collecting = false;
|
|
|
|
/**
|
|
* 수집된 쿼리 (sql, time)
|
|
*
|
|
* @var array<int, array{sql: string, time: float}>
|
|
*/
|
|
private array $queries = [];
|
|
|
|
public function __construct()
|
|
{
|
|
DB::listen(function (QueryExecuted $event) {
|
|
if (! $this->collecting) {
|
|
return;
|
|
}
|
|
|
|
$this->queries[] = ['sql' => $event->sql, 'time' => (float) $event->time];
|
|
});
|
|
}
|
|
|
|
/**
|
|
* 콜백 실행 구간의 쿼리를 수집합니다.
|
|
*
|
|
* @template TReturn
|
|
*
|
|
* @param \Closure(): TReturn $callback 계측 대상 작업
|
|
* @return array{value: TReturn, queries: array<int, array{sql: string, time: float}>} 반환값과 수집 결과
|
|
*/
|
|
public function collect(\Closure $callback): array
|
|
{
|
|
$this->queries = [];
|
|
$this->collecting = true;
|
|
|
|
try {
|
|
$value = $callback();
|
|
} finally {
|
|
$this->collecting = false;
|
|
}
|
|
|
|
return ['value' => $value, 'queries' => $this->queries];
|
|
}
|
|
|
|
/**
|
|
* 수집된 쿼리를 요약합니다.
|
|
*
|
|
* @param array<int, array{sql: string, time: float}> $queries 수집 결과
|
|
* @return array{count: int, db_ms: float, n_plus_one: array<int, array{count: int, sql: string}>} 요약
|
|
*/
|
|
public function summarize(array $queries): array
|
|
{
|
|
$grouped = [];
|
|
|
|
foreach ($queries as $query) {
|
|
$grouped[$query['sql']] = ($grouped[$query['sql']] ?? 0) + 1;
|
|
}
|
|
|
|
arsort($grouped);
|
|
|
|
$candidates = [];
|
|
|
|
foreach ($grouped as $sql => $count) {
|
|
if ($count < self::N_PLUS_ONE_THRESHOLD) {
|
|
continue;
|
|
}
|
|
|
|
$candidates[] = ['count' => $count, 'sql' => $sql];
|
|
}
|
|
|
|
return [
|
|
'count' => count($queries),
|
|
'db_ms' => round(array_sum(array_column($queries, 'time')), 2),
|
|
'n_plus_one' => $candidates,
|
|
];
|
|
}
|
|
}
|