XoopsModules25x / efqdirectory

upgrade/class/dbmanager.php

<?php
/*
 * You may not change or alter any portion of this comment or credits
 * of supporting developers from this source code or any supporting source code
 * which is considered copyrighted (c) material of the original comment or credit authors.
 *
 * 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.
 */

/**
 * @copyright    {@link https://xoops.org/ XOOPS Project}
 * @license      {@link http://www.gnu.org/licenses/gpl-2.0.html GNU GPL 2 or later}
 * @package      efqdirectory
 * @since
 * @author       Martijn Hertog (aka wtravel)
 * @author       XOOPS Development Team,
 */

require_once XOOPS_ROOT_PATH . '/class/logger.php';

The constant XOOPS_ROOT_PATH was not found. Maybe you did not declare it correctly or list all dependencies?

require_once XOOPS_ROOT_PATH . '/class/database/databasefactory.php';
require_once XOOPS_ROOT_PATH . '/class/database/' . XOOPS_DB_TYPE . 'database.php';

The constant XOOPS_DB_TYPE was not found. Maybe you did not declare it correctly or list all dependencies?

require_once XOOPS_ROOT_PATH . '/class/database/sqlutility.php';

/**
 * database manager for XOOPS installer
 *
 * @author  Haruki Setoyama  <haruki@planewave.org>
 * @version $Id: dbmanager.php 19391 2010-06-13 06:53:15Z underdogg $
 * @access  public
 **/
class db_manager
{
    public $s_tables = array();
    public $f_tables = array();
    public $db;

    /**
     * db_manager constructor.
     */
    public function __construct()
    {
        $this->db = XoopsDatabaseFactory::getDatabase();

The type XoopsDatabaseFactory was not found. Maybe you did not declare it correctly or list all dependencies?

        $this->db->setPrefix(XOOPS_DB_PREFIX);

The constant XOOPS_DB_PREFIX was not found. Maybe you did not declare it correctly or list all dependencies?

        $this->db->setLogger(XoopsLogger::instance());

The type XoopsLogger was not found. Maybe you did not declare it correctly or list all dependencies?

    }

    /**
     * @return bool
     */
    public function isConnectable()
    {
        return ($this->db->connect(false) !== false) ? true : false;
    }

    /**
     * @return bool
     */
    public function dbExists()
    {
        return ($this->db->connect() !== false) ? true : false;
    }

    /**
     * @return bool
     */
    public function createDB()
    {
        $this->db->connect(false);

        $result = $this->db->query('CREATE DATABASE ' . XOOPS_DB_NAME);

The constant XOOPS_DB_NAME was not found. Maybe you did not declare it correctly or list all dependencies?

        return ($result !== false) ? true : false;
    }

    /**
     * @param $sql_file_path
     * @return bool
     */
    public function queryFromFile($sql_file_path)
    {
        global $pieces;
        $tables = array();

The assignment to $tables is dead and can be removed.

        if (!file_exists($sql_file_path)) {
            return false;
        }
        $sql_query = trim(fread(fopen($sql_file_path, 'r'), filesize($sql_file_path)));
        SqlUtility::splitMySqlFile($pieces, $sql_query);

The type SqlUtility was not found. Maybe you did not declare it correctly or list all dependencies?

        $this->db->connect();
        foreach ($pieces as $piece) {
            $piece = trim($piece);
            // [0] contains the prefixed query
            // [4] contains unprefixed table name
            $prefixed_query = SqlUtility::prefixQuery($piece, $this->db->prefix());
            if ($prefixed_query !== false) {
                $table = $this->db->prefix($prefixed_query[4]);
                if ($prefixed_query[1] === 'CREATE TABLE') {
                    if ($this->db->query($prefixed_query[0]) !== false) {

This code seems to be duplicated across your project.

                        if (!isset($this->s_tables['create'][$table])) {
                            $this->s_tables['create'][$table] = 1;
                        }
                    } else {
                        if (!isset($this->f_tables['create'][$table])) {
                            $this->f_tables['create'][$table] = 1;
                        }
                    }
                } elseif ($prefixed_query[1] === 'INSERT INTO') {
                    if ($this->db->query($prefixed_query[0]) !== false) {
                        if (!isset($this->s_tables['insert'][$table])) {

This code seems to be duplicated across your project.

                            $this->s_tables['insert'][$table] = 1;
                        } else {
                            $this->s_tables['insert'][$table]++;
                        }
                    } else {

This code seems to be duplicated across your project.

                        if (!isset($this->f_tables['insert'][$table])) {
                            $this->f_tables['insert'][$table] = 1;
                        } else {
                            $this->f_tables['insert'][$table]++;
                        }
                    }
                } elseif ($prefixed_query[1] === 'ALTER TABLE') {

This code seems to be duplicated across your project.

                    if ($this->db->query($prefixed_query[0]) !== false) {
                        if (!isset($this->s_tables['alter'][$table])) {
                            $this->s_tables['alter'][$table] = 1;
                        }
                    } else {
                        if (!isset($this->s_tables['alter'][$table])) {
                            $this->f_tables['alter'][$table] = 1;
                        }
                    }
                } elseif ($prefixed_query[1] === 'DROP TABLE') {
                    if ($this->db->query('DROP TABLE ' . $table) !== false) {
                        if (!isset($this->s_tables['drop'][$table])) {
                            $this->s_tables['drop'][$table] = 1;
                        }
                    } else {
                        if (!isset($this->s_tables['drop'][$table])) {
                            $this->f_tables['drop'][$table] = 1;
                        }
                    }
                }
            }
        }

        return true;
    }

    /**
     * @return string
     */
    public function report()
    {
        $content = "<table align='center'><tr><td align='left'>\n";
        if (isset($this->s_tables['create'])) {

This code seems to be duplicated across your project.

            foreach ($this->s_tables['create'] as $key => $val) {
                $content .= sprintf(_INSTALL_L45, "<b>$key</b>") . "<br>\n";
            }
        }
        if (isset($this->s_tables['insert'])) {

This code seems to be duplicated across your project.

            foreach ($this->s_tables['insert'] as $key => $val) {
                $content .= sprintf(_INSTALL_L119, $val, "<b>$key</b>") . "<br>\n";
            }
        }
        if (isset($this->s_tables['alter'])) {

This code seems to be duplicated across your project.

            foreach ($this->s_tables['alter'] as $key => $val) {
                $content .= sprintf(_INSTALL_L133, "<b>$key</b>") . "<br>\n";
            }
        }
        if (isset($this->s_tables['drop'])) {

This code seems to be duplicated across your project.

            foreach ($this->s_tables['drop'] as $key => $val) {
                $content .= sprintf(_INSTALL_L163, "<b>$key</b>") . "<br>\n";
            }
        }
        $content .= "<br>\n";
        if (isset($this->f_tables['create'])) {

This code seems to be duplicated across your project.

            foreach ($this->f_tables['create'] as $key => $val) {
                $content .= sprintf(_INSTALL_L118, "<b>$key</b>") . "<br>\n";
            }
        }
        if (isset($this->f_tables['insert'])) {

This code seems to be duplicated across your project.

            foreach ($this->f_tables['insert'] as $key => $val) {
                $content .= sprintf(_INSTALL_L120, $val, "<b>$key</b>") . "<br>\n";
            }
        }
        if (isset($this->f_tables['alter'])) {

This code seems to be duplicated across your project.

            foreach ($this->f_tables['alter'] as $key => $val) {
                $content .= sprintf(_INSTALL_L134, "<b>$key</b>") . "<br>\n";
            }
        }
        if (isset($this->f_tables['drop'])) {

This code seems to be duplicated across your project.

            foreach ($this->f_tables['drop'] as $key => $val) {
                $content .= sprintf(_INSTALL_L164, "<b>$key</b>") . "<br>\n";
            }
        }
        $content .= "</td></tr></table>\n";

        return $content;
    }

    /**
     * @param $sql
     * @return mixed
     */
    public function query($sql)
    {
        $this->db->connect();

        return $this->db->query($sql);
    }

    /**
     * @param $table
     * @return mixed
     */
    public function prefix($table)
    {
        $this->db->connect();

        return $this->db->prefix($table);
    }

    /**
     * @param $ret
     * @return mixed
     */
    public function fetchArray($ret)
    {
        $this->db->connect();

        return $this->db->fetchArray($ret);
    }

    /**
     * @param $table
     * @param $query
     * @return bool
     */
    public function insert($table, $query)
    {
        $this->db->connect();
        $table = $this->db->prefix($table);
        $query = 'INSERT INTO ' . $table . ' ' . $query;
        if (!$this->db->queryF($query)) {
            if (!isset($this->f_tables['insert'][$table])) {

This code seems to be duplicated across your project.

                $this->f_tables['insert'][$table] = 1;
            } else {
                $this->f_tables['insert'][$table]++;
            }

            return false;
        } else {

This code seems to be duplicated across your project.

            if (!isset($this->s_tables['insert'][$table])) {
                $this->s_tables['insert'][$table] = 1;
            } else {
                $this->s_tables['insert'][$table]++;
            }

            return $this->db->getInsertId();
        }
    }

    /**
     * @return bool
     */
    public function isError()
    {
        return isset($this->f_tables) ? true : false;
    }

    /**
     * @param $tables
     * @return array
     */
    public function deleteTables($tables)
    {
        global $ct;
        $deleted = array();
        $this->db->connect();
        foreach ($tables as $key => $val) {
            if (!$this->db->query('DROP TABLE ' . $this->db->prefix($key))) {
                $deleted[] = $ct;
            }
        }

        return $deleted;
    }

    /**
     * @param $table
     * @return bool
     */
    public function tableExists($table)
    {
        $table = trim($table);
        $ret   = false;
        if ($table !== '') {
            $this->db->connect();
            $sql = 'SELECT * FROM ' . $this->db->prefix($table);
            $ret = (false != $this->db->query($sql)) ? true : false;
        }

        return $ret;
    }
}