已安装mysql数据库；
检查php环境是否已开启mysql扩展（一般情况下是开启的）；
检查方法：a.使用phpinfo()函数，看有没有mysql项；b.打开php.ini文件，检查php_mysql.dll前分号是否已取掉。
php链接代码如下：
<?php
//设置编码格式
header("Content-type:text/htmlcharset=utf-8")
//定义数据库主机地址
$host="localhost"
//定义mysql数据库登录用户名
$user="root"
//定义mysql数据库登录密码
$pwd=""
//链接数据库
$conn = mysql_connect($host,$user,$pwd)
//对连接进行判断
if(!$conn){
die("数据库连接失败！".mysql_errno())
}else{
echo "数据库连接成功！"
}
?>
本文所述的是一个在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:3pxcolor:#6E6E6E">'.$value['sql'].'</div></td>'
$html .= '<td align="center" bgcolor="#FFFFFF"><div style="padding:3pxcolor:#000000">'.$value["count"].'</div></td></tr>'
}
$html.= "</table>"
$html.= "</td></tr></table>"
return $html
}
function conn_status()
{
if(!$this->conn) return false
return true
}
}
?>
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）