MySQL操作PHP類

openkk 13年前發布 | 63K 次閱讀 MySQL PHP開發

本類全靜態 使用的時候直接include后 用mysql::方法()名即可 由于類在php5里面全局可視,所以不必擔心變量范圍的問題.如果有什么意見 請圍脖私信||qq郵件;

目前沒有與存儲過程有關的方法,當然存儲過程一般是創建數據庫的時候做的.

config文件需要配置以下常量信息:

LIB:類存放位置

DEBUG:是否開啟debug(如果開啟會輸出錯誤信息跟蹤)
TB_EX:數據庫表前綴; 
<?php 
/mysql 簡單類 by joffe q89949401 圍脖@狂code詩人;
本類全靜態 使用的時候直接include后 用mysql::方法()名即可 由于類在php5里面全局可視,所以不必擔心變量范圍的問題.如果有什么意見 請圍脖私信||qq郵件;
目前沒有與存儲過程有關的方法,當然存儲過程一般是創建數據庫的時候做的.
config文件需要配置以下常量信息:
LIB:類存放位置
DEBUG:是否開啟debug(如果開啟會輸出錯誤信息跟蹤)
TB_EX:數據庫表前綴;/
defined('LIB') or die('Missing config!!');
final class mysql {

/**


    

  • 查詢總次數  
    • 

  • 

  • @var int
    
*/
    
public static $querynum = 0;
    
/**  
    • 

  • 連接句柄  
    • 

  • 

  • @var object
    
/
    
public static $link;
    
/    
表前綴
@var string 下面方法需要在配置文件中配置TB_EX 作為表的前綴
*/
    • 



static function add_ex($tb){
    return TB_EX.$tb_ex.$tb;
}
 /*mysql數據庫是否使用嚴格的類型(mysql類型沒開啟自動轉換)默認為false,表示mysql有開啟類型轉換,這個變量目前只要是用于insert函數的單引號在沒有自動轉換的mysql里面的問題,可能將來會增加相關函數


*/
public static $is_type_tight=false;


/**


    

  • 構造函數  
    • 

  • 

  • @param string $dbhost 主機名  
    • 

  • @param string $dbuser 用戶  
    • 

  • @param string $dbpw 密碼  
    • 

  • @param string $dbname 數據庫名  
    • 

  • @param int $pconnect 是否持續連接
    
*/
    
static function connent($dbhost, $dbuser, $dbpw, $dbname = "",$dbcharset, $pconnect = 0) {
    
if($pconnect) {
    
if(!self::$link = @mysql_pconnect($dbhost, $dbuser, $dbpw)) {
    
self::halt("Can not connect to MySQL server");
    
}
    
} else {
    
if(!self::$link = @mysql_connect($dbhost, $dbuser, $dbpw)) {
    
self::halt("Can not connect to MySQL server");
    
}
    
}
    
if(self::version() > "4.1") {
    
if($dbcharset) {
    
mysql_query("SET character_set_connection={$dbcharset}, character_set_results=$dbcharset, character_set_client=binary", self::$link);
    
}
    
if(self::version() > "5.0.1") {
    
mysql_query("SET sql_mode=''", self::$link);
    
}
    
}
    
if($dbname) {
    
mysql_select_db($dbname, self::$link);
    
}
    
}
    
/**  
    • 

  • 選擇數據庫  
    • 

  • 

  • @param string $dbname  
    • 

  • @return
    
*/
    
static function select_db($dbname) {
    
return mysql_select_db($dbname, self::$link);
    
}
    
/**  
    • 

  • 取出結果集中一條記錄  
    • 

  • 

  • @param object $query  
    • 

  • @param int $result_type  
    • 

  • @return array
    
*/
    
static function fetch_array($query, $result_type = MYSQL_ASSOC) {  //默認只取關聯數組 不取數字數組.
return mysql_fetch_array($query, $result_type);
    
}  
    • 



/**


    

  • 查詢SQL  
    • 

  • 

  • @param string $sql  
    • 

  • @param string $type  
    • 

  • @return object
    
*/
    
static function query($sql, $type = "") {
    
$func = $type == "UNBUFFERED" && @function_exists("mysql_unbuffered_query") ?
    
"mysql_unbuffered_query" : "mysql_query";
    
if(!($query = $func($sql, self::$link)) && $type != "SILENT") {
    
self::halt("MySQL Query Error", $sql);
    
}
    
self::$querynum++;
    
return $query;
    
}
    
/**  
    • 

  • 取影響條數  
    • 

  • 

  • @return int
    
*/
    
static function affected_rows() {
    
return mysql_affected_rows(self::$link);
    
}
    
/**  
    • 

  • 返回錯誤信息  
    • 

  • 

  • @return array
    
*/
    
static function error() {
    
return ((self::$link) ? mysql_error(self::$link) : mysql_error());
    
}
    
/**  
    • 

  • 返回錯誤代碼  
    • 

  • 

  • @return int
    
*/
    
static function errno() {
    
return intval((self::$link) ? mysql_errno(self::$link) : mysql_errno());
    
}
    
/**  
    • 

  • 返回查詢結果  
    • 

  • 

  • @param object $query  
    • 

  • @param string $row  
    • 

  • @return mixed
    
*/
    
static function result($query, $row,$flname=0) {
    
$query = @mysql_result($query, $row,$flname);
    
return $query;
    
}
    
/**  
    • 

  • 結果條數  
    • 

  • 

  • @param object $query  
    • 

  • @return int
    
*/
    
static function num_rows($query) {
    
$query = mysql_num_rows($query);
    
return $query;
    
}
    
/**  
    • 

  • 取字段總數  
    • 

  • 

  • @param object $query  
    • 

  • @return int
    
*/
    
static function num_fields($query) {
    
return mysql_num_fields($query);
    
}
    
/**  
    • 

  • 釋放結果集  
    • 

  • 

  • @param object $query  
    • 

  • @return bool
    
*/
    
static function free_result($query) {
    
return @mysql_free_result($query);
    
}
    
/**  
    • 

  • 返回自增ID  
    • 

  • 

  • @return int
    
*/
    
static function insert_id() {
    
return ($id = mysql_insert_id(self::$link)) >= 0 ? $id : self::$result(self::$query("SELECT last_insert_id()"), 0);
    
}
    
/**  
    • 

  • 從結果集中取得一行作為枚舉數組  
    • 

  • 

  • @param object $query  
    • 

  • @return array
    
*/
    
static function fetch_row($query) {
    
$query = mysql_fetch_row($query);
    
return $query;
    
}
    
/**  
    • 

  • 從結果集中取得列信息并作為對象返回  
    • 

  • 

  • @param object $query  
    • 

  • @return object
    
*/
    
static function fetch_fields($query) {
    
return mysql_fetch_field($query);
    
}  
    • 



static function select_affectedt_rows($rs){
     return mysql_affected_rows($rs,self::$link);


}
/**


    

  • 返回mysql版本  
    • 

  • 

  • @return string
    
*/
    
static function version() {
    
return mysql_get_server_info(self::$link);
    
}
    
/**  
    • 

  • 關閉連接  
    • 

  • 

  • @return bool
    
*/
    
static function close() {
    
return mysql_close(self::$link);
    
}
    
/**  
    • 

  • 輸出錯誤信息  
    • 

  • 

  • @param string $message  
    • 

  • @param string $sql
    
*/
    
static function halt($message = "", $sql = "") {
   @header("Content-type: text/html; charset=utf-8");
    

    if (DEBUG==1){
    


      $debug = debug_backtrace();
  echo $message . "\r\n<br/>SQL--> " . $sql."\r\n<br/>ERROR_MESSAGE-->".self::error().
  "\r\n<br/>--------------debug--------------\r\n<br/>";
  self::echoarray($debug);
  echo "\r\n<br/>-------------debug end----------------";  


    

    }else{
    


      echo 'SQL Error';

    

    }
  @self::rollback();
  exit;
}
    
/////////////////////////////以下是擴展的sql方法.//////
/ 把數組按照 key value value 的對應關系插入數據表table中
table 要插入的數據表
要注意 這些擴展方法是沒自己給表有加前綴的./
static function insert($table,$array){
  $temp="";$temp2='';
  foreach($array as $key=>$value){
    


      if(self::$is_type_tight){
      if(is_string($value)){
          $temp .="$key,";$temp2 .="'$value',";
      }elseif(is_int($value||is_null($value)||is_float($value))){
          $value+=0;
          $temp .="$key,";$temp2 .="'$value',";
      }
  }else{
      $temp .="$key,";$temp2 .="'$value',";
  }

    

    }
  $temp = substr($temp,0,strlen($temp)-1);
  $temp2 = substr($temp2,0,strlen($temp2)-1);
    

    $sql = "INSERT INTO $table ($temp) VALUE($temp2)";
  return self::query($sql);
}
    

    • 



static function del($table,$where){
    $sql = "DELETE FROM {$table} where {$where}";
    return self::query($sql);
}


static function update($table,$array,$where){
    foreach ($array as $key=>$value){
        $temp .= "$key='$value',";
    }
    $temp = substr($temp,0,strlen($temp)-1);
    $sql = "update {$table} set ($temp) where {$where} ";
    return self::query($sql);
}


/*進行數據庫查詢select 參數不定
參數說明:所有參數必須是string
第一個參數必須是表名;
從第二個參數起,
如果是寫上 "where:XXX" 則認為是where條件;
如果寫上 "xxx" 則認為是鍵值
如果寫上 "by:XXX" 則認為是排序
如果寫上 "limit:xxx,xxx" 則認為是分頁


參數不正確則返回false; 成功查詢返回查詢后的數組;


*/
static function select(){
    $numargs = func_num_args();//獲取參數個數;
    $where = "";$key="";$limit="";$by="";
    if($numargs==0){return false;}
    //echo $numargs;
    if($numargs>=2){
        $arg_list = func_get_args();
        $table = $arg_list[0];
        unset($arg_list[0]);
    //  print_r($arg_list);
        foreach($arg_list as $k=>$value){
            if(preg_match("#^(where:)\w#",$value)){
                $temp = explode(":",$value);
                    $where = "WHERE {$temp[1]} " ;
            }elseif(preg_match("#^by:\w#",$value)){
                $temp = explode(":",$value);
                $by = "order by {$temp[1]}" ;
            }elseif(preg_match("#^limit:\w#",$value)){
                $temp = explode(":",$value);
                $limit = "limit {$temp[1]}";
            }else{
                $key .= "$value,";
            }
        }



    if($key==""){
        $key = "*";
    }else{
        $key =substr($key,0,strlen($key)-1); 
    }

$sql_base="SELECT $key FROM $table";
}
if(!empty($where)){
    $sql_base .= " $where";
}
if(!empty($by)){
    $sql_base .= " $by";
}
if(!empty($limit)){
    $sql_base .= " $limit";
}
//echo $sql_base;
//echo $by ;
$rs = self::query($sql_base);
$re=array();
if(self::num_rows($rs)>=1){
    while($info = self::fetch_array($rs)){
        $re[]=$info;
    }
}
self::free_result($rs);
return $re;
}


/*回滾事務*/
static function rollback(){
    self::query('rollback');
}
/*開始事務*/
static function begin(){
    self::query('SET AUTOCOMMIT =0'); //停用自動提交;
    self::query('BEGIN') ;//開始一個事務;
}

/*提交事務*/
static function commit(){
    self::query('commit');
}


static function echoarray($array){
    foreach($array as $k=>$v ){
        if(is_array($v)){
            if(is_array($v)){
                echo "<br/>--------------------------------<br/>";
                self::echoarray($v);
            }
        }else{
            if($k==='line')
            echo "<b style='color:red'>$k -> " .$v."</b>  ";
            else
            echo "$k -> " .$v."  ";
        }
    }
}

function get_server_info(){
    return mysql_get_server_info();
}





//下面是應付大數據的表的優化查詢


/
big_select 適合用于大規模的查詢,利用覆蓋索引實現大幅度的偏移活動窗口,令查詢在覆蓋索引上偏移而不是在所有數據上,減少msql在數據上檢查,再把其他數據join進來這樣更效率.但對于小規模數據,這種查詢反而增加復雜度,增加優化器壓力.說個例子,如果你是limit 10000,20;mysql會先查出10020條數據 再丟棄10000 這種操作代價非常大,利用這個函數可以有效提升效率,但如果是 limit 20,那就會稍微比直接select 慢了一些
@table string要查詢的表 如"table1"
@keys string 要查詢的鍵值,多個鍵值用","分割 如"key1,key2,key3"結束不含","盡量少用""且一些關鍵詞請加上`;
@Index string主索引鍵或者唯一索引鍵名,只需要一個 如"id";
@pagesize int 分頁大小,必須,你不會想這么多數據全部出來吧
@pageNo 頁碼,從0開始
@orderby string 排序 如"id desc";可空,但不建議空
@where string 條件 如 "date>122424533"可空


返回數組


/
    static function big_select($table,$keys,$index,$pagesize,$pageNo,$orderby=NULL,$where=NULL){
        $start=$pageNo$pagesize;
        if($where){
            $sqlIndex="SELEECT {$index} from {$table} where {$where}";
        }else{
            $sqlIndex="SELEECT {$index} from {$table}";
        }
        if($orderby){
            $sqlIndex .=" ORDER BY {$orderby} Limit $start,$pagesize";

        }else{
            $sqlIndex .=" ORDER BY  Limit $start,$pagesize";
        }
        $sql = "SELECT $keys FROM {$table} INNER JOIN({$sqlIndex}) AS lim USING({$index})";



    $rs =   self::query($sql);

        $re=array();
if(self::num_rows($rs)>=1){
    while($info = self::fetch_array($rs)){
        $re[]=$info;
    }
}
self::free_result($rs);
return $re;

}
/* 如果一個很大的數據(預計大于萬行)刪除它的工作周期會比較長,會長時間鎖住不應該鎖住的表或行,令一些不該打斷的數據被打斷 以下方法是把一個大的sql任務分小(分為一次5000行)但次操作可能會造成刪除空隙期間插入了新的數據,而新的數據可能因滿足條件而被刪除.本方法容易因為超時而失敗.
@table string 要刪除數據的表名
@where string 條件 可省略
#int 刪除掉的行數
*/
static function big_del($table,$where){
    set_time_limit(0);
    $sql="delete from {$table} where {$where} Limit 5000";
    $rows = 0;
    $eff=0;
    do{
        self::query($sql);
        $rows=self::affected_rows();
        $eff += $rows;
    }while($rows>0);
    return $eff;
}



}


?>

 </pre>
 本文由用戶 openkk 自行上傳分享，僅供網友學習交流。所有權歸原作者，若您的權利被侵害，請聯系管理員。
 轉載本站原創文章，請注明出處，并保留原始鏈接、圖片水印。
 本站是一個以用戶分享為主的開源技術平臺，歡迎各類分享！