Avoid reusing closed DB connection. (#79)
Set DB connection to nil upon closing it.
This commit is contained in:
		
							parent
							
								
									f15f93f479
								
							
						
					
					
						commit
						87a379f663
					
				|  | @ -64,7 +64,10 @@ func (c *Cluster) initDbConn() (err error) { | ||||||
| func (c *Cluster) closeDbConn() (err error) { | func (c *Cluster) closeDbConn() (err error) { | ||||||
| 	if c.pgDb != nil { | 	if c.pgDb != nil { | ||||||
| 		c.logger.Debug("closing database connection") | 		c.logger.Debug("closing database connection") | ||||||
| 		return c.pgDb.Close() | 		if err = c.pgDb.Close(); err != nil { | ||||||
|  | 			c.logger.Errorf("could not close database connection: %v", err) | ||||||
|  | 		} | ||||||
|  | 		c.pgDb = nil | ||||||
| 	} | 	} | ||||||
| 	c.logger.Warning("attempted to close an empty db connection object") | 	c.logger.Warning("attempted to close an empty db connection object") | ||||||
| 	return nil | 	return nil | ||||||
|  |  | ||||||
		Loading…
	
		Reference in New Issue