ConfigDBBackend.class.php

Go to the documentation of this file.

<?php
include_once("core/config/IConfigBackend.class.php");
include_once("core/db/dbjames.class.php");

class ConfigDBBackend extends IConfigBackend
{
        var $idM;       
        var $idG;       
        var $idU;       
        
        var $dbObj;     
        
        function ConfigDBBackend($petition)
        {
                $this->idM = $petition->GetModule();
                $this->idG = $petition->GetGroup();
                $this->idU= $petition->GetUser();
                
                // If it is a system petition...
                if ($this->idM == null) $this->idM = 0;
                if ($this->idG == null) $this->idG = 0;
                if ($this->idU == null) $this->idU = 0;
                
                $this->dbObj = new DBJames();
        }
        
        function GetConfig()
        {
                $result = array();
                
                $query  = " SELECT ConfigValues.*, ConfigKeys.keyName FROM ";
                $query .= " ConfigValues LEFT JOIN ConfigKeys ON ConfigValues.idK = ConfigKeys.idK ";
                $query .= " WHERE ConfigValues.idU=".$this->idU." ";
                $query .= " AND ConfigValues.idG=".$this->idG." ";
                $query .= " AND ConfigKeys.idM=".$this->idM;
                
                $this->dbObj->Query($query);
                
                /* Carga la configuración */
                while (! $this->dbObj->EOF)
                {
                        $result[$this->dbObj->row["key"]]=$this->dbObj->row["value"];
                        $this->dbObj->Next();
                }
                
                return $result;
        }
        
        function SetConfig($keys)
        {
                if (count($keys) > 0)
                {
                        foreach($keys as $key => $value)
                        {
                                $this->_MakeQuery($key, $value);
                        }
                }
        }
        
        function _MakeQuery($key, $value)
        {
                $idK = $this->_GetIdK($key);
                
                // First, we try to update the value in the DB
                $result = $this->_UpdateValue($idK, $value);
                
                // If there was an error, maybe that it is the first time it
                // is added in the DB, so we'll try an insert.
                if (! $result)
                        $result = $this->_InsertValue($idK, $value);
                        
                return $result;
        }
        
        function _GetIdK($key)
        { 
                $query  = " SELECT * FROM ConfigKeys ";
                $query .= " WHERE ConfigKeys.idM=".$this->idM;
                $query .= " AND ConfigKeys.key='".$key."'";
                
                $this->dbObj->Query($query);
                
                if ($this->dbObj->numRows == 0)
                {
                        return false;
                }
                else
                {
                        return $this->dbObj->row["idK"];
                }
        }
        
        function _InsertValue($idK, $value)
        {
                $query  = " INSERT INTO ConfigValues ";
                $query .= " ( idU, idG, idK, value ) ";
                $query .= " VALUES ( ".$this->idU.", ".$this->idG;
                $query .= ", ".$idK.", '".$value."' )";

                $this->dbObj->Execute($query);
        
                // It will be false if there was an error
                return $this->dbObj->rs;
        }

        function _UpdateValue($idK, $value)
        {          
                $query  = " UPDATE ConfigValues ";
                $query .= " SET value='".$value."' ";
                $query .= " WHERE idU=".$this->idU." AND ";
                $query .= " idG=".$this->idG." AND idK=".$idK;

                $this->dbObj->Execute($query);

                if (! $this->dbObj->rs || $this->dbObj->numRows == 0)
                {
                        return false;
                }
                else
                        return $this->dbObj->rs;
        }               
                
}
?>

---