可实现PHP连接数据库类

  • 栏目:编程 时间:2020-05-08 08:28
<返回列表

php经典分页类

分享一个PHP以mysqli方式连接类完整代码实例,有关mysqli用法实例。

?phpclass db{public $conn,$db,$table,$user,$host,$unm,$pwd;public $res;public $char;public $linkType;function __construct($linkType=false,$char=gb2312){ $this-linkType=$linkType;//设定连接类型 $this-char=$char;//设定连接校对字符 $this-db=DB; $this-user=USER; $this-host=HOST; $this-unm=UNM; $this-pwd=PWD; if($this-linkType) { $this-conn=mysql_pconnect($this-host,$this-unm,$this-pwd) or die(Database connection failure); } else { $this-conn=mysql_connect($this-host,$this-unm,$this-pwd) or die(Database connection failure); } mysql_select_db($this-db); mysql_query(set names .$this-char); }function query($sql,$type=true){ //$type:默认的操作。 指代select操作 $this-res=mysql_query($sql) or die(SQL Statement error !Please check it again); $row=$type?mysql_num_rows($this-res):mysql_affected_rows(); $result[res]=$this-res; $result[row]=$row; return $result;}//fetch()方法:获取所有的记录,并写入数组function fetch($sql){ $res=self::query($sql); while ($rs=mysql_fetch_array($res[res])) { $result[]=$rs; } return $result;}//获取下一条记录function fetchNext($filed,$currenID,$table){ $sql=select * from $table where $filed$currenID limit 0,1 ; return self::fetch($sql);}//获取前一条记录function fetchPre($filed,$currenID,$table){ $sql=select * from $table where $filed$currenID limit 0,1 ; return self::fetch($sql);} }class page extends db {public $currentPage,$totalRecord,$totalPage,$pageSize;public $start;public $flag;public $sql;function __construct($sql,$pagesize=5,$flag=page){ $this-sql=$sql; $this-pageSize=$pagesize; $this-flag=$flag;//设定翻页链接标识符 $row=parent::query($sql); $this-totalRecord=$row[row]; $this-totalPage=ceil($this-totalRecord/$this-pageSize); $page=$_REQUEST[$this-flag]; if($page0||$page==) { $this-currentPage=1; } else { $page$this-totalPage?$this-currentPage=$this-totalPage:$this-currentPage=$page; } $this-start=($this-currentPage-1)*$this-pageSize; }//显示分页列表function show($page=10){ $str.='div class=pages_btnsdiv class=pages'; $str.=em .$this-totalRecord. /em; $pre=$this-currentPage-1; if($pre!=0) { $str.='a href=?'.$this-flag.'='.$pre.' class=next/a'; } if($this-currentPage=$page) { if($this-totalPage-$this-currentPage10) { $start=$this-currentPage-($this-currentPage%10); $end=$this-totalPage; } else { $start=$this-currentPage-2; $end=$start+$page-1; } } else { $start=1; $end=10; } for ($i=$start;$i=$end;$i++) { if($i==$this-currentPage) { $str.=strong.$i./strong; } else { $str.=a href=?.$this-flag.=$i$i/a; } } $next=$this-currentPage+1; $str.='a href=?'.$this-flag.'='.$next.' class=next/a'; $str.=a href=?.$this-flag.=.$this-totalPage. class=last....$this-totalPage./a; $str.=kbdinput type='text' name='custompage' size='3' onkeydown=/if(event.keyCode==13) {window.location='{$_SERVER['PHP_SELF']}?{$this-flag}='+this.value; return false;}/ //kbd; $str.=/div/div; return $str;}}??phpdefine(HOST,localhost);define(UNM,root);define(PWD,root);define(DB,test);require_once('db.class.php');$db=new db();$sql=select * from yy; $page=new page($sql,10); $sql.= limit $page-start,$page-pageSize;$rs = $db-fetch($sql);?table width=100% border=0 cellpadding=0 cellspacing=1 bgcolor=#FF0000 tr td height=25 bgcolor=#FFFFFFID/td td bgcolor=#FFFFFFUNM/td /tr ?php for($i=0;$icount($rs);$i++) { ? tr td height=25 bgcolor=#FFFFFF?=$rs[$i][0]?/td td bgcolor=#FFFFFF?=$rs[$i][1]?/td /tr ?php } ? tr td height=25 colspan=2 bgcolor=#FFFFFF?=$page-show()?/td /tr/table

一个在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))
{ (脚本学堂 www.jbxue.com)
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入门:保存数据到数据库 下一篇:没有了

更多阅读

可实现PHP连接数据库类

编程 2020-05-08
php经典分页类 分享一个PHP以mysqli方式连接类完整代码实例,有关mysqli用法实例。 ?phpclass db{pub...
查看全文

php入门:保存数据到数据库

编程 2020-05-06
?phpinclude(inc/connect.php);//数据库连接include(inc/base_function.php);//这里有get_value函数$buy=get_value...
查看全文

并会发送上述的错误消息之一,一旦脚本

编程 2020-05-06
本文讨论的是如何彻底杜绝warning: Cannot add header information - headersalready sent in......这种令人莫明...
查看全文

友情链接: 网站地图

Copyright © 2015-2019 http://www.koi-bumi.com. 韦德体育有限公司 版权所有