ExpressionGroup.php

Go to the documentation of this file.

<?php
 
namespace Wikimedia\Rdbms;
 
use InvalidArgumentException;
use Wikimedia\Rdbms\Database\DbQuoter;
 
abstract class ExpressionGroup implements IExpression {
    protected array $children = [];
 
    public function __construct( IExpression ...$children ) {
        $this->children = $children;
    }
 
    final protected function add( IExpression $expression ) {
        $this->children[] = $expression;
    }
 
    abstract protected function getType(): string;
 
    public static function newFromArray( array $conds ): static {
        if ( !$conds ) {
            throw new InvalidArgumentException( "The array of conditions can't be empty." );
        }
        $exprs = [];
        foreach ( $conds as $field => $cond ) {
            if ( is_numeric( $field ) ) {
                if ( !$cond instanceof IExpression ) {
                    throw new InvalidArgumentException(
                        __METHOD__ . ": Only IExpression are allowed with numeric key." );
                }
                $exprs[] = $cond;
            } else {
                if ( $cond instanceof IExpression ) {
                    throw new InvalidArgumentException( __METHOD__ . ": unexpected key $field for IExpression value" );
                }
                $exprs[] = new Expression( $field, '=', $cond );
            }
        }
        // @phan-suppress-next-line PhanTypeInstantiateAbstractStatic
        return new static( ...$exprs );
    }
 
    final public function toSql( DbQuoter $dbQuoter ): string {
        if ( !$this->children ) {
            throw new InvalidArgumentException( "The array of values can't be empty." );
        }
        $sqls = array_map( static fn ( $value ) => $value->toSql( $dbQuoter ), $this->children );
        return '(' . implode( ' ' . $this->getType() . ' ', $sqls ) . ')';
    }
 
    final public function toGeneralizedSql(): string {
        if ( !$this->children ) {
            throw new InvalidArgumentException( "The array of values can't be empty." );
        }
        $sqls = array_map( static fn ( $value ) => $value->toGeneralizedSql(), $this->children );
        return '(' . implode( ' ' . $this->getType() . ' ', $sqls ) . ')';
    }
}