common-cache.php

Go to the documentation of this file.

<?php
/*
 SPDX-FileCopyrightText: © 2008-2012 Hewlett-Packard Development Company, L.P.
 
 SPDX-License-Identifier: LGPL-2.1-only
*/
 
function ReportCacheGet($CacheKey)
{
  global $PG_CONN;
  global $UserCacheStat;
 
  /* Purge old entries ~ 1/500 of the times this fcn is called */
  if (random_int(1, 500) == 1) {
    ReportCachePurgeByDate(" now() - interval '365 days'");
  }
 
  if ($UserCacheStat == 0) {
    $sql = "SELECT cache_on FROM report_cache_user WHERE user_fk='$_SESSION[UserId]';";
    $result = pg_query($PG_CONN, $sql);
    DBCheckResult($result, $sql, __FILE__, __LINE__);
    $row = pg_fetch_assoc($result);
    pg_free_result($result);
    if (! empty($row['cache_on']) && ($result['cache_on'] == 'N')) {
      $UserCacheStat = 2;
      return; /* cache is off for this user */
    }
  }
 
  $EscKey = pg_escape_string($CacheKey);
 
  // update time last accessed
  $sql = "UPDATE report_cache SET report_cache_tla = now() WHERE report_cache_key='$EscKey';";
  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);
  pg_free_result($result);
 
  // Get the cached data
  $sql = "SELECT report_cache_value FROM report_cache WHERE report_cache_key='$EscKey';";
  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);
  $row = pg_fetch_assoc($result);
  if ($row == false) {
    return;
  }
  $cashedvalue = $row['report_cache_value'];
  pg_free_result($result);
  return $cashedvalue;
} // ReportCacheGet()
 
 
function ReportCachePut($CacheKey, $CacheValue)
{
  global $PG_CONN;
  global $UserCacheStat;
 
  /* Check if user has cache turned off
   * CacheUserStat is set in ReportCacheGet
  * If it isn't, it is safe to fallback to the default
  * behavior (cache is on).
  */
  if ($UserCacheStat == 2) {
    return;
  }
 
  $EscKey = pg_escape_string($CacheKey);
  $EscValue = pg_escape_string($CacheValue);
 
  /* Parse the key.  If the key is a uri  */
  /* look for upload =>, if not found, look for item => */
  /* in order to get the upload key */
  $ParsedURI = array();
  parse_str($EscKey, $ParsedURI);
  /* use 'upload= ' to define the upload in the cache key */
  if (array_key_exists("upload", $ParsedURI)) {
    $Upload = $ParsedURI['upload'];
  }
  if (array_key_exists("item", $ParsedURI)) {
    $sql = "SELECT upload_fk FROM uploadtree WHERE uploadtree_pk='$ParsedURI[item]';";
    $result = pg_query($PG_CONN, $sql);
    DBCheckResult($result, $sql, __FILE__, __LINE__);
 
    $row = pg_fetch_assoc($result);
    $Upload = $row['upload_fk'];
    pg_free_result($result);
  }
  if (empty($Upload)) {
    $Upload = "Null";
  }
 
  $sql = "INSERT INTO report_cache (report_cache_key, report_cache_value, report_cache_uploadfk)
                           VALUES ('$EscKey', '$EscValue', $Upload);";
  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);
  pg_free_result($result);
  $PGError = pg_last_error($PG_CONN);
  /* If duplicate key, do an update, else report the error */
  if (strpos($PGError, "uplicate") > 0) {
    $sql = "UPDATE report_cache SET report_cache_value = '$EscValue', " .
      "report_cache_tla=now() WHERE report_cache_key = '$EscKey';";
    $result = pg_query($PG_CONN, $sql);
    DBCheckResult($result, $sql, __FILE__, __LINE__);
    pg_free_result($result);
  }
} // ReportCacheInit()
 
function ReportCachePurgeAll()
{
  global $PG_CONN;
  $sql = "DELETE FROM report_cache;";
  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);
  pg_free_result($result);
} // ReportCachePurgeAll()
 
function ReportCachePurgeByDate($PurgeDate)
{
  global $PG_CONN;
  $sql = "DELETE FROM report_cache WHERE report_cache_tla < $PurgeDate;";
  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);
  pg_free_result($result);
} // ReportCachePurgeByDate()
 
function ReportCachePurgeByUpload($UploadPK)
{
  global $PG_CONN;
  $sql = "DELETE FROM report_cache WHERE report_cache_uploadfk = $UploadPK;";
  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);
  pg_free_result($result);
} // ReportCachePurgeByUpload()
 
function ReportCachePurgeByKey($CacheKey)
{
  global $PG_CONN;
  $ParsedURI = array();
  $EscKey = pg_escape_string($CacheKey);
  parse_str($EscKey, $ParsedURI);
 
  $sql = "DELETE FROM report_cache WHERE report_cache_key = '$EscKey';";
  $result = pg_query($PG_CONN, $sql);
  DBCheckResult($result, $sql, __FILE__, __LINE__);
  $Err = pg_last_error($PG_CONN);
  pg_free_result($result);
 
  return $Err;
} // ReportCachePurgeByKey()