feat: Added strict mode and fetch mode for Mysql client (swoft-cloud/swoft-component#208)

* 增加DB严格模式配置

* 增加配置读取单测

* Update SqlTest.php

* Update DbPoolProperties.php

* Remoe useless comments.

Author: limingxinleo

src/Driver/Mysql/MysqlConnection.php

@@ -14,6 +14,7 @@
 use Swoft\Db\AbstractDbConnection;
 use Swoft\Db\Bean\Annotation\Connection;
 use Swoft\Db\Exception\MysqlException;
+use Swoft\Db\Pool\Config\DbPoolProperties;
 use Swoole\Coroutine\Mysql;
 
 /**
@@ -59,17 +60,29 @@ public function createConnection()
         $options            = $this->parseUri($uri);
         $options['timeout'] = $this->pool->getTimeout();
 
+        /** @var DbPoolProperties $config */
+        $config     = $this->pool->getPoolConfig();
+        $strictType = $config->isStrictType();
+        $fetchMode  = $config->isFetchMode();
+
+        $serverConfig = [
+            'host'        => $options['host'],
+            'port'        => $options['port'],
+            'user'        => $options['user'],
+            'password'    => $options['password'],
+            'database'    => $options['database'],
+            'timeout'     => $options['timeout'],
+            'charset'     => $options['charset'],
+            'strict_type' => $strictType,
+        ];
+
+        if (version_compare(swoole_version(), '4.0', '>=')) {
+            $serverConfig['fetch_mode'] = $fetchMode;
+        }
+
         // init
         $mysql = new MySQL();
-        $mysql->connect([
-            'host'     => $options['host'],
-            'port'     => $options['port'],
-            'user'     => $options['user'],
-            'password' => $options['password'],
-            'database' => $options['database'],
-            'timeout'  => $options['timeout'],
-            'charset'  => $options['charset'],
-        ]);
+        $mysql->connect($serverConfig);
 
         // error
         if ($mysql->connected === false) {

src/Driver/Mysql/SyncMysqlConnection.php

@@ -15,6 +15,7 @@
 use Swoft\Db\Bean\Annotation\Connection;
 use Swoft\Db\Driver\DriverType;
 use Swoft\Db\Exception\MysqlException;
+use Swoft\Db\Pool\Config\DbPoolProperties;
 
 /**
  * Mysql sync connection
@@ -47,6 +48,9 @@ public function createConnection()
         $options            = $this->parseUri($uri);
         $options['timeout'] = $this->pool->getTimeout();
 
+        /** @var DbPoolProperties $config */
+        $config = $this->pool->getPoolConfig();
+
         $user    = $options['user'];
         $passwd  = $options['password'];
         $host    = $options['host'];
@@ -60,6 +64,12 @@ public function createConnection()
             \PDO::ATTR_TIMEOUT    => $timeout,
             \PDO::ATTR_PERSISTENT => true,
         ];
+
+        if ($config->isStrictType()) {
+            $pdoOptions[\PDO::ATTR_STRINGIFY_FETCHES] = false;
+            $pdoOptions[\PDO::ATTR_EMULATE_PREPARES]  = false;
+        }
+
         $dsn              = "mysql:host=$host;port=$port;dbname=$dbName;charset=$charset";
         $this->connection = new \PDO($dsn, $user, $passwd, $pdoOptions);
         $this->connection->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);

src/Pool/Config/DbPoolConfig.php

@@ -108,4 +108,16 @@ class DbPoolConfig extends DbPoolProperties
      * @var string
      */
     protected $driver = Driver::MYSQL;
+
+    /**
+     * @Value(name="${config.db.master.strictType}", env="${DB_STRICT_TYPE}")
+     * @var bool
+     */
+    protected $strictType = false;
+
+    /**
+     * @Value(name="${config.db.master.fetchMode}", env="${DB_FETCH_MODE}")
+     * @var bool
+     */
+    protected $fetchMode = true;
 }

src/Pool/Config/DbPoolProperties.php

@@ -14,12 +14,6 @@
 
 /**
  * The pool properties of database
- *
- * @uses      DbPoolProperties
- * @version   2018年01月27日
- * @author    stelin <phpcrazy@126.com>
- * @copyright Copyright 2010-2016 swoft software
- * @license   PHP Version 7.x {@link http://www.php.net/license/3_0.txt}
  */
 class DbPoolProperties extends PoolProperties
 {
@@ -31,10 +25,32 @@ class DbPoolProperties extends PoolProperties
     protected $driver = Driver::MYSQL;
 
     /**
-     * @return string
+     * 开启严格模式，返回的字段将自动转为数字类型
+     *
+     * @var bool
      */
+    protected $strictType = false;
+
+    /**
+     * 开启 Fetch 模式, 可类似于 PDO 一样使用 fetch/fetchAll 逐行获取或获取全部结果集
+     *
+     * @since Swoole 4.0
+     * @var bool
+     */
+    protected $fetchMode = true;
+
     public function getDriver(): string
     {
         return $this->driver;
     }
+
+    public function isStrictType(): bool
+    {
+        return $this->strictType;
+    }
+
+    public function isFetchMode(): bool
+    {
+        return $this->fetchMode;
+    }
 }

src/Pool/Config/DbSlavePoolConfig.php

@@ -108,4 +108,16 @@ class DbSlavePoolConfig extends DbPoolProperties
      * @var string
      */
     protected $driver = Driver::MYSQL;
+
+    /**
+     * @Value(name="${config.db.slave.strictType}", env="${DB_SLAVE_STRICT_TYPE}")
+     * @var bool
+     */
+    protected $strictType = false;
+
+    /**
+     * @Value(name="${config.db.slave.fetchMode}", env="${DB_SLAVE_FETCH_MODE}")
+     * @var bool
+     */
+    protected $fetchMode = true;
 }

test/Cases/Mysql/SqlTest.php

@@ -194,4 +194,21 @@ public function testTableNameIsDbKeywordByCo()
             $this->testTableNameIsDbKeyword();
         });
     }
+
+    public function testSqlQueryStrictType()
+    {
+        $result = Db::query('SELECT * FROM user LIMIT 1;', [], 'other')->getResult();
+        $id = $result[0]['id'];
+        $name = $result[0]['name'];
+
+        $this->assertTrue(is_int($id));
+        $this->assertTrue(is_string($name));
+    }
+
+    public function testSqlQueryStrictTypeByCo()
+    {
+        go(function () {
+            $this->testSqlQueryStrictType();
+        });
+    }
 }

test/Cases/PoolTest.php

@@ -14,6 +14,7 @@
 use SwoftTest\Db\Testing\Pool\DbPptPoolConfig;
 use SwoftTest\Db\Testing\Pool\DbSlaveEnvPoolConfig;
 use SwoftTest\Db\Testing\Pool\DbSlavePptConfig;
+use SwoftTest\Db\Testing\Pool\OtherDbConfig;
 use SwoftTest\Db\Testing\Pool\OtherDbPool;
 
 /**
@@ -91,6 +92,13 @@ public function testDbSlaveEnv()
         $this->assertEquals($pConfig->getMaxWait(), 10);
     }
 
+    public function testOtherConfig()
+    {
+        $config = bean(OtherDbConfig::class);
+        $this->assertTrue($config->isStrictType());
+        $this->assertTrue($config->isFetchMode());
+    }
+
     public function testMaxIdleTime()
     {
         $pool = App::getPool('idle.master');

test/Testing/Pool/OtherDbConfig.php

@@ -85,4 +85,10 @@ class OtherDbConfig extends DbPoolProperties
      * @var string
      */
     protected $driver = Driver::MYSQL;
+
+    /**
+     * @Value(name="${config.db.other.master.strictType}", env="${DB_OTHER_STRICT_TYPE}")
+     * @var bool
+     */
+    protected $strictType = false;
 }

test/Testing/Pool/OtherDbSlaveConfig.php

@@ -85,4 +85,10 @@ class OtherDbSlaveConfig extends DbPoolProperties
      * @var string
      */
     protected $driver = Driver::MYSQL;
+
+    /**
+     * @Value(name="${config.db.other.slave.strictType}", env="${DB_OTHER_SLAVE_STRICT_TYPE}")
+     * @var bool
+     */
+    protected $strictType = false;
 }

test/config/properties/db.php

@@ -49,6 +49,7 @@
             'maxActive'   => 1,
             'maxWait'     => 1,
             'timeout'     => 1,
+            'strictType'  => true,
         ],
 
         'slave' => [
@@ -61,6 +62,7 @@
             'maxActive'   => 1,
             'maxWait'     => 1,
             'timeout'     => 1,
+            'strictType'  => true,
         ],
     ],
 ];