vendor/pimcore/output-data-config-toolkit-bundle/src/OutputDefinition/Dao.php line 49

Open in your IDE?
  1. <?php
  3. /**
  4.  * Pimcore
  5.  *
  6.  * This source file is available under two different licenses:
  7.  * - GNU General Public License version 3 (GPLv3)
  8.  * - Pimcore Commercial License (PCL)
  9.  * Full copyright and license information is available in
  10.  * LICENSE.md which is distributed with this source code.
  11.  *
  12.  *  @copyright  Copyright (c) Pimcore GmbH (http://www.pimcore.org)
  13.  *  @license    http://www.pimcore.org/license     GPLv3 and PCL
  14.  */
  16. namespace OutputDataConfigToolkitBundle\OutputDefinition;
  18. use OutputDataConfigToolkitBundle\OutputDefinition;
  20. class Dao extends \Pimcore\Model\Dao\AbstractDao
  21. {
  22.     const TABLE_NAME = 'bundle_outputdataconfigtoolkit_outputdefinition';
  24.     /**
  25.      * Contains all valid columns in the database table
  26.      *
  27.      * @var array
  28.      */
  29.     protected $validColumns = [];
  31.     /**
  32.      * Get the valid columns from the database
  33.      *
  34.      * @return void
  35.      */
  36.     public function init()
  37.     {
  38.         $this->validColumns = $this->getValidTableColumns(self::TABLE_NAME);
  39.     }
  41.     /**
  42.      * @return void
  43.      *
  44.      * @throws \Doctrine\DBAL\DBALException
  45.      * @throws \Exception
  46.      */
  47.     public function getByO_IdClassIdChannel($o_id, $classId, $channel)
  48.     {
  49.         $outputDefinitionRaw = $this->db->fetchRow('SELECT * FROM ' . self::TABLE_NAME . ' WHERE o_id=? AND o_classId = ? AND ' . $this->db->quoteIdentifier('channel') . ' = ?', [$o_id, $classId, $channel]);
  50.         if (empty($outputDefinitionRaw)) {
  51.             throw new \Exception('OutputDefinition ' . $o_id . ' - ' . $classId  . ' - ' . $channel . ' not found.');
  52.         }
  53.         $this->assignVariablesToModel($outputDefinitionRaw);
  54.     }
  56.     /**
  57.      * @return void
  58.      *
  59.      * @throws \Doctrine\DBAL\DBALException
  60.      * @throws \Exception
  61.      */
  62.     public function getById($id)
  63.     {
  64.         $outputDefinitionRaw = $this->db->fetchRow('SELECT * FROM ' . self::TABLE_NAME . ' WHERE id=?', [$id]);
  65.         if (empty($outputDefinitionRaw)) {
  66.             throw new \Exception('OutputDefinition-Id ' . $id . ' not found.');
  67.         }
  68.         $this->assignVariablesToModel($outputDefinitionRaw);
  69.     }
  71.     /**
  72.      * Create a new record for the object in database
  73.      *
  74.      * @return void
  75.      */
  76.     public function create()
  77.     {
  78.         $this->db->insert(self::TABLE_NAME, []);
  79.         $this->model->setId($this->db->lastInsertId());
  81.         $this->save();
  82.     }
  84.     /**
  85.      * Save object to database
  86.      *
  87.      * @return void
  88.      */
  89.     public function save()
  90.     {
  91.         $other = OutputDefinition::getByO_IdClassIdChannel($this->model->getO_Id(), $this->model->getO_ClassId(), $this->model->getChannel());
  92.         if ($other) {
  93.             $this->model->setId($other->getId());
  94.         }
  96.         if ($this->model->getId()) {
  97.             return $this->update();
  98.         }
  100.         return $this->create();
  101.     }
  103.     /**
  104.      * @return void
  105.      */
  106.     public function update()
  107.     {
  108.         $class = get_object_vars($this->model);
  110.         foreach ($class as $key => $value) {
  111.             if (in_array($key, $this->validColumns)) {
  112.                 if (is_array($value) || is_object($value)) {
  113.                     $value = serialize($value);
  114.                 } elseif (is_bool($value)) {
  115.                     $value = (int)$value;
  116.                 }
  117.                 $data[$key] = $value;
  118.             }
  119.         }
  120.         $this->db->updateWhere(self::TABLE_NAME, $data, 'id=' . $this->db->quote($this->model->getId()));
  121.     }
  123.     /**
  124.      * Deletes object from database
  125.      *
  126.      * @return void
  127.      */
  128.     public function delete()
  129.     {
  130.         $this->db->deleteWhere(self::TABLE_NAME, 'id=' . $this->db->quote($this->model->getId()));
  131.     }
  132. }