这篇文章主要介绍了PHP Swoole异步MySQL客户端实现方法,结合实例形式分析了php操作Swoole扩展异步mysql操作的面向对象实现方式,需要的朋友可以参考下。

本文实例讲述了PHP Swoole异步MySQL客户端实现方法，分享给大家供大家参考，具体如下：

使用函数：swoole_mysql

使用版本：1.8.6及以上

把官方文档的例子改写成了面向对象的形式，示例如下：

SwooleMysql.php：

1. <?php 
2. class SwooleMysql { 
3.   public $db = ""; 
4.   public $server = []; 
5.   public function __construct() { 
6.     //实例化 
7.     $this->db = new swoole_mysql(); 
8.     //配置参数 
9.     $this->server = [ 
10.       'host' => '127.0.0.1', 
11.       'port' => 3306, 
12.       'user' => 'root', 
13.       'password' => 'xxooni', 
14.       'database' => 'lws', 
15.       'charset' => 'utf8', 
16.       'timeout' => 2, // 可选：连接超时时间（非查询超时时间），默认为SW_MYSQL_CONNECT_TIMEOUT（1.0） 
17.     ]; 
18.   } 
19.   //执行SQL语句操作 
20.   public function execute($sql) { 
21.     $this->db->connect($this->server, function($db, $res) use($sql) { 
22.       echo "连接MySQL...\n"; 
23.       if($res === false) { 
24.         var_dump($db->connect_errno, $db->connect_error); 
25.         die; 
26.       } 
27.       $db->query($sql, function($db, $res){ 
28.         if($res === false) { 
29.           var_dump($db->error, $db->errno); 
30.         }elseif($result === true) { 
31.           var_dump($db->affected_rows, $db->insert_id); 
32.         } 
33.         var_dump($res); 
34.         $db->close(); 
35.       }); 
36.     }); 
37.     return true; 
38.   } 
39. } 
40. $obj = new SwooleMysql(); 
41. $sql = 'select `article_title` from `lws_article` where `article_id`=66'; 
42. $res = $obj->execute($sql); 
43. var_dump($res); 
44. echo "lws\n"; 

运行结果：

Tags: Swoole PHP异步MySQL

分享到：