Add check to ensure we don't overwrite existing connections

This commit is contained in:
Brian Kassouf 2017-04-26 16:43:42 -07:00
parent f92d6868a0
commit 2e2d3827da

View File

@ -78,12 +78,17 @@ func (b *databaseBackend) getDBObj(name string) (dbplugin.Database, bool) {
// caches it in the connections map. The caller of this function needs to hold // caches it in the connections map. The caller of this function needs to hold
// the backend's write lock // the backend's write lock
func (b *databaseBackend) createDBObj(s logical.Storage, name string) (dbplugin.Database, error) { func (b *databaseBackend) createDBObj(s logical.Storage, name string) (dbplugin.Database, error) {
db, ok := b.connections[name]
if ok {
return db, nil
}
config, err := b.DatabaseConfig(s, name) config, err := b.DatabaseConfig(s, name)
if err != nil { if err != nil {
return nil, err return nil, err
} }
db, err := dbplugin.PluginFactory(config.PluginName, b.System(), b.logger) db, err = dbplugin.PluginFactory(config.PluginName, b.System(), b.logger)
if err != nil { if err != nil {
return nil, err return nil, err
} }