diff --git a/kiri-engine/Pool/Connection.php b/kiri-engine/Pool/Connection.php
index f6607c6a..eeffcb75 100644
--- a/kiri-engine/Pool/Connection.php
+++ b/kiri-engine/Pool/Connection.php
@@ -108,6 +108,9 @@ class Connection extends Component
 		$pdo = $this->pool->get($coroutineName, static function () use ($coroutineName, $config) {
 			return Kiri::getDi()->create(PDO::class, [$config]);
 		}, $minx);
+		if (Db::inTransactionsActive() && !$pdo->inTransaction()) {
+			$pdo->beginTransaction();
+		}
 		return Context::setContext($config['cds'], $pdo);
 	}