phpmysql异步_PHPSwoole异步MySQL客户端实现方法示例

本文实例讲述了PHP Swoole异步MysqL客户端实现方法。分享给大家供大家参考&＃xff0c;具体如下&＃xff1a;

使用版本&＃xff1a;1.8.6及以上

把官方文档的例子改写成了面向对象的形式&＃xff0c;示例如下&＃xff1a;

SwooleMysqL.PHP&＃xff1a;

class SwooleMysqL {

public $db &＃61; "";

public $server &＃61; [];

public function __construct() {

//实例化

$this->db &＃61; new swoole_MysqL();

//配置参数

$this->server &＃61; [

&＃39;host&＃39; &＃61;> &＃39;127.0.0.1&＃39;,&＃39;port&＃39; &＃61;> 3306,&＃39;user&＃39; &＃61;> &＃39;root&＃39;,&＃39;password&＃39; &＃61;> &＃39;xxooni&＃39;,&＃39;database&＃39; &＃61;> &＃39;lws&＃39;,&＃39;charset&＃39; &＃61;> &＃39;utf8&＃39;,&＃39;timeout&＃39; &＃61;> 2,// 可选&＃xff1a;连接超时时间(非查询超时时间)&＃xff0c;默认为SW_MysqL_CONNECT_TIMEOUT(1.0)

];

}

//执行sql语句操作

public function execute($sql) {

$this->db->connect($this->server,function($db,$res) use($sql) {

echo "连接MysqL...\n";

if($res &＃61;&＃61;&＃61; false) {

var_dump($db->connect_errno,$db->connect_error);

die;

}

$db->query($sql,$res){

if($res &＃61;&＃61;&＃61; false) {

var_dump($db->error,$db->errno);

}elseif($result &＃61;&＃61;&＃61; true) {

var_dump($db->affected_rows,$db->insert_id);

}

var_dump($res);

$db->close();

});

});

return true;

}

}

$obj &＃61; new SwooleMysqL();

$sql &＃61; &＃39;select &＃96;article_title&＃96; from &＃96;lws_article&＃96; where &＃96;article_id&＃96;&＃61;66&＃39;;

$res &＃61; $obj->execute($sql);

var_dump($res);

echo "lws\n";

运行结果&＃xff1a;

更多关于PHP相关内容感兴趣的读者可查看本站专题&＃xff1a;《PHP扩展开发教程》、《PHP网络编程技巧总结》、《PHP curl用法总结》、《PHP数组(Array)操作技巧大全》、《PHP数据结构与算法教程》、《PHP程序设计算法总结》及《PHP字符串(string)用法总结》

希望本文所述对大家PHP程序设计有所帮助。

总结

如果觉得编程之家网站内容还不错&＃xff0c;欢迎将编程之家网站推荐给程序员好友。

本图文内容来源于网友网络收集整理提供&＃xff0c;作为学习参考使用&＃xff0c;版权属于原作者。

如您喜欢交流学习经验&＃xff0c;点击链接加入交流1群&＃xff1a;1065694478(已满)交流2群&＃xff1a;163560250