首先，将代码保存到一个文件，如：mysql.class.php
其次，在一个常用的文件里调用：比如头部文件header.php,因为我放在根目录所以用下面方式导入其他文件：
require dirname(__FILE__) . 'include/config.php'
//导入类文件
require dirname(__FILE__) . 'include/mysql.class.php'
//定义一个类及初始化数据库类
$db = new mysql($db_host, $db_user, $db_pass, $db_name)
$db_host = $db_user = $db_pass = $db_name = NULL
然后，在test.php文件调用：
require_once dirname(__FILE__) . '/header.php'
使用方法：
$sql = "读取表"
$res = $db->query($sql)
$info = array()//定义数组
while($row=$db->fetchRow($res))
{
$arr['id'] = $row['id']
$arr['title'] = $row['title']
$info[] = $arr
}
可以在显示的地方用：
foreach($info as $i)
{
echo $i['title']."<br />"
}
或是直接使用while
还用另一种调用方式：
$here_area = $db->getRow("select areaid,areaname from {$table}area where areaid='$areaid'")
$here[] = array('name'=>$here_area['areaname'],'id'=>$here_area['areaid'])
测试通过，因为我正在使用.....................................
config.php代码：
<?php
$db_host = "localhost"
$db_name = "test"
$db_user = "root"
$db_pass = ""
$table = "mini_"
$charset = "gb2312"
$dbcharset = "gbk"
?>
mysql.class.php代码：
<?php
class mysql
{
var $link= NULL
//自动执行__construct php5类构建方法，如果PHP4和PHP5同时使用会自动使用PHP5的方法
function __construct($dbhost, $dbuser, $dbpw, $dbname = '', $pconnect = 0, $quiet = 0)
{
//自动执行时调用mysql函数
$this->mysql($dbhost, $dbuser, $dbpw, $dbname, $pconnect, $quiet)
}
//php4类构建方法，如果没有 __construct 就自动执行此功能
function mysql($dbhost, $dbuser, $dbpw, $dbname = '', $pconnect = 0, $quiet = 0)
{
if ($quiet)
{
$this->connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect, $quiet)
}
else
{
$this->settings = array(
'dbhost' =>$dbhost,
'dbuser' =>$dbuser,
'dbpw' =>$dbpw,
'dbname' =>$dbname,
'charset' =>$charset,
'pconnect' =>$pconnect
)
}
}
function connect($dbhost, $dbuser, $dbpw, $dbname = '', $pconnect = 0, $quiet = 0)
{
global $dbcharset
if ($pconnect)
{
if (!($this->link = @mysql_pconnect($dbhost, $dbuser, $dbpw)))
{
if (!$quiet)
{
$this->ErrorMsg("Can't pConnect MySQL Server($dbhost)!")
}
return false
}
}
else
{
if (PHP_VERSION >= '4.2')
{
$this->link = @mysql_connect($dbhost, $dbuser, $dbpw, true)
}
else
{
$this->link = @mysql_connect($dbhost, $dbuser, $dbpw)
mt_srand((double)microtime() * 1000000)
}
if (!$this->link)
{
if (!$quiet)
{
$this->ErrorMsg("Can't Connect MySQL Server($dbhost)!")
}
return false
}
}
$this->dbhash = md5($this->root_path . $dbhost . $dbuser . $dbpw . $dbname)
$this->version = mysql_get_server_info($this->link)
if ($this->version >'4.1')
{
if ($dbcharset != 'latin1')
{
mysql_query("SET character_set_connection=$dbcharset, character_set_results=$dbcharset, character_set_client=binary", $this->link)
}
if ($this->version >'5.0.1')
{
mysql_query("SET sql_mode=''", $this->link)
}
}
if ($dbname)
{
if (mysql_select_db($dbname, $this->link) === false )
{
if (!$quiet)
{
$this->ErrorMsg("Can't select MySQL database($dbname)!")
}
return false
}
else
{
return true
}
}
else
{
return true
}
}
function query($sql, $type = '')
{
if ($this->link === NULL)
{
$this->connect($this->settings['dbhost'], $this->settings['dbuser'], $this->settings['dbpw'], $this->settings['dbname'], $this->settings['charset'], $this->settings['pconnect'])
$this->settings = array()
}
if ($this->queryCount++ <= 99)
{
$this->queryLog[] = $sql
}
if ($this->queryTime == '')
{
if (PHP_VERSION >= '5.0.0')
{
$this->queryTime = microtime(true)
}
else
{
$this->queryTime = microtime()
}
}
if (!($query = mysql_query($sql, $this->link)) &&$type != 'SILENT')
{
$this->error_message[]['message'] = 'MySQL Query Error'
$this->error_message[]['sql'] = $sql
$this->error_message[]['error'] = mysql_error($this->link)
$this->error_message[]['errno'] = mysql_errno($this->link)
$this->ErrorMsg()
return false
}
return $query
}
function affected_rows()
{
return mysql_affected_rows($this->link)
}
function num_fields($query)
{
return mysql_num_fields($query)
}
function error()
{
return mysql_error($this->link)
}
function errno()
{
return mysql_errno($this->link)
}
function num_rows($query)
{
return mysql_num_rows($query)
}
function insert_id()
{
return mysql_insert_id($this->link)
}
function fetchRow($query)
{
return mysql_fetch_assoc($query)
}
function fetcharray($query)
{
return mysql_fetch_array($query)
}
function version()
{
return $this->version
}
function close()
{
return mysql_close($this->link)
}
function ErrorMsg($message = '', $sql = '')
{
if ($message)
{
echo "$message\n\n"
}
else
{
echo "<b>MySQL server error report:"
print_r($this->error_message)
}
exit
}
function getCol($sql)
{
$res = $this->query($sql)
if ($res !== false)
{
$arr = array()
while ($row = mysql_fetch_row($res))
{
$arr[] = $row[0]
}
return $arr
}
else
{
return false
}
}
function getOne($sql, $limited = false)
{
if ($limited == true)
{
$sql = trim($sql . ' LIMIT 1')
}
$res = $this->query($sql)
if ($res !== false)
{
$row = mysql_fetch_row($res)
if ($row !== false)
{
return $row[0]
}
else
{
return ''
}
}
else
{
return false
}
}
function getAll($sql)
{
$res = $this->query($sql)
if ($res !== false)
{
$arr = array()
while ($row = mysql_fetch_assoc($res))
{
$arr[] = $row
}
return $arr
}
else
{
return false
}
}
//使用： getRow($sql,true) 如果有true那值是 limit 1,读取一条信息
function getRow($sql, $limited = false)
{
if ($limited == true)
{
$sql = trim($sql . ' LIMIT 1')
}
$res = $this->query($sql)
if ($res !== false)
{
return mysql_fetch_assoc($res)
}
else
{
return false
}
}
}
?>
常规方式
常规方式就是按部就班的读取文件了。其余的话和上述方案一致。
// 读取配置文件内容
$handle = fopen("filepath", "r") $content = fread($handle, filesize("filepath"))123
PHP解析XML
上述两种读取文件，其实都是为了PHP解析XML来做准备的。关于PHP解析XML的方式的博客有很多。方式也有很多，像simplexml，XMLReader，DOM啦等等。但是对于比较小型的xml配置文件，simplexml就足够了。
配置文件
<?xml version="1.0" encoding="UTF-8" ?><mysql>
<!-- 为防止出现意外，请按照此标准顺序书写.其实也无所谓了 -->
<host>localhost</host>
<user>root</user>
<password>123456</password>
<db>test</db>
<port>3306</port></mysql>12345678910
解析
<?php/**
* 作为解析XML配置文件必备工具
*/class XMLUtil {
public static $dbconfigpath = "./db.config.xml" public static function getDBConfiguration() {
$dbconfig = array () try { // 读取配置文件内容
$handle = fopen(self::$dbconfigpath, "r") $content = fread($handle, filesize(self::$dbconfigpath)) // 获取xml文档根节点，进而获取相关的数据库信息
$mysql = simplexml_load_string($content) // 将获取到的xml节点信息赋值给关联数组，方便接下来的方法调用
$dbconfig['host'] = $mysql->host $dbconfig['user'] = $mysql->user $dbconfig['password'] = $mysql->password $dbconfig['db'] = $mysql->db $dbconfig['port'] = $mysql->port // 将配置信息以关联数组的形式返回
return $dbconfig
} catch ( Exception $e ) { throw new RuntimeException ( "<mark>读取数据库配置文件信息出错！</mark><br />" )
} return $dbconfig
}
}1234567891011121314151617181920212223242526272829
数据库连接池
对于PHP程序而言，优化永无止境。而数据库连接池就在一定程度上起到了优化的作用。其使得对用户的每一个请求而言，无需每次都像数据库申请链接资源。而是通过已存在的数据库连接池中的链接来返回，从时间上，效率上，都是一个大大的提升。
于是，这里简单的模拟了一下数据库连接池的实现。核心在于维护一个“池”。
从池子中取，用毕，归还给池子。
<?php/**x
* PHP中的数据库 工具类设计
* 郭璞
* 2016年12月23日
*
**/class DbHelper { private $dbconfig private $dbpool public $poolsize public function __construct($poolsize = 20) { if (! file_exists ( "./utils.php" )) { throw new RuntimeException ( "<mark>utils.php文件丢失，无法进行配置文件的初始化 *** 作！</mark><br />" )
}else {
require './utils.php'
} // 初始化 配置文件信息
$this->dbconfig = XMLUtil::getDBConfiguration () // 准备好数据库连接池“伪队列”
$this->poolsize = $poolsize
$this->dbpool = array () for($index = 1$index <= $this->poolsize$index ++) {
$conn = mysqli_connect ( $this->dbconfig ['host'], $this->dbconfig ['user'], $this->dbconfig ['password'], $this->dbconfig ['db'] ) or die ( "<mark>连接数据库失败！</mark><br />" )
array_push ( $this->dbpool, $conn )
}
} /**
* 从数据库连接池中获取一个数据库链接资源
*
* @throws ErrorException
* @return mixed
*/
public function getConn() { if (count ( $this->dbpool ) <= 0) { throw new ErrorException ( "<mark>数据库连接池中已无链接资源，请稍后重试!</mark>" )
} else { return array_pop ( $this->dbpool )
}
} /**
* 将用完的数据库链接资源放回到数据库连接池
*
* @param unknown $conn
* @throws ErrorException
*/
public function release($conn) { if (count ( $this->dbpool ) >= $this->poolsize) { throw new ErrorException ( "<mark>数据库连接池已满</mark><br />" )
} else {
array_push ( $this->dbpool, $conn )
}
}
}
<?php#
FileName="Connection_php_mysql.htm"
头三行内容都是被注释掉的，估计是个说明。这可能指的是文件名吧
#
Type="MYSQL"
告诉你类型为MYSQL
#
HTTP="true"
$hostname_conn_news
=
"localhost"
//主机地址
$database_conn_news
=
"sl"
//数据库名
$username_conn_news
=
"root"
//数据库帐号
$password_conn_news
=
"admin"
//数据库密码
$conn_news
=
mysql_pconnect($hostname_conn_news,
$username_conn_news,
$password_conn_news)
or
trigger_error(mysql_error(),E_USER_ERROR)
//传入参数连接数据库。失败则返回MYSQL错误信息。
?>
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）