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()