@@ 325-339 (lines=15) @@ | ||
322 | /** |
|
323 | * {@inheritdoc} |
|
324 | */ |
|
325 | public function affectingStatement($query, $bindings = []) |
|
326 | { |
|
327 | return $this->run($query, $bindings, function ($me, $query, $bindings) { |
|
328 | if ($me->pretending()) { |
|
329 | return 0; |
|
330 | } |
|
331 | $query = \CouchbaseN1qlQuery::fromString($query); |
|
332 | $query->consistency($this->consistency); |
|
333 | $query->namedParams(['parameters' => $bindings]); |
|
334 | $result = $this->executeQuery($query); |
|
335 | $this->metrics = (isset($result->metrics)) ? $result->metrics : []; |
|
336 | ||
337 | return (isset($result->rows[0])) ? $result->rows[0] : false; |
|
338 | }); |
|
339 | } |
|
340 | ||
341 | /** |
|
342 | * @param $query |
|
@@ 347-361 (lines=15) @@ | ||
344 | * |
|
345 | * @return mixed |
|
346 | */ |
|
347 | public function positionalStatement($query, array $bindings = []) |
|
348 | { |
|
349 | return $this->run($query, $bindings, function ($me, $query, $bindings) { |
|
350 | if ($me->pretending()) { |
|
351 | return 0; |
|
352 | } |
|
353 | $query = \CouchbaseN1qlQuery::fromString($query); |
|
354 | $query->consistency($this->consistency); |
|
355 | $query->positionalParams($bindings); |
|
356 | $result = $this->executeQuery($query); |
|
357 | $this->metrics = (isset($result->metrics)) ? $result->metrics : []; |
|
358 | ||
359 | return (isset($result->rows[0])) ? $result->rows[0] : false; |
|
360 | }); |
|
361 | } |
|
362 | ||
363 | /** |
|
364 | * {@inheritdoc} |