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 database functions
class DBI{

        var $connectionId = false;      # db connectio id
        var $error = false;             # error while databse operations
        
        function connectDatabase($dbServer, $dbUser, $dbPassword, $dbName){
                
                $this->connectionId = @mysqli_connect($dbServer, $dbUser, $dbPassword, $dbName);
                
                if (!$this->connectionId){
                        $this->error = true;
                        $error =  "Mysql Error: Database connection failed.";
                        return $error;
                }
                
                return true;
        }

        # func to Execute a general mysql query
        function query($query, $noRows=false){
                
                $res = @mysqli_query($this->connectionId, $query);
                
                if (empty($res)){
                        return $this->getError();
                        @mysqli_free_result($res);
                }
                
                return $res;
        }
        
    #func to execute a select query
        function select($query, $fetchFirst = false){
                $res = @mysqli_query($this->connectionId, $query);
                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 Display the Mysql error
        function getError(){
                if (@mysqli_errno($this->connectionId) != 0) {                  
                        $this->error = true;
                        $error =  "Mysql Error: " . @mysqli_error($this->connectionId);
                }
                return $error;
        }
        
        function importDatabaseFile($filename, $block=true){
                
                # 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)){
                                        $errMsg = $this->query($tmpline);
                                        if($block && $this->error) return $errMsg;
                                }
                                $tmpline = '';
                        }
                }               
        }
}
?>