Home > Backend Development > PHP Tutorial > PHP implements mysql database operation class sharing_PHP tutorial

PHP implements mysql database operation class sharing_PHP tutorial

WBOY
Release: 2016-07-13 10:24:56
Original
897 people have browsed it

Copy code The code is as follows:

/*
Database operation class
*/
class Mysql{
private $LocalHost = 'localhost';
private $LoaclUser = 'root';
private $LocalPass = '123456';
private $LocalBase = 'jiangxibaiyi';
private $LocalCode = 'UTF8';
private $PreFix;
private $Conn ;
private $Start = 0;
private $Error = false; //Database connection status, false means not connected or the connection is abnormal
public $Err = true; //Sql execution result

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

private $PageSize = 0; //Page display->How many items per page, 0 means no paging display
private $PageCount = 1; //Page display->How many items in total
private $PageNum = 1; //Page display ->How many pages are there in total
private $PageNo = 1; //Paging display->The current page
private $PageKey = 'page'; //Paging url parameter key
private $PageStart = 0; //Page display-> From which item is currently returned


private $Select;
private $Rest;

private $Result = false;/ /Result set

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('Query failed, unable to load mysqli extension') : null;
$this->Conn = @new mysqli( $this->LocalHost, $this->LoaclUser, $this->LocalPass, $this->LocalBase);
$this->Error = mysqli_connect_errno() == 0 ? true : false;
!$this->Error ? die('Database connection error, please check the database connection parameters') : 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 ) {//Data table
$this -> null();
$this->Table = '`' . $this->PreFix . $ TableName . '`';
return $this;
}

public function Field( $Array = '*' ) {//Data field
!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 ) {//Condition
$this->Where = ' where ' .$Where;
return $this;
}

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

public function pk( $key ) {//Paging url parameter key
$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 < 1 ? 1 : $this->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 . ' from ' . $this->Table . $this->Where . $this->Order;
  $this->Connection( $this->Select );
  if ( $this->Rest->num_rows ) {
   while ( $Rs = $this->Rest->fetch_assoc() ) {
     $this->Result[] = $Rs;
    }
  }
    $DataBase = $this->Result;
    return empty($DataBase) ? false : $DataBase;
 }

 public function querys( $Sql = '', $Type = 'not', $biao = false ) {
  $this->Select = $Sql;
  $this->Connection( $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->Result[] = $Rs;
    }
  }
  }
    $DataBase = $this->Result;
    return empty($DataBase) ? false : $DataBase;

 }

 public function executes( $Sql = '' ){
  $this->Connection( $Sql  );
  return $this->Rest;
 }

 
 public function exists( $T = '', $F = '', $W = ''){
  if ( empty( $F ) ) { return 0; }
  $cmd = empty( $W ) ? 'Select sum(' . $F . ') as `baiyinum` from `' . $this->PreFix . $T .'`' : 'Select sum(' . $F . ') as `baiyinum` from `' . $this->PreFix . $T .'` Where ' . $W;
        $this->Connection( $cmd );
  unset( $T, $F, $W, $cmd );
  $Rel =  $this->Rest->fetch_array();
  return round( $Rel['baiyinum'], 2 );
 }

 
 public function ExistsTo( $Bili = 10000, $T = '', $F = '', $W = ''){
  if ( empty( $F ) ) { return 0; }
  $cmd = empty( $W ) ? 'Select sum(' . $F . ') as `baiyinum` from `' . $this->PreFix . $T .'`' : 'Select sum(' . $F . ') as `baiyinum` from `' . $this->PreFix . $T .'` Where ' . $W;
        $this->Connection( $cmd );
  unset( $T, $F, $W, $cmd );
  $Rel =  $this->Rest->fetch_array();
  return round( $Rel['baiyinum'] * $Bili );
 }

 
 public function Select( $Type = true, $ListNum = 1 ){ //返回记录(数组形式, 返回条数)
   $this->Select = 'Select ' . $this->Field . ' from ' . $this->Table . $this->Where . $this->Order;
   if ( is_numeric( $ListNum ) ) {
  if ( $this->PageSize > 0 ) {
   $this->Connection( $this->Select );//执行查询
   $this->PageCount =  $this->Rest->num_rows;//取得记录总数
   $this->PageNum   =  ceil($this->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 . ', ' .$this->PageSize; //重新构造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 or !is_numeric( $ListNum ) ) && !$this->PageSize) { $this->Result = $this->Result[0]; }
   $DataBase = $this->Result;
   return empty($DataBase) ? false : $DataBase;
 }

   public function Num() { //返回记录总数
     $this->Select = 'Select ' . $this->Field . ' from ' . $this->Table . $this->Where . $this->Order;
  $this->Connection( $this->Select );//执行查询
  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;
   }

   private function NumPage( $Can = '' ) { //数字分页
    $NumHtml = '';
    $First   = 1;
    $Last    = $this->PageNum;
    if ( $this->PageNum > 5 ) {
     if ( $this->PageNo < $this->PageNum ) {
     $First = $this->PageNo - 2;
     $Last  = $this->PageNo + 2;
     }else{
     $First = $this->PageNo - 4;
     $Last  = $this->PageNum;
     }
    }
    if ( $First < 1 ) { $First = 1; $Last = $First + 4;}
if ( $Last > $this->PageNum ) { $First   = $this->PageNum - 4; $Last = $this->PageNum;}
    for( $i = $First; $i <= $Last; $i++) {
$NumHtml .= $this->PageNo != $i ? "\n\t" . '' . $i . '' . "\n\t" : "\n\t" .'' . $i . '' . "\n\t";
    }
    unset($Can, $First, $i, $Last);
    return $NumHtml;
   }

   public function UserPage($NumNav = false, $PageName = 'index', $Mulu = 'user' ) {  //会员中心分页
     $NavUrl   = '/' . $Mulu . '/' . $PageName . '/' . $this->PageKey . '/';
  $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 = '') {
  $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返回True/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( $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 = '', $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 );
    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("HTTP_X_FORWARDED_FOR");
  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['REMOTE_ADDR'];
  else
    $ip = "unknown";
   return($ip);
 }

  
   //最后关闭数据库连接
   public function Close(){
    !is_object( $this -> Conn ) or mysqli_close( $this -> Conn );
   }

}

使用方法:
声明数据库对象
$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(); //The query returns all records in the user table
$Rult = $Conn -> Table(' user') -> Page(20) -> Select();//The query returns all records in the user table and displays them in pages, 20 records per page;


www.bkjia.comtruehttp: //www.bkjia.com/PHPjc/825254.htmlTechArticleCopy the code as follows: ?php /* Database operation class*/ class Mysql{ private $LocalHost = 'localhost' ; private $LoaclUser = 'root'; private $LocalPass = '123456'; private $LocalBa...
Related labels:
source:php.cn
Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Popular Tutorials
More>
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template