JuelichDbReader.php

gehe zur Dokumentation dieser Datei

<?php
require_once TM_PATH . 'credentials.php';
require_once TM_PATH . 'MDB2.php';

class JuelichDbReader {

  var $dbms;                    
  var $tplCache = array();      
  function JuelichDbReader() {
    $dsn = getDsn();
    $db  =& MDB2::connect($dsn);
    if (PEAR::isError($db)) {
      include_once TM_PATH . 'juelich/web/JuelichError.php';
      $error = new JuelichError;
      $error->printError(1, $db->getMessage());
      exit();
    }
    $db->setFetchMode(MDB2_FETCHMODE_ASSOC);
    $this->dbms = $db;
  }

  function getOneValue($sql) {
    $value = '';
    $this->checkSql($sql);
    $value = $this->dbms->queryOne($sql);
    $this->checkError($value);
    return $value;
  }

  function getOneRow($sql, &$row) {
    $this->checkSql($sql);
    $row = $this->dbms->queryRow($sql);
    $this->checkError($row);
    if (empty($row)) {
      return false;
    }
    return true;
  }

  function getAllRows($sql, &$rows) {
    $this->checkSql($sql);
    $rows = $this->dbms->queryAll($sql);
    $this->checkError($rows);
    return count($rows);
  }

  function getAllCols($sql, &$cols) {
    $this->checkSql($sql);
    $cols = $this->dbms->queryCol($sql);
    $this->checkError($cols);
    return count($cols);
  }

  function getTemplateContent($tName, $l10n) {
    if (!empty($this->tplCache[$tName])) {
      return $this->tplCache[$tName];
    }
    $sqlPrep = "SELECT t_content "
      . "FROM template "
      . "WHERE template_id = '%s' "
      . "AND l10n_id = %d";
    $sql = sprintf($sqlPrep,
                   $tName,
                   $l10n
                   );
    $content = $this->getOneValue($sql);
    $this->tplCache[$tName] = $content;
    return $content;
  }

  function getModuleString($id) {
    $sqlPrep = "SELECT g_modString "
      . "FROM gruppe "
      . "LEFT JOIN produkt USING(gruppe_id) "
      . "WHERE produkt_id = %s ";
    $sql = sprintf($sqlPrep, $id);
    return $this->getOneValue($sql);
  }

  function getImage($id, &$imgData) {
    $sqlPrep = "SELECT i_name, i_size, i_time, i_data "
      . "FROM image "
      . "WHERE id = '%s'";
    $sql = sprintf($sqlPrep, $id);
    $this->getOneRow($sql, $imgData);
    return;
  }

  function getTelAccessCats($hId, &$catData) {
    $sqlPrep = "SELECT DISTINCT "
      . "telZub_kat.telZub_kat_id AS id, k_name AS name "
      . "FROM telZub_kat "
      . "LEFT JOIN telZub USING(telZub_kat_id) "
      . "WHERE hersteller_id = %s "
      . "AND tz_online = '%s'";
    $sql = sprintf($sqlPrep,
                   $hId,
                   SQL_ONLINE
                   );
    $this->getAllRows($sql, $catData);
    return;
  }

  function getTelAccess($catId, &$accData) {
    $sqlPrep = "SELECT tz_name AS name, tz_preis AS price "
      . "FROM telZub "
      . "WHERE telZub_kat_id = %s "
      . "AND tz_online = '%s' "
      . "ORDER BY tz_sort";
    $sql = sprintf($sqlPrep,
                   $catId,
                   SQL_ONLINE
                   );
    $this->getAllRows($sql, $accData);
    return;
  }

  function checkError(&$value) {
    if (PEAR::isError($value)) {
      include_once TM_PATH . 'juelich/web/JuelichError.php';
      $error = new JuelichError;
      $error->printError(2, $value->getDebugInfo());
      exit();
    }
    return false;
  }

  function checkSql($sql) {
    // echo $sql, "<br>";
    $pos = strpos( $sql, '=;' );
    if( $pos > 0 ) {
      include_once TM_PATH . 'juelich/web/JuelichError.php';
      $error = new JuelichError;
      $error->printError(2,
                         'SQL-ScriptKiddies unterwegs?: ' . $sql);
      exit();
    }
    return;
  }

}

?>

---