Passed
Push — dbal ( a4ab32...59fa40 )
by Greg
06:02
created

GroupConcat::__construct()   A

Complexity

Conditions 3
Paths 4

Size

Total Lines 20
Code Lines 13

Duplication

Lines 0
Ratio 0 %

Importance

Changes 1
Bugs 0 Features 0
Metric Value
cc 3
eloc 13
c 1
b 0
f 0
nc 4
nop 4
dl 0
loc 20
rs 9.8333
1
<?php
2
3
/**
4
 * webtrees: online genealogy
5
 * Copyright (C) 2022 webtrees development team
6
 * This program is free software: you can redistribute it and/or modify
7
 * it under the terms of the GNU General Public License as published by
8
 * the Free Software Foundation, either version 3 of the License, or
9
 * (at your option) any later version.
10
 * This program is distributed in the hope that it will be useful,
11
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13
 * GNU General Public License for more details.
14
 * You should have received a copy of the GNU General Public License
15
 * along with this program. If not, see <https://www.gnu.org/licenses/>.
16
 */
17
18
declare(strict_types=1);
19
20
namespace Fisharebest\Webtrees;
21
22
use Illuminate\Database\Capsule\Manager as DB;
23
use Illuminate\Database\Query\Expression;
24
25
/**
26
 * SQL GROUP_CONCAT function.
27
 */
28
class GroupConcat extends Expression
29
{
30
    public function __construct(string $expression, string $separator = ',', string $order_by = '', string $alias = '')
31
    {
32
        $quoted_expression = DB::connection()->getSchemaGrammar()->wrap($expression);
33
        $quoted_separator  = DB::connection()->getPdo()->quote($separator);
34
        $quoted_order_by   = DB::connection()->getSchemaGrammar()->wrap($order_by);
35
36
        switch (DB::connection()->getDriverName()) {
37
            case 'sqlsrv':
38
                $sql = 'STRING_AGG(' . $quoted_expression . ',' . $quoted_separator . ') WITHIN GROUP (ORDER BY ' . $quoted_order_by . ' ASC)';
39
                break;
40
            default:
41
                $sql = 'GROUP_CONCAT(' . $quoted_expression . ',' . $quoted_separator . ' ORDER BY ' . $quoted_order_by . ')';
42
                break;
43
        }
44
45
        if ($alias !== '') {
46
            $sql .= ' AS ' . DB::connection()->getSchemaGrammar()->wrap($alias);
47
        }
48
49
        parent::__construct($sql);
50
    }
51
}
52