PHP以mysqli方式连接类完整代码实例_php技巧

本文所述的是一个在PHP中以mysqli方式连接数据库的一个数据库类实例，该数据库类是从一个PHP的CMS中整理出来的，可实现PHP连接数据库类，MySQLi版，兼容PHP4，对于有针对性需要的朋友可根据此代码进行优化和修改。

<?php
#==================================================================================================
# Filename: /db/db_mysqli.php
# Note : 连接数据库类，MySQLi版
#==================================================================================================
#[类库sql]
class db_mysqli
{
 var $query_count = 0;
 var $host;
 var $user;
 var $pass;
 var $data;
 var $conn;
 var $result;
 var $prefix = "qinggan_";
 //返回结果集类型，默认是数字+字符
 var $rs_type = MYSQLI_ASSOC;
 var $query_times = 0;#[查询时间]
 var $conn_times = 0;#[连接数据库时间]
 var $unbuffered = false;
 //定义查询列表
 var $querylist;
 var $debug = false;
 #[构造函数]
 function __construct($config=array())
 {
 $this->host = $config['host'] ? $config['host'] : 'localhost';
 $this->port = $config['port'] ? $config['port'] : '3306';
 $this->user = $config['user'] ? $config['user'] : 'root';
 $this->pass = $config['pass'] ? $config['pass'] : '';
 $this->data = $config['data'] ? $config['data'] : '';
 $this->debug = $config["debug"] ? $config["debug"] : false;
 $this->prefix = $config['prefix'] ? $config['prefix'] : 'qinggan_';
 if($this->data)
 {
  $ifconnect = $this->connect($this->data);
  if(!$ifconnect)
  {
  $this->conn = false;
  return false;
  }
 }
 return true;
 }
 #[兼容PHP4]
 function db_mysqli($config=array())
 {
 return $this->__construct($config);
 }
 #[连接数据库]
 function connect($database="")
 {
 $start_time = $this->time_used();
 if(!$this->port) $this->port = "3306";
 $this->conn = @mysqli_connect($this->host,$this->user,$this->pass,"",$this->port) or false;
 if(!$this->conn)
 {
  return false;
 }
 $version = $this->get_version();
 if($version>"4.1")
 {
  mysqli_query($this->conn,"SET NAMES 'utf8'");
  if($version>"5.0.1")
  {
  mysqli_query($this->conn,"SET sql_mode=''");
  }
 }
 $end_time = $this->time_used();
 $this->conn_times += round($end_time - $start_time,5);#[连接数据库的时间]
 $ifok = $this->select_db($database);
 return $ifok ? true : false;
 }
 function select_db($data="")
 {
 $database = $data ? $data : $this->data;
 if(!$database)
 {
  return false;
 }
 $this->data = $database;
 $start_time = $this->time_used();
 $ifok = mysqli_select_db($this->conn,$database);
 if(!$ifok)
 {
  return false;
 }
 $end_time = $this->time_used();
 $this->conn_times += round($end_time - $start_time,5);#[连接数据库的时间]
 return true;
 }
 #[关闭数据库连接，当您使用持续连接时该功能失效]
 function close()
 {
 if(is_resource($this->conn))
 {
  return mysqli_close($this->conn);
 }
 else
 {
  return true;
 }
 }
 function __destruct()
 {
 return $this->close();
 }
 function set($name,$value)
 {
 if($name == "rs_type")
 {
  $value = strtolower($value) == "num" ? MYSQLI_NUM : MYSQLI_ASSOC;
 }
 $this->$name = $value;
 }
 function query($sql)
 {
 if(!is_resource($this->conn))
 {
  $this->connect();
 }
 else
 {
  if(!mysql_ping($this->conn))
  {
   $this->close();
   $this->connect();
  }
 }
 if($this->debug)
 {
  $sqlkey = md5($sql);
  if($this->querylist)
  {
  $qlist = array_keys($this->querylist);
  if(in_array($sqlkey,$qlist))
  {
   $count = $this->querylist[$sqlkey]["count"] + 1;
   $this->querylist[$sqlkey] = array("sql"=>$sql,"count"=>$count);
  }else{
   $this->querylist[$sqlkey] = array("sql"=>$sql,"count"=>1);
  }
  }
  else{
  $this->querylist[$sqlkey] = array("sql"=>$sql,"count"=>1);
  }
 }
 $start_time = $this->time_used();
 $func = $this->unbuffered && function_exists("mysqli_multi_query") ? "mysqli_multi_query" : "mysqli_query";
 $this->result = @$func($this->conn,$sql);
 $this->query_count++;
 $end_time = $this->time_used();
 $this->query_times += round($end_time - $start_time,5);#[查询时间]
 if(!$this->result)
 {
  return false;
 }
 return $this->result;
 }
 function get_all($sql="",$primary="")
 {
 $result = $sql ? $this->query($sql) : $this->result;
 if(!$result)
 {
  return false;
 }
 $start_time = $this->time_used();
 $rs = array();
 $is_rs = false;
 while($rows = mysqli_fetch_array($result,$this->rs_type))
 {
  if($primary && $rows[$primary])
  {
  $rs[$rows[$primary]] = $rows;
  }
  else
  {
  $rs[] = $rows;
  }
  $is_rs = true;
 }
 $end_time = $this->time_used();
 $this->query_times += round($end_time - $start_time,5);#[查询时间]
 return ($is_rs ? $rs : false);
 }
 function get_one($sql="")
 {
 $start_time = $this->time_used();
 $result = $sql ? $this->query($sql) : $this->result;
 if(!$result)
 {
  return false;
 }
 $rows = mysqli_fetch_array($result,$this->rs_type);
 $end_time = $this->time_used();
 $this->query_times += round($end_time - $start_time,5);#[查询时间]
 return $rows;
 }
 function insert_id($sql="")
 {
 if($sql)
 {
  $rs = $this->get_one($sql);
  return $rs;
 }
 else
 {
  return mysqli_insert_id($this->conn);
 }
 }
 function insert($sql)
 {
 $this->result = $this->query($sql);
 $id = $this->insert_id();
 return $id;
 }
 function all_array($table,$condition="",$orderby="")
 {
 if(!$table)
 {
  return false;
 }
 $table = $this->prefix.$table;
 $sql = "SELECT * FROM ".$table;
 if($condition && is_array($condition) && count($condition)>0)
 {
  $sql_fields = array();
  foreach($condition AS $key=>$value)
  {
  $sql_fields[] = "`".$key."`='".$value."' ";
  }
  $sql .= " WHERE ".implode(" AND ",$sql_fields);
 }
 if($orderby)
 {
  $sql .= " ORDER BY ".$orderby;
 }
 $rslist = $this->get_all($sql);
 return $rslist;
 }
 function one_array($table,$condition="")
 {
 if(!$table)
 {
  return false;
 }
 $table = $this->prefix.$table;
 $sql = "SELECT * FROM ".$table;
 if($condition && is_array($condition) && count($condition)>0)
 {
  $sql_fields = array();
  foreach($condition AS $key=>$value)
  {
  $sql_fields[] = "`".$key."`='".$value."' ";
  }
  $sql .= " WHERE ".implode(" AND ",$sql_fields);
 }
 $rslist = $this->get_one($sql);
 return $rslist;
 }
 //将数组写入数据中
 function insert_array($data,$table,$insert_type="insert")
 {
 if(!$table || !is_array($data) || !$data)
 {
  return false;
 }
 $table = $this->prefix.$table;//自动增加表前缀
 if($insert_type == "insert")
 {
  $sql = "INSERT INTO ".$table;
 }
 else
 {
  $sql = "REPLACE INTO ".$table;
 }
 $sql_fields = array();
 $sql_val = array();
 foreach($data AS $key=>$value)
 {
  $sql_fields[] = "`".$key."`";
  $sql_val[] = "'".$value."'";
 }
 $sql.= "(".(implode(",",$sql_fields)).") VALUES(".(implode(",",$sql_val)).")";
 return $this->insert($sql);
 }
 //更新数据
 function update_array($data,$table,$condition)
 {
 if(!$data || !$table || !$condition || !is_array($data) || !is_array($condition))
 {
  return false;
 }
 $table = $this->prefix.$table;//自动增加表前缀
 $sql = "UPDATE ".$table." SET ";
 $sql_fields = array();
 foreach($data AS $key=>$value)
 {
  $sql_fields[] = "`".$key."`='".$value."'";
 }
 $sql.= implode(",",$sql_fields);
 $sql_fields = array();
 foreach($condition AS $key=>$value)
 {
  $sql_fields[] = "`".$key."`='".$value."' ";
 }
 $sql .= " WHERE ".implode(" AND ",$sql_fields);
 return $this->query($sql);
 }
 function count($sql="")
 {
 if($sql)
 {
  $this->rs_type = MYSQLI_NUM;
  $this->query($sql);
  $rs = $this->get_one();
  $this->rs_type = MYSQLI_ASSOC;
  return $rs[0];
 }
 else
 {
  return mysqli_num_rows($this->result);
 }
 }
 function num_fields($sql="")
 {
 if($sql)
 {
  $this->query($sql);
 }
 return mysqli_num_fields($this->result);
 }
 function list_fields($table)
 {
 $rs = $this->get_all("SHOW COLUMNS FROM ".$table);
 if(!$rs)
 {
  return false;
 }
 foreach($rs AS $key=>$value)
 {
  $rslist[] = $value["Field"];
 }
 return $rslist;
 }
 #[显示表名]
 function list_tables()
 {
 $rs = $this->get_all("SHOW TABLES");
 return $rs;
 }
 function table_name($table_list,$i)
 {
 return $table_list[$i];
 }
 function escape_string($char)
 {
 if(!$char)
 {
  return false;
 }
 return mysqli_escape_string($this->conn,$char);
 }
 function get_version()
 {
 return mysqli_get_server_info($this->conn);
 }
 function time_used()
 {
 $time = explode(" ",microtime());
 $used_time = $time[0] + $time[1];
 return $used_time;
 }
 //Mysql的查询时间
 function conn_times()
 {
 return $this->conn_times + $this->query_times;
 }
 //MySQL查询资料
 function conn_count()
 {
 return $this->query_count;
 }
 # 高效SQL生成查询，仅适合单表查询
 function phpok_one($tbl,$condition="",$fields="*")
 {
 $sql = "SELECT ".$fields." FROM ".$this->db->prefix.$tbl;
 if($condition)
 {
  $sql .= " WHERE ".$condition;
 }
 return $this->get_one($sql);
 }
 function debug()
 {
 if(!$this->querylist || !is_array($this->querylist) || count($this->querylist) < 1)
 {
  return false;
 }
 $html = '<table cellpadding="0" cellspacing="0" width="100%" bgcolor="#CECECE"><tr><td>';
 $html.= '<table cellpadding="1" cellspacing="1" width="100%">';
 $html.= '<tr><th bgcolor="#EFEFEF" height="30px">SQL</th><th bgcolor="#EFEFEF" width="80px">查询</th></tr>';
 foreach($this->querylist AS $key=>$value)
 {
  $html .= '<tr><td bgcolor="#FFFFFF"><div style="padding:3px;color:#6E6E6E;">'.$value['sql'].'</div></td>';
  $html .= '<td align="center" bgcolor="#FFFFFF"><div style="padding:3px;color:#000000;">'.$value["count"].'</div></td></tr>';
 }
 $html.= "</table>";
 $html.= "</td></tr></table>";
 return $html;
 }
 function conn_status()
 {
 if(!$this->conn) return false;
 return true;
 }
}
?>

以上是小编为您精心准备的的内容，在的博客、问答、公众号、人物、课程等栏目也有的相关内容，欢迎继续使用右上角搜索按钮进行搜索php
， 连接
mysqli
mysqli实例、vue实例完整项目源码、ztree ajax 完整实例、yii2 rbac 完整实例、jhipster 完整实例，以便于您获取更多的相关知识。

时间： 2024-11-01 21:11:54

PHP以mysqli方式连接类完整代码实例_php技巧的相关文章

php简单socket服务器客户端代码实例_php技巧

本篇文章分享一个简单的socket示例,用php.实现一个接收输入字符串,处理并返回这个字符串到客户端的TCP服务. 产生一个 socket 服务端 <?php /*文件名:socket_server.php*/ // 设置一些基本的变量 $host="127.0.0.1";//Socket运行的服务器的IP地址 $port=1234;//Socket运行的服务器的端口,端口取值为1到65535之间的数字,前提是这个端口未被使用 // 设置超时时间,这里设置为永不超时,确保PHP

PHP防盗链代码实例_php技巧

防盗链是目前非常常见的web程序设计技巧.本文就以一个实例展示了PHP防盗链的实现方法.分享给大家供大家参考之用.具体方法如下: 主要功能代码如下: <?php /* 使用方法:将上述代码保存为dao4.php, 比如测试用的validatecode.rar在站点http://www.XXXX.com里面, 则用以下代码表示下载连接. 文件名?site=1&file=文件 例如以下URL: http://www.XXXX.cn/dao4.php?site=1&file=validat

PHP中Memcache操作类及用法实例_php技巧

本文实例讲述了PHP中Memcache操作类及用法.分享给大家供大家参考.具体分析如下: 复制代码 代码如下: <?php      /*  内存缓存管理      */ class Yc_Memcache{   private $memcache=null;       public function __construct(){   }   /**      * 连接数据库      *      * @param mixed $host      * @param mixed $port 

PHP答题类应用接口实例_php技巧

本文实例讲述了PHP答题类应用接口的实现方法.分享给大家供大家参考.具体实现方法如下: question_get.php文件如下: 复制代码 代码如下: <?php  session_cache_expire(60);  session_start();  if(!isset($_SESSION['zaszh_user_id'])){      echo json_encode(array('status'=>'error','msg'=>'连接超时,请重新打开页面.'));     

php使用pdo连接mssql server数据库实例_php技巧

本文实例讲述了利用php的pdo来连接微软的mssql server数据库的方法,分享给大家供大家参考.具体实现方法如下: 复制代码 代码如下: $dsn = 'mssql:dbname=bookStore_demo;host=192.168.1.106'; $user = 'sa'; $password = '123';     //mssql_connect('192.168.1.106','sa','123');     //echo 22; try {        // echo 11

PHP多线程类及用法实例_php技巧

本文实例讲述了PHP多线程类及用法.分享给大家供大家参考.具体分析如下: 一般来说可通过WEB服务器来实现PHP多线程功能,当然,对多线程有深入理解的人都知道通过WEB服务器实现的多线程只能模仿多线程的一些效果,并不是真正意义上的多线程. 但不管怎么样,它还是能满足我们的一些需要的,在需要类似多线程的功能方面还是可以采用这个类,代码如下: 复制代码 代码如下: /** * @title: PHP多线程类(Thread) * @version: 1.0 * * PHP多线程应用示例: * requ

PHP编程中的常见漏洞和代码实例_php技巧

不是固若金汤,随着PHP的广泛运用,一些黑客们也在无时不想找PHP的麻烦,通过PHP程序漏洞进行攻击就是其中一种.在节,我们将从全局变量,远程文件,文件上载,库文件,Session文件,数据类型和容易出错的函数这几个方面分析了PHP的安全性. 如何通过全局变量进行攻击? PHP中的变量不需要事先声明,它们会在第一次使用时自动创建,它们的类型根据上下文环境自动确定.从程序员的角度来看,这无疑是一种极其方便的处理方法.一旦一个变量被创建了,就可以在程序中的任何地方使用.这个特点导致的结果就是程序员很

用PHP与XML联手进行网站编程代码实例_php技巧

一.小序  HTML简单易学又通用,一般的PHP程序就是嵌入在HTML语言之中实现的.但是随着WEB越来越广泛的应用,HTML的弱点也越来越明显了.XML的出现,弥补了这些不足,它提供了一个能够处理互联网上全部数据的通用方法. 二.HTML的局限性分析 1. HTML的可扩展性差.虽然作为一般的应用,HTML应经够用了,但是在处理数学和化学等符号时,HTML有明显的缺点,而且它无法进行扩展,这样使它的发展收到了极大的限制. 2. 链路丢失后不能自动纠正.由于Web页面的URL地址经常改变,而在改

PHP连接操作access数据库实例_php技巧

因为之前做的PingSwitch要做一个WEB展示的前端,因为一开始用了Delphi和access的结构,而Delphi与MySQL的连接又相对麻烦,最后只能选择用PHP+Access的组合,比较奇怪,但是也合理····· 在PHP中连接access数据库的话我们必须ADO来连接,这跟ASP中连接数据库非常的类似.下边给出了一段DEMO供大家参考. <?PHP /* 创建ADO连接 */ $conn = @new COM("ADODB.Connection") or die (&