SqlError.php

Go to the documentation of this file.

<?php

/*
 * libasynql
 *
 * Copyright (C) 2018 SOFe
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

declare(strict_types=1);

namespace poggit\libasynql;

use Closure;
use Exception;
use ReflectionClass;
use ReflectionFunction;
use RuntimeException;
use function get_class;
use function get_resource_type;
use function is_object;
use function is_resource;
use function json_encode;
use function sprintf;

class SqlError extends RuntimeException{
    public const STAGE_CONNECT = "CONNECT";
    public const STAGE_PREPARE = "PREPARE";
    public const STAGE_EXECUTE = "EXECUTION";
    public const STAGE_RESPONSE = "RESPONSE";

    private $stage;
    private $errorMessage;
    private $query;
    private $args;

    public function __construct(string $stage, string $errorMessage, string $query = null, array $args = null){
        $this->stage = $stage;
        $this->errorMessage = $errorMessage;
        $this->query = $query;
        $this->args = $args;

        parent::__construct("SQL $stage error: $errorMessage" . ($query === null ? "" : (", for query $query | " . json_encode($args))));
        $this->flattenTrace();
    }

    public function getStage() : string{
        return $this->stage;
    }

    public function getErrorMessage() : string{
        return $this->errorMessage;
    }

    public function getQuery() : ?string{
        return $this->query;
    }

    public function getArgs() : ?array{
        return $this->args;
    }

    protected function flattenTrace() : void{
        $traceProperty = (new ReflectionClass(Exception::class))->getProperty('trace');
        $traceProperty->setAccessible(true);
        $flatten = function(&$value){
            if($value instanceof Closure){
                $closureReflection = new ReflectionFunction($value);
                $value = sprintf(
                    '(Closure at %s:%s)',
                    $closureReflection->getFileName(),
                    $closureReflection->getStartLine()
                );
            }elseif(is_object($value)){
                $value = sprintf('object(%s)', get_class($value));
            }elseif(is_resource($value)){
                $value = sprintf('resource(%s)', get_resource_type($value));
            }
        };
        do{
            $trace = $traceProperty->getValue($this);
            foreach($trace as &$call){
                array_walk_recursive($call['args'], $flatten);
            }
            unset($call);
            $traceProperty->setValue($this, $trace);
        }while($exception = $this->getPrevious());
        $traceProperty->setAccessible(false);
    }
}