<?php 

//默認(rèn)的連接參數(shù) 

define('DB_HOST','localhost'); 

define('DB_NAME','db_performance'); 

define('DB_USER','root'); 

define('DB_PASSWORD','111111'); 

define('DEFAULT_CHASET','UTF8'); 

//define('SORT_UPDATE_ASC',0); 

//define('SORT_UPDATE_DESC',1); 

?> 

<?php 

/** 

* 獲取規(guī)格化的列名稱列表 

* 

* @param mix $fields 

* @return array 

*/ 

function get_column_names($fields ){ 

$fieldResult= array(); //存放結(jié)果 

if(!is_array($fields)){ //不是數(shù)組的處理 

$fields= str_replace(',',' ',$fields); 

$fields= explode(' ',$fields); 

foreach($fields as $field){ 

if(trim($field) != null && !in_array($field, $fieldResult)){ //不添加重復(fù)的field value 

$fieldResult[]= $field; 

} 

} 

return $fieldResult; 

}else{ 

foreach( $fields as $field){ 

$arr_field= get_column_names($field); 

foreach($arr_field as $field){ 

if(!in_array($field, $fieldResult)){ //不添加重復(fù)的field 

value 

$fieldResult[]= $field; 

} 

} 

} 

return $fieldResult; 

} 

} 

////class define code 

class MySql{ 

private $conn= null; //連接資源 

private $connect= false;//引用的數(shù)據(jù)庫(kù)連接標(biāo)記& 

private $referenceCount= 1;//引用計(jì)數(shù)器 

private $result= null; //查詢結(jié)果資源 

private $table= null; //當(dāng)前表 

private $describe= null;//連接描述 

private $sql= null; //最后執(zhí)行的SQL 

private $db_host; //用于重新連接數(shù)據(jù)庫(kù)的參數(shù) 

private $db_name; // 

private $db_user; // 

private $db_password; // 

private $db_chaset; // 

////set Functions 

/** 

* clone 方法已被禁用。請(qǐng)使用 getClone()來(lái)取代 

* 

*/ 

function __clone(){ 

exit("can't be clone. using $mysql->getClone('$describe') instead"); 

} 

/** 

* __construct 

* 

* @param string $_describe 

*/ 

function __construct($describe){ 

$this->describe= $describe; 

} 

function __destruct(){ 

$this->close(); 

} 

/** 

* 關(guān)閉當(dāng)前連接 

* 

*/ 

function close(){ 

//free private vars 

$this->freeResult(); 

$this->sql= null; 

$this->describe= null; 

$this->table= null; 

//free reference vars 

$this->cleanReferenceData(); 

} 

/** 

* 檢查當(dāng)前引用數(shù)據(jù)連接是否被其它Mysql所引用，此方法不導(dǎo)出。 

* 

* @return boolean 

*/ 

private function checkReference(){ 

if($this->referenceCount >1){ 

return true; 

} 

return false; 

} 

/** 

* debug 

* 

*/ 

function debug(){ 

$result= array(); 

if($this->checkReference()){ 

$result['isReference']= "true"; 

} 

else{ 

$result['isReference']= "false"; 

} 

$result['conn']=$this->conn; 

$result['connect']=$this->connect; 

$result['referenceC 

$result['result']=$this->result; 

$result['table']=$this->table; 

$result['describe']=$this->describe; 

$result['sql']=$this->sql; 

$result['db_host']=$this->db_host; 

$result['db_name']=$this->db_name; 

$result['db_user']=$this->db_user; 

$result['db_password']=$this->db_password; 

$result['db_chaset']=$this->db_chaset; 

print_r($result); 

} 

/** 

* 清理引用的共享數(shù)據(jù) 

* 

* @return true 

*/ 

//function unsetReference(){ 

private function cleanReferenceData(){ 

if($this->checkReference()){ 

$this->referenceCount --; //計(jì)數(shù)器減一 

unset($this->conn); //釋放引用的數(shù)據(jù) 

unset($this->referenceCount); //釋放引用的數(shù)據(jù) 

unset($this->connect); //釋放引用的數(shù)據(jù) 

}else{ 

if($this->isConnected() ){ 

mysql_close($this->conn); 

} 

} 

$this->referenceCount= 1; //referenceCount 重置 

$this->sql= null; 

$this->conn= null; 

$this->connect= false; 

return true; 

} 

////set&get functions 

/** 

* 設(shè)置數(shù)據(jù)連接相關(guān)描述，用于錯(cuò)誤信息顯示。 

* 

* @param string $describe 

*/ 

function setDescribe($describe){ 

$this->describe= $describe; 

} 

/** 

* 設(shè)置默認(rèn)的表名 

* 

* @param string $table 

* @return boolean 

*/ 

function setTable($table){ 

if($table != null){ 

$this->table= $table; 

} 

return true; 

} 

////get Functions 

function getDbName(){ 

return $this->db_name; 

} 

function &getConn(){ 

if($this->isConnected()){ 

return $this->conn; 

} 

return null; 

} 

function getDescribe(){ 

return $this->describe; 

} 

function getLastSql(){ 

return $this->sql; 

} 

function getTable($table= null){ 

if($table){ 

$this->table= $table; 

} 

if($this->table){ 

return $this->table; 

} 

exit('no table selected error'); 

} 

/** 

* 數(shù)據(jù)庫(kù)是否連接 

* 

* @return boolean 

*/ 

function isConnected(){ 

if($this->connect && is_resource($this->conn)){ 

return true; 

} 

return false; 

} 

/** 

* 連接數(shù)據(jù)庫(kù) 

* 如果指定數(shù)據(jù)庫(kù)名，則嘗試連接指定數(shù)據(jù)庫(kù)。置空則忽略連接數(shù)據(jù)庫(kù)步驟，不設(shè)置則嘗試連接默認(rèn)數(shù)據(jù)庫(kù) 

* 

* @param string $_dbName 數(shù)據(jù)庫(kù)名 

* @param string $_db_user mysql登錄用戶名 

* @param string $_db_password mysql登錄密碼 

* @param string $_db_host mysql主機(jī) 

* @return boolean 成功返回 true，失敗返回false 

*/ 

function connect($db_name= DB_NAME, $db_user= DB_USER, $db_password= 

DB_PASSWORD, $db_host= DB_HOST){ 

//echo "try to connect<br>"; 

$this->close();//重新連接，則先斷開(kāi)原來(lái)的連接關(guān)系 

$this->conn= mysql_connect($db_host, $db_user, $db_password, true)or 

die('error at connect datebase'); 

if(!$this->conn) return false; 

$this->connect= true; 

$this->db_host= $db_host; 

$this->db_user= $db_user; 

$this->db_name= $db_name; 

$this->db_password= $db_passw 

//$this->setDefaultCharset(); 

//設(shè)置默認(rèn)的字符集 

$this->query('SET NAMES '.DEFAULT_CHASET); 

$this->db_chaset= DEFAULT_CHASET; 

if($db_name != null){ 

$this->selectDb($db_name); 

} 

return true; 

} 

/** 

* 重新連接 

* 

* @return boolean 

*/ 

private function reConnect(){ 

$db_name= $this->db_name; 

$db_user= $this->db_user; 

$db_password= $this->db_password; 

$db_host= $this->db_host; 

$chaset= $this->db_chaset; 

$result= $this->connect($db_name, $db_user, $db_password, $db_host); 

if($result){ 

//$this->setCharset($chaset ); 

//設(shè)置字符集 

$this->query('SET NAMES '.$chaset); 

$this->db_chaset= $chaset; 

} 

return $result; 

} 

/** 

* 選擇數(shù)據(jù)庫(kù) 

* 

* @param string $db_name 數(shù)據(jù)庫(kù)名 

* @return boolean 

*/ 

function selectDb($db_name= DB_NAME){ 

if(!$this->isConnected()){ 

return false; 

} 

$this->freeResult(); 

$this->sql= null; 

$this->table= null; 

if($this->checkReference()){ 

$this->cleanReferenceData(); 

$this->reConnect(); 

} 

$result= mysql_select_db($db_name, $this->conn) or die("error at selectDb: 

'{$db_name}'"); 

if($result) { 

$this->db_name= $db_name; 

return $result; 

} 

return false; 

} 

/** 

* 獲取 mysql連接類的克隆對(duì)象。該方法將取代 clone方法 

* 

* @param string $describe 新的描述 

* @return Mysql 

*/ 

function &getClone($describe= null){ 

if($describe == null){ 

//$describe= $this->describe.'copy of '.$this->referenceCount; 

$describe= "{$this->describe}[{$this->referenceCount}]"; 

} 

$newMySql = new Mysql($describe);//新MySql類 

$this->referenceCount ++;//更新引用計(jì)數(shù) 

$newMySql->conn= &$this->conn; //建立引用關(guān)聯(lián) 

$newMySql->referenceCount= &$this->referenceCount; 

$newMySql->connect= &$this->connect; 

$newMySql->describe= $describe; 

$newMySql->db_host= $this->db_host; 

$newMySql->db_name= $this->db_name; 

$newMySql->db_user= $this->db_user; 

$newMySql->db_password= $this->db_password; 

$newMySql->db_chaset= $this->db_chaset; 

return $newMySql; 

} 

/** 

* 執(zhí)行一條sql語(yǔ)句，需之前正確連接數(shù)據(jù)庫(kù) 

* 注意:如果執(zhí)行的是select語(yǔ)句，則返回的記錄集自動(dòng)保存在成員變量

$this->result中 

* 

* @param string $sql 執(zhí)行的sql字符串 

* @return mix 

*/ 

function query($sql){ 

if( $this->isConnected()){ 

$this->sql= $sql; 

$result= mysql_query($sql, $this->conn) 

or die("[error at {$this->describe}][query sql:'{$this->sql}']"); 

if(is_resource($result)){ 

$this->result= $result; 

} 

return $result; 

} 

exit($this->describe.'[unable conn]'); 

} 

/** 

* 執(zhí)行一條sql語(yǔ)句。此為 query()的同名方法 

* 

* @param string $_sql 

* @return mix 

*/ 

function execute($sql){ 

return $this->query($sql); 

} 

/** 

* 查詢一條SQL語(yǔ)句并返回 

* 如果為select則返回第 * 

* @param string $sql 

* @param int $result_type 

* @return mix 

*/ 

function queryOnce($sql ,$result_type= MYSQL_ASSOC){//查詢一條SQL語(yǔ)句，如果

為select則返回第一條結(jié)果 

if( $this->isConnected()){ 

$this->sql= $sql; 

$result= mysql_query($sql, $this->conn) 

or die("[error at {$this->describe}][query sql:'{$this->sql}']"); 

if(is_resource($result)){ 

$result= mysql_fetch_array($result,$result_type); 

} 

return $result; 

} 

exit($this->describe.'[unable $conn]'); 

} 

/** 

* 獲取select查詢數(shù)據(jù) 返回 查詢的索引數(shù)組 

* 

* @param int $result_type 索引數(shù)組類型:MYSQL_BOTH/MYSQL_ASSOC/MYSQL_NUM 

* @return array 成功返回?cái)?shù)組，失敗返回false 

*/ 

function fetchArray($result_type= MYSQL_BOTH ){ 

if($this->isConnected() && is_resource($this->result)){ 

return mysql_fetch_array( $this->result, $result_type); 

} 

return false; 

} 

/** 

* 獲取select查詢數(shù)據(jù) 返回 查詢的關(guān)聯(lián)索引的數(shù)組 

* 

* @return array 成功返回?cái)?shù)組，失敗返回false 

*/ 

function fetchAssoc(){ 

if($this->isConnected() && is_resource($this->result)){ 

return mysql_fetch_assoc( $this->result);//MYSQL_ASSOC 

} 

return false; 

} 

/** 

* 獲取select查詢數(shù)據(jù) 返回 查詢的數(shù)字索引的數(shù)組 

* 

* @return array 成功返回?cái)?shù)組，失敗返回false 

*/ 

function fetchNum(){ 

if($this->isConnected() && is_resource($this->result)){ 

return mysql_fetch_array( $this->result, MYSQL_NUM); 

} 

return false; 

} 

/** 

* 釋放當(dāng)前的結(jié)果集 

* 

* @return boolean 成功返回true 

*/ 

function freeResult(){ 

if($this->isConnected() && is_resource($this->result)){ 

$result= mysql_free_result($this->result); 

$this->result = null; 

return $result; 

} 

return true; 

} 

/** 

* 操作影響的數(shù)據(jù)行數(shù) 

* 此方法應(yīng)在執(zhí)行select/update之后調(diào)用 

* 

* @return int 

*/ 

function affectedRows(){ 

if($this->isConnected()){ 

return mysql_affected_rows($this->conn); 

} 

return null; 

} 

/** 

* 獲取select之后的結(jié)果集中數(shù)量 

* 

* @return int 

*/ 

function numRows(){ 

if( is_resource($this->result)){ 

$num= mysql_num_rows($this->result); 

return $num; 

} 

return null; 

} 

/** 

* 連接狀態(tài)，狀態(tài)數(shù)組信息參見(jiàn) mysql_stat() 

* 

* @return boolean 連接正常返回狀態(tài)數(shù)組，已斷開(kāi)返回 false 

*/ 

function stat(){ 

if($this->isConnected()){ 

return mysql_stat($this->conn); 

} 

return false; 

} 

/** 

* 檢測(cè)服務(wù)器連接，如果沒(méi)有連接則重新連接 

* 

* @return boolean 成功返回true，失敗返回false 

*/ 

function ping(){ 

if($this->isConnected()){ 

return mysql_ping($this->conn); 

} 

return null; 

} 

/** 

* 最新插入的數(shù)據(jù)后，AUTO_INCREMENT 的 ID號(hào) 

* 該 * 

* @return int 失敗返回 0 

*/ 

function insertId(){ 

if($this->isConnected()){ 

return mysql_insert_id($this->conn); 

} 

return 0; 

} 

/** 

* 返回?zé)o Limit結(jié)果的數(shù)據(jù)數(shù)目。僅用于select sql_calc_rows查詢之后 

* 

* @return int 

*/ 

function foundRows(){//僅用于select sql_calc_rows查詢之后 

$result= $this->queryOnce("SELECT FOUND_ROWS()",MYSQL_NUM); 

if($result) return $result[0]; 

return false; 

} 

///set char set functions 

/** 

* 1.設(shè)置字符集 

* 

* @param string $_chaset 

* @return 成功返回true 

*/ 

function setCharset($chaset= DEFAULT_CHASET){ 

if($this->isConnected()){ 

if($this->checkReference()){ 

$this->cleanReferenceData(); 

$this->reConnect(); 

} 

$this->query('SET NAMES '.$chaset); 

$this->db_chaset= $chaset; 

return true; 

} 

return false; 

} 

/** 

* 2.設(shè)置數(shù)據(jù)連接字符集為 utf-8 

* 注意，如果有多個(gè)Mysql類共用同一個(gè)數(shù)據(jù)連接，該方法將導(dǎo)致當(dāng)前Mysql類的連接

從原連接分離 

* @return boolean true 

*/ 

function setCharsetUtf8(){ 

return $this->setCharset('UTF8'); 

} 

/** 

* 3.設(shè)置為默認(rèn)的字符集。 

* 注意，如果有多個(gè)Mysql類共用同一個(gè)數(shù)據(jù)連接，該方法將導(dǎo)致當(dāng)前Mysql類的連接

從原連接分離。 

* 

* @return boolean 

*/ 

function setDefaultCharset(){ 

return $this->setCharset(DEFAULT_CHASET); 

} 

//sort functions 

/** 

* 1.根據(jù)主鍵出現(xiàn)的先后順序，重新排序數(shù)據(jù)表中的數(shù)據(jù) 

* 注意:僅支持排序ID的升序更新，如果是降序讀取，更新的時(shí)候需先反轉(zhuǎn)主鍵列表 

* 

* @param mix $primaryKeys 主鍵列表 

* @param string $table 操作的數(shù)據(jù)表名 

* @param string $sortField 排序列名 

* @param string $primaryField 主鍵列名 

* @return boolean 成功返回true，失敗返回false 

*/ 

function sortUpdate($primaryKeys,$table= null,$sortField='sortId',$primaryField= 'id'/*, $order_by= SORT_UPDATE_ASC*/){ 

if(!$this->isConnected()) return false; 

$table= $this->getTable($table); 

$primaryKeys= get_column_names($primaryKeys);//反序查找的需要反序更新 

/*if($order_by == SORT_UPDATE_DESC ){ 

$primaryKeys= array_reverse($primaryKeys); 

}else if($order_by != SORT_UPDATE_ASC ){ 

exit(); 

}*/ 

$newPrimaryKeySort= $primaryKeys; //新的排序 

$primaryKeys= implode(',',$primaryKeys); 

$sortSql= "select {$primaryField},{$sortField} from {$table} where 

{$primaryField} in ({$primaryKeys}) order by {$sortField} asc, {$primaryField} asc"; 

$this->query($sortSql); 

$findedPrimaryKeys= array(); //查找到的數(shù)據(jù)ID 

$updateItem= array(); //查找到的數(shù)據(jù) 

while(!!$result= $this->fetchArray(MYSQL_ASSOC)){ //整理查找到的記錄結(jié)果 

$findedPrimaryKeys[]= $result[$primaryField]; //記錄找到的ID，用于方便檢索 

$updateItem[]= $result; //記 } 

$keyIndex= 0; //查找到的數(shù)據(jù)ID索引初始化 

foreach($newPrimaryKeySort as $sortKey){ 

if(in_array($sortKey,$findedPrimaryKeys)){ //可以查找到的有效ID 

if($sortKey != $findedPrimaryKeys[$keyIndex]){//排序不正確的才需要更新 

$update[$sortField]= $updateItem[$keyIndex][$sortField]; 

$this->update($update,"{$primaryField}= '{$sortKey}'",$table); 

} 

$keyIndex++; //索引自加 

} 

} 

return true; 

} 

/** 

* 2.對(duì)數(shù)據(jù)表中指定的數(shù)據(jù)的排序順序進(jìn)行上移/下移調(diào)整 

* offset>0則向后移動(dòng)該數(shù)據(jù);offset<0則向前移動(dòng)該數(shù)據(jù)。同時(shí)更新所有受影響的數(shù)據(jù)排序 

* 僅支持排序列的升序更新，如果需要降序的更新，請(qǐng)把offset取負(fù) 

* 不支持排序列存在重復(fù)的情況。為了避免此問(wèn)題，請(qǐng)總是使用此方法排序，不要手動(dòng)修改數(shù)據(jù)庫(kù)。此方法已完全隱蔽排序列數(shù)據(jù)。 

* 

* @param int $primaryKey 主鍵 

* @param int $offset 數(shù)據(jù)位移值，0則不移動(dòng) 

* @param string $table 操作的數(shù)據(jù)表 

* @param string $sortField 排序列名 

* @param string $primaryField 主鍵列名 

* @return boolean 成功返回true，失敗返回false 

*/ 

function sort($primaryKey,$offset,$table= null,$sortField='sortId',$primaryField='id'){ 

if(!$this->isConnected()) return false; 

$table= $this->getTable($table); 

$sortSql= "select {$primaryField},{$sortField} from {$table} where 

{$primaryField}='{$primaryKey}' LIMIT 1"; 

if(!$result= $this->queryOnce($sortSql)){ 

return false;//未找到此ID數(shù)據(jù) 

} 

$offset= intval($offset); 

$sortOrder= $result[$sortField]; 

$limiter = ($offset>0)? ($offset+1):(1- $offset); 

if($offset <0 ){ 

$sortSql= "select {$primaryField},{$sortField} from {$table} where 

$sortField <= '{$sortOrder}' order by {$sortField} desc, {$primaryField} desc limit 

{$limiter}"; 

}elseif($offset > 0){ 

$sortSql= "select {$primaryField},{$sortField} from {$table} where 

$sortField >= '{$sortOrder}' order by {$sortField} asc, {$primaryField} asc limit 

{$limiter}"; 

}else{ 

return true;//0無(wú)須排序 

} 

$this->query($sortSql); 

$sortArray= array(); 

$result= $this->fetchAssoc(); //如果數(shù)據(jù)庫(kù)無(wú)錯(cuò)誤，則第一條記錄為要查找的數(shù)據(jù)ID(通常都能找到，除非數(shù)據(jù)庫(kù)數(shù)據(jù)不正確) 

if($result[$primaryField] == $primaryKey){ //find the id 

$sortArray[]= $result[$primaryField]; //save 

}else{ 

//重復(fù)的sortID導(dǎo)致查找失敗，或者未找到的數(shù)據(jù)記錄 

return false; 

} 

//獲取剩下的數(shù)據(jù)記錄 

while(!!$result= $this->fetchAssoc()){ 

$sortArray[]= $result[$primaryField]; 

} 

$head= array_shift($sortArray); //移除隊(duì)列頭元素(查找的元素本身) 

array_push($sortArray,$head); //將查找元素添加到數(shù)組末尾 

if($offset <0){//反序查找的數(shù)據(jù)需要反序排序 

$sortArray= array_reverse($sortArray); 

} 

if(!em return 

$this->sortUpdate($sortArray,$table,$sortField,$primaryField); 

} 

return false; 

} 

// 

/** 

* 簡(jiǎn)化的select sql語(yǔ)句封裝 

* 

* @param mix $field_names 選擇的列，數(shù)組或以','分開(kāi)的選項(xiàng)列字符串 

* @param string $condition 條件字符串 

* @param string $parameters 附加參數(shù)字符串 limit、order by 等 

* @param string $table 操作的表名 

* @return resource 

*/ 

function select($field_names= '*', $condition= null, $parameters= null, $table= 

null){ 

if(!$this->isConnected()){ 

return false; 

} 

$table= $this->getTable($table); 

$field_names= get_column_names($field_names); 

$field_names= implode(', ',$field_names); 

if(empty($field_names)) $field_names= '*'; 

$condition= trim($condition); 

if(!empty($condition)){ 

$condition= ' where '.$condition; 

} 

//Make sql 

$sql= "select {$field_names} from {$table} {$condition} {$parameters}"; 

$result= $this->query($sql); 

if(is_resource($result)){ 

$this->result= $result; 

} 

return $result; 

} 

/** 

* 簡(jiǎn)化的insert語(yǔ)句操作封裝 

* 

* @param mix $arr_fields 插入的數(shù)據(jù)數(shù)組 insert[fieldname]=fieldvalue。如果數(shù)據(jù)較少可以直接寫字符串 

* @param string $table 操作的數(shù)據(jù)表名 

* @return boolean 返回insert操作的結(jié)果 

*/ 

function insert($arr_fields, $table= null){ 

if(!$this->isConnected()) return false; 

$table= $this->getTable($table); 

$field_values= null; 

if(is_array($arr_fields)){ 

$arr_keys= array(); 

$arr_values= array(); 

foreach($arr_fields as $key => $value ){ 

array_push($arr_keys, $key); 

array_push($arr_values, "'{$value}'"); 

} 

$keys= implode(', ', $arr_keys); 

$values= implode(', ', $arr_values); 

$field_values= "({$keys}) values ({$values})"; 

}else{ 

$field_values= $arr_fields; 

} 

//Make sql 

$sql= "insert into {$table} {$field_values}"; 

return $this->query($sql); 

} 

/** 

* 簡(jiǎn)化的 update操作封裝 

* 

* @param mix $arr_fields 更新的列數(shù)組 

* @param string $condition 更新的條件 

* @param string $table 操作的數(shù)據(jù)表名 

* @return boolean 返回操作結(jié)果 

*/ 

function update($arr_fields, $condition, $table= null){ 

if(!$this->isConnected()){ 

return false; 

} 

$table= $this->getTable($table); 

$field_values= null; 

if(is_array($arr_fields)){ 

$fields_array= array(); 

foreach($arr_fields as $key => $value ){ 

array_push($fields_array, "{$key}= '{$value}'"); 

} 

$field_values= implode(', ', $fields_array); 

}else{ 

$field_values= $arr_fields; 

} 

$condition= trim($condition); 

if(!empty($condition)){ 

$condition= ' where '.$condition; 

} 

$sql= "update {$table} set {$field_values} {$condition}"; 

return $this->query($sql); 

} 

/** 

* 簡(jiǎn)化的 delete操作封裝 

* 

* @param string $condition 刪除的條件字符串 

* @param string $table 刪除 * @return boolean 

*/ 

function delete($condition, $table= null){ 

if(!$this->isConnected()) return false; 

$table= $this->getTable($table); 

$condition= trim($condition); 

if(!empty($condition)){ 

$condition= ' where '.$condition; 

} 

$sql= "delete from {$table} {$condition}"; 

return $this->query($sql); 

} 

}