diff --git a/infra/driver/driver.go b/infra/driver/driver.go index 649bd64..2bf80e7 100644 --- a/infra/driver/driver.go +++ b/infra/driver/driver.go @@ -8,7 +8,7 @@ import ( func InitDriver(config model.DB) error { switch config.DBType { - case "mssql": + case model.ENGINE_TYPE_SQLSERVER: return InitMssqlDriver(config) } return grmi.NewBusinessError("不支持该类型的数据库") @@ -17,6 +17,6 @@ func InitDriver(config model.DB) error { func DestroyDriver(id int) { global.ETLDriver.Lock.Lock() defer global.ETLDriver.Lock.Unlock() - delete(global.ETLDriver.Map, id) _ = global.ETLDriver.Map[id].Close() + delete(global.ETLDriver.Map, id) } \ No newline at end of file