|
@ -8,7 +8,7 @@ import ( |
|
|
|
|
|
|
|
|
func InitDriver(config model.DB) error { |
|
|
func InitDriver(config model.DB) error { |
|
|
switch config.DBType { |
|
|
switch config.DBType { |
|
|
case "mssql": |
|
|
|
|
|
|
|
|
case model.ENGINE_TYPE_SQLSERVER: |
|
|
return InitMssqlDriver(config) |
|
|
return InitMssqlDriver(config) |
|
|
} |
|
|
} |
|
|
return grmi.NewBusinessError("不支持该类型的数据库") |
|
|
return grmi.NewBusinessError("不支持该类型的数据库") |
|
@ -17,6 +17,6 @@ func InitDriver(config model.DB) error { |
|
|
func DestroyDriver(id int) { |
|
|
func DestroyDriver(id int) { |
|
|
global.ETLDriver.Lock.Lock() |
|
|
global.ETLDriver.Lock.Lock() |
|
|
defer global.ETLDriver.Lock.Unlock() |
|
|
defer global.ETLDriver.Lock.Unlock() |
|
|
delete(global.ETLDriver.Map, id) |
|
|
|
|
|
_ = global.ETLDriver.Map[id].Close() |
|
|
_ = global.ETLDriver.Map[id].Close() |
|
|
|
|
|
delete(global.ETLDriver.Map, id) |
|
|
} |
|
|
} |