mysqldatabase.php

Go to the documentation of this file.

<?php
class XoopsMySQLDatabase extends XoopsDatabase
{

    private $lastResult = null;

    public $conn;

    private $connect = false;

    private $selectdb;

    protected function deprecated()
    {
        static $warning_issued = false;
        if (!$warning_issued) {
            $warning_issued = true;
            $stack = debug_backtrace();
            $frame = $stack[1];
            Xoops::getInstance()->deprecated(
                'Legacy XoopsDB is deprecated since 2.6.0; all calls should be using Doctrine through $xoops->db(). '
                . 'Called from ' . $frame['function'] . '() in ' . $frame['file'] . ' line '. $frame['line']
            );
        }
    }


    public function connect($selectdb = true)
    {
        $this->connect = (is_object($this->conn));
        $this->selectdb = $selectdb;
        $this->allowWebChanges = ($_SERVER['REQUEST_METHOD'] != 'GET');
        return $this->connect;
    }


    public function genId($sequence)
    {
        $this->deprecated();
        return 0; // will use auto_increment
    }

    public function fetchRow($result)
    {
        $this->deprecated();
        if (!is_object($result)) {
            return null;
        }
        return $result->fetch(\PDO::FETCH_NUM);
    }

    public function fetchArray($result)
    {
        $this->deprecated();

        if (!is_object($result)) {
            return null;
        }
        return $result->fetch(\PDO::FETCH_ASSOC);
    }

    public function fetchBoth($result)
    {
        $this->deprecated();

        if (!is_object($result)) {
            return null;
        }
        return $result->fetch(\PDO::FETCH_BOTH);
    }

    public function fetchObject($result)
    {
        $this->deprecated();

        if (!is_object($result)) {
            return null;
        }
        return $result->fetch(\PDO::FETCH_OBJ);
    }

    public function getInsertId()
    {
        $this->deprecated();
        return $this->conn->lastInsertId();
    }

    public function getRowsNum($result)
    {
        Xoops::getInstance()->deprecated('getRowsNum is deprecated and not dependable.');
        //$this->deprecated();
        return $result->rowCount();
    }

    public function getAffectedRows()
    {
        $this->deprecated();
        return $this->lastResult->rowCount();
    }

    public function close()
    {
        $this->deprecated();
        return $this->conn->close();
    }

    public function freeRecordSet($result)
    {
        $this->deprecated();

        return $result->closeCursor();
    }

    public function error()
    {
        $this->deprecated();

        return $this->conn->errorInfo();
    }

    public function errno()
    {
        $this->deprecated();

        return $this->conn->errorCode();
    }

    public function quoteString($str)
    {
        $this->deprecated();

        return $this->quote($str);
    }

    public function quote($string)
    {
        $this->deprecated();

        return  $this->conn->quote($string);
    }

    public function escape($string)
    {
        $this->deprecated();

        $string = $this->quote($input);
        return substr($string, 1, -1);
    }

    public function queryF($sql, $limit = 0, $start = 0)
    {
        $this->deprecated();

        if (!empty($limit)) {
            if (empty($start)) {
                $start = 0;
            }
            $sql = $sql . ' LIMIT ' . (int) $start . ', ' . (int) $limit;
        }
        $xoopsPreload = XoopsPreload::getInstance();
        $xoopsPreload->triggerEvent('core.database.query.start');
        try {
            $result = $this->conn->query($sql);
        } catch (Exception $e) {
            $result=false;
        }
        $this->lastResult = $result;
        $xoopsPreload->triggerEvent('core.database.query.end');

        if ($result) {
            $xoopsPreload->triggerEvent('core.database.query.success', (array($sql)));
            return $result;
        } else {
            $xoopsPreload->triggerEvent('core.database.query.failure', (array($sql, $this)));
            return false;
        }
    }

    public function query($sql, $limit = 0, $start = 0)
    {
        $this->deprecated();

    }

    public function queryFromFile($file)
    {
        $this->deprecated();

        if (false !== ($fp = fopen($file, 'r'))) {
            $sql_queries = trim(fread($fp, filesize($file)));
            SqlUtility::splitMySqlFile($pieces, $sql_queries);
            foreach ($pieces as $query) {
                // [0] contains the prefixed query
                // [4] contains unprefixed table name
                $prefixed_query
                    = SqlUtility::prefixQuery(trim($query), $this->prefix());
                if ($prefixed_query != false) {
                    $this->query($prefixed_query[0]);
                }
            }
            return true;
        }
        return false;
    }

    public function getFieldName($result, $offset)
    {
        $this->deprecated();

        try {
            $temp = $result->getColumnMeta($offset);
            return $temp['name'];
        } catch (PDOException $e) {
            return null;
        }

    }

    public function getFieldType($result, $offset)
    {
        $this->deprecated();

        try {
            $temp = ($result->getColumnMeta($offset));
            $t = $temp['native_type'];

            $temp = (string)(
                ((($t == 'STRING') || ($t == 'VAR_STRING') ) ? 'string' : '' ) .
                ( (in_array($t, array('TINY', 'SHORT', 'LONG', 'LONGLONG', 'INT24'))) ? 'int' : '' ) .
                ( (in_array($t, array('FLOAT', 'DOUBLE', 'DECIMAL', 'NEWDECIMAL'))) ? 'real' : '' ) .
                ( ($t == 'TIMESTAMP') ? 'timestamp' : '' ) .
                ( ($t == 'YEAR') ? 'year' : '') .
                ( (($t == 'DATE') || ($t == 'NEWDATE') ) ? 'date' : '' ) .
                ( ($t == 'TIME') ? 'time' : '' ) .
                ( ($t == 'SET') ? 'set' : '' ) .
                ( ($t == 'ENUM') ? 'enum' : '' ) .
                ( ($t == 'GEOMETRY') ? 'geometry' : '' ) .
                ( ($t == 'DATETIME') ? 'datetime' : '' ) .
                ( (in_array($t, array('TINY_BLOB', 'BLOB', 'MEDIUM_BLOB', 'LONG_BLOB' ))) ? 'blob' : '' ) .
                ( ($t == 'NULL') ? 'null' : '' )
            );
            return $temp;
        } catch (PDOException $e) {
            return null;
        }
    }

    public function getFieldsNum($result)
    {
        $this->deprecated();

        return $result->columnCount();
    }
}