修改DB事务回滚BUG (swoft-cloud/swoft-component#173)

Author: limingxinleo

src/Driver/Mysql/MysqlConnection.php

@@ -106,12 +106,13 @@ public function execute(array $params = [])
     public function receive()
     {
         $result = $this->connection->recv();
+        $this->recv = true;
+
         if ($result === false) {
             throw new MysqlException('Mysql recv error，connectError=' . $this->connection->connect_error . ' error=' . $this->connection->error);
         }
         $this->connection->setDefer(false);
 
-        $this->recv   = true;
         $this->result = $result;
 
         return $result;

test/Cases/Mysql/SqlTest.php

@@ -142,4 +142,35 @@ public function testUpdateByCo($id)
             $this->testUpdate($id);
         });
     }
+
+    public function testErrorSql()
+    {
+        Db::beginTransaction();
+
+        try {
+            $user = new User();
+            $user->setName('limx');
+            $user->setSex(1);
+            $user->setAge(27);
+            $user->setDesc('Swoft');
+            $id = $user->save()->getResult();
+
+            $sql = 'SELECT des FROM `user` WHERE id = ?';
+            $res = Db::query($sql, [$id])->getResult();
+            $this->assertTrue(false);
+            Db::commit();
+        } catch (\Exception $ex) {
+            Db::rollback();
+
+            $user = User::findById($id)->getResult();
+            $this->assertNull($user);
+        }
+    }
+
+    public function testErrorSqlByCo()
+    {
+        go(function () {
+            $this->testErrorSql();
+        });
+    }
 }