Cache ids from mysql when fetching all objects

carlbennett · carlbennett · commit 72d1a4132158 · 2016-04-16T08:55:39.000Z
diff --git a/libraries/Document.php b/libraries/Document.php
@@ -58,6 +58,16 @@ public function __construct($data) {
   }
   
   public static function getAllDocuments() {
+    $cache_key = "bnetdocs-documents";
+    $cache_val = Common::$cache->get($cache_key);
+    if ($cache_val !== false) {
+      $ids     = explode(",", $cache_val);
+      $objects = [];
+      foreach ($ids as $id) {
+        $objects[] = new self($id);
+      }
+      return $objects;
+    }
     if (!isset(Common::$database)) {
       Common::$database = DatabaseDriver::getDatabaseObject();
     }
@@ -78,15 +88,18 @@ public static function getAllDocuments() {
       if (!$stmt->execute()) {
         throw new QueryException("Cannot refresh documents");
       }
-      $documents = [];
+      $ids     = [];
+      $objects = [];
       while ($row = $stmt->fetch(PDO::FETCH_OBJ)) {
-        $documents[] = new self($row);
+        $ids[]     = (int) $row->id;
+        $objects[] = new self($row);
         Common::$cache->set(
           "bnetdocs-document-" . $row->id, serialize($row), 300
         );
       }
       $stmt->closeCursor();
-      return $documents;
+      Common::$cache->set($cache_key, implode(",", $ids), 300);
+      return $objects;
     } catch (PDOException $e) {
       throw new QueryException("Cannot refresh documents", $e);
     }
diff --git a/libraries/NewsCategory.php b/libraries/NewsCategory.php
@@ -43,6 +43,16 @@ public function __construct($data) {
   }
 
   public static function getAll() {
+    $cache_key = "bnetdocs-newscategories";
+    $cache_val = Common::$cache->get($cache_key);
+    if ($cache_val !== false) {
+      $ids     = explode(",", $cache_val);
+      $objects = [];
+      foreach ($ids as $id) {
+        $objects[] = new self($id);
+      }
+      return $objects;
+    }
     if (!isset(Common::$database)) {
       Common::$database = DatabaseDriver::getDatabaseObject();
     }
@@ -59,15 +69,18 @@ public static function getAll() {
       if (!$stmt->execute()) {
         throw new QueryException("Cannot refresh news categories");
       }
-      $news_categories = [];
+      $ids     = [];
+      $objects = [];
       while ($row = $stmt->fetch(PDO::FETCH_OBJ)) {
-        $news_categories[] = new self($row);
+        $ids[]     = (int) $row->id;
+        $objects[] = new self($row);
         Common::$cache->set(
           "bnetdocs-newscategory-" . $row->id, serialize($row), 300
         );
       }
       $stmt->closeCursor();
-      return $news_categories;
+      Common::$cache->set($cache_key, implode(",", $ids), 300);
+      return $objects;
     } catch (PDOException $e) {
       throw new QueryException("Cannot refresh news categories", $e);
     }
diff --git a/libraries/NewsPost.php b/libraries/NewsPost.php
@@ -95,6 +95,16 @@ public static function create(
   }
 
   public static function getAllNews($reverse) {
+    $cache_key = "bnetdocs-newsposts";
+    $cache_val = Common::$cache->get($cache_key);
+    if ($cache_val !== false) {
+      $ids     = explode(",", $cache_val);
+      $objects = [];
+      foreach ($ids as $id) {
+        $objects[] = new self($id);
+      }
+      return $objects;
+    }
     if (!isset(Common::$database)) {
       Common::$database = DatabaseDriver::getDatabaseObject();
     }
@@ -121,15 +131,18 @@ public static function getAllNews($reverse) {
       if (!$stmt->execute()) {
         throw new QueryException("Cannot refresh news post");
       }
-      $news_posts = [];
+      $ids     = [];
+      $objects = [];
       while ($row = $stmt->fetch(PDO::FETCH_OBJ)) {
-        $news_posts[] = new self($row);
+        $ids[]     = (int) $row->id;
+        $objects[] = new self($row);
         Common::$cache->set(
           "bnetdocs-newspost-" . $row->id, serialize($row), 300
         );
       }
       $stmt->closeCursor();
-      return $news_posts;
+      Common::$cache->set($cache_key, implode(",", $ids), 300);
+      return $objects;
     } catch (PDOException $e) {
       throw new QueryException("Cannot refresh news post", $e);
     }
diff --git a/libraries/Packet.php b/libraries/Packet.php
@@ -80,6 +80,16 @@ public function __construct($data) {
   }
   
   public static function getAllPackets() {
+    $cache_key = "bnetdocs-packets";
+    $cache_val = Common::$cache->get($cache_key);
+    if ($cache_val !== false) {
+      $ids     = explode(",", $cache_val);
+      $objects = [];
+      foreach ($ids as $id) {
+        $objects[] = new self($id);
+      }
+      return $objects;
+    }
     if (!isset(Common::$database)) {
       Common::$database = DatabaseDriver::getDatabaseObject();
     }
@@ -105,15 +115,18 @@ public static function getAllPackets() {
       if (!$stmt->execute()) {
         throw new QueryException("Cannot refresh packets");
       }
-      $packets = [];
+      $ids     = [];
+      $objects = [];
       while ($row = $stmt->fetch(PDO::FETCH_OBJ)) {
-        $packets[] = new self($row);
+        $ids[]     = (int) $row->id;
+        $objects[] = new self($row);
         Common::$cache->set(
           "bnetdocs-packet-" . $row->id, serialize($row), 300
         );
       }
       $stmt->closeCursor();
-      return $packets;
+      Common::$cache->set($cache_key, implode(",", $ids), 300);
+      return $objects;
     } catch (PDOException $e) {
       throw new QueryException("Cannot refresh packets", $e);
     }
diff --git a/libraries/PacketApplicationLayer.php b/libraries/PacketApplicationLayer.php
@@ -36,6 +36,16 @@ public function __construct($data) {
   }
 
   public static function getAllPacketApplicationLayers() {
+    $cache_key = "bnetdocs-packetapplicationlayers";
+    $cache_val = Common::$cache->get($cache_key);
+    if ($cache_val !== false) {
+      $ids     = explode(",", $cache_val);
+      $objects = [];
+      foreach ($ids as $id) {
+        $objects[] = new self($id);
+      }
+      return $objects;
+    }
     if (!isset(Common::$database)) {
       Common::$database = DatabaseDriver::getDatabaseObject();
     }
@@ -51,15 +61,18 @@ public static function getAllPacketApplicationLayers() {
       if (!$stmt->execute()) {
         throw new QueryException("Cannot refresh packet application layers");
       }
-      $packetapplicationlayers = [];
+      $ids     = [];
+      $objects = [];
       while ($row = $stmt->fetch(PDO::FETCH_OBJ)) {
-        $packetapplicationlayers[] = new self($row);
+        $ids[]     = (int) $row->id;
+        $objects[] = new self($row);
         Common::$cache->set(
           "bnetdocs-packetapplicationlayer-" . $row->id, serialize($row), 300
         );
       }
       $stmt->closeCursor();
-      return $packetapplicationlayers;
+      Common::$cache->set($cache_key, implode(",", $ids), 300);
+      return $objects;
     } catch (PDOException $e) {
       throw new QueryException("Cannot refresh packet application layers", $e);
     }
diff --git a/libraries/PacketTransportLayer.php b/libraries/PacketTransportLayer.php
@@ -36,6 +36,16 @@ public function __construct($data) {
   }
 
   public static function getAllPacketTransportLayers() {
+    $cache_key = "bnetdocs-packettransportlayers";
+    $cache_val = Common::$cache->get($cache_key);
+    if ($cache_val !== false) {
+      $ids     = explode(",", $cache_val);
+      $objects = [];
+      foreach ($ids as $id) {
+        $objects[] = new self($id);
+      }
+      return $objects;
+    }
     if (!isset(Common::$database)) {
       Common::$database = DatabaseDriver::getDatabaseObject();
     }
@@ -51,15 +61,18 @@ public static function getAllPacketTransportLayers() {
       if (!$stmt->execute()) {
         throw new QueryException("Cannot refresh packet transport layers");
       }
-      $packettransportlayers = [];
+      $ids     = [];
+      $objects = [];
       while ($row = $stmt->fetch(PDO::FETCH_OBJ)) {
-        $packettransportlayers[] = new self($row);
+        $ids[]     = (int) $row->id;
+        $objects[] = new self($row);
         Common::$cache->set(
           "bnetdocs-packettransportlayer-" . $row->id, serialize($row), 300
         );
       }
       $stmt->closeCursor();
-      return $packettransportlayers;
+      Common::$cache->set($cache_key, implode(",", $ids), 300);
+      return $objects;
     } catch (PDOException $e) {
       throw new QueryException("Cannot refresh packet transport layers", $e);
     }
diff --git a/libraries/Product.php b/libraries/Product.php
@@ -45,6 +45,16 @@ public function __construct($data) {
   }
 
   public static function getAllProducts() {
+    $cache_key = "bnetdocs-products";
+    $cache_val = Common::$cache->get($cache_key);
+    if ($cache_val !== false) {
+      $ids     = explode(",", $cache_val);
+      $objects = [];
+      foreach ($ids as $id) {
+        $objects[] = new self($id);
+      }
+      return $objects;
+    }
     if (!isset(Common::$database)) {
       Common::$database = DatabaseDriver::getDatabaseObject();
     }
@@ -63,15 +73,18 @@ public static function getAllProducts() {
       if (!$stmt->execute()) {
         throw new QueryException("Cannot refresh products");
       }
-      $products = [];
+      $ids     = [];
+      $objects = [];
       while ($row = $stmt->fetch(PDO::FETCH_OBJ)) {
-        $products[] = new self($row);
+        $ids[]     = (int) $row->bnet_product_id;
+        $objects[] = new self($row);
         Common::$cache->set(
           "bnetdocs-product-" . $row->bnet_product_id, serialize($row), 300
         );
       }
       $stmt->closeCursor();
-      return $products;
+      Common::$cache->set($cache_key, implode(",", $ids), 300);
+      return $objects;
     } catch (PDOException $e) {
       throw new QueryException("Cannot refresh products", $e);
     }
diff --git a/libraries/Server.php b/libraries/Server.php
@@ -63,6 +63,16 @@ public function getAddress() {
   }
 
   public static function getAllServers() {
+    $cache_key = "bnetdocs-servers";
+    $cache_val = Common::$cache->get($cache_key);
+    if ($cache_val !== false) {
+      $ids     = explode(",", $cache_val);
+      $objects = [];
+      foreach ($ids as $id) {
+        $objects[] = new self($id);
+      }
+      return $objects;
+    }
     if (!isset(Common::$database)) {
       Common::$database = DatabaseDriver::getDatabaseObject();
     }
@@ -89,15 +99,18 @@ public static function getAllServers() {
       if (!$stmt->execute()) {
         throw new QueryException("Cannot refresh servers");
       }
-      $servers = [];
+      $ids     = [];
+      $objects = [];
       while ($row = $stmt->fetch(PDO::FETCH_OBJ)) {
-        $servers[] = new self($row);
+        $ids[]     = (int) $row->id;
+        $objects[] = new self($row);
         Common::$cache->set(
           "bnetdocs-server-" . $row->id, serialize($row), 300
         );
       }
       $stmt->closeCursor();
-      return $servers;
+      Common::$cache->set($cache_key, implode(",", $ids), 300);
+      return $objects;
     } catch (PDOException $e) {
       throw new QueryException("Cannot refresh servers", $e);
     }
diff --git a/libraries/ServerType.php b/libraries/ServerType.php
@@ -33,6 +33,16 @@ public function __construct($data) {
   }
 
   public static function getAllServerTypes() {
+    $cache_key = "bnetdocs-servertypes";
+    $cache_val = Common::$cache->get($cache_key);
+    if ($cache_val !== false) {
+      $ids     = explode(",", $cache_val);
+      $objects = [];
+      foreach ($ids as $id) {
+        $objects[] = new self($id);
+      }
+      return $objects;
+    }
     if (!isset(Common::$database)) {
       Common::$database = DatabaseDriver::getDatabaseObject();
     }
@@ -47,15 +57,18 @@ public static function getAllServerTypes() {
       if (!$stmt->execute()) {
         throw new QueryException("Cannot refresh server types");
       }
-      $servers = [];
+      $ids     = [];
+      $objects = [];
       while ($row = $stmt->fetch(PDO::FETCH_OBJ)) {
-        $servers[] = new self($row);
+        $ids[]     = (int) $row->id;
+        $objects[] = new self($row);
         Common::$cache->set(
           "bnetdocs-servertype-" . $row->id, serialize($row), 300
         );
       }
       $stmt->closeCursor();
-      return $servers;
+      Common::$cache->set($cache_key, implode(",", $ids), 300);
+      return $objects;
     } catch (PDOException $e) {
       throw new QueryException("Cannot refresh server types", $e);
     }
