异步MySQL客户端重连的代码有BUG

matyhtf · matyhtf · commit dc5b25dfa44b · 2016-04-21T14:25:56.000+08:00
diff --git a/libs/Swoole/Async/MySQL.php b/libs/Swoole/Async/MySQL.php
@@ -316,7 +316,8 @@ protected function doQuery($sql, callable $callback)
                 if ($mysqli->errno == 2013 or $mysqli->errno == 2006 or (isset($mysqli->_errno) and $mysqli->_errno == 2006))
                 {
                     $mysqli->close();
-                    $r = $mysqli->connect();
+                    $config = $this->config;
+                    $r = $mysqli->connect($config['host'], $config['user'], $config['password'], $config['database'], $config['port']);
                     if ($r === true)
                     {
                         continue;
@@ -351,7 +352,7 @@ function isFree() {
         return (!$this->work_pool && count($this->wait_queue) == 0) ? true : false;
 	}
 
-	function getConnectionNum() {
+	function getionNum() {
 		return $this->connection_num;
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -316,7 +316,8 @@ protected function doQuery($sql, callable $callback)`
`316`	`316`	`if ($mysqli->errno == 2013 or $mysqli->errno == 2006 or (isset($mysqli->_errno) and $mysqli->_errno == 2006))`
`317`	`317`	`{`
`318`	`318`	`$mysqli->close();`
`319`		`- $r = $mysqli->connect();`
	`319`	`+ $config = $this->config;`
	`320`	`+ $r = $mysqli->connect($config['host'], $config['user'], $config['password'], $config['database'], $config['port']);`
`320`	`321`	`if ($r === true)`
`321`	`322`	`{`
`322`	`323`	`continue;`
`@@ -351,7 +352,7 @@ function isFree() {`
`351`	`352`	`return (!$this->work_pool && count($this->wait_queue) == 0) ? true : false;`
`352`	`353`	`}`
`353`	`354`
`354`		`- function getConnectionNum() {`
	`355`	`+ function getionNum() {`
`355`	`356`	`return $this->connection_num;`
`356`	`357`	`}`
`357`	`358`