Swoole异步MySQL客户端

使用函数&＃xff1a;swoole_mysql

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

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

SwooleMysql.php&＃xff1a;

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;连接超时时间&＃xff08;非查询超时时间&＃xff09;&＃xff0c;默认为SW_MYSQL_CONNECT_TIMEOUT&＃xff08;1.0&＃xff09;];}//执行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, function($db, $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;