@@ -150,7 +150,7 @@ discard block |
||
| 150 | 150 | |
| 151 | 151 | $PDO = new PDO("sqlite:" . $this->SqliteDir . '/' . self::INDEXING_FILE); |
| 152 | 152 | $PDO->setAttribute(PDO::ATTR_ERRMODE, |
| 153 | - PDO::ERRMODE_EXCEPTION); |
|
| 153 | + PDO::ERRMODE_EXCEPTION); |
|
| 154 | 154 | |
| 155 | 155 | if ($createTable == true) { |
| 156 | 156 | $this->initIndexing($PDO); |
@@ -185,7 +185,7 @@ discard block |
||
| 185 | 185 | // look for keyword |
| 186 | 186 | $stm = $this->indexing->prepare("SELECT * FROM `balancing` WHERE `keyword`=:keyword LIMIT 1"); |
| 187 | 187 | $stm->execute([ |
| 188 | - ':keyword' => $keyword, |
|
| 188 | + ':keyword' => $keyword, |
|
| 189 | 189 | ]); |
| 190 | 190 | $row = $stm->fetch(PDO::FETCH_ASSOC); |
| 191 | 191 | if (isset($row[ 'db' ]) && $row[ 'db' ] != '') { |
@@ -197,8 +197,8 @@ discard block |
||
| 197 | 197 | $db = $this->currentDB; |
| 198 | 198 | $stm = $this->indexing->prepare("INSERT INTO `balancing` (`keyword`,`db`) VALUES(:keyword, :db)"); |
| 199 | 199 | $stm->execute([ |
| 200 | - ':keyword' => $keyword, |
|
| 201 | - ':db' => $db, |
|
| 200 | + ':keyword' => $keyword, |
|
| 201 | + ':db' => $db, |
|
| 202 | 202 | ]); |
| 203 | 203 | } |
| 204 | 204 | |
@@ -269,11 +269,11 @@ discard block |
||
| 269 | 269 | if ($toWrite == true) { |
| 270 | 270 | try { |
| 271 | 271 | $stm = $this->getDb($item->getKey()) |
| 272 | - ->prepare("INSERT OR REPLACE INTO `caching` (`keyword`,`object`,`exp`) values(:keyword,:object,:exp)"); |
|
| 272 | + ->prepare("INSERT OR REPLACE INTO `caching` (`keyword`,`object`,`exp`) values(:keyword,:object,:exp)"); |
|
| 273 | 273 | $stm->execute([ |
| 274 | - ':keyword' => $item->getKey(), |
|
| 275 | - ':object' => $this->encode($this->driverPreWrap($item)), |
|
| 276 | - ':exp' => time() + $item->getTtl(), |
|
| 274 | + ':keyword' => $item->getKey(), |
|
| 275 | + ':object' => $this->encode($this->driverPreWrap($item)), |
|
| 276 | + ':exp' => time() + $item->getTtl(), |
|
| 277 | 277 | ]); |
| 278 | 278 | |
| 279 | 279 | return true; |
@@ -281,11 +281,11 @@ discard block |
||
| 281 | 281 | |
| 282 | 282 | try { |
| 283 | 283 | $stm = $this->getDb($item->getKey(), true) |
| 284 | - ->prepare("INSERT OR REPLACE INTO `caching` (`keyword`,`object`,`exp`) values(:keyword,:object,:exp)"); |
|
| 284 | + ->prepare("INSERT OR REPLACE INTO `caching` (`keyword`,`object`,`exp`) values(:keyword,:object,:exp)"); |
|
| 285 | 285 | $stm->execute([ |
| 286 | - ':keyword' => $item->getKey(), |
|
| 287 | - ':object' => $this->encode($this->driverPreWrap($item)), |
|
| 288 | - ':exp' => time() + $item->getTtl(), |
|
| 286 | + ':keyword' => $item->getKey(), |
|
| 287 | + ':object' => $this->encode($this->driverPreWrap($item)), |
|
| 288 | + ':exp' => time() + $item->getTtl(), |
|
| 289 | 289 | ]); |
| 290 | 290 | } catch (PDOException $e) { |
| 291 | 291 | return false; |
@@ -307,20 +307,20 @@ discard block |
||
| 307 | 307 | { |
| 308 | 308 | try { |
| 309 | 309 | $stm = $this->getDb($key) |
| 310 | - ->prepare("SELECT * FROM `caching` WHERE `keyword`=:keyword AND (`exp` >= :U) LIMIT 1"); |
|
| 310 | + ->prepare("SELECT * FROM `caching` WHERE `keyword`=:keyword AND (`exp` >= :U) LIMIT 1"); |
|
| 311 | 311 | $stm->execute([ |
| 312 | - ':keyword' => $key, |
|
| 313 | - ':U' => time(), |
|
| 312 | + ':keyword' => $key, |
|
| 313 | + ':U' => time(), |
|
| 314 | 314 | ]); |
| 315 | 315 | $row = $stm->fetch(PDO::FETCH_ASSOC); |
| 316 | 316 | |
| 317 | 317 | } catch (PDOException $e) { |
| 318 | 318 | try { |
| 319 | 319 | $stm = $this->getDb($key, true) |
| 320 | - ->prepare("SELECT * FROM `caching` WHERE `keyword`=:keyword AND (`exp` >= :U) LIMIT 1"); |
|
| 320 | + ->prepare("SELECT * FROM `caching` WHERE `keyword`=:keyword AND (`exp` >= :U) LIMIT 1"); |
|
| 321 | 321 | $stm->execute([ |
| 322 | - ':keyword' => $key, |
|
| 323 | - ':U' => time(), |
|
| 322 | + ':keyword' => $key, |
|
| 323 | + ':U' => time(), |
|
| 324 | 324 | ]); |
| 325 | 325 | $row = $stm->fetch(PDO::FETCH_ASSOC); |
| 326 | 326 | } catch (PDOException $e) { |
@@ -358,13 +358,13 @@ discard block |
||
| 358 | 358 | if ($item instanceof Item) { |
| 359 | 359 | try { |
| 360 | 360 | $stm = $this->getDb($item->getKey()) |
| 361 | - //->prepare("DELETE FROM `caching` WHERE (`id`=:id) OR (`exp` <= :U) "); |
|
| 362 | - ->prepare("DELETE FROM `caching` WHERE (`exp` <= :U) OR (`keyword`=:keyword) "); |
|
| 361 | + //->prepare("DELETE FROM `caching` WHERE (`id`=:id) OR (`exp` <= :U) "); |
|
| 362 | + ->prepare("DELETE FROM `caching` WHERE (`exp` <= :U) OR (`keyword`=:keyword) "); |
|
| 363 | 363 | |
| 364 | 364 | return $stm->execute([ |
| 365 | 365 | // ':id' => $row[ 'id' ], |
| 366 | - ':keyword' => $item->getKey(), |
|
| 367 | - ':U' => time(), |
|
| 366 | + ':keyword' => $item->getKey(), |
|
| 367 | + ':U' => time(), |
|
| 368 | 368 | ]); |
| 369 | 369 | } catch (PDOException $e) { |
| 370 | 370 | return false; |
@@ -422,10 +422,10 @@ discard block |
||
| 422 | 422 | * @todo: Check expiration time here |
| 423 | 423 | */ |
| 424 | 424 | $stm = $this->getDb($item->getKey()) |
| 425 | - ->prepare("SELECT COUNT(`id`) as `total` FROM `caching` WHERE (`keyword`=:keyword) AND (`exp` <= :U) "); |
|
| 425 | + ->prepare("SELECT COUNT(`id`) as `total` FROM `caching` WHERE (`keyword`=:keyword) AND (`exp` <= :U) "); |
|
| 426 | 426 | $stm->execute([ |
| 427 | - ':keyword' => $item->getKey(), |
|
| 428 | - ':U' => time(), |
|
| 427 | + ':keyword' => $item->getKey(), |
|
| 428 | + ':U' => time(), |
|
| 429 | 429 | ]); |
| 430 | 430 | $data = $stm->fetch(PDO::FETCH_ASSOC); |
| 431 | 431 | if ($data[ 'total' ] >= 1) { |
@@ -464,11 +464,11 @@ discard block |
||
| 464 | 464 | try { |
| 465 | 465 | $PDO = new PDO("sqlite:" . $file_path); |
| 466 | 466 | $PDO->setAttribute(PDO::ATTR_ERRMODE, |
| 467 | - PDO::ERRMODE_EXCEPTION); |
|
| 467 | + PDO::ERRMODE_EXCEPTION); |
|
| 468 | 468 | |
| 469 | 469 | $stm = $PDO->prepare("DELETE FROM `caching` WHERE `exp` <= :U"); |
| 470 | 470 | $stm->execute([ |
| 471 | - ':U' => date('U'), |
|
| 471 | + ':U' => date('U'), |
|
| 472 | 472 | ]); |
| 473 | 473 | |
| 474 | 474 | $PDO->exec('VACUUM;'); |
@@ -482,9 +482,9 @@ discard block |
||
| 482 | 482 | } |
| 483 | 483 | |
| 484 | 484 | $stat->setSize($optimized) |
| 485 | - ->setInfo('Total before removing expired entries [bytes]: ' . $total . ', ' |
|
| 485 | + ->setInfo('Total before removing expired entries [bytes]: ' . $total . ', ' |
|
| 486 | 486 | . 'Optimized after removing expired entries [bytes]: ' . $optimized |
| 487 | - ); |
|
| 487 | + ); |
|
| 488 | 488 | |
| 489 | 489 | return $stat; |
| 490 | 490 | } |