1
|
|
|
<?php |
2
|
|
|
|
3
|
|
|
require_once __DIR__ . "/../vendor/autoload.php"; |
4
|
|
|
|
5
|
|
|
//connection config file |
6
|
|
|
require_once __DIR__ . "/config.php"; |
7
|
|
|
require_once __DIR__ . "/helpers.php"; |
8
|
|
|
|
9
|
|
|
use Willry\QueryBuilder\Connect; |
10
|
|
|
use Willry\QueryBuilder\Create; |
11
|
|
|
use Willry\QueryBuilder\Delete; |
12
|
|
|
use Willry\QueryBuilder\Query; |
13
|
|
|
use Willry\QueryBuilder\QueryHelpers; |
14
|
|
|
use Willry\QueryBuilder\Update; |
15
|
|
|
|
16
|
|
|
|
17
|
|
|
|
18
|
|
|
/** |
19
|
|
|
* Informar um array onde a chave é o nome da conexão |
20
|
|
|
* e dentro vai os dados da conexão para o PDO |
21
|
|
|
*/ |
22
|
|
|
$connections = [ |
23
|
|
|
'default' => [ |
24
|
|
|
"driver" => "mysql", |
25
|
|
|
"host" => "127.0.0.1", |
26
|
|
|
"port" => "3306", |
27
|
|
|
"dbname" => "fullstackphp", |
28
|
|
|
"username" => "root", |
29
|
|
|
"passwd" => "root", |
30
|
|
|
"options" => [ |
31
|
|
|
PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8", |
32
|
|
|
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, |
33
|
|
|
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_OBJ, |
34
|
|
|
PDO::ATTR_CASE => PDO::CASE_NATURAL |
35
|
|
|
] |
36
|
|
|
], |
37
|
|
|
'banco_teste' => [ |
38
|
|
|
"driver" => "mysql", |
39
|
|
|
"host" => "127.0.0.1", |
40
|
|
|
"port" => "3306", |
41
|
|
|
"dbname" => "teste", |
42
|
|
|
"username" => "root", |
43
|
|
|
"passwd" => "root", |
44
|
|
|
"options" => [ |
45
|
|
|
PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8", |
46
|
|
|
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, |
47
|
|
|
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_OBJ, |
48
|
|
|
PDO::ATTR_CASE => PDO::CASE_NATURAL |
49
|
|
|
] |
50
|
|
|
], |
51
|
|
|
]; |
52
|
|
|
|
53
|
|
|
/** |
54
|
|
|
* @important |
55
|
|
|
* |
56
|
|
|
* Aqui injeta as configurações |
57
|
|
|
*/ |
58
|
|
|
Connect::config($connections); |
59
|
|
|
/** |
60
|
|
|
* Leitura de dados basicos(trazer multiplos resultados) |
61
|
|
|
*/ |
62
|
|
|
$data = (new Query()) |
63
|
|
|
->from('users as u') |
64
|
|
|
->select(["u.id", "u.first_name", "u.email"]) // OR ->selectRaw("u.id, u.first_name, u.email") |
65
|
|
|
->selectRaw("IF(1 = ?, 'verdadeiro','falso') AS boolean", [1]) |
66
|
|
|
->where("id >= ?", [1]) |
67
|
|
|
->where("email is not null") |
68
|
|
|
->order("id ASC") |
69
|
|
|
->get(); |
70
|
|
|
|
71
|
|
|
|
72
|
|
|
var_dump($data); |
73
|
|
|
|
74
|
|
|
|
75
|
|
|
/** |
76
|
|
|
* Leitura de dados basicos(trazer único resultado) |
77
|
|
|
*/ |
78
|
|
|
$data = (new Query()) |
79
|
|
|
->from('users as u') |
80
|
|
|
->select(["u.id", "u.first_name", "u.email"]) // OR ->selectRaw("u.id, u.first_name, u.email") |
81
|
|
|
->selectRaw("IF(1 = ?, 'verdadeiro','falso') AS boolean", [1]) |
82
|
|
|
->where("id <= ?", [5]) |
83
|
|
|
->where("email is not null") |
84
|
|
|
->order("id ASC") |
85
|
|
|
->first(); |
86
|
|
|
var_dump($data); |
87
|
|
|
|
88
|
|
|
|
89
|
|
|
/** |
90
|
|
|
* Escolher a conexão de banco de dados |
91
|
|
|
*/ |
92
|
|
|
$nomeConexao = 'default'; |
93
|
|
|
$data = (new Query($nomeConexao)) |
94
|
|
|
->from('users as u') |
95
|
|
|
->select(["u.id", "u.first_name", "u.email"]) // OR ->selectRaw("u.id, u.first_name, u.email") |
96
|
|
|
->selectRaw("IF(1 = ?, 'verdadeiro','falso') AS boolean", [1]) |
97
|
|
|
->where("id <= ?", [5]) |
98
|
|
|
->where("email is not null") |
99
|
|
|
->order("id ASC") |
100
|
|
|
->first(); |
101
|
|
|
|
102
|
|
|
var_dump($data); |
103
|
|
|
|
104
|
|
|
|
105
|
|
|
/** |
106
|
|
|
* JOINS |
107
|
|
|
* join() |
108
|
|
|
* leftJoin() |
109
|
|
|
* rightJoin() |
110
|
|
|
*/ |
111
|
|
|
$join = (new Query()) |
112
|
|
|
->from('users as u') |
113
|
|
|
->selectRaw("u.id, u.first_name, u.email, ad.street as address") |
114
|
|
|
->leftJoin("address as ad", "ad.user_id = u.id and ad.street LIKE ?", ['%a%']) |
115
|
|
|
->limit(3) |
116
|
|
|
->get(); |
117
|
|
|
var_dump($join); |
118
|
|
|
|
119
|
|
|
|
120
|
|
|
/** |
121
|
|
|
* Join com subquery |
122
|
|
|
* |
123
|
|
|
* joinSub |
124
|
|
|
* leftJoinSub |
125
|
|
|
* rightJoinSub |
126
|
|
|
*/ |
127
|
|
|
|
128
|
|
|
/** objeto de query builder, sem executar(->get(), ->first())*/ |
129
|
|
|
$address = (new Query()) |
130
|
|
|
->from('address as u') |
131
|
|
|
->where("street is not null") |
132
|
|
|
->where('id > ?', [1]); |
133
|
|
|
|
134
|
|
|
$users = (new Query()) |
135
|
|
|
->from('users as u') |
136
|
|
|
->selectRaw("u.id as usuario, sub.street as rua") |
137
|
|
|
->leftJoinSub($address, 'sub', "sub.user_id = u.id AND 1 = ?", [1]); |
138
|
|
|
var_dump($users->get()); |
139
|
|
|
|
140
|
|
|
/** |
141
|
|
|
* Selecionar de uma subquery |
142
|
|
|
* |
143
|
|
|
* Select * from (select * from users) as sub |
144
|
|
|
*/ |
145
|
|
|
$dbSub = (new Query())->from('users as u')->where("2 = ?", [2])->limit(10); |
146
|
|
|
|
147
|
|
|
$data = (new Query())->fromSubQuery(function (Query $query) { |
148
|
|
|
return $query->from("users")->selectRaw('id,first_name')->where("1 = ?", [1])->limit(10); |
149
|
|
|
}, 'sub') |
150
|
|
|
->where('4 = ?', [4]) |
151
|
|
|
->joinSub($dbSub, 'sub2', 'sub2.id = sub.id and 3 = ?', [3]); |
152
|
|
|
var_dump($data->toSQL(), $data->flatBindings(), $data->get()); |
153
|
|
|
|
154
|
|
|
|
155
|
|
|
/** |
156
|
|
|
* WHERE IN |
157
|
|
|
*/ |
158
|
|
|
$dinamico = (new Query())->from("users as u") |
159
|
|
|
->selectRaw("u.id, u.first_name, u.email") |
160
|
|
|
->whereIn("u.id", [1, 2, 3, 4, 5]) |
161
|
|
|
->get(); |
162
|
|
|
var_dump($dinamico); |
163
|
|
|
|
164
|
|
|
/** |
165
|
|
|
* Create |
166
|
|
|
*/ |
167
|
|
|
$create = (new Create())->from("users") |
168
|
|
|
->create([ |
169
|
|
|
'first_name' => 'fulano', |
170
|
|
|
'last_name' => 'qualquer' . generateRandomString(), |
|
|
|
|
171
|
|
|
"email" => "fulano" . generateRandomString() . "@fulano.com" |
172
|
|
|
])->exec(); |
173
|
|
|
var_dump($create); |
174
|
|
|
|
175
|
|
|
/** |
176
|
|
|
* UPDATE |
177
|
|
|
*/ |
178
|
|
|
$update = (new Update())->from("users as u") |
179
|
|
|
->where("id = ?", [$create]) |
180
|
|
|
->update([ |
181
|
|
|
"email" => "fulano" . generateRandomString() . "@fulano.com" |
182
|
|
|
])->exec(); |
183
|
|
|
var_dump($update); |
184
|
|
|
|
185
|
|
|
/** |
186
|
|
|
* DELETE |
187
|
|
|
*/ |
188
|
|
|
$delete = (new Delete())->from("users as u") |
189
|
|
|
->where("id > ?", [56]) |
190
|
|
|
->delete(); |
191
|
|
|
var_dump($delete); |
192
|
|
|
|
193
|
|
|
|
194
|
|
|
/** |
195
|
|
|
* Condições dinamicas(where de acordo com a necessidade) |
196
|
|
|
*/ |
197
|
|
|
$dinamico = (new Query())->from("users as u")->select(["u.id", "u.first_name", "u.email"]); |
198
|
|
|
|
199
|
|
|
$filtroId = 5; |
200
|
|
|
|
201
|
|
|
if (!empty($filtroId)) { |
|
|
|
|
202
|
|
|
$dinamico->where("u.id <= ?", [$filtroId]); |
203
|
|
|
} |
204
|
|
|
var_dump($dinamico->get()); |
205
|
|
|
|
206
|
|
|
/** |
207
|
|
|
* Query sem query builder |
208
|
|
|
*/ |
209
|
|
|
$stmt = Connect::getInstance()->prepare(' |
210
|
|
|
select |
211
|
|
|
u.id, |
212
|
|
|
u.first_name, |
213
|
|
|
GROUP_CONCAT(distinct CONCAT_WS(";", a.id, a.street) SEPARATOR " | ") as enderecos |
214
|
|
|
from |
215
|
|
|
users u |
216
|
|
|
left join address a on |
217
|
|
|
a.user_id = u.id |
218
|
|
|
group by |
219
|
|
|
u.id |
220
|
|
|
limit 10 offset 0 |
221
|
|
|
'); |
222
|
|
|
$stmt->execute(); |
223
|
|
|
$result = $stmt->fetchAll(\PDO::FETCH_OBJ); |
224
|
|
|
var_dump($result); |
225
|
|
|
|
226
|
|
|
/** |
227
|
|
|
* Having |
228
|
|
|
*/ |
229
|
|
|
$sql = (new Query())->from("users as u") |
230
|
|
|
->select([ |
231
|
|
|
"u.id", |
232
|
|
|
"count(ao.id) as qtd" |
233
|
|
|
]) |
234
|
|
|
->join("app_orders as ao","ao.user_id = u.id") |
235
|
|
|
->groupBy("u.id") |
236
|
|
|
->having("count(ao.id) > ?", [1]) |
237
|
|
|
->get(); |
238
|
|
|
|
239
|
|
|
var_dump($sql); |
240
|
|
|
/** |
241
|
|
|
* DEBUG QUERY |
242
|
|
|
*/ |
243
|
|
|
|
244
|
|
|
$sql = (new Query())->from("users as u") |
245
|
|
|
->select([ |
246
|
|
|
"u.id", |
247
|
|
|
"count(ao.id) as qtd" |
248
|
|
|
]) |
249
|
|
|
->join("app_orders as ao", "ao.user_id = u.id") |
250
|
|
|
->groupBy("u.id") |
251
|
|
|
->having("count(ao.id) > ?", [1]) |
252
|
|
|
->toSQL(); |
253
|
|
|
var_dump($sql); |
254
|
|
|
|
255
|
|
|
|
256
|
|
|
/** |
257
|
|
|
* CREATE |
258
|
|
|
*/ |
259
|
|
|
$create = (new Create())->from("users") |
260
|
|
|
->create([ |
261
|
|
|
'first_name' => 'fulano', |
262
|
|
|
'last_name' => 'qualquer' . generateRandomString(), |
263
|
|
|
"email" => "fulano" . generateRandomString() . "@fulano.com" |
264
|
|
|
])->dump(); |
265
|
|
|
var_dump($create); |
266
|
|
|
|
267
|
|
|
/** |
268
|
|
|
* UPDATE |
269
|
|
|
*/ |
270
|
|
|
$update = (new Update())->from("users as u") |
271
|
|
|
->where("id = ?", [$create]) |
272
|
|
|
->update([ |
273
|
|
|
"email" => "fulano" . generateRandomString() . "@fulano.com" |
274
|
|
|
])->dump(); |
275
|
|
|
var_dump($update); |
276
|
|
|
|
277
|
|
|
/** |
278
|
|
|
* DELETE |
279
|
|
|
*/ |
280
|
|
|
$delete = (new Delete())->from("users as u") |
281
|
|
|
->where("id > ?", [56]) |
282
|
|
|
->dump(); |
283
|
|
|
var_dump($delete); |
284
|
|
|
|
285
|
|
|
/** |
286
|
|
|
* Criar filtros de queries de forma dinamica, gerando a string dos "where" e um array com bind params |
287
|
|
|
*/ |
288
|
|
|
|
289
|
|
|
$urlFilter = filter_input(INPUT_GET, 'search', FILTER_SANITIZE_FULL_SPECIAL_CHARS); |
|
|
|
|
290
|
|
|
|
291
|
|
|
$filtersArrReference = []; |
292
|
|
|
|
293
|
|
|
QueryHelpers::dynamicQueryFilters($filtersArrReference, 'id >= ?', [1]); |
294
|
|
|
|
295
|
|
|
if ($urlFilter) { |
296
|
|
|
QueryHelpers::dynamicQueryFilters($filtersArrReference, 'first_name like ?', ["%$urlFilter%"]); |
297
|
|
|
} |
298
|
|
|
|
299
|
|
|
|
300
|
|
|
$sql = (new Query())->from("users as u") |
301
|
|
|
->select(['*']) |
302
|
|
|
->where($filtersArrReference['queryString'], $filtersArrReference['binds']) |
303
|
|
|
->first(); |
304
|
|
|
var_dump($sql); |
305
|
|
|
|