ChunkTaxonomyRepository.php

• Pfad: src/Infrastructure/Persistence/ChunkTaxonomyRepository.php
• Namespace: Infrastructure\Persistence
• Zeilen: 175 | Größe: 4,864 Bytes
• Geändert: 2025-12-27 23:52:04 | Gescannt: 2025-12-31 10:22:15

Code Hygiene Score: 95

• Dependencies: 80 (25%)
• LOC: 100 (20%)
• Methods: 100 (20%)
• Secrets: 100 (15%)
• Classes: 100 (10%)
• Magic Numbers: 100 (10%)

Keine Issues gefunden.

Dependencies 6

• implements Domain\Repository\ChunkTaxonomyRepositoryInterface
• constructor PDO
• use Domain\Constants
• use Domain\Entity\ChunkTaxonomyMapping
• use Domain\Repository\ChunkTaxonomyRepositoryInterface
• use PDO

Klassen 1

• ChunkTaxonomyRepository class Zeile 14

Funktionen 9

• __construct() public Zeile 18
• findByChunkId() public Zeile 26
• findByTaxonomyTermId() public Zeile 44
• save() public Zeile 60
• delete() public Zeile 102
• deleteByChunkId() public Zeile 112
• getUnmappedChunks() public Zeile 123
• exists() public Zeile 142
• countByTaxonomyTerm() public Zeile 159

Verwendet von 2

• ContentServiceProvider.php use
• InfrastructureServiceProvider.php use

Versionen 2

• v2 2025-12-27 23:52 | claude-code-hook | modified
  Claude Code Pre-Hook Backup vor Edit-Operation
• v1 2025-12-27 23:51 | claude-code-hook | modified
  Claude Code Pre-Hook Backup vor Edit-Operation

Code

<?php

declare(strict_types=1);

namespace Infrastructure\Persistence;

// @responsibility: CRUD-Operationen für Chunk-Taxonomie-Mappings

use Domain\Constants;
use Domain\Entity\ChunkTaxonomyMapping;
use Domain\Repository\ChunkTaxonomyRepositoryInterface;
use PDO;

final class ChunkTaxonomyRepository implements ChunkTaxonomyRepositoryInterface
{
    private PDO $db;

    public function __construct(PDO $pdo)
    {
        $this->db = $pdo;
    }

    /**
     * {@inheritDoc}
     */
    public function findByChunkId(int $chunkId): array
    {
        $stmt = $this->db->prepare(
            'SELECT * FROM chunk_taxonomy WHERE chunk_id = :chunk_id ORDER BY confidence DESC'
        );
        $stmt->execute(['chunk_id' => $chunkId]);

        $mappings = [];
        foreach ($stmt->fetchAll(PDO::FETCH_ASSOC) as $row) {
            $mappings[] = ChunkTaxonomyMapping::fromArray($row);
        }

        return $mappings;
    }

    /**
     * {@inheritDoc}
     */
    public function findByTaxonomyTermId(int $termId): array
    {
        $stmt = $this->db->prepare(
            'SELECT chunk_id, confidence, source
             FROM chunk_taxonomy
             WHERE taxonomy_term_id = :term_id
             ORDER BY confidence DESC'
        );
        $stmt->execute(['term_id' => $termId]);

        return $stmt->fetchAll(PDO::FETCH_ASSOC);
    }

    /**
     * {@inheritDoc}
     */
    public function save(ChunkTaxonomyMapping $mapping): int
    {
        if ($mapping->getId() !== null) {
            // Update
            $stmt = $this->db->prepare(
                'UPDATE chunk_taxonomy
                 SET chunk_id = :chunk_id,
                     taxonomy_term_id = :term_id,
                     confidence = :confidence,
                     source = :source
                 WHERE id = :id'
            );
            $stmt->execute([
                'id' => $mapping->getId(),
                'chunk_id' => $mapping->getChunkId(),
                'term_id' => $mapping->getTaxonomyTermId(),
                'confidence' => $mapping->getConfidence()->value(),
                'source' => $mapping->getSource()->value,
            ]);

            return $mapping->getId();
        }

        // Insert
        $stmt = $this->db->prepare(
            'INSERT INTO chunk_taxonomy (chunk_id, taxonomy_term_id, confidence, source, created_at)
             VALUES (:chunk_id, :term_id, :confidence, :source, :created_at)'
        );
        $stmt->execute([
            'chunk_id' => $mapping->getChunkId(),
            'term_id' => $mapping->getTaxonomyTermId(),
            'confidence' => $mapping->getConfidence()->value(),
            'source' => $mapping->getSource()->value,
            'created_at' => $mapping->getCreatedAt()->format('Y-m-d H:i:s'),
        ]);

        return (int) $this->db->lastInsertId();
    }

    /**
     * {@inheritDoc}
     */
    public function delete(int $id): bool
    {
        $stmt = $this->db->prepare('DELETE FROM chunk_taxonomy WHERE id = :id');

        return $stmt->execute(['id' => $id]);
    }

    /**
     * {@inheritDoc}
     */
    public function deleteByChunkId(int $chunkId): int
    {
        $stmt = $this->db->prepare('DELETE FROM chunk_taxonomy WHERE chunk_id = :chunk_id');
        $stmt->execute(['chunk_id' => $chunkId]);

        return $stmt->rowCount();
    }

    /**
     * {@inheritDoc}
     */
    public function getUnmappedChunks(int $limit = Constants::DEFAULT_LIMIT): array
    {
        $stmt = $this->db->prepare(
            'SELECT c.id, c.document_id, SUBSTRING(c.content, 1, 500) as content
             FROM chunks c
             LEFT JOIN chunk_taxonomy ct ON c.id = ct.chunk_id
             WHERE ct.id IS NULL
               AND c.status = "embedded"
             LIMIT :limit'
        );
        $stmt->bindValue('limit', $limit, PDO::PARAM_INT);
        $stmt->execute();

        return $stmt->fetchAll(PDO::FETCH_ASSOC);
    }

    /**
     * {@inheritDoc}
     */
    public function exists(int $chunkId, int $taxonomyTermId): bool
    {
        $stmt = $this->db->prepare(
            'SELECT COUNT(*) FROM chunk_taxonomy
             WHERE chunk_id = :chunk_id AND taxonomy_term_id = :term_id'
        );
        $stmt->execute([
            'chunk_id' => $chunkId,
            'term_id' => $taxonomyTermId,
        ]);

        return (int) $stmt->fetchColumn() > 0;
    }

    /**
     * {@inheritDoc}
     */
    public function countByTaxonomyTerm(): array
    {
        $stmt = $this->db->query(
            'SELECT taxonomy_term_id, COUNT(*) as count
             FROM chunk_taxonomy
             GROUP BY taxonomy_term_id'
        );

        $counts = [];
        foreach ($stmt->fetchAll(PDO::FETCH_ASSOC) as $row) {
            $counts[(int) $row['taxonomy_term_id']] = (int) $row['count'];
        }

        return $counts;
    }
}