PHP DB 数据库连接类定义与用法介绍

发布时间：2022-07-27 11:49:54 所属栏目：PHP教程来源：互联网

导读：这篇文章主要介绍了PHP DB 数据库连接类定义与用法,涉及php基于mysqli针对数据库的连接、增删改查等常见操作封装与使用技巧,需要的朋友可以参考下。本文实例讲述了PHP DB 数据库连接类定义与用法，分享给大家供大家参考，具体如下：声明：近期观看了一节

这篇文章主要介绍了PHP DB 数据库连接类定义与用法,涉及php基于mysqli针对数据库的连接、增删改查等常见操作封装与使用技巧,需要的朋友可以参考下。

　　本文实例讲述了PHP DB 数据库连接类定义与用法，分享给大家供大家参考，具体如下：

　　声明：

　　近期观看了一节 PHP 消息队列视频，对于讲师WiconWang提供的代码，在此分享一下，希望能对爱学习的小伙伴有所帮助…

　　<?php
　　// 数据库连接类
　　class DB{
　　 //私有的属性
　　 private static $dbcon=false;
　　 private $host;
　　 private $port;
　　 private $user;
　　 private $pass;
　　 private $db;
　　 private $charset;
　　 private $link;
　　 //私有的构造方法
　　 private function __construct(){
　　 $this->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();
　　 }
　　 //连接数据库
　　 private function db_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;
　　 }
　　 }
　　 //设置字符集
　　 private function db_charset(){
　　 mysqli_query($this->link,"set names {$this->charset}");
　　 }
　　 //选择数据库
　　 private function db_usedb(){
　　 mysqli_query($this->link,"use {$this->db}");
　　 }
　　 //私有的克隆
　　 private function __clone(){
　　 die('clone is not allowed');
　　 }
　　 //公用的静态方法
　　 public static function getIntance(){
　　 if(self::$dbcon==false){
　　 self::$dbcon=new self;
　　 }
　　 return self::$dbcon;
　　 }
　　 //执行sql语句的方法
　　 public function query($sql){
　　 $res=mysqli_query($this->link,$sql);
　　 if(!$res){
　　 echo "sql语句执行失败 ";
　　 echo "错误编码是".mysqli_errno($this->link)." ";
　　 echo "错误信息是".mysqli_error($this->link)." ";
　　 }
　　 return $res;
　　 }
　　 //获得最后一条记录id
　　 public function getInsertid(){
　　 return mysqli_insert_id($this->link);
　　 }
　　 /**
　　 * 查询某个字段
　　 * @param
　　 * @return string or int
　　 */
　　 public function getOne($sql){
　　 $query=$this->query($sql);
　　 return mysqli_free_result($query);
　　 }
　　 //获取一行记录,return array 一维数组
　　 public function getRow($sql,$type="assoc"){
　　 $query=$this->query($sql);
　　 if(!in_array($type,array("assoc",'array',"row"))){
　　 die("mysqli_query error");
　　 }
　　 $funcname="mysqli_fetch_".$type;
　　 return $funcname($query);
　　 }
　　 //获取一条记录,前置条件通过资源获取一条记录
　　 public function getFormSource($query,$type="assoc"){
　　 if(!in_array($type,array("assoc","array","row")))
　　 {
　　 die("mysqli_query error");
　　 }
　　 $funcname="mysqli_fetch_".$type;
　　 return $funcname($query);
　　 }
　　 //获取多条数据，二维数组
　　 public function getAll($sql){
　　 $query=$this->query($sql);
　　 $list=array();
　　 while ($r=$this->getFormSource($query)) {
　　 $list[]=$r;
　　 }
　　 return $list;
　　 }
　　 public function selectAll($table,$where,$fields='*',$order='',$skip=0,$limit=1000)
　　 {
　　 if(is_array($where)){
　　 foreach ($where as $key => $val) {
　　 if (is_numeric($val)) {
　　 $condition = $key.'='.$val;
　　 }else{
　　 $condition = $key.'="'.$val.'"';
　　 }
　　 }
　　 } else {
　　 $condition = $where;
　　 }
　　 if (!emptyempty($order)) {
　　 $order = " order by ".$order;
　　 }
　　 $sql = "select $fields from $table where $condition $order limit $skip,$limit";
　　 $query = $this->query($sql);
　　 $list = array();
　　 while ($r= $this->getFormSource($query)) {
　　 $list[] = $r;
　　 }
　　 return $list;
　　 }
　　 /**
　　 * 定义添加数据的方法
　　 * @param string $table 表名
　　 * @param string orarray $data [数据]
　　 * @return int 最新添加的id
　　 */
　　 public function insert($table,$data){
　　 //遍历数组，得到每一个字段和字段的值
　　 $key_str='';
　　 $v_str='';
　　 foreach($data as $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="insert into $table ($key_str) values ($v_str)";
　　 $this->query($sql);
　　 //返回上一次增加操做产生ID值
　　 return $this->getInsertid();
　　 }
　　 /*
　　 * 删除一条数据方法
　　 * @param1 $table, $where=array('id'=>'1') 表名条件
　　 * @return 受影响的行数
　　 */
　　 public function deleteOne($table, $where){
　　 if(is_array($where)){
　　 foreach ($where as $key => $val) {
　　 $condition = $key.'='.$val;
　　 }
　　 } else {
　　 $condition = $where;
　　 }
　　 $sql = "delete from $table where $condition";
　　 $this->query($sql);
　　 //返回受影响的行数
　　 return mysqli_affected_rows($this->link);
　　 }
　　 /*
　　 * 删除多条数据方法
　　 * @param1 $table, $where 表名条件
　　 * @return 受影响的行数
　　 */
　　 public function deleteAll($table, $where){
　　 if(is_array($where)){
　　 foreach ($where as $key => $val) {
　　 if(is_array($val)){
　　 $condition = $key.' in ('.implode(',', $val) .')';
　　 } else {
　　 $condition = $key. '=' .$val;
　　 }
　　 }
　　 } else {
　　 $condition = $where;
　　 }
　　 $sql = "delete from $table where $condition";
　　 $this->query($sql);
　　 //返回受影响的行数
　　 return mysqli_affected_rows($this->link);
　　 }
　　 /**
　　 * [修改操作description]
　　 * @param [type] $table [表名]
　　 * @param [type] $data [数据]
　　 * @param [type] $where [条件]
　　 * @return [type]
　　 */
　　 public function update($table,$data,$where,$limit=0){
　　 //遍历数组，得到每一个字段和字段的值
　　 $str='';
　　 foreach($data as $key=>$v){
　　 $str.="$key='$v',";
　　 }
　　 $str=rtrim($str,',');
　　 if(is_array($where)){
　　 foreach ($where as $key => $val) {
　　 if(is_array($val)){
　　 $condition = $key.' in ('.implode(',', $val) .')';
　　 } else {
　　 $condition = $key. '=' .$val;
　　 }

（编辑：我爱故事小小网_铜陵站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!

php提前判断远程文件是	php include与require
KindEditor编辑器调用	php中的观察者模式简单