首先，将代码保存到一个文件，如：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
}
}
}
?>
其实不用一开始就关心conn.php，建议先写一个最简单的php脚本来验证MYSQL数据库的连接、查询、关闭功能是否正常，测试脚本示例如下：<?php
$mysqli = new mysqli('localhost', 'my_user', 'my_password', 'my_db')
if ($mysqli->connect_error) {
die('Connect Error (' . $mysqli->connect_errno . ') '
. $mysqli->connect_error)
}
if (mysqli_connect_error()) {
die('Connect Error (' . mysqli_connect_errno() . ') '
. mysqli_connect_error())
}
echo 'Success... ' . $mysqli->host_info . "\n"
$mysqli->close()
?>
如果测试通过了，我们再来看为什么需要conn.php文件——不可能把数据的IP地址、用户名、密码等参数写入每一个PHP文件，办法就是做一个简单的conn.php来存放这些内容，所有需要连接MYSQL的程序都引用conn.php进行工作，所以conn.php中只要有如下一行即可：
$mysqli = new mysqli('localhost', 'my_user', 'my_password', 'my_db')
在PHP-FPM处理HTTP请求时，有时会遇到一个请求需要进行多次MySQL查询（在报表类应用中比较常见）。通常我们会以串行方式查询：
$link = new mysqli()$rs1 = $link->query('SELECT * FROM table1')
while ($row = $rs1->fetch_row()) { ... }
$rs2 = $link->query('SELECT * FROM table2')
while ($row = $rs2->fetch_row()) { ... }
$rs3 = $link->query('SELECT * FROM table3')
while ($row = $rs3->fetch_row()) { ... }
串行查询方式有个缺点：在MySQL返回数据之前，PHP一直是处于空等的状态，不会继续往后执行。如果数据量大或者查询复杂，MySQL响应可能会比较慢，那么以串行方式查询会有一些延迟。给用户最直接的感受就是 Loading… 的圈圈一直打转。
那么有什么办法可以减少查询MySQL的时间？用多进程并行查询不行，因为PHP-FPM 中不允许用 pcntl_fork 一类的调用。
幸好还有 mysqlnd，mysqlnd提供了类似 stream_select 的机制（见 这篇文章） ，可以做到在单进程中对MySQL并行查询。这主要运用了mysqli_poll 和 reap_async_query 两个函数。
还是通过例子来介绍MySQL并行查询的实施方法。假设要并行地向MySQL发出10个查询，最基本的代码应该是这样的：
1. $links = []2. for ($i = 0 $i !== 10 $i++) {
3. $links[$i] = new mysqli('127.0.0.1', 'user', 'password', 'db1')
4. $links[$i]->query('SELECT SLEEP(1)', MYSQLI_ASYNC)
5. }
6. $allResult = []
7. while (!empty($links)) {
8. $reads = $links
9. $errors = $reject = []
10. if (!mysqli_poll($reads, $errors, $reject, null)) {
11. continue
12. }
13. foreach ($reads as $read) {
14. $idx = array_search($read, $links, true)
15. $allResult[$idx] = []
16. $result = $read->reap_async_query()
17. while ($row = $result->fetch_row()) {
18. $allResult[$idx][] = $row
19. }
20. $read->close()
21. unset($links[$idx])
22. }
23. }
解释下这段代码的含义：
2~5行，同时发起10个MySQL连接，并发出查询
注意query() 的第二个参数带上了 MYSQLI_ASYNC 表示非阻塞查询
10行，使用mysqli_poll 轮询10个连接的查询有无返回
mysqli_poll 的第一个参数$reads是个数组，包含需要轮询那些连接。mysqli_poll 执行完后，会改写$reads，改写后$reads包含的是那些已经有数据返回连接。
mysqli_poll的第四个参数，控制的是轮询的等待时间，单位是“秒”。如果像本例当中设置为null，那么mysqli_poll轮询是阻塞的：只有监听的连接中，任意一个连接有数据返回了，mysqli_poll才会返回。如果等待时间设置为0，那么每次执行mysqli_poll会立即返回，外层的while会频繁循环。
第11~19行，遍历已经有数据返回的连接
reap_async_query和普通query一样，返回的是mysqli_result，可以一行行fetch数据
20~21行，对于已经获得了数据的连接，下次mysqli_poll就不需要再轮询这个连接了，所以关闭连接，并从$links数组删除这个连接
当所有的连接都返回了数据，$links数组空了，while循环也就终止了。
使用并行查询的方式，可以大大缩短处理HTTP请求的时间，假设本例中的10个SQL查询，每个需要执行1秒。因为是并行，处理所有的查询，也只需要1秒左右。
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）