PHP DB 数据库连接类定义与用法示例
本文实例讲述了PHPDB数据库连接类定义与用法。分享给大家供大家参考，具体如下：
声明：
近期观看了一节PHP消息队列视频，对于讲师WiconWang提供的代码，在此分享一下，希望能对爱学习的小伙伴有所帮助…
host='localhost';
$this->port='3306';
$this->user='root';
$this->pass='root';
$this->db='imooc';
$this->charset='utf8';
//连接数据库
$this->db_connect();
//选择数据库
$this->db_usedb();
//设置字符集
$this->db_charset();
}
//连接数据库
privatefunctiondb_connect(){
$this->link=mysqli_connect($this->host.':'.$this->port,$this->user,$this->pass);
if(!$this->link){
echo"数据库连接失败
";
echo"错误编码".mysqli_errno($this->link)."
";
echo"错误信息".mysqli_error($this->link)."
";
exit;
}
}
//设置字符集
privatefunctiondb_charset(){
mysqli_query($this->link,"setnames{$this->charset}");
}
//选择数据库
privatefunctiondb_usedb(){
mysqli_query($this->link,"use{$this->db}");
}
//私有的克隆
privatefunction__clone(){
die('cloneisnotallowed');
}
//公用的静态方法
publicstaticfunctiongetIntance(){
if(self::$dbcon==false){
self::$dbcon=newself;
}
returnself::$dbcon;
}
//执行sql语句的方法
publicfunctionquery($sql){
$res=mysqli_query($this->link,$sql);
if(!$res){
echo"sql语句执行失败
";
echo"错误编码是".mysqli_errno($this->link)."
";
echo"错误信息是".mysqli_error($this->link)."
";
}
return$res;
}
//获得最后一条记录id
publicfunctiongetInsertid(){
returnmysqli_insert_id($this->link);
}
/**
*查询某个字段
*@param
*@returnstringorint
*/
publicfunctiongetOne($sql){
$query=$this->query($sql);
returnmysqli_free_result($query);
}
//获取一行记录,returnarray一维数组
publicfunctiongetRow($sql,$type="assoc"){
$query=$this->query($sql);
if(!in_array($type,array("assoc",'array',"row"))){
die("mysqli_queryerror");
}
$funcname="mysqli_fetch_".$type;
return$funcname($query);
}
//获取一条记录,前置条件通过资源获取一条记录
publicfunctiongetFormSource($query,$type="assoc"){
if(!in_array($type,array("assoc","array","row")))
{
die("mysqli_queryerror");
}
$funcname="mysqli_fetch_".$type;
return$funcname($query);
}
//获取多条数据，二维数组
publicfunctiongetAll($sql){
$query=$this->query($sql);
$list=array();
while($r=$this->getFormSource($query)){
$list[]=$r;
}
return$list;
}
publicfunctionselectAll($table,$where,$fields='*',$order='',$skip=0,$limit=1000)
{
if(is_array($where)){
foreach($whereas$key=>$val){
if(is_numeric($val)){
$condition=$key.'='.$val;
}else{
$condition=$key.'=\"'.$val.'\"';
}
}
}else{
$condition=$where;
}
if(!empty($order)){
$order="orderby".$order;
}
$sql="select$fieldsfrom$tablewhere$condition$orderlimit$skip,$limit";
$query=$this->query($sql);
$list=array();
while($r=$this->getFormSource($query)){
$list[]=$r;
}
return$list;
}
/**
*定义添加数据的方法
*@paramstring$table表名
*@paramstringorarray$data[数据]
*@returnint最新添加的id
*/
publicfunctioninsert($table,$data){
//遍历数组，得到每一个字段和字段的值
$key_str='';
$v_str='';
foreach($dataas$key=>$v){
//if(empty($v)){
//die("error");
//}
//$key的值是每一个字段s一个字段所对应的值
$key_str.=$key.',';
$v_str.="'$v',";
}
$key_str=trim($key_str,',');
$v_str=trim($v_str,',');
//判断数据是否为空
$sql="insertinto$table($key_str)values($v_str)";
$this->query($sql);
//返回上一次增加操做产生ID值
return$this->getInsertid();
}
/*
*删除一条数据方法
*@param1$table,$where=array('id'=>'1')表名条件
*@return受影响的行数
*/
publicfunctiondeleteOne($table,$where){
if(is_array($where)){
foreach($whereas$key=>$val){
$condition=$key.'='.$val;
}
}else{
$condition=$where;
}
$sql="deletefrom$tablewhere$condition";
$this->query($sql);
//返回受影响的行数
returnmysqli_affected_rows($this->link);
}
/*
*删除多条数据方法
*@param1$table,$where表名条件
*@return受影响的行数
*/
publicfunctiondeleteAll($table,$where){
if(is_array($where)){
foreach($whereas$key=>$val){
if(is_array($val)){
$condition=$key.'in('.implode(',',$val).')';
}else{
$condition=$key.'='.$val;
}
}
}else{
$condition=$where;
}
$sql="deletefrom$tablewhere$condition";
$this->query($sql);
//返回受影响的行数
returnmysqli_affected_rows($this->link);
}
/**
*[修改操作description]
*@param[type]$table[表名]
*@param[type]$data[数据]
*@param[type]$where[条件]
*@return[type]
*/
publicfunctionupdate($table,$data,$where,$limit=0){
//遍历数组，得到每一个字段和字段的值
$str='';
foreach($dataas$key=>$v){
$str.="$key='$v',";
}
$str=rtrim($str,',');
if(is_array($where)){
foreach($whereas$key=>$val){
if(is_array($val)){
$condition=$key.'in('.implode(',',$val).')';
}else{
$condition=$key.'='.$val;
}
}
}else{
$condition=$where;
}
if(!empty($limit)){
$limit="limit".$limit;
}else{
$limit='';
}
//修改SQL语句
$sql="update$tableset$strwhere$condition$limit";
$this->query($sql);
//返回受影响的行数
returnmysqli_affected_rows($this->link);
}
}
?>
使用方法
- 对DB类中__construct()中的配置信息，进行符合自己数据库的修改
- include引入DB类
- 使用DB类中的方法需要先进行实例化，以插入数据为例：
$db=DB::getIntance();
$insert_data=['order_id'=>'10010','order_amount'='200.00','status'=>1];
$res=$db->insert('order_info',$insert_data);
更多关于PHP相关内容感兴趣的读者可查看本站专题：《php+mysqli数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《PHP数组(Array)操作技巧大全》、《PHP基本语法入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。