suda\application\database\DebugObserver

Complexity

Total Complexity

6

Size/Duplication

Total Lines	55
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	observe()	0	34	5
A	__construct()	0	3	1

<?php

namespace suda\application\database;

use suda\framework\Debugger;
use suda\orm\statement\Statement;
use suda\orm\connection\Connection;
use suda\orm\statement\QueryAccess as StatementQueryAccess;
use suda\orm\connection\observer\Observer;

class DebugObserver implements Observer
{
    /**
     * 调试记录
     *
     * @var Debugger
     */
    protected $debug;

    public function __construct(Debugger $debug)
    {
        $this->debug = $debug;
    }

    /**
     * @param StatementQueryAccess $access
     * @param Connection $connection
     * @param Statement $statement
     * @param $timeSpend
     * @param bool $result
     */
    public function observe(StatementQueryAccess $access, Connection $connection, Statement $statement, $timeSpend, bool $result)
    {
        $query = $connection->prefix($statement->getString());
        $status = $result ? 'OK' : 'Err';
        if ($result) {
            $effect = $statement->getStatement()->rowCount();
            $this->debug->info(sprintf(
                "query [%s] %s %ss",
                $status,
                $query,
                number_format($timeSpend, 5)
            ));
            $this->debug->info(sprintf("query effect %s rows", $effect));
        } else {
            $this->debug->error(sprintf(
                "query [%s] %s %ss",
                $status,
                $query,
                number_format($timeSpend, 5)
            ));
            $this->debug->error(sprintf(
                "query [%s] %s",
                $status,
                implode(':', $statement->getStatement()->errorInfo())
            ));
        }
        $binder = $statement->getBinder();
        foreach ($binder as $item) {
            if ($item->getKey() !== null) {
                $value = $access->getMiddleware()->input($item->getKey(), $item->getValue());
            } else {
                $value = $item->getValue();
            }
            $this->debug->debug(sprintf("query value :%s = %s", $item->getName(), json_encode($value)));
        }
    }
}