ForwardFW
[ class tree: ForwardFW ] [ index: ForwardFW ] [ all elements ]
Packages:
ForwardFW

Source for file MDB2.php

Documentation is available at MDB2.php

  1. <?php
  2. declare(encoding = "utf-8");
  3. /**
  4.  * This file is part of ForwardFW a web application framework.
  5.  *
  6.  * This library is free software; you can redistribute it and/or
  7.  * modify it under the terms of the GNU General Public
  8.  * License as published by the Free Software Foundation; either
  9.  * version 2.1 of the License, or (at your option) any later version.
  10.  *
  11.  * This library is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14.  * General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public
  17.  * License along with this library; if not, write to the Free Software
  18.  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  19.  *
  20.  * PHP version 5
  21.  *
  22.  * @category   Application
  23.  * @package    ForwardFW
  24.  * @subpackage Controller/DataHandler
  25.  * @author     Alexander Opitz <opitz.alexander@primacom.net>
  26.  * @copyright  2009-2010 The Authors
  27.  * @license    http://www.gnu.org/copyleft/gpl.html GNU General Public License
  28.  * @version    SVN: $Id: $
  29.  * @link       http://forwardfw.sourceforge.net
  30.  * @since      File available since Release 0.0.7
  31.  */
  32.  
  33. require_once 'ForwardFW/Exception/DataHandler.php';
  34. require_once 'ForwardFW/Controller/DataHandler.php';
  35. require_once 'ForwardFW/Interface/Application.php';
  36. require_once 'PEAR/MDB2.php';
  37.  
  38. /**
  39.  * Managing DataLoading via PEAR::MDB2
  40.  *
  41.  * @category   Application
  42.  * @package    ForwardFW
  43.  * @subpackage Controller/DataHandler
  44.  * @author     Alexander Opitz <opitz.alexander@primacom.net>
  45.  * @license    http://www.gnu.org/copyleft/gpl.html GNU General Public License
  46.  * @link       http://forwardfw.sourceforge.net
  47.  */
  48. class ForwardFW_Controller_DataHandler_MDB2 extends ForwardFW_Controller_DataHandler
  49. {
  50.     /**
  51.      * @var array Prefix for tables
  52.      */
  53.     private $arTablePrefix = array();
  54.  
  55.     /**
  56.      * Loads Data from a connection (DB, SOAP, File)
  57.      *
  58.      * @param string $strConnection Name of connection
  59.      * @param array  $arOptions     Options to load the data
  60.      *
  61.      * @return mixed Data from the connection.
  62.      */
  63.     public function loadFrom($strConnection, array $arOptions)
  64.     {
  65.         $conMDB2 = $this->getConnection($strConnection);
  66.  
  67.         $strQuery = 'SELECT ' . $arOptions['select'] . ' FROM ';
  68.         if (isset($this->arTablePrefix[$strConnection])) {
  69.             $strQuery .= '`' . $this->arTablePrefix[$strConnection]
  70.                 .'_' . $arOptions['from'] . '`';
  71.         } else {
  72.             $strQuery .= '`' . $arOptions['from'] . '`';
  73.         }
  74.         if (isset($arOptions['where'])) {
  75.             $strQuery .= ' WHERE ' . $arOptions['where'];
  76.         }
  77.         if (isset($arOptions['group'])) {
  78.             $strQuery .= ' GROUP BY ' . $arOptions['group'];
  79.         }
  80.         if (isset($arOptions['order'])) {
  81.             $strQuery .= ' ORDER BY ' . $arOptions['order'];
  82.         }
  83.         if (isset($arOptions['limit'])) {
  84.             $strQuery .= ' LIMIT ' . $arOptions['limit'];
  85.         }
  86.  
  87.         $arResult = array();
  88.         $resultMDB2 = $conMDB2->query($strQuery);
  89.  
  90.         if (PEAR::isError($resultMDB2)) {
  91.             $this->application->getResponse()->addError($resultMDB2->getMessage() . $resultMDB2->getUserinfo());
  92.             throw new ForwardFW_Exception_DataHandler(
  93.                 'Error while execute: '
  94.                 . $resultMDB2->getMessage()
  95.                 . $resultMDB2->getUserinfo()
  96.             );
  97.         }
  98.         while ($arRow = $resultMDB2->fetchRow(MDB2_FETCHMODE_ASSOC)) {
  99.             array_push($arResult, $arRow);
  100.         }
  101.         return $arResult;
  102.     }
  103.  
  104.     /**
  105.      * Saves Data to a connection (DB, SOAP, File)
  106.      *
  107.      * @param string $strConnection Name of connection
  108.      * @param array  $arOptions     Options to load the data
  109.      *
  110.      * @return mixed Data from the connection.
  111.      */
  112.     public function saveTo($strConnection, array $options)
  113.     {
  114.         // @TODO
  115.     }
  116.  
  117.  
  118.     /**
  119. /**
  120.      * Loads and initialize the connection handler.
  121.      *
  122.      * @param string $strConnection Name of connection
  123.      *
  124.      * @return void 
  125.      */
  126.     public function initConnection($strConnection)
  127.     {
  128.         $arConfig = $this->getConfigParameter($strConnection);
  129.  
  130.         if (isset($arConfig['prefix'])) {
  131.             $this->arTablePrefix[$strConnection] = $arConfig['prefix'];
  132.         }
  133.         $options = array('portability' => MDB2_PORTABILITY_ALL ^ MDB2_PORTABILITY_FIX_CASE);
  134.         $options = array_merge($options, $arConfig['options']);
  135.         $conMDB2 = MDB2::connect($arConfig['dsn'], $options);
  136.  
  137.         if (PEAR::isError($conMDB2)) {
  138.             $this->application->getResponse()->addError(
  139.                 $conMDB2->getMessage() . $conMDB2->getUserinfo()
  140.             );
  141.             throw new ForwardFW_Exception_DataHandler(
  142.                 'Cannot initialize MDB Connection: '
  143.                 . $conMDB2->getMessage()
  144.                 . $conMDB2->getUserinfo()
  145.             );
  146.         }
  147.  
  148.         $ret = $conMDB2->exec('set character set utf8');
  149.         $this->arConnectionCache[$strConnection] = $conMDB2;
  150.     }
  151.  
  152. }
  153.  
  154. ?>
Documentation generated on Sun, 30 Jan 2011 20:46:43 +0100 by phpDocumentor 1.4.3