Converter.php 7.13 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92
<?php

declare(strict_types=1);

namespace Doctrine\DBAL\Portability;

use function array_change_key_case;
use function array_map;
use function array_reduce;
use function is_string;
use function rtrim;

final class Converter
{
    /** @var callable */
    private $convertNumeric;

    /** @var callable */
    private $convertAssociative;

    /** @var callable */
    private $convertOne;

    /** @var callable */
    private $convertAllNumeric;

    /** @var callable */
    private $convertAllAssociative;

    /** @var callable */
    private $convertFirstColumn;

    /**
     * @param bool     $convertEmptyStringToNull Whether each empty string should be converted to NULL
     * @param bool     $rightTrimString          Whether each string should right-trimmed
     * @param int|null $case                     Convert the case of the column names
     *                                           (one of {@link CASE_LOWER} and {@link CASE_UPPER})
     */
    public function __construct(bool $convertEmptyStringToNull, bool $rightTrimString, ?int $case)
    {
        $id = static function ($value) {
            return $value;
        };

        $convertValue       = $this->createConvertValue($convertEmptyStringToNull, $rightTrimString);
        $convertNumeric     = $this->createConvertRow($convertValue, null);
        $convertAssociative = $this->createConvertRow($convertValue, $case);

        $this->convertNumeric     = $this->createConvert($convertNumeric, $id);
        $this->convertAssociative = $this->createConvert($convertAssociative, $id);
        $this->convertOne         = $this->createConvert($convertValue, $id);

        $this->convertAllNumeric     = $this->createConvertAll($convertNumeric, $id);
        $this->convertAllAssociative = $this->createConvertAll($convertAssociative, $id);
        $this->convertFirstColumn    = $this->createConvertAll($convertValue, $id);
    }

    /**
     * @param array<int,mixed>|false $row
     *
     * @return array<int,mixed>|false
     */
    public function convertNumeric($row)
    {
        return ($this->convertNumeric)($row);
    }

    /**
     * @param array<string,mixed>|false $row
     *
     * @return array<string,mixed>|false
     */
    public function convertAssociative($row)
    {
        return ($this->convertAssociative)($row);
    }

    /**
     * @param mixed|false $value
     *
     * @return mixed|false
     */
    public function convertOne($value)
    {
        return ($this->convertOne)($value);
    }

    /**
     * @param array<int,array<int,mixed>> $data
     *
     * @return array<int,array<int,mixed>>
     */
93
    public function convertAllNumeric(array $data): array
94 95 96 97 98 99 100 101 102
    {
        return ($this->convertAllNumeric)($data);
    }

    /**
     * @param array<int,array<string,mixed>> $data
     *
     * @return array<int,array<string,mixed>>
     */
103
    public function convertAllAssociative(array $data): array
104 105 106 107 108 109 110 111 112
    {
        return ($this->convertAllAssociative)($data);
    }

    /**
     * @param array<int,mixed> $data
     *
     * @return array<int,mixed>
     */
113
    public function convertFirstColumn(array $data): array
114 115 116 117 118 119 120 121 122 123 124 125
    {
        return ($this->convertFirstColumn)($data);
    }

    /**
     * Creates a function that will convert each individual value retrieved from the database
     *
     * @param bool $convertEmptyStringToNull Whether each empty string should be converted to NULL
     * @param bool $rightTrimString          Whether each string should right-trimmed
     *
     * @return callable|null The resulting function or NULL if no conversion is needed
     */
126
    private function createConvertValue(bool $convertEmptyStringToNull, bool $rightTrimString): ?callable
127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160
    {
        $functions = [];

        if ($convertEmptyStringToNull) {
            $functions[] = static function ($value) {
                if ($value === '') {
                    return null;
                }

                return $value;
            };
        }

        if ($rightTrimString) {
            $functions[] = static function ($value) {
                if (! is_string($value)) {
                    return $value;
                }

                return rtrim($value);
            };
        }

        return $this->compose(...$functions);
    }

    /**
     * Creates a function that will convert each array-row retrieved from the database
     *
     * @param callable|null $function The function that will convert each value
     * @param int|null      $case     Column name case
     *
     * @return callable|null The resulting function or NULL if no conversion is needed
     */
161
    private function createConvertRow(?callable $function, ?int $case): ?callable
162 163 164 165 166 167 168 169
    {
        $functions = [];

        if ($function !== null) {
            $functions[] = $this->createMapper($function);
        }

        if ($case !== null) {
170
            $functions[] = static function (array $row) use ($case): array {
171 172 173 174 175 176 177 178 179 180 181 182 183 184
                return array_change_key_case($row, $case);
            };
        }

        return $this->compose(...$functions);
    }

    /**
     * Creates a function that will be applied to the return value of Statement::fetch*()
     * or an identity function if no conversion is needed
     *
     * @param callable|null $function The function that will convert each tow
     * @param callable      $id       Identity function
     */
185
    private function createConvert(?callable $function, callable $id): callable
186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206
    {
        if ($function === null) {
            return $id;
        }

        return static function ($value) use ($function) {
            if ($value === false) {
                return false;
            }

            return $function($value);
        };
    }

    /**
     * Creates a function that will be applied to the return value of Statement::fetchAll*()
     * or an identity function if no transformation is required
     *
     * @param callable|null $function The function that will transform each value
     * @param callable      $id       Identity function
     */
207
    private function createConvertAll(?callable $function, callable $id): callable
208 209 210 211 212 213 214 215 216 217 218 219 220
    {
        if ($function === null) {
            return $id;
        }

        return $this->createMapper($function);
    }

    /**
     * Creates a function that maps each value of the array using the given function
     *
     * @param callable $function The function that maps each value of the array
     */
221
    private function createMapper(callable $function): callable
222
    {
223
        return static function (array $array) use ($function): array {
224 225 226 227 228 229 230 231 232 233 234
            return array_map($function, $array);
        };
    }

    /**
     * Creates a composition of the given set of functions
     *
     * @param callable ...$functions The functions to compose
     *
     * @return callable|null The composition or NULL if an empty set is provided
     */
235
    private function compose(callable ...$functions): ?callable
236
    {
237
        return array_reduce($functions, static function (?callable $carry, callable $item): callable {
238 239 240 241 242 243 244 245 246 247
            if ($carry === null) {
                return $item;
            }

            return static function ($value) use ($carry, $item) {
                return $item($carry($value));
            };
        });
    }
}