oxlegacydb.php

Go to the documentation of this file.

<?php

require_once 'interface/DatabaseInterface.php';

class oxLegacyDb extends oxSuperCfg implements DatabaseInterface
{

    protected $_oDb = null;


    public function setConnection($oConnection)
    {
        $this->_oDb = $oConnection;
    }

    public function setFetchMode($iFetchMode)
    {
        $this->_oDb->setFetchMode($iFetchMode);

    }

    public function getDb($blType = true)
    {

        return $this->_oDb;
    }

    public function getOne($sSql, $aParams = array(), $blType = true)
    {
        return $this->getDb($blType)->getOne($sSql, $aParams);
    }

    public function getArray($sSql, $aParams = array(), $blType = true)
    {
        return $this->getDb($blType)->getArray($sSql, $aParams);
    }

    public function getRow($sSql, $aParams = array(), $blType = true)
    {
        return $this->getDb($blType)->getRow($sSql, $aParams);
    }

    public function getAll($sSql, $aParams = array(), $blType = true)
    {

        return $this->getDb($blType)->getAll($sSql, $aParams);
    }

    public function select($sSql, $aParams = array(), $blType = true)
    {
        return $this->getDb($blType)->execute($sSql, $aParams);
    }

    public function getAssoc($sSql, $aParams = array(), $blType = true)
    {
        return $this->getDb($blType)->getAssoc($sSql, $aParams);
    }

    public function getCol($sSql, $aParams = array(), $blType = true)
    {
        return $this->getDb($blType)->getCol($sSql, $aParams);
    }

    public function selectLimit($sSql, $iRows = -1, $iOffset = -1, $aParams = array(), $blType = true)
    {
        return $this->getDb($blType)->SelectLimit($sSql, $iRows, $iOffset, $aParams);
    }

    public function execute($sSql, $aParams = array())
    {
        return $this->getDb(false)->execute($sSql, $aParams);
    }

    public function query($sSql, $aParams = array())
    {
        return $this->getDb(false)->Query($sSql, $aParams);
    }

    public function Affected_Rows()
    {
        return $this->getDb(false)->Affected_Rows();
    }

    public function errorNo()
    {
        return $this->getDb(false)->ErrorNo();
    }

    public function errorMsg()
    {
        return $this->getDb(false)->ErrorMsg();
    }

    public function qstr($sValue)
    {
        return $this->getDb(false)->qstr($sValue);
    }

    public function quote($sValue)
    {
        return $this->getDb(false)->quote($sValue);
    }

    public function quoteArray($aStrArray)
    {
        foreach ($aStrArray as $sKey => $sString) {
            $aStrArray[$sKey] = $this->quote($sString);
        }

        return $aStrArray;
    }

    public function metaColumns($sTable)
    {
        return $this->getDb(false)->MetaColumns($sTable);
    }

    public function metaColumnNames($sTable, $blNumIndexes = false)
    {
        return $this->getDb(false)->MetaColumnNames($sTable, $blNumIndexes);
    }

    public function startTransaction()
    {
        return $this->getDb(false)->execute('START TRANSACTION');
    }

    public function commitTransaction()
    {
        return $this->getDb(false)->execute('COMMIT');
    }

    public function rollbackTransaction()
    {
        return $this->getDb(false)->execute('ROLLBACK');
    }

    public function setTransactionIsolationLevel($sLevel = null)
    {
        $blResult = false;

        $aLevels = array('READ UNCOMMITTED', 'READ COMMITTED', 'REPEATABLE READ', 'SERIALIZABLE');
        if (in_array(strtoupper($sLevel), $aLevels)) {
            $blResult = $this->getDb(false)->execute('SET TRANSACTION ISOLATION LEVEL ' . $sLevel);
        }

        return $blResult;
    }

    public function UI($iPollSecs = 5)
    {
        $this->getDb(false)->UI($iPollSecs);
    }

    public function Insert_ID()
    {
        return $this->lastInsertId();
    }

    public function lastInsertId()
    {
        return $this->getDb(false)->Insert_ID();
    }
}