From 751168b2deb799e92c5e08f2169fb1d359e7d4b2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=90=91=E6=9E=97?= <as2252258@163.com>
Date: Wed, 8 Jun 2022 16:00:54 +0800
Subject: [PATCH] modify plugin name

---
 kiri-engine/Pool/Connection.php | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/kiri-engine/Pool/Connection.php b/kiri-engine/Pool/Connection.php
index 3da9cba4..d242cf04 100644
--- a/kiri-engine/Pool/Connection.php
+++ b/kiri-engine/Pool/Connection.php
@@ -22,6 +22,9 @@ class Connection extends Component
 {
 
 
+	private array $master = [];
+
+
 	/**
 	 * @param Pool $pool
 	 * @param array $config
@@ -93,6 +96,9 @@ class Connection extends Component
 	public function get(mixed $config): ?PDO
 	{
 		$coroutineName = $config['cds'];
+		if (Db::inTransactionsActive() && isset($this->master[$coroutineName])) {
+			return $this->master[$coroutineName];
+		}
 		$minx = Config::get('databases.pool.min', 1);
 		return $this->pool->get($coroutineName, static function () use ($coroutineName, $config) {
 			$connect = Kiri::getDi()->create(PDO::class, [$config]);