/var/www/hkosl.com/b2b2c/webadmin/libraies/illuminate/database/Query/Grammars/PostgresGrammar.php


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
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
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
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
<?php

namespace Illuminate\Database\Query\Grammars;

use 
Illuminate\Support\Arr;
use 
Illuminate\Support\Str;
use 
Illuminate\Database\Query\Builder;

class 
PostgresGrammar extends Grammar
{
    
/**
     * All of the available clause operators.
     *
     * @var array
     */
    
protected $operators = [
        
'=''<''>''<=''>=''<>''!=',
        
'like''not like''between''ilike',
        
'&''|''#''<<''>>',
        
'@>''<@''?''?|''?&''||''-''-''#-',
    ];

    
/**
     * Compile the lock into SQL.
     *
     * @param  \Illuminate\Database\Query\Builder  $query
     * @param  bool|string  $value
     * @return string
     */
    
protected function compileLock(Builder $query$value)
    {
        if (
is_string($value)) {
            return 
$value;
        }

        return 
$value 'for update' 'for share';
    }

    
/**
     * Compile a "where date" clause.
     *
     * @param  \Illuminate\Database\Query\Builder  $query
     * @param  array  $where
     * @return string
     */
    
protected function whereDate(Builder $query$where)
    {
        
$value $this->parameter($where['value']);

        return 
$this->wrap($where['column']).'::date '.$where['operator'].' '.$value;
    }

    
/**
     * Compile a date based where clause.
     *
     * @param  string  $type
     * @param  \Illuminate\Database\Query\Builder  $query
     * @param  array  $where
     * @return string
     */
    
protected function dateBasedWhere($typeBuilder $query$where)
    {
        
$value $this->parameter($where['value']);

        return 
'extract('.$type.' from '.$this->wrap($where['column']).') '.$where['operator'].' '.$value;
    }

    
/**
     * Compile an update statement into SQL.
     *
     * @param  \Illuminate\Database\Query\Builder  $query
     * @param  array  $values
     * @return string
     */
    
public function compileUpdate(Builder $query$values)
    {
        
$table $this->wrapTable($query->from);

        
// Each one of the columns in the update statements needs to be wrapped in the
        // keyword identifiers, also a place-holder needs to be created for each of
        // the values in the list of bindings so we can make the sets statements.
        
$columns $this->compileUpdateColumns($values);

        
$from $this->compileUpdateFrom($query);

        
$where $this->compileUpdateWheres($query);

        return 
trim("update {$table} set {$columns}{$from} $where");
    }

    
/**
     * Prepare the bindings for an update statement.
     *
     * @param  array  $bindings
     * @param  array  $values
     * @return array
     */
    
public function prepareBindingsForUpdate(array $bindings, array $values)
    {
        
$bindingsWithoutJoin Arr::except($bindings'join');

        return 
array_values(
            
array_merge($values$bindings['join'], Arr::flatten($bindingsWithoutJoin))
        );
    }

    
/**
     * Compile the columns for the update statement.
     *
     * @param  array   $values
     * @return string
     */
    
protected function compileUpdateColumns($values)
    {
        
$columns = [];

        
// When gathering the columns for an update statement, we'll wrap each of the
        // columns and convert it to a parameter value. Then we will concatenate a
        // list of the columns that can be added into this update query clauses.
        
foreach ($values as $key => $value) {
            
$columns[] = $this->wrap($key).' = '.$this->parameter($value);
        }

        return 
implode(', '$columns);
    }

    
/**
     * Compile the "from" clause for an update with a join.
     *
     * @param  \Illuminate\Database\Query\Builder  $query
     * @return string|null
     */
    
protected function compileUpdateFrom(Builder $query)
    {
        if (! isset(
$query->joins)) {
            return 
'';
        }

        
$froms = [];

        
// When using Postgres, updates with joins list the joined tables in the from
        // clause, which is different than other systems like MySQL. Here, we will
        // compile out the tables that are joined and add them to a from clause.
        
foreach ($query->joins as $join) {
            
$froms[] = $this->wrapTable($join->table);
        }

        if (
count($froms) > 0) {
            return 
' from '.implode(', '$froms);
        }
    }

    
/**
     * Compile the additional where clauses for updates with joins.
     *
     * @param  \Illuminate\Database\Query\Builder  $query
     * @return string
     */
    
protected function compileUpdateWheres(Builder $query)
    {
        
$baseWhere $this->compileWheres($query);

        if (! isset(
$query->joins)) {
            return 
$baseWhere;
        }

        
// Once we compile the join constraints, we will either use them as the where
        // clause or append them to the existing base where clauses. If we need to
        // strip the leading boolean we will do so when using as the only where.
        
$joinWhere $this->compileUpdateJoinWheres($query);

        if (
trim($baseWhere) == '') {
            return 
'where '.$this->removeLeadingBoolean($joinWhere);
        }

        return 
$baseWhere.' '.$joinWhere;
    }

    
/**
     * Compile the "join" clauses for an update.
     *
     * @param  \Illuminate\Database\Query\Builder  $query
     * @return string
     */
    
protected function compileUpdateJoinWheres(Builder $query)
    {
        
$joinWheres = [];

        
// Here we will just loop through all of the join constraints and compile them
        // all out then implode them. This should give us "where" like syntax after
        // everything has been built and then we will join it to the real wheres.
        
foreach ($query->joins as $join) {
            foreach (
$join->wheres as $where) {
                
$method "where{$where['type']}";

                
$joinWheres[] = $where['boolean'].' '.$this->$method($query$where);
            }
        }

        return 
implode(' '$joinWheres);
    }

    
/**
     * Compile an insert and get ID statement into SQL.
     *
     * @param  \Illuminate\Database\Query\Builder  $query
     * @param  array   $values
     * @param  string  $sequence
     * @return string
     */
    
public function compileInsertGetId(Builder $query$values$sequence)
    {
        if (
is_null($sequence)) {
            
$sequence 'id';
        }

        return 
$this->compileInsert($query$values).' returning '.$this->wrap($sequence);
    }

    
/**
     * Compile a truncate table statement into SQL.
     *
     * @param  \Illuminate\Database\Query\Builder  $query
     * @return array
     */
    
public function compileTruncate(Builder $query)
    {
        return [
'truncate '.$this->wrapTable($query->from).' restart identity' => []];
    }

    
/**
     * Wrap a single string in keyword identifiers.
     *
     * @param  string  $value
     * @return string
     */
    
protected function wrapValue($value)
    {
        if (
$value === '*') {
            return 
$value;
        }

        if (
Str::contains($value'->')) {
            return 
$this->wrapJsonSelector($value);
        }

        return 
'"'.str_replace('"''""'$value).'"';
    }

    
/**
     * Wrap the given JSON selector.
     *
     * @param  string  $value
     * @return string
     */
    
protected function wrapJsonSelector($value)
    {
        
$path explode('->'$value);

        
$field $this->wrapValue(array_shift($path));

        
$wrappedPath $this->wrapJsonPathAttributes($path);

        
$attribute array_pop($wrappedPath);

        if (! empty(
$wrappedPath)) {
            return 
$field.'->'.implode('->'$wrappedPath).'->>'.$attribute;
        }

        return 
$field.'->>'.$attribute;
    }

    
/**
     * Wrap the attributes of the give JSON path.
     *
     * @param  array  $path
     * @return array
     */
    
protected function wrapJsonPathAttributes($path)
    {
        return 
array_map(function ($attribute) {
            return 
"'$attribute'";
        }, 
$path);
    }
}