From af9c0e0599d7040aedf60357e42cc6a3ea5e28a8 Mon Sep 17 00:00:00 2001
From: zhangxin <xin.zhang@le-it.com.cn>
Date: Tue, 28 Dec 2021 21:03:58 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=9B=B4=E6=96=B0=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E5=BA=93=E9=85=8D=E7=BD=AE=E6=97=B6=20=E9=94=80?=
 =?UTF-8?q?=E6=AF=81=E5=88=9D=E5=A7=8B=E5=8C=96=E4=B8=8D=E6=88=90=E5=8A=9F?=
 =?UTF-8?q?=E7=9A=84bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 services/etl/implments/DB.service.impl.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/services/etl/implments/DB.service.impl.go b/services/etl/implments/DB.service.impl.go
index 6c4528e..eaa539e 100644
--- a/services/etl/implments/DB.service.impl.go
+++ b/services/etl/implments/DB.service.impl.go
@@ -193,6 +193,10 @@ func (impl *DBServiceImplement) UpdateOne(entity *model.DB) error {
 	err = driver.InitDriver(*entity)
 	if err != nil {
 		_ = session.Rollback()
+		innerErr := driver.InitDriver(*record)
+		if innerErr != nil {
+			return grmi.NewBusinessError("初始化原数据库失败, error:" + err.Error())
+		}
 		return err
 	}
 	_ = session.Commit()