<?php

/**
 * DbSource.php
 * @package    workflow.engine.classes.model
 *
 * ProcessMaker Open Source Edition
 * Copyright (C) 2004 - 2011 Colosa Inc.
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 *
 * For more information, contact Colosa Inc, 2566 Le Jeune Rd.,
 * Coral Gables, FL, 33134, USA, or email info@colosa.com.
 *
 */
//require_once 'classes/model/Content.php';
//require_once 'classes/model/om/BaseDbSource.php';

/**
 * Skeleton subclass for representing a row from the 'DB_SOURCE' table.
 *
 *
 *
 * You should add additional methods to this class to meet the
 * application requirements.  This class will only be generated as
 * long as it does not already exist in the output directory.
 *
 * @package    workflow.engine.classes.model
 */
class DbSource extends BaseDbSource
{

    /**
     * This value goes in the content table
     * @var        string
     */
    protected $db_source_description = '';

    /**
     * Get the rep_tab_title column value.
     * @return     string
     */
    public function getDBSourceDescription()
    {
        if ($this->getDbsUid() == "") {
            throw ( new Exception("Error in getDBSourceDescription, the getDbsUid() can't be blank") );
        }
        $lang = defined('SYS_LANG') ? SYS_LANG : 'en';
        $this->db_source_description = Content::load('DBS_DESCRIPTION', '', $this->getDbsUid(), $lang);
        return $this->db_source_description;
    }

    public function getCriteriaDBSList($sProcessUID)
    {
        $sDelimiter = DBAdapter::getStringDelimiter();
        $oCriteria = new Criteria('workflow');
        $oCriteria->addSelectColumn(DbSourcePeer::DBS_UID);
        $oCriteria->addSelectColumn(DbSourcePeer::PRO_UID);
        $oCriteria->addSelectColumn(DbSourcePeer::DBS_TYPE);
        $oCriteria->addAsColumn("DBS_SERVER", "CASE WHEN " . DbSourcePeer::DBS_TYPE . " = 'oracle' AND " . DbSourcePeer::DBS_CONNECTION_TYPE . " = 'TNS' THEN CONCAT('[', " . DbSourcePeer::DBS_TNS . ", ']') ELSE " . DbSourcePeer::DBS_SERVER . " END");
        $oCriteria->addAsColumn("DBS_DATABASE_NAME", "CASE WHEN " . DbSourcePeer::DBS_TYPE . " = 'oracle' AND " . DbSourcePeer::DBS_CONNECTION_TYPE . " = 'TNS' THEN CONCAT('[', " . DbSourcePeer::DBS_TNS . ", ']') ELSE " . DbSourcePeer::DBS_DATABASE_NAME . " END");
        $oCriteria->addSelectColumn(DbSourcePeer::DBS_USERNAME);
        $oCriteria->addSelectColumn(DbSourcePeer::DBS_PASSWORD);
        $oCriteria->addSelectColumn(DbSourcePeer::DBS_PORT);
        $oCriteria->addAsColumn('DBS_DESCRIPTION', 'C.CON_VALUE');
        $oCriteria->addAlias('C', 'CONTENT');
        $aConditions = array();
        $aConditions[] = array(DbSourcePeer::DBS_UID, 'C.CON_ID');
        $aConditions[] = array('C.CON_CATEGORY', $sDelimiter . 'DBS_DESCRIPTION' . $sDelimiter);
        $aConditions[] = array('C.CON_LANG', $sDelimiter . SYS_LANG . $sDelimiter);
        $oCriteria->addJoinMC($aConditions, Criteria::LEFT_JOIN);
        $oCriteria->add(DbSourcePeer::PRO_UID, $sProcessUID);
        return $oCriteria;
    }

    public function load($Uid, $ProUID = '')
    {
        try {
            $oRow = DbSourcePeer::retrieveByPK($Uid, $ProUID);
            if (!is_null($oRow)) {
                $aFields = $oRow->toArray(BasePeer::TYPE_FIELDNAME);
                $this->fromArray($aFields, BasePeer::TYPE_FIELDNAME);
                $aFields['DBS_DESCRIPTION'] = $this->getDBSourceDescription();
                $this->setNew(false);
                return $aFields;
            } else {
                throw(new Exception("The row '$Uid'/'$ProUID' in table DbSource doesn't exist!"));
            }
        } catch (exception $oError) {
            throw ($oError);
        }
    }

    public function getValProUid($Uid)
    {
        $oCriteria = new Criteria('workflow');
        $oCriteria->clearSelectColumns();
        $oCriteria->addSelectColumn(DbSourcePeer::PRO_UID);
        $oCriteria->add(DbSourcePeer::DBS_UID, $Uid);
        $result = DbSourcePeer::doSelectRS($oCriteria);
        $result->next();
        $aRow = $result->getRow();
        return $aRow[0];
    }

    public function Exists($Uid, $ProUID = "")
    {
        try {
            $oPro = DbSourcePeer::retrieveByPk($Uid, $ProUID);
            if (is_object($oPro) && get_class($oPro) == 'DbSource') {
                return true;
            } else {
                return false;
            }
        } catch (Exception $oError) {
            throw($oError);
        }
    }

    public function update($fields)
    {
        if ($fields['DBS_ENCODE'] == '0') {
            unset($fields['DBS_ENCODE']);
        }
        $con = Propel::getConnection(DbSourcePeer::DATABASE_NAME);
        try {
            $con->begin();
            $this->load($fields['DBS_UID'], $fields['PRO_UID']);
            $this->fromArray($fields, BasePeer::TYPE_FIELDNAME);
            if ($this->validate()) {
                $result = $this->save();
                $con->commit();
                //Add Audit Log
                G::auditLog("UpdateDatabaseConnection", "Connection Uid: ".$fields['DBS_UID'].", Connection Engine: ".$fields['DBS_TYPE'].", Connection Encode: ".$fields['DBS_ENCODE'].", Connection Server: ".$fields['DBS_SERVER'].", Connection Database: ".$fields['DBS_DATABASE_NAME'].", Connection Port: ".$fields['DBS_PORT']);
                
                return $result;
            } else {
                $con->rollback();
                throw (new Exception("Failed Validation in class " . get_class($this) . "."));
            }
        } catch (exception $e) {
            $con->rollback();
            throw ($e);
        }
    }

    public function remove($DbsUid, $ProUID)
    {
        $con = Propel::getConnection(DbSourcePeer::DATABASE_NAME);
        try {
            $fields = $this->load($DbsUid, $ProUID);
            $con->begin();
            $this->setDbsUid($DbsUid);
            $this->setProUid($ProUID);
            // note added by gustavo cruz gustavo-at-colosa-dot-com
            // we assure that the _delete attribute must be set to false
            // if a record exists in the database with that uid.
            if ($this->Exists($DbsUid, $ProUID)) {
                $this->setDeleted(false);
            }
            $result = $this->delete();
            $con->commit();
            //Add Audit Log
            G::auditLog("DeleteDatabaseConnection", "Connection Uid: ".$DbsUid.", Connection Engine: ".$fields['DBS_TYPE'].", Connection Database: ".$fields['DBS_DATABASE_NAME']);
            
            return $result;
        } catch (exception $e) {
            $con->rollback();
            throw ($e);
        }
    }

    public function create($aData)
    {
        if ($aData['DBS_ENCODE'] == '0') {
            unset($aData['DBS_ENCODE']);
        }
        $con = Propel::getConnection(DbSourcePeer::DATABASE_NAME);
        try {
            if (isset($aData['DBS_UID']) && $aData['DBS_UID'] == '') {
                unset($aData['DBS_UID']);
            }
            if (!isset($aData['DBS_UID'])) {
                $aData['DBS_UID'] = G::generateUniqueID();
            }
            $this->fromArray($aData, BasePeer::TYPE_FIELDNAME);
            if ($this->validate()) {
                $result = $this->save();
            } else {
                $e = new Exception("Failed Validation in class " . get_class($this) . ".");
                $e->aValidationFailures = $this->getValidationFailures();
                throw ($e);
            }
            $con->commit();
            //Add Audit Log
            G::auditLog("CreateDatabaseConnection", "Connection Uid: ".$aData['DBS_UID'].", Connection Engine: ".$aData['DBS_TYPE'].", Connection Encode: ".$aData['DBS_ENCODE'].", Connection Server: ".$aData['DBS_SERVER'].", Connection Database: ".$aData['DBS_DATABASE_NAME'].", Connection Port: ".$aData['DBS_PORT']);
             
            return $this->getDbsUid();
        } catch (exception $e) {
            $con->rollback();
            throw ($e);
        }
    }
}