Veškerá práce s daty probíhá výhradně přes repozitáře v app/repositories/. Žádné SQL dotazy nesmí být nikde jinde v projektu — ne v kontrolerech, ne v servisách, ne v jobech.

Struktura

app/repositories/
├── BaseRepository.php          // Abstraktní základ — CRUD metody
├── UserRepository.php          // Repozitář pro tabulku users
├── system/                     // Systémové repozitáře
│   ├── CronVariablesRepository.php
│   └── MigrationsRepository.php
└── admin/                      // Admin repozitáře
    └── ...

Složky odpovídají logickým sekcím (admin, system, ...). Pro každou DB tabulku existuje jeden repozitář.

Vytvoření repozitáře

namespace Moony\app\repositories;

class OrdersRepository extends BaseRepository
{
    public const string MAIN_TABLE = 'orders';

    // Vlastní metody pro složitější dotazy
    public static function getActiveByUserId(int $userId): ?array
    {
        return self::queryBuilder()
            ->setCriteria([
                ['[orders].[user_id] = ?', $userId],
                ['[orders].[status] = ?', 'active']
            ])
            ->order(['created_at', 'DESC'])
            ->getResult();
    }

    public static function getTotalRevenue(): float
    {
        return self::queryBuilder()
            ->getSum('amount', 0);
    }

    public static function hasActiveOrders(int $userId): bool
    {
        return self::queryBuilder()
            ->setCriteria([
                ['[orders].[user_id] = ?', $userId],
                ['[orders].[status] = ?', 'active']
            ])
            ->exists();
    }
}

Zděděné metody dostupné v každém repozitáři:

Vytvoření

Čtení — jeden záznam

Čtení — více záznamů

Aktualizace

Mazání

QueryBuilder

// Vytvoření
$id = OrdersRepository::create([
    'user_id' => User::getId(),
    'amount' => 199.90,
    'status' => 'pending',
    'created_at' => UTC::get()
]);

// Čtení
$order = OrdersRepository::getOneById($id);
$orders = OrdersRepository::getAllBy('user_id', User::getId());
$count = OrdersRepository::getAllCountBy('status', 'active');

// S joiny a řazením (BaseRepository metody)
$order = OrdersRepository::getOneById($id,
    columns: ['orders.*', 'users.email'],
    joins: ['LEFT JOIN users ON users.id = orders.user_id'],
);

// Update
OrdersRepository::updateById($id, [
    'status' => 'completed'
]);

// Soft delete
OrdersRepository::safeDeleteById($id);

// Hromadný insert (queue)
foreach($items as $item) {
    OrderItemsRepository::addToQueue([
        'order_id' => $orderId,
        'product_id' => $item['id'],
        'quantity' => $item['qty']
    ]);
}
OrderItemsRepository::flushQueue();

Pro složitější dotazy se používá queryBuilder(). Všechny metody jsou fluent (chainable).

Filtry a kritéria

// Jedna podmínka → criterion()
->criterion(['status' => 'active'])
->criterion([['[orders].[amount] > ?', 100]])

// Více podmínek → setCriteria()
->setCriteria([
    ['[orders].[status] = ?', 'active'],
    ['[orders].[user_id] = ?', $userId]
])

Sloupce

// Jeden sloupec → column()
->column('users.email')

// Více sloupců → setColumns()
->setColumns(['id', 'email', 'created_at'])

Joiny

// Jeden join → join()
->join('LEFT JOIN users ON users.id = orders.user_id')

// Více joinů → setJoins()
->setJoins([
    'LEFT JOIN users ON users.id = orders.user_id',
    'LEFT JOIN products ON products.id = items.product_id'
])

Řazení a stránkování

GROUP BY

->groupBy('status')
->groupBy(['status', 'user_id'], 'COUNT(*) > 5')

Výsledky

FOR UPDATE (transakce)

Zápis a mazání

Cache

Debug

Kompletní příklad

$results = OrdersRepository::queryBuilder()
    ->setCriteria([
        ['[orders].[status] IN (?)', ['active', 'pending']],
        ['[orders].[created_at] > ?', '2026-01-01']
    ])
    ->join('LEFT JOIN users ON users.id = orders.user_id')
    ->setColumns(['orders.*', 'users.email'])
    ->order(['created_at' => 'DESC'])
    ->setPagination($page, $perPage)
    ->getResult();

// Počet a součet
$count = OrdersRepository::queryBuilder()
    ->setCriteria(['status' => 'active'])
    ->getCount();

$total = OrdersRepository::queryBuilder()
    ->setCriteria(['user_id' => User::getId()])
    ->getSum('amount', 0);

// Existuje?
$hasOrders = OrdersRepository::queryBuilder()
    ->setCriteria(['user_id' => User::getId()])
    ->exists();

// S cache (5 minut APCu)
$topProducts = ProductsRepository::queryBuilder()
    ->order(['sales' => 'DESC'])
    ->limit(10)
    ->useAPCuCache(300)
    ->getResult();

// Hromadný update
OrdersRepository::queryBuilder()
    ->multipleUpdates('id', [
        42 => ['status' => 'completed', 'completed_at' => UTC::get()],
        43 => ['status' => 'cancelled'],
        44 => ['status' => 'completed', 'completed_at' => UTC::get()],
    ]);