sqlexpression.php

<?php
namespace Bitrix\Main\DB;
 
use Bitrix\Main\Application;
 
class SqlExpression
{
    protected $expression;
 
    protected $args = array();
 
    protected $pattern = '/([^\\\\]|^)(\?[#sifv]?)/';
 
    protected $i;
 
    protected $connection;
 
    public function __construct()
    {
        $args = func_get_args();
 
        if (!isset($args[0]))
        {
            throw new \Bitrix\Main\ArgumentException('No pattern has been found for SqlExpression');
        }
 
        $this->expression = $args[0];
 
        for ($i = 1, $n = count($args); $i < $n; $i++)
        {
            $this->args[] = $args[$i];
        }
    }
 
    public function compile()
    {
        $this->i = -1;
 
        if (strpos($this->expression, '\\') === false)
        {
            // regular case
            return preg_replace_callback($this->pattern, array($this, 'execPlaceholders'), $this->expression);
        }
        else
        {
            // handle escaping \ and \\
            $parts = explode('\\\\', $this->expression);
 
            foreach ($parts as &$part)
            {
                if (!empty($part))
                {
                    $part = preg_replace_callback($this->pattern, array($this, 'execPlaceholders'), $part);
                }
            }
 
            $parts = str_replace('\\?', '?', $parts);
 
            return implode('\\\\', $parts);
        }
    }
 
    protected function execPlaceholders($matches)
    {
        $sqlHelper = $this->getConnection()->getSqlHelper();
 
        $this->i++;
 
        $pre = $matches[1];
        $ph = $matches[2];
 
        if (array_key_exists($this->i, $this->args))
        {
            $value = $this->args[$this->i];
 
            if ($value === null && $ph !== '?#')
            {
                $value = 'NULL';
            }
            elseif ($ph == '?' || $ph == '?s')
            {
                $value = "'" . $sqlHelper->forSql($value) . "'";
            }
            elseif ($ph == '?#')
            {
                $value = $sqlHelper->quote($value);
            }
            elseif ($ph == '?v')
            {
                $value = $sqlHelper->values($value);
            }
            elseif ($ph == '?i')
            {
                $value = (int) $value;
            }
            elseif ($ph == '?f')
            {
                $value = (float) $value;
            }
 
            return $pre . $value;
        }
 
        return $matches[0];
    }
 
    public function __toString()
    {
        return $this->compile();
    }
 
    public function getConnection()
    {
        if ($this->connection === null)
        {
            $this->connection = Application::getConnection();
        }
 
        return $this->connection;
    }
 
    public function setConnection($connection)
    {
        $this->connection = $connection;
    }
}