Subversion Repositories cheapmusic

<?php

/***************************************************************************
 *   Copyright (C) 2009-2011 by Geo Varghese(www.seopanel.in)      *
 *   sendtogeo@gmail.com                                                                                                   *
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 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 General Public License for more details.                          *
 *                                                                         *
 *   You should have received a copy of the GNU General Public License     *
 *   along with this program; if not, write to the                         *
 *   Free Software Foundation, Inc.,                                       *
 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
 ***************************************************************************/

# class defines all mysql functions
class MysqliHelper extends Database{

        var $connectionId = false;
        var $debugMode;
        var $rowsAffected;
        var $lastInsertId;
        var $noRows = 0;

        // constructor
        function __construct($dbServer, $dbUser, $dbPassword, $dbName, $debug){
                global $SP_DB_CONN_OBJ;
                $this->setDebugMode($debug);
                
                // check connection id existing and it is a resource
                if (!empty($SP_DB_CONN_OBJ) && is_object($SP_DB_CONN_OBJ) ) {
                    $this->connectionId =  $SP_DB_CONN_OBJ;
                } else {
                        
                        $dbServer = SP_DB_PERSISTENT_CONNECTION ? "p:$dbServer" : $dbServer;
                        $this->connectionId = @mysqli_connect($dbServer, $dbUser, $dbPassword, $dbName);
                
                if (!$this->connectionId){
                        $this->showError();                     
                        showErrorMsg("<p style='color:red'>Database connection failed!<br>Please check your database settings!</p>");
                } else {        
                    $this->query( "SET NAMES utf8");
                    $SP_DB_CONN_OBJ = $this->connectionId;
                }
                
                }               
                
        }

        // func to execute a select query
        function select($query, $fetchFirst = false){
                $res = mysqli_query($this->connectionId, $query);
                $this->showError();
                
                if (!$res){
                        return false;
                }
                
                $returnArr = array();
                while ($row = mysqli_fetch_assoc($res)){
                        $returnArr[] = $row;
                }
                
                mysqli_free_result($res);
                
                if ($fetchFirst){
                        return $returnArr[0];
                }
                
                return $returnArr;
        }

        // func to Execute a general mysql query
        function query($query, $noRows=false){
                $res = @mysqli_query($this->connectionId, $query);
                
                if ($res){
                        $this->rowsAffected = @mysqli_affected_rows($this->connectionId);
                        $this->lastInsertId = @mysqli_insert_id($this->connectionId);
                } else {
                        $this->showError();
                        @mysqli_free_result($res);
                }
                
                if($noRows) $this->noRows = mysqli_num_rows($res);
                return $res;
        }

        # func to get max id of a table
        function getMaxId($table, $col='id') {
                $sql = "select max($col) maxid from $table";
                $maxInfo = $this->select($sql);
                return empty($maxInfo[0]['maxid']) ? 1 : $maxInfo[0]['maxid'];
        }

        # func to Sets the dubug mode for mysql access
        function setDebugMode($debug){
                $this->debugMode = $debug ? true: false;
                return;
        }

        # func to Display the Mysql error
        function showError(){
                
                // if debugmode enabled
                if ($this->debugMode) {
                        
                        // if connection is failed
                        if (!$this->connectionId) {
                                echo "Error: Unable to connect to Database." . PHP_EOL;
                                echo "Debugging errno: " . mysqli_connect_errno() . PHP_EOL;
                                echo "Debugging error: " . mysqli_connect_error() . PHP_EOL;
                                exit;
                        } else if (@mysqli_errno($this->connectionId) != 0) {
                                echo "Script Halted. \n Mysql Error Number: " . @mysqli_errno($this->connectionId) . "\n" . @mysqli_error($this->connectionId);
                                $this->close();
                                exit;
                                
                        }
                        
                }
                
        }

        # func to escape mysql string
        function escapeMysqlString($str){
                return mysqli_escape_string($this->connectionId, $str);
        }

        # func to Close Mysql Connection
        function close(){
                $res = @mysqli_close($this->connectionId);
                return $res;
        }
        
        function importDatabaseFile($filename){
                
                # temporary variable, used to store current query
                $tmpline = '';
                
                # read in entire file
                $lines = file($filename);
                
                # loop through each line
                foreach ($lines as $line){
                        
                        # skip it if it's a comment
                        if (substr($line, 0, 2) == '--' || $line == '')
                                continue;
                 
                        # add this line to the current segment
                        $tmpline .= $line;
                        
                        # if it has a semicolon at the end, it's the end of the query
                        if (substr(trim($line), -1, 1) == ';'){
                                
                                if(!empty($tmpline)){
                                        $this->query($tmpline);
                                }
                                $tmpline = '';
                        }
                }
                
        }
}
?>