变更

2023-04-02 20:09:40 +08:00
parent 0f28608180
commit 735c077f46
1 changed files with 8 additions and 1 deletions
@@ -186,8 +186,15 @@ class Connection extends Component
 	 */
 	public function getPdo(): PDO
 	{
+		if (!Db::inTransactionsActive()) {
 			return $this->getMasterClient();
 		}
+		if (!Context::hasContext($this->cds)) {
+			return Context::setContext($this->cds, $this->getMasterClient());
+		} else {
+			return Context::getContext($this->cds);
+		}
+	}

 	/**
 	 * @return $this|bool