1 Star 0 Fork 0

louislivi / SwooleMysqlPool

加入 Gitee
与超过 600 万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未指定开源许可证,未经作者的许可,此代码仅用于学习,不能用于其他用途。
克隆/下载
test.php 680 Bytes
一键复制 编辑 Web IDE 原始数据 按行查看 历史
louislivi 提交于 2018-09-13 16:16 . Create test.php
<?php
/**
* @param string $query
*
* @return array|bool
*/
function mysqlpool_query(string $query,string $db_name)
{
$swoole_mysql = new \Swoole\Coroutine\Client(SWOOLE_SOCK_TCP);
if (!$swoole_mysql->connect('127.0.0.1', 9510,0.5)) {
print_r("connect mysql pool failed. Error: {$swoole_mysql ->errCode}\n");
\Swoole\Coroutine::sleep(0.2);
$this ->query($query,$db_name);
}else{
$swoole_mysql->send(json_encode(['database' => $db_name,'query' => $query]));
$result = $swoole_mysql->recv();
$swoole_mysql->close();
return json_decode($result,true);
}
}
mysqlpool_query('select * from test','1_connect');

评论 ( 0 )

你可以在登录后,发表评论

PHP
1
https://gitee.com/louislivi/swoole_mysqlpool.git
git@gitee.com:louislivi/swoole_mysqlpool.git
louislivi
swoole_mysqlpool
SwooleMysqlPool
master

搜索帮助