多并发php查询数据代码 多并发php查询数据代码是多少

PHP查询代码怎么写?

连接数据库

网站建设哪家好，找成都创新互联公司！专注于网页设计、网站建设、微信开发、微信小程序、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了达拉特免费建站欢迎大家使用！

代码如下

?php

$conn = @mysql_connect("localhost","root","root") or die ("database error");

mysql_select_db("DB",$conn);

if (isset($_POST['submit'])){

$num=$_POST['num'];

$sql="SELECT num FROM TEST WHERE num=$num";

$tt=mysql_query($sql,$conn);

$row = mysql_fetch_assoc($tt);

echo "num：".$row['num']."/br";

}

?

PHP + Mysql多个表并行查询如何实现

在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秒左右。

PHP中写一个数据库查询的类的方法代码要如何写

?php

if(!defined("INCLUDE_MYSQL_OK")) {

define("INCLUDE_MYSQL_OK","");

class MySQL_class {

var $debug = true;

var $db,

$id,

$result, /* 查询结果指针 */

$rows, /* 查询结果行数 */

$fields, /* 查询结果列数 */

$data, /* 数据结果 */

$arows, /* 发生作用的纪录行数目 */

$iid; /* 上次插入操作后，可能存在的"AUTO_INCREMENT"属性字段的值，如果为"0"，则为空 */

var $user, $pass, $host, $charset;

/*

* 请注意用户名和密码是否正确

*/

function Setup ($host, $user, $pass, $charset='utf8') {

$this-host = $host;

$this-user = $user;

$this-pass = $pass;

$this-charset = $charset;

}

function Connect ($db = "") {

global $CFG_MYSQL_INFO;

if (!$this-host) {

$this-host = $CFG_MYSQL_INFO["host"];

}

if (!$this-user) {

$this-user = $CFG_MYSQL_INFO["user"]; /* 在这里作修改 */

}

if (!$this-pass) {

$this-pass = $CFG_MYSQL_INFO["passwd"]; /* 在这里作修改 */

}

if (!$this-charset) {

$this-charset = "utf8"; /* 在这里作修改 */

}

if (empty($db))

$this-db = $CFG_MYSQL_INFO["database"];

else

$this-db = $db;

$this-id = @mysql_connect($this-host, $this-user, $this-pass);

if (!$this-id)

return false;

$this-SelectDB($this-db); /* 定位到指定数据库 */

$this-Query("SET NAMES '".$this-charset."'");

return true;

}

function Close(){

@mysql_close($this-id);

}

function SelectDB ($db) {

if(!@mysql_select_db($db, $this-id))

return false;

else

return true;

}

function Begin () {

$this-result = @mysql_query("START TRANSACTION WITH CONSISTENT SNAPSHOT", $this-id);

if (!$this-result)

return false;

return true;

}

function Commit () {

$this-result = @mysql_query("COMMIT", $this-id);

if (!$this-result)

return false;

return true;

}

function Rollback () {

$this-result = @mysql_query("ROLLBACK", $this-id);

if (!$this-result)

return false;

return true;

}

function Escape ($str) {

$escstr = mysql_escape_string($str);

return $escstr;

}

# 普通查询功能，主要用于返回结果是多条记录的情况

# 请使用 Fetch 方法取得每条记录信息

function Query ($query) {

$this-result = @mysql_query($query, $this-id);

if (!$this-result)

{

if ($this-debug)

MySQL_ErrorMsg ("不能执行查询(query): $query");

else

return false;

}

$this-rows = @mysql_num_rows($this-result);

$this-fields = @mysql_num_fields($this-result);

if (!$this-rows) return false;

return true;

}

function QuerySql ($query) {

$ret = @mysql_query($query, $this-id);

if ($ret === false)

{

if ($this-debug)

MySQL_ErrorMsg ("不能执行查询(query): $query");

else

return false;

}

$this-result = $ret;

$this-rows = @mysql_num_rows($this-result);

$this-fields = @mysql_num_fields($this-result);

return true;

}

# 如果查询结果为单条记录时使用，返回结果存储于数组 data 中

function QueryRow ($query) {

$this-result = @mysql_query($query, $this-id);

if (!$this-result)

{

if ($this-debug)

MySQL_ErrorMsg ("不能执行查询(query): $query");

else

return false;

}

$this-rows = @mysql_num_rows($this-result);

$this-data = @mysql_fetch_array($this-result, MYSQL_ASSOC);

//MySQL_ErrorMsg ("不能从查询结果中取得数据 $query");

if (!$this-result || !$this-rows)

return false;

return true;

}

# 移动到指定记录行，将该行结果储存于数组 data 中

function Fetch ($row) {

if(!@mysql_data_seek($this-result, $row))

//MySQL_ErrorMsg ("不能定位到指定数据行 $row");

return false;

$this-data = @mysql_fetch_array($this-result, MYSQL_ASSOC);

//MySQL_ErrorMsg ("不能提取指定数据行数据 $row");

if (!$this-data)

return false;

return true;

}

/* 以下方法将作用于 arows */

/* 此方法将作用于 iid */

function Insert ($query) {

$this-result = @mysql_query($query, $this-id);

if (!$this-result)

{

if ($this-debug)

MySQL_ErrorMsg ("不能执行查询(query): $query");

else

return false;

}

$this-arows = @mysql_affected_rows($this-id);

$this-iid = @mysql_insert_id($this-id);

return true;

}

function Update ($query) {

$this-result = @mysql_query($query, $this-id);

if (!$this-result)

{

if ($this-debug)

MySQL_ErrorMsg ("不能执行查询(query): $query");

else

return false;

}

$this-arows = @mysql_affected_rows($this-id);

if (!$this-arows || $this-arows == -1)

return false;

return true;

}

function Delete ($query) {

$this-result = @mysql_query($query, $this-id);

if (!$this-result)

{

if ($this-debug)

MySQL_ErrorMsg ("不能执行查询(query): $query");

else

return false;

}

$this-arows = @mysql_affected_rows($this-id);

return true;

}

function Error (){

return mysql_error()."(".mysql_errno().")";

}

function Errno (){

return mysql_errno();

}

}

/*

* MySQL_ErrorMsg

* 输出错误信息

*/

function MySQL_ErrorMsg ($msg) {

# 关闭可能影响字符显示的HTML代码

echo("/ul/dl/ol\n");

echo("/table/script\n");

# 错误信息

$text = "font color=\"#000000\" style=\"font-size: 9pt; line-height: 12pt\"p系统提示：".$msg."br";

$text .= "错误信息：";

$text .= mysql_error()."br";

$text .= "错误代码：".mysql_errno()."brbr";

$text .= "请稍候再试，如果问题仍然存在，请与 a href=\"mailto:wuqiong@igenus.org\"系统管理员/a 联系！";

$text .= "/font\n";

die($text);

}

}

?

一些细节的地方自己修改吧 主要是我在别的文件专门定义了全局变量，你看一遍，把应改的地方改一下就好了