rename coroutine class

Signed-off-by: XieBiao <[email protected]>

Author: hhxsv5

src/Illuminate/Database/ConnectionFactory.php

@@ -24,7 +24,7 @@ protected function createConnection($driver, $connection, $database, $prefix = '
     {
         switch ($driver) {
             case 'sw-co-mysql':
-                return new CoroutineMySQLConnection($connection, $database, $prefix, $config);
+                return new SwooleMySQLConnection($connection, $database, $prefix, $config);
         }
         return parent::createConnection($driver, $connection, $database, $prefix, $config);
     }

src/Illuminate/Database/Connectors/CoroutineMySQLConnector.php

@@ -5,7 +5,7 @@
 use Illuminate\Support\Arr;
 use Illuminate\Database\Connectors\Connector;
 use Illuminate\Database\Connectors\ConnectorInterface;
-use Hhxsv5\LaravelS\Illuminate\Database\CoroutineMySQL;
+use Hhxsv5\LaravelS\Illuminate\Database\SwoolePDO;
 use Illuminate\Support\Str;
 
 class CoroutineMySQLConnector extends Connector implements ConnectorInterface
@@ -14,7 +14,7 @@ class CoroutineMySQLConnector extends Connector implements ConnectorInterface
      * @param string $dsn
      * @param array $config
      * @param array $options
-     * @return CoroutineMySQL
+     * @return SwoolePDO
      * @throws \Throwable
      */
     public function createConnection($dsn, array $config, array $options)
@@ -31,7 +31,7 @@ public function createConnection($dsn, array $config, array $options)
     /**
      * @param \Throwable $e
      * @param array $config
-     * @return CoroutineMySQL
+     * @return SwoolePDO
      * @throws \Throwable
      */
     protected function _tryAgainIfCausedByLostConnection($e, array $config)
@@ -44,11 +44,11 @@ protected function _tryAgainIfCausedByLostConnection($e, array $config)
 
     /**
      * @param array $config
-     * @return CoroutineMySQL
+     * @return SwoolePDO
      */
     public function connect(array $config)
     {
-        $connection = new CoroutineMySQL();
+        $connection = new SwoolePDO();
         $connection->connect([
             'host'        => Arr::get($config, 'host', '127.0.0.1'),
             'port'        => Arr::get($config, 'port', 3306),

…te/Database/CoroutineMySQLConnection.php …inate/Database/SwooleMySQLConnection.phpsrc/Illuminate/Database/CoroutineMySQLConnection.php renamed to src/Illuminate/Database/SwooleMySQLConnection.php src/Illuminate/Database/CoroutineMySQLConnection.php renamed to src/Illuminate/Database/SwooleMySQLConnection.php

@@ -4,30 +4,24 @@
 
 use Illuminate\Database\MySqlConnection;
 
-class CoroutineMySQLConnection extends MySqlConnection
+class SwooleMySQLConnection extends MySqlConnection
 {
     /**
      * The active swoole mysql connection.
      *
-     * @var CoroutineMySQL
+     * @var SwoolePDO
      */
     protected $pdo;
 
     /**
      * The active swoole mysql used for reads.
      *
-     * @var CoroutineMySQL
+     * @var SwoolePDO
      */
     protected $readPdo;
 
     public function getDriverName()
     {
         return 'Swoole Coroutine MySQL';
     }
-//
-//    protected function prepared($statement)
-//    {
-//        //TODO
-//        return $statement;
-//    }
 }

…c/Illuminate/Database/CoroutineMySQL.php src/Illuminate/Database/SwoolePDO.phpsrc/Illuminate/Database/CoroutineMySQL.php renamed to src/Illuminate/Database/SwoolePDO.php src/Illuminate/Database/CoroutineMySQL.php renamed to src/Illuminate/Database/SwoolePDO.php

@@ -5,7 +5,7 @@
 use Illuminate\Database\QueryException;
 use Swoole\Coroutine\MySQL as SwooleMySQL;
 
-class CoroutineMySQL extends \PDO
+class SwoolePDO extends \PDO
 {
     protected $coMySQL;
 
@@ -25,7 +25,7 @@ public function prepare($statement, $options = null)
         if ($oldStatement === false) {
             throw new QueryException($statement, [], new \Exception($this->coMySQL->error, $this->coMySQL->errno));
         }
-        return new CoroutineMySQLStatement($oldStatement);
+        return new SwoolePDOStatement($oldStatement);
     }
 
     public function beginTransaction()

…ate/Database/CoroutineMySQLStatement.php …luminate/Database/SwoolePDOStatement.phpsrc/Illuminate/Database/CoroutineMySQLStatement.php renamed to src/Illuminate/Database/SwoolePDOStatement.php src/Illuminate/Database/CoroutineMySQLStatement.php renamed to src/Illuminate/Database/SwoolePDOStatement.php

@@ -4,7 +4,7 @@
 
 use Swoole\Coroutine\MySQL\Statement as SwooleStatement;
 
-class CoroutineMySQLStatement extends \PDOStatement
+class SwoolePDOStatement extends \PDOStatement
 {
     protected $statement;
     protected $bindParams = [];