<?php
namespace Relay\Database;

final class DbSink implements SqlSink
{
    private Db $db;
    private int $bytes = 0;

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

    public function statement(string $sql): void
    {
        $this->db->raw($sql);
        $this->bytes += strlen($sql);
    }

    public function bytes(): int { return $this->bytes; }
}