分享一個自己寫的php操作mysql資料庫的類

這是我自己寫的一個類，歡迎大家討論指導
部分使用方法：
//聲明資料庫物件
$Conn = new Mysql;
//載入資料庫參數
$Conn ->Parameter(資料庫伺服器, 資料庫使用者名稱, 資料庫密碼, 資料庫名稱, 資料庫編碼, 資料庫表前綴[可為空]);

上面的程式碼就已經載入這個類別檔案進來了，並且初始化了一些資料庫連線參數！
以下介紹幾個基本上是方法函數：
1、 $Conn -> Table();
選擇資料表，參數是資料表名稱
2、$Conn -> Field();
選擇的欄位名稱，多個用逗號隔開，如不呼叫這個方法，則傳回全部
3、$Conn -> Where();
Sql Where子語句，依照條件篩選
4、$Conn -> Order();
Sql 排序
5、$Conn -> Page(int);
參數是一個正整數數字，如調用這個方法，記錄將分頁顯示
6、$Conn -> Select(布林值);
執行查詢，返回查詢結果，如果有，則是一個二維數組，如果無，則返回假，參數可省略，如省略，默認為真，傳回的陣列包含數字元素
7、$Conn -> Del();
刪除記錄
8、 $Conn -> Edit(array());
修改記錄，參數是一個一維數組，數組鍵是字段名稱，數組值是字段值
9、$Conn -> Into(array());
新增記錄，參數是一個一維數組，數組鍵是字段名稱，數組值是字段值。

以上方法可連續調用，例如：

$Rult = $Conn -> Table('user') -> Select(); //查詢返回user表的所有記錄
$Rult = $Conn -> Table('user') -> Page(20) -> Select();//查詢回傳user表的所有記錄，並分頁顯示，每頁20筆；

還有很多方法呼叫和訣竅，以後有空再慢慢細說！

/*

 資料庫操作類別
 操作方式：面對物件
 製作時間：2013-3-10
 目前版本：BqhMysql(mysqli)1.0.1
 軟體作者：傷心的歌
 聯絡QQ ：36975
 聯絡電話：18907975647
 聯絡電子郵件：admin@1288.com地址：江西省贛州市石城縣小松鎮
 郵遞區號：342706

*/
class Mysql{
 private $LocalHost = 'localhost';
 private $Lof root';
 private $LocalPass = '123456';
 private $LocalBase = 'jiangxibaiyi';
 private $LocalCode = 'UTF8';
 private $private $private
 private $Start = 0;
 private $Error = false; //資料庫連線狀態, false表示未連線或連線不正常
 public $Err = true; //Sql執行結果

 private $Table;
 private $Field = '*';
 private $Where = '';
 private $Order = '';

 private $private $Order = '';

 private $PageSize = 0; /分頁顯示->每頁多少條，0為不分頁顯示
 private $PageCount = 1; //分頁顯示->總共有多少條
 private $PageNum = 1; //分頁顯示->總共有多少頁
 private $PageNo = 1; //分頁顯示->目前第幾頁
 private $PageKey = 'page'; //分頁url參數鍵
 private $PageStart = 0; //分頁顯示->目前從第幾條開始回傳


 private $Select;
 private $Rest;

 private $Result = false;//結果集


 public $FormArray = array();

 public $Instr_ID = 0;
 private $j = 0;


 public function Parameter($Loca, $Root , $Pass, $Base, $Code, $PreFix = ''){
 $this->LoaclUser = $Root;
 $this->LocalBase = $Base;
 $this->LocalCode = $Code;
 $this->LocalHost = $Loca;
 $this->LocalPass = $Pass;
 $this->PreFix = $PreFix;
 return $this;
 } }
 private function Connection( $Sql ){
 !function_exists(mysqli_connect) ? die('查詢失敗，無法載入mysqli擴充') : null;
 $this->Conn = @new mysqli擴充 $ ->LocalHost, $this->LoaclUser, $this->LocalPass, $this->LocalBase);
 $this->Error = mysqli_connect_errno() == 0 ? true : false;
 !$this-this-this- >Error ? die('資料庫連線錯誤，請檢查資料庫連線參數') : null;
 $this->Conn->query('SET NAMES ' . $this->LocalCode);
 $this- >Rest = $this->Conn->query($Sql);
 $this->Err = mysqli_error($this->Conn);
 $this->Instr_ID = mysqli_insert_id($this->Conn );
 $this->Rest->free_result;
 $this->Conn->close;
 $this -> FormArray = '';
 return $this;
 }

 public function null(){
 $this->PageSize = 0;
 //$this->PageCount = 1;
 $this->PageStart = 1;
 $ this->Field = ' * ';
 $this->Select = '';
 unset($this->Table, $this->Where,$this->Order, $this->Result) ;
 }

 public function Table( $TableName ) {//資料表
 $this -> null();
 $this->Table = '`' . $this- >PreFix . $TableName . '`';
 return $this;
 }

 public function Field( $Array = '*' ) {//資料欄位
 !empty( $ this->Field ) ? $this->Field = '' : null;
 $Array = explode(',', $Array);
 foreach ( $Array as $field ) {
 $this ->Field .= !$this->Start ? '`' . $field . '`' : ', `' . $field . '`';
 $this->Start ;
 }
 $this->Start = 0;
 return $this;
 }

 public function Where( $Where ) {//條件
 $this->Where = ' where ' . $Where;
 return $this;
 }

 public function Order( $Order ) {//排序
 $this->Order = ' order by ' . $Order;
 return $this;
 }

 public function pk( $key ) {//分頁url參數鍵
 $this->PageKey = $key;
 return $this;
 }

 public function Page( $PageSize ) {//分頁
 $this->PageSize = $PageSize;
 $this->PageNo = $this->get( $this-> PageKey );
 $this->PageNo = empty( $this->PageNo ) || !isset( $this->PageNo ) || !is_numeric( $this->PageNo ) || $this->PageNo PageNo PageNo;
 return $this;
 }

 public function post( $Key, $Filter = true ){
 return $Filter ? strip_tags($ _POST[$Key]) : $_POST[$Key];
 }

 public function get( $Key, $Filter = true ){
 return $Filter ? strip_tags($_GET[$ Key]) : $_GET[$Key]; }

 public function Sel(){
 $this->Select = 'Select ' . $this->Field 。 this->Rest->num_rows ) {
 while ( $Rs = $this->Rest->fetch_assoc() ) {
 $this->Result[] = $Rs;
 }
 }
 $DataBase = $this->結果;
 回傳空($DataBase) ？ > $this->Select = $Sql ;
 $this->連接( $this->Select );
 if ( $this->Rest->num_rows ) {
 if ( !$biao ) {
 while ( $Rs = $this->Rest->fetch_array() ) {
 $this->Result[] = !preg_match('/^d $/i', $Type) ？  $Rs : $Rs[ $Type ];
 }
 } else {
 while ( $Rs = $this->Rest->fetch_assoc() ) {
 $this->; 結果[ ] = $Rs;
 }
 }
 }
 $DataBase = $this->Result;
 回傳空($DataBase) ？ }

 公用函數執行( $Sql = '' ){
 $this->Connection( $Sql );
 return $this- >Rest;
 }


 公用函數存在( $T = '', $F = '', $W = ''){
 if ( 空( $F ) ) { 回傳0; }
 $cmd = 空( $W ) ? '從 `' 選擇 sum(' . $F . ') 作為 `baiyinum` 。 baiyinum` 。 );
 $Rel = $this->休息->; fetch_array();
 return round( $Rel['baiyinum'], 2 );
 }


 public function ExistsTo( $Bili = 10000, $T = '', $ F = '', $W = ''){
 if (empty( $F ) ) { return 0; }
 $cmd = 空( $W ) ? '從 `' 選擇 sum(' . $F . ') 作為 `baiyinum` 。 baiyinum` 。 cmd );
 $Rel = $this->Rest->; fetch_array();
 return round( $Rel['baiyinum'] * $Bili );
 }


 public function Select( $Type = true, $ListNum = 1 ){ //傳回記錄（貨物形式，回傳條數）
 $this->Select = 'Select ' . $this->Field 。 > 0 ) {
 $this->Connection( $this->; Select );//執行查詢
 $this->PageCount = $this->Rest->num_rows;//取得記錄總數
 $this->PageNum = ceil($this->PageNum) PageCount / $this->PageSize); // 總共有多少頁
 $this->PageNo = $this->PageNo > $this->PageNum ? $this->PageNum : $this->PageNo;
 $this->PageStart = ( $this->PageNo - 1 ) * $this->PageSize;   //目前從第幾條開始回傳
 $this->Select .= ' limit ' . $this->PageStart 。 // 重建構sql語句
 } else {
 $this->Select .= ' limit ' . $ListNum; // 重構sql語句
 }
 } else {
 $this->Select .= ' limit 1'; //重建構重sql語句
 }
 //echo $this->Select;
 $this->Connection( $this->Select );//執行查詢
 if ( $this ->Rest->num_rows ) {//如果記錄存在
 if ( $Type ) {
 while ( $Rs = $this->Rest->fetch_array() ) {
 $this->Result [] = $Rs;
 }
 }else{
 while ( $Rs = $this->Rest->fetch_assoc() ) {
 $this->Result[] = $Rs;
 }
 }
 }
 if ( ( $ListNum == 1 或!is_numeric( $ListNum ) ) && !$this->PageSize ) { $this->結果= $this->結果[0]； }
 $DataBase = $this->Result;
 回傳空($DataBase) ? false : $DataBase;
 }

 public function Num() { // 回傳記錄總數
 $this->Select = 'Select ' . $this->Field 。 > return $this->Rest->num_rows;//取得總記錄
 }

   public function PageNav($NumNav = false ) {  //分页
	 $Action = $this -> get('action');
	 !empty( $Action ) or $Action =  'index';
	 $Module = $this -> get('module');
	 !empty( $Module ) or $Module = 'index';
	 $NavUrl   = '/' . $Module . '/' . $Action . '/' . $this -> PageKey .'/';
	 $NaIndex  = '/' . $Module . '/' . $Action;
	 $PageHtml = "\n";
	 $PageHtml .= '' . $this->PageCount . '条记录        ' . $this->PageNo . '/' . $this->PageNum . '页            ';
	 $this->PageNo <= 1 or $PageHtml .= "首页\nPageNo - 1) . "\">上一页\n";
	if ( $NumNav ) { $PageHtml .= $this->NumPage($NavUrl); }
	$this->PageNo >= $this->PageNum or $PageHtml .= "PageNo + 1) .  "\">下一页\nPageNum . "\">尾页\n";
	$PageHtml .= "

n";

return $PageHtml;

}

//表單處理開始

//判斷表單時候提交

public function FormIs( $Keys = 'mm' ) {

return $_POST[ $Keys ] == 1 ? true : false;

}

//post方式取得資料

public function _post( $Keys = '', $TiHuan = '') {

$Values = strip_tags( $_POST[ $Keys ] );

$this->FormArray[$Keys] = empty( $Values ) ? $TiHuan : $Values ;

return empty( $Values ) ? $TiHuan : $Values;

}

//get方法取得資料

public function _get( $Keys = '', $TiHuan = '> public function _get( $Keys = '', $TiHuan = ' ') {

$Values = strip_tags( $_GET[ $Keys ] );

return empty( $Values ) ? $TiHuan : $Values;

}

//判斷是否為數字且不小於0

public function IsNum( $Num = 0, $Mesg = '參數必須為數字' ) {

if ( is_numeric( $Num ) && !empty( $Num ) && $Num >= 0 ) {

return $Num;

}else{

die( $Mesg );

}

}

//判斷是否為數字且不小於0真/False

public function NumBer( $Num = 0) {

return is_numeric( $Num ) && !empty( $Num ) && $Num >= 0 ? true : false;

}

}

//偵測相關資料似乎存在

public function IsData($Types = true, $memg = '資料已經存在' ){

$this->Connection('select ' . $this->Field . ' from ' . $this->Table . $this->Where);

if ( $Types ){

$this->Rest->num_rows > 0 ? die( $memg ) : null;

} else {

return $this->Rest->num_rows;

}

}

//寫入資料庫記錄

public function into( $Mesgto( $Mesg = '' ){

!is_array( $this->FormArray ) ? die( $Mesg ) : null;

$Sql = 'insert into ' . $this->Table . ' (`';

$I = 0;

foreach ( $this->FormArray as $Key => $Val ){

$Duan .= !$I ? $Key . '`' : ', `' . $Key . '`';

if ( is_numeric( $Val ) ){

$Vals .= !$I ? $Val : ', ' . $Val;

}else{

$Vals . = !$I ? ''' . $Val . ''' : ', '' . $Val . ''';

}

$I ;

}

$Sql .= $ Duan . ') values (' . $Vals . ')';

//@file_put_contents('1.sql', $Sql, FILE_APPEND);

$this->Connection( $Sql );

return !empty( $this->Err ) ? false : true;

}

//陣列形式寫入資料

public function MsgBox( $Table = ' //陣列形式寫入資料

public function MsgBox( $Table = ' ', $Filed = array() ) {

$this -> Table($Table);

foreach( $Filed as $Key => $Val ) {

$this -> FormArray[ $Key ] = $Val;

}

return $this -> Into('未取得資料');

}

//修改資料庫記錄

public function Edit( $Array = array() ) {

if ( empty( $Array ) ) { $Array = $this -> FormArray; }

if ( !is_array( $Array ) || empty( $Array ) ) {

return false;

} else {

$Sql = 'update ' . $this -> Table . ' set ';

$I = 0;

$Sub = '';

$Huan = array('-' => '[jian]', ' ' => '[jia]', '*' => '[cheng]', '/' => '[chu]');

$Zhan = array('[jian]' => '-', '[jia]' => ' ', '[cheng]' => '*', '[chu]' => '/') ;

foreach ( $Array as $Files => $Val ) {

$Val = !is_numeric( $Val ) && !preg_match('/`w `s*( |-|*|/ )/i', $Val) ? ''' . $Val . ''' : $Val;

foreach ( $Huan as $key => $val ){

$Val = str_replace($key, $val, $Val);

}

$duan = !$I ? '`' . $Files . '` = ' : ', `' . $Files . '` = ';

$ Sub .= $duan . $Val;

$I ;

}

$Sql .= $Sub . $this -> Where;

foreach ( $Zhan as $Fan => $Hui ) {

$Sql = str_replace($Fan, $Hui, $Sql);

}

//echo $Sql; die;

$this -> Connection( $Sql; die;

$this -> Connection( $Sql; die;

$this -> Connection( $Sql; die;

$this -> Connection( $Sql; die;

$this -> Connection( $ Sql );

unset( $Array, $duan, $Fan, $Files, $Huan, $Hui, $I, $key, $Sql, $Sub, $Val, $Zhan, $val );

return !empty( $this -> Err ) ? false : true;

}

}

//刪除數據庫記錄

public function del(){

$Sql = 'delete from ' . $this->Table . $this->Where;

$this->Connection( $Sql );

unset($Sql);

return !empty( $this-> Err ) ? false : true;

}

//表單處理結束

//頁面跳轉

public function Msg( $Text = '操作成功' ) {

echo '';

echo ''; exit; } #取得系統當前時間 public function Times(){ return str_replace('-', '[jian] ', date('Y-m-d H:i:s')); }

#取得使用者IP位址

public function GetIP(){

if (getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown") ip = getenv("HTTP_CLIENT_IP");

else if (getenv("HTTP_X_FORWARDED_FOR") && strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown"))

$ip = getenv("HTTPED_FORWARD);

else if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown"))

$ip = getenv("REMOTE_ADDR");

else if (isset($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], "unknown"))

$ip = $_SERVER'ADDR'], "unknown"))

$ip = $_SERVER[' REMOTE_ADDR'];

else

$ip = "未知";

返回($ip);

}

//最後關閉資料庫連線

public function Close(){

!is_object( $this -> Conn ) 或 mysqli_close( $this -> Conn );

}

}

複製程式碼