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 Mysql extends Database{

	var $connectionId = false;

	var $debugMode;

	var $rowsAffected;

	var $lastInsertId;

	var $noRows = 0;

	// constructor

	function __construct($dbServer, $dbUser, $dbPassword, $dbName, $debug){

		$this->setDebugMode($debug);

		// check connection id existing and it is a resource

		if (defined('SP_DB_CONN_ID') && is_resource(SP_DB_CONN_ID) ) {

		    $this->connectionId =  SP_DB_CONN_ID;

		} else {

    		// if mysql persistent connection enabled

    		if (SP_DB_PERSISTENT_CONNECTION) {

    		    $this->connectionId = @mysql_pconnect($dbServer, $dbUser, $dbPassword, true);

    		} else {

    		    $this->connectionId = @mysql_connect($dbServer, $dbUser, $dbPassword, true);

    		}

    		if (!$this->connectionId){

    			$this->showError();

    			showErrorMsg("<p style='color:red'>Database connection failed!<br>Please check your database settings!</p>");

    		} else {

    		    $this->selectDatabase($dbName);

    		    $this->query( "SET NAMES utf8");

    		    define('SP_DB_CONN_ID', $this->connectionId);

    		}

		}

	}

	# func to select database

	function selectDatabase($dbName){

		$res = @mysql_select_db($dbName, $this->connectionId);

		$this->showError();

		if(mysql_errno() != 0){

			showErrorMsg("<p style='color:red'>Database connection failed!<br>Please check your database settings!</p>");

		}

		return $res;

	}

	#func to execute a select query

	function select($query, $fetchFirst = false){

		$res = mysql_query($query, $this->connectionId);

		$this->showError();

		if (!$res){

			return false;

		}

		$returnArr = array();

		while ($row = mysql_fetch_assoc($res)){

			$returnArr[] = $row;

		}

		mysql_free_result($res);

		if ($fetchFirst){

			return $returnArr[0];

		}

		return $returnArr;

	}

	# func to Execute a general mysql query

	function query($query, $noRows=false){

		$res = @mysql_query($query, $this->connectionId);

		if ($res){

			$this->rowsAffected = @mysql_affected_rows($this->connectionId);

			$this->lastInsertId = @mysql_insert_id($this->connectionId);

		}else{

			$this->showError();

			@mysql_free_result($res);

		}

		if($noRows) $this->noRows = mysql_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 ($this->debugMode && @mysql_errno() != 0) {

			echo "Script Halted. \n Mysql Error Number: " . @mysql_errno() . "\n" . @mysql_error();

			$this->close();

			exit();

		}

		return;

	}

	# func to escape mysql string

	function escapeMysqlString($str){

		return mysql_escape_string($str);

	}

	# func to Close Mysql Connection

	function close(){

		$res = @mysql_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 = '';

			}

		}

	}

}

?>