ホームページ バックエンド開発 PHPチュートリアル PHP以mysqli方式连接类完整代码实例_php技巧

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

May 16, 2016 pm 08:39 PM
mysqli php 接続する

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

<&#63;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'] &#63; $config['host'] : 'localhost';
 $this->port = $config['port'] &#63; $config['port'] : '3306';
 $this->user = $config['user'] &#63; $config['user'] : 'root';
 $this->pass = $config['pass'] &#63; $config['pass'] : '';
 $this->data = $config['data'] &#63; $config['data'] : '';
 $this->debug = $config["debug"] &#63; $config["debug"] : false;
 $this->prefix = $config['prefix'] &#63; $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 &#63; true : false;
 }
 function select_db($data="")
 {
 $database = $data &#63; $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" &#63; 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") &#63; "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 &#63; $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 &#63; $rs : false);
 }
 function get_one($sql="")
 {
 $start_time = $this->time_used();
 $result = $sql &#63; $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;
 }
}
&#63;>
ログイン後にコピー
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。

ホットな記事タグ

メモ帳++7.3.1

メモ帳++7.3.1

使いやすく無料のコードエディター

SublimeText3 中国語版

SublimeText3 中国語版

中国語版、とても使いやすい

ゼンドスタジオ 13.0.1

ゼンドスタジオ 13.0.1

強力な PHP 統合開発環境

ドリームウィーバー CS6

ドリームウィーバー CS6

ビジュアル Web 開発ツール

SublimeText3 Mac版

SublimeText3 Mac版

神レベルのコード編集ソフト(SublimeText3)

Ubuntu および Debian 用の PHP 8.4 インストールおよびアップグレード ガイド Ubuntu および Debian 用の PHP 8.4 インストールおよびアップグレード ガイド Dec 24, 2024 pm 04:42 PM

Ubuntu および Debian 用の PHP 8.4 インストールおよびアップグレード ガイド

CakePHP の日付と時刻 CakePHP の日付と時刻 Sep 10, 2024 pm 05:27 PM

CakePHP の日付と時刻

CakePHP ファイルのアップロード CakePHP ファイルのアップロード Sep 10, 2024 pm 05:27 PM

CakePHP ファイルのアップロード

CakePHP ルーティング CakePHP ルーティング Sep 10, 2024 pm 05:25 PM

CakePHP ルーティング

CakePHP プロジェクトの構成 CakePHP プロジェクトの構成 Sep 10, 2024 pm 05:25 PM

CakePHP プロジェクトの構成

CakePHP について話し合う CakePHP について話し合う Sep 10, 2024 pm 05:28 PM

CakePHP について話し合う

CakePHP クイックガイド CakePHP クイックガイド Sep 10, 2024 pm 05:27 PM

CakePHP クイックガイド

PHP 開発用に Visual Studio Code (VS Code) をセットアップする方法 PHP 開発用に Visual Studio Code (VS Code) をセットアップする方法 Dec 20, 2024 am 11:31 AM

PHP 開発用に Visual Studio Code (VS Code) をセットアップする方法

See all articles