diff --git a/collector/collector.go b/collector/collector.go
index e06ef7d1..c643bd91 100644
--- a/collector/collector.go
+++ b/collector/collector.go
@@ -173,6 +173,7 @@ func (p PostgresCollector) Collect(ch chan<- prometheus.Metric) {
 		level.Error(p.logger).Log("msg", "Error opening connection to database", "err", err)
 		return
 	}
+	defer p.instance.Close()
 
 	wg := sync.WaitGroup{}
 	wg.Add(len(p.Collectors))
diff --git a/collector/probe.go b/collector/probe.go
index a7630272..4c0f0419 100644
--- a/collector/probe.go
+++ b/collector/probe.go
@@ -81,6 +81,7 @@ func (pc *ProbeCollector) Collect(ch chan<- prometheus.Metric) {
 		level.Error(pc.logger).Log("msg", "Error opening connection to database", "err", err)
 		return
 	}
+	defer pc.instance.Close()
 
 	wg := sync.WaitGroup{}
 	wg.Add(len(pc.collectors))