<?php
//==========================================
//		mysql database driver
//		power by ice_berg16
//		time 2003-12-10     
//		last modified 2004-06-30
//==========================================

//make sure all sytax error are reported.
//error_reporting(E_ALL);

class mysql
{
	var $host     = "";			//mysql主機名
	var $user     = "";			//mysql用戶名
	var $pwd      = "";			//mysql密碼
	var $dbName   = "";			//mysql數據庫名稱
	var $linkID   = 0;			//用來保存連接ID
	var $queryID  = 0;			//用來保存查詢ID
	var $fetchMode= MYSQL_ASSOC;//取記錄時的模式
	var $queryTimes = 0;		//保存查詢的次數
	var $errno    = 0;			//mysql出錯代號
	var $error    = "";			//mysql出錯信息
	var $record   = array();	//一條記錄數組

	//======================================
	// 函數: mysql()
	// 功能: 構造函數
	// 參數: 參數類的變量定義
	// 說明: 構造函數將自動連接數據庫
	//      如果想手動連接去掉連接函數
	//======================================
	function mysql($host,$user,$pwd,$dbName)
	{	if(empty($host) || empty($user) || empty($dbName))
			$this->halt("數據庫主機地址,用戶名或數據庫名稱不完全,請檢查!");
		$this->host    = $host;
		$this->user    = $user;
		$this->pwd     = $pwd;
		$this->dbName  = $dbName;
		$this->connect();//設置為自動連接
	}
	//======================================
	// 函數: connect($host,$user,$pwd,$dbName)
	// 功能: 連接數據庫
	// 參數: $host 主機名, $user 用戶名
	// 參數: $pwd 密碼, $dbName 數據庫名稱
	// 返回: 0:失敗
	// 說明: 默認使用類中變量的初始值
	//======================================
	function connect($host = "", $user = "", $pwd = "", $dbName = "")
	{
		if ("" == $host)
			$host = $this->host;
		if ("" == $user)
			$user = $this->user;
		if ("" == $pwd)
			$pwd = $this->pwd;
		if ("" == $dbName)
			$dbName = $this->dbName;
		//now connect to the database
		$this->linkID = mysql_pconnect($host, $user, $pwd);
		if (!$this->linkID)
		{
			$this->halt();
			return 0;
		}
		if (!mysql_select_db($dbName, $this->linkID))
		{
			$this->halt();
			return 0;
		}
		return $this->linkID;			
	}
	//======================================
	// 函數: query($sql)
	// 功能: 數據查詢
	// 參數: $sql 要查詢的SQL語句
	// 返回: 0:失敗
	//======================================
	function query($sql)
	{
		$this->queryTimes++;
		$this->queryID = mysql_query($sql, $this->linkID);
		if (!$this->queryID)
		{	
			$this->halt();
			return 0;
		}
		return $this->queryID;
	}
	//======================================
	// 函數: setFetchMode($mode)
	// 功能: 設置取得記錄的模式
	// 參數: $mode 模式 MYSQL_ASSOC, MYSQL_NUM, MYSQL_BOTH
	// 返回: 0:失敗
	//======================================
	function setFetchMode($mode)
	{
		if ($mode == MYSQL_ASSOC || $mode == MYSQL_NUM || $mode == MYSQL_BOTH) 
		{
			$this->fetchMode = $mode;
			return 1;
		}
		else
		{
			$this->halt("錯誤的模式.");
			return 0;
		}
		
	}
	//======================================
	// 函數: fetchRow()
	// 功能: 從記錄集中取出一條記錄
	// 返回: 0: 出錯 record: 一條記錄
	//======================================
	function fetchRow()
	{
		$this->record = mysql_fetch_array($this->queryID,$this->fetchMode);
		return $this->record;
	}
	//======================================
	// 函數: fetchAll()
	// 功能: 從記錄集中取出所有記錄
	// 返回: 記錄集數組
	//======================================
	function fetchAll()
	{
		$arr = array();
		while($this->record = mysql_fetch_array($this->queryID,$this->fetchMode))
		{
			$arr[] = $this->record;
		}
		mysql_free_result($this->queryID);
		return $arr;
	}
	//======================================
	// 函數: getValue()
	// 功能: 返回記錄中指定字段的數據
	// 參數: $field 字段名或字段索引
	// 返回: 指定字段的值
	//======================================
	function getValue($field)
	{
		return $this->record[$field];
	}
	//======================================
	// 函數: affectedRows()
	// 功能: 返回影響的記錄數
	//======================================
	function affectedRows()
	{
		return mysql_affected_rows($this->linkID);
	}
	//======================================
	// 函數: recordCount()
	// 功能: 返回查詢記錄的總數
	// 參數: 無
	// 返回: 記錄總數
	//======================================
	function recordCount()
	{
		return mysql_num_rows($this->queryID);
	}
	//======================================
	// 函數: getQueryTimes()
	// 功能: 返回查詢的次數
	// 參數: 無
	// 返回: 查詢的次數
	//======================================
	function getQueryTimes()
	{
		return $this->queryTimes;
	}
	//======================================
	// 函數: getVersion()
	// 功能: 返回mysql的版本
	// 參數: 無
	//======================================
	function getVersion() 
	{
		$this->query("select version() as ver");
		$this->fetchRow();
		return $this->getValue("ver");
	}
	//======================================
	// 函數: getDBSize($dbName, $tblPrefix=null)
	// 功能: 返回數據庫占用空間大小
	// 參數: $dbName 數據庫名
	// 參數: $tblPrefix 表的前綴,可選
	//======================================
	function getDBSize($dbName, $tblPrefix=null) 
	{
		$sql = "SHOW TABLE STATUS FROM " . $dbName;
		if($tblPrefix != null) {
			$sql .= " LIKE '$tblPrefix%'";
		}
		$this->query($sql);
		$size = 0;
		while($this->fetchRow())
			$size += $this->getValue("Data_length") + $this->getValue("Index_length");
		return $size;
	}
	//======================================
	// 函數: insertID()
	// 功能: 返回最后一次插入的自增ID
	// 參數: 無
	//======================================
	function insertID() {
		return mysql_insert_id();
	}
	//====================================== 
	// 函數: halt($err_msg)
	// 功能: 處理所有出錯信息
	// 參數: $err_msg 自定義的出錯信息
	//=====================================
	function halt($err_msg="")
	{
		if ("" == $err_msg)
		{
			$this->errno = mysql_errno();
			$this->error = mysql_error();
			echo "<b>mysql error:<b><br>";
			echo $this->errno.":".$this->error."<br>";
			exit;
		}
		else
		{
			echo "<b>mysql error:<b><br>";
			echo $err_msg."<br>";
			exit;
		}
	}
}
?>