PHP Swoole异步MySQL客户端实现方法
使用函数:swoole_mysql
使用版本:1.8.6及以上
把官方文档的例子改写成了面向对象的形式,示例如下:
SwooleMysql.php:
- <?php
- class SwooleMysql {
- public $db = "";
- public $server = [];
- public function __construct() {
- //实例化
- $this->db = new swoole_mysql();
- //配置参数
- $this->server = [
- 'host' => '127.0.0.1','port' => 3306,'user' => 'root','password' => 'xxooni','database' => 'lws','charset' => 'utf8','timeout' => 2,// 可选:连接超时时间(非查询超时时间),默认为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 === false) {
- var_dump($db->connect_errno,$db->connect_error);
- die;
- }
- $db->query($sql,$res){
- if($res === false) {
- var_dump($db->error,$db->errno);
- }elseif($result === true) {
- var_dump($db->affected_rows,$db->insert_id);
- }
- var_dump($res);
- $db->close();
- });
- });
- return true;
- }
- }
- $obj = new SwooleMysql();
- $sql = 'select `article_title` from `lws_article` where `article_id`=66';
- $res = $obj->execute($sql);
- var_dump($res);
- echo "lws\n";
运行结果:
更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP扩展开发教程》、《PHP网络编程技巧总结》、《php curl用法总结》、《PHP数组(Array)操作技巧大全》、《PHP数据结构与算法教程》、《php程序设计算法总结》及《php字符串(string)用法总结》
希望本文所述对大家PHP程序设计有所帮助。
THE END