Fix MySQLPool example

Author: nox7

mysql-example.php

@@ -1,6 +1,9 @@
 <?php
-	require_once __DIR__ . "/classes/Async.php";
-	require_once __DIR__ . "/classes/AsyncMySQL/MySQLPool.php";
+
+	use AsyncMySQL\MySQLPool;
+
+	require_once __DIR__ . "/src/Async.php";
+	require_once __DIR__ . "/src/AsyncMySQL/MySQLPool.php";
 
 	header("content-type: text/plain");
 

src/AsyncMySQL/AsyncMySQL.php

@@ -1,6 +1,11 @@
 <?php
 	namespace AsyncMySQL;
 
+	use const MYSQLI_ASYNC;
+	use const MYSQLI_REPORT_ERROR;
+	use const MYSQLI_REPORT_STRICT;
+	use const MYSQLI_STORE_RESULT;
+
 	require_once __DIR__ . "/exceptions/OperationsOutOfSync.php";
 	require_once __DIR__ . "/exceptions/QueryTimedOut.php";
 
@@ -26,7 +31,7 @@ public function __construct(
 			public string $database,
 			public int $port = 3306
 		){
-			mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);
+			\mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);
 
 			$connection = new \mysqli($host, $user, $password, $database, $port);
 			$this->connection = $connection;
@@ -40,15 +45,15 @@ public function __construct(
 		 * Will return the result of the query.
 		 * @throws OperationsOutOfSync
 		 */
-		public function execute(string $query, array $namedArgs = []): Fiber{
+		public function execute(string $query, array $namedArgs = []): \Fiber{
 
 			if (!$this->isAvailable){
 				throw new OperationsOutOfSync("Cannot run execute on this AsyncMySQL object at this time. It is currently handling another query. Consider using the MySQLPool class.");
 			}
 
 			$this->isAvailable = false;
 
-			return new Fiber(function() use ($query, $namedArgs){
+			return new \Fiber(function() use ($query, $namedArgs){
 				if (count($namedArgs) > 0){
 					$query = $this->buildQueryFromNamedArgs($query, $namedArgs);
 				}
@@ -58,7 +63,7 @@ public function execute(string $query, array $namedArgs = []): Fiber{
 				$errors = [];
 				$rejections = [];
 				$beginTime = time();
-				Fiber::suspend();
+				\Fiber::suspend();
 
 				$numReadyQueries;
 				do{
@@ -67,7 +72,7 @@ public function execute(string $query, array $namedArgs = []): Fiber{
 						break;
 					}
 
-					Fiber::suspend();
+					\Fiber::suspend();
 				} while ((time() - $beginTime <= self::$defaultQueryTimeout));
 
 				$this->isAvailable = true;

src/AsyncMySQL/MySQLPool.php

@@ -24,10 +24,10 @@ public function __construct(
 		* Runs an asynchronous ::execute() on an available AsyncMySQL object.
 		* If none are available, will wait until one is.
 		*/
-		public function execute(string $query, array $namedArgs = []): Fiber{
+		public function execute(string $query, array $namedArgs = []): \Fiber{
 			$asyncMySQL = null;
 
-			return new Fiber(function() use ($query, $namedArgs){
+			return new \Fiber(function() use ($query, $namedArgs){
 				do{
 					foreach ($this->asyncMySQLs as $obj){
 						if ($obj->isAvailable){
@@ -37,11 +37,11 @@ public function execute(string $query, array $namedArgs = []): Fiber{
 					}
 
 					if ($asyncMySQL === null){
-						Fiber::suspend();
+						\Fiber::suspend();
 					}
 				} while ($asyncMySQL === null);
 
-				return Async::await($asyncMySQL->execute($query, $namedArgs));
+				return \Async::await($asyncMySQL->execute($query, $namedArgs));
 			});
 
 		}