修复判断事务时Db实例错误 (#532)

# Conflicts: # src/Db/Query/Query.php
imiphp · Jun 9, 2023 · a92c980 · a92c980
1 parent e1e1899
commit a92c980
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/src/Db/Query/Query.php b/src/Db/Query/Query.php
@@ -146,6 +146,11 @@ public function setOption($option): self
      */
     public function getDb(): IDb
     {
+        if (!$this->isInitDb)
+        {
+            $this->db = Db::getInstance($this->poolName, $this->queryType);
+        }
+
         return $this->db;
     }
 
@@ -892,7 +897,12 @@ public function setFieldDec(string $fieldName, float $decValue = 1): self
      */
     protected function isInTransaction(): bool
     {
-        return QueryType::WRITE === $this->queryType && Db::getInstance($this->poolName)->inTransaction();
+        if (QueryType::WRITE !== $this->queryType)
+        {
+            return false;
+        }
+
+        return $this->getDb()->inTransaction();
     }
 
     /**