diff --git a/plugins/helper/database/connutil/sql.go b/plugins/helper/database/connutil/sql.go
index 2e34065d03..8a7f57e077 100644
--- a/plugins/helper/database/connutil/sql.go
+++ b/plugins/helper/database/connutil/sql.go
@@ -76,6 +76,9 @@ func (c *SQLConnectionProducer) Initialize(ctx context.Context, conf map[string]
 }
 
 func (c *SQLConnectionProducer) Connection(ctx context.Context) (interface{}, error) {
+	c.Lock()
+	defer c.Unlock()
+
 	if !c.Initialized {
 		return nil, ErrNotInitialized
 	}