Final Class Yiisoft\Translator\Message\Db\MessageSource

                public function __construct(
    private ConnectionInterface $db,
    private CacheInterface|null $cache = null,
    private string $sourceMessageTable = '{{%yii_source_message}}',
    private string $messageTable = '{{%yii_message}}',
    private int $cachingDuration = 3600
) {
}

            

                public function getMessage(string $id, string $category, string $locale, array $parameters = []): string|null
{
    if (!isset($this->messages[$category][$locale])) {
        $this->messages[$category][$locale] = $this->read($category, $locale);
    }
    return $this->messages[$category][$locale][$id]['message'] ?? null;
}

            

                public function getMessages(string $category, string $locale): array
{
    if (!isset($this->messages[$category][$locale])) {
        $this->messages[$category][$locale] = $this->read($category, $locale);
    }
    return $this->messages[$category][$locale] ?? [];
}

            

                public function write(string $category, string $locale, array $messages): void
{
    /** @psalm-var array<int, array<string, string|null>> $sourceMessages */
    $sourceMessages = (new Query($this->db))
        ->select(['id', 'message_id'])
        ->from($this->sourceMessageTable)
        ->where(['category' => $category])
        ->all();
    $sourceMessages = ArrayHelper::map($sourceMessages, 'message_id', 'id');
    $translatedMessages = $this->readFromDb($category, $locale);
    foreach ($messages as $messageId => $messageData) {
        if (!array_key_exists('message', $messageData)) {
            throw new InvalidArgumentException("Message is not valid for ID \"$messageId\". \"message\" key is missing.");
        }
        /** @psalm-suppress DocblockTypeContradiction */
        if (!is_string($messageData['message'])) {
            throw new InvalidArgumentException("Message is not a string for ID \"$messageId\".");
        }
        if (!isset($sourceMessages[$messageId])) {
            $comment = '';
            if (array_key_exists('comment', $messageData)) {
                /** @psalm-suppress DocblockTypeContradiction */
                if (!is_string($messageData['comment'])) {
                    throw new InvalidArgumentException("Message comment is not a string for ID \"$messageId\".");
                }
                $comment = $messageData['comment'];
            }
            /** @psalm-var array<string,string>|false $result */
            $result = $this->db
                ->createCommand()
                ->insertWithReturningPks(
                    $this->sourceMessageTable,
                    [
                        'category' => $category,
                        'message_id' => $messageId,
                        'comment' => $comment,
                    ],
                );
            if ($result === false) {
                throw new RuntimeException("Failed to write source message with \"$messageId\" ID.");
            }
            $sourceMessages[$messageId] = $result['id'];
        }
        $needUpdate = false;
        if (isset($translatedMessages[$messageId]) && $translatedMessages[$messageId]['message'] !== $messageData['message']) {
            $this->db
                ->createCommand()
                ->delete($this->messageTable, ['id' => $sourceMessages[$messageId]])
                ->execute();
            $needUpdate = true;
        }
        if ($needUpdate || !isset($translatedMessages[$messageId])) {
            $result = $this->db
                ->createCommand()
                ->insertWithReturningPks(
                    $this->messageTable,
                    [
                        'id' => $sourceMessages[$messageId],
                        'locale' => $locale,
                        'translation' => $messageData['message'],
                    ]
                );
            if ($result === false) {
                throw new RuntimeException("Failed to write message with \"$messageId\" ID.");
            }
        }
    }
}