本文实例讲述了PHP封装类似thinkphp连贯操作数据库Db类与简单应用。分享给大家供大家参考，具体如下：

header("Content-Type:text/html;charset=utf-8");

/**

*php操作mysql的工具类

*/

classDb{

private$_db=null;//数据库连接句柄

private$_table=null;//表名

private$_where=null;//where条件

private$_order=null;//order排序

private$_limit=null;//limit限定查询

private$_group=null;//group分组

private$_configs=array(

'hostname'=>'localhost',

'dbname'=>'test',

'username'=>'root',

'password'=>'1234'

);//数据库配置

/**

*构造函数，连接数据库

*/

publicfunction__construct(){

$link=$this->_db;

if(!$link){

$db=mysqli_connect($this->_configs['hostname'],$this->_configs['username'],$this->_configs['password'],$this->_configs['dbname']);

mysqli_query($db,"setnamesutf8");

if(!$db){

$this->ShowException("错误信息".mysqli_connect_error());

}

$this->_db=$db;

}

}

/**

*获取所有数据

*

*@param$tableThetable

*

*@returnbooleanAll.

*/

publicfunctiongetAll($table=null){

$link=$this->_db;

if(!$link)returnfalse;

$sql="SELECT*FROM{$table}";

$data=mysqli_fetch_all($this->execute($sql));

return$data;

}

publicfunctiontable($table){

$this->_table=$table;

return$this;

}

/**

*实现查询操作

*

*@paramstring$fieldsThefields

*

*@returnboolean(description_of_the_return_value)

*/

publicfunctionselect($fields="*"){

$fieldsStr='';

$link=$this->_db;

if(!$link)returnfalse;

if(is_array($fields)){

$fieldsStr=implode(',',$fields);

}elseif(is_string($fields)&&!empty($fields)){

$fieldsStr=$fields;

}

$sql="SELECT{$fields}FROM{$this->_table}{$this->_where}{$this->_order}{$this->_limit}";

$data=mysqli_fetch_all($this->execute($sql));

return$data;

}

/**

*order排序

*

*@paramstring$orderTheorder

*

*@returnboolean(description_of_the_return_value)

*/

publicfunctionorder($order=''){

$orderStr='';

$link=$this->_db;

if(!$link)returnfalse;

if(is_string($order)&&!empty($order)){

$orderStr="ORDERBY".$order;

}

$this->_order=$orderStr;

return$this;

}

/**

*where条件

*

*@paramstring$whereThewhere

*

*@return(description_of_the_return_value)

*/

publicfunctionwhere($where=''){

$whereStr='';

$link=$this->_db;

if(!$link)return$link;

if(is_array($where)){

foreach($whereas$key=>$value){

if($value==end($where)){

$whereStr.="`".$key."`='".$value."'";

}else{

$whereStr.="`".$key."`='".$value."'AND";

}

}

$whereStr="WHERE".$whereStr;

}elseif(is_string($where)&&!empty($where)){

$whereStr="WHERE".$where;

}

$this->_where=$whereStr;

return$this;

}

/**

*group分组

*

*@paramstring$groupThegroup

*

*@returnboolean(description_of_the_return_value)

*/

publicfunctiongroup($group=''){

$groupStr='';

$link=$this->_db;

if(!$link)returnfalse;

if(is_array($group)){

$groupStr="GROUPBY".implode(',',$group);

}elseif(is_string($group)&&!empty($group)){

$groupStr="GROUPBY".$group;

}

$this->_group=$groupStr;

return$this;

}

/**

*limit限定查询

*

*@paramstring$limitThelimit

*

*@return(description_of_the_return_value)

*/

publicfunctionlimit($limit=''){

$limitStr='';

$link=$this->_db;

if(!$link)return$link;

if(is_string($limit)||!empty($limit)){

$limitStr="LIMIT".$limit;

}elseif(is_numeric($limit)){

$limitStr="LIMIT".$limit;

}

$this->_limit=$limitStr;

return$this;

}

/**

*执行sql语句

*

*@param$sqlThesql

*

*@returnboolean(description_of_the_return_value)

*/

publicfunctionexecute($sql=null){

$link=$this->_db;

if(!$link)returnfalse;

$res=mysqli_query($this->_db,$sql);

if(!$res){

$errors=mysqli_error_list($this->_db);

$this->ShowException("报错啦！
错误号：".$errors[0]['errno']."
SQL错误状态：".$errors[0]['sqlstate']."
错误信息：".$errors[0]['error']);

die();

}

return$res;

}

/**

*插入数据

*

*@param$dataThedata

*

*@returnboolean(description_of_the_return_value)

*/

publicfunctioninsert($data){

$link=$this->_db;

if(!$link)returnfalse;

if(is_array($data)){

$keys='';

$values='';

foreach($dataas$key=>$value){

$keys.="`".$key."`,";

$values.="'".$value."',";

}

$keys=rtrim($keys,',');

$values=rtrim($values,',');

}

$sql="INSERTINTO`{$this->_table}`({$keys})VALUES({$values})";

mysqli_query($this->_db,$sql);

$insertId=mysqli_insert_id($this->_db);

return$insertId;

}

/**

*更新数据

*

*@param$dataThedata

*

*@return(description_of_the_return_value)

*/

publicfunctionupdate($data){

$link=$this->_db;

if(!$link)return$link;

if(is_array($data)){

$dataStr='';

foreach($dataas$key=>$value){

$dataStr.="`".$key."`='".$value."',";

}

$dataStr=rtrim($dataStr,',');

}

$sql="UPDATE`{$this->_table}`SET{$dataStr}{$this->_where}{$this->_order}{$this->_limit}";

$res=$this->execute($sql);

return$res;

}

/**

*删除数据

*

*@return(description_of_the_return_value)

*/

publicfunctiondelete(){

$link=$this->_db;

if(!$link)return$link;

$sql="DELETEFROM`{$this->_table}`{$this->_where}";

$res=$this->execute($sql);

return$res;

}

/**

*异常信息输出

*

*@param$varThevariable

*/

privatefunctionShowException($var){

if(is_bool($var)){

var_dump($var);

}elseif(is_null($var)){

var_dump(NULL);

}else{

echo"".print_r($var,true)."";

}

}

}

$db=newDb();

//查询操作

var_dump($db->table('user')->where('id>2')->order('iddesc')->limit('2,4')->select());

//插入操作

var_dump($db->table('user')->insert(array('username'=>'user','password'=>'pwd')));

//更新操作

var_dump($db->table('user')->where('id=1')->update(array('username'=>'user1','password'=>'pwd1')));

//删除操作

var_dump($db->table('user')->where('id=1')->delete());

更多关于PHP相关内容感兴趣的读者可查看本站专题：《php+mysqli数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《PHP数组(Array)操作技巧大全》、《PHP基本语法入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

希望本文所述对大家PHP程序设计有所帮助。

您可能感兴趣的文章:PHP实现的连贯操作、链式操作实例PHP简单数据库操作类实例【支持增删改查及链式操作】PHP三种方式实现链式操作详解PHP对象链式操作实现原理分析PHP实现链式操作的核心思想PHP实现链式操作的原理详解PHP实现链式操作的三种方法详解php类自动装载、链式操作、魔术方法实现代码thinkPHP5框架数据库连贯操作之cache()用法分析thinkphp连贯操作实例分析php链式操作的实现方式分析