From e2b56d0a09143bfbd54862baf603bd9c1ffdb369 Mon Sep 17 00:00:00 2001 From: Mark Sagi-Kazar Date: Mon, 26 Apr 2021 11:09:52 +0200 Subject: [PATCH] fix(storage/mysql): add missing port to the address Signed-off-by: Mark Sagi-Kazar --- storage/sql/config.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/storage/sql/config.go b/storage/sql/config.go index 0ce0f117..97ec6cb9 100644 --- a/storage/sql/config.go +++ b/storage/sql/config.go @@ -242,6 +242,10 @@ func (s *MySQL) open(logger log.Logger) (*conn, error) { if s.Host[0] != '/' { cfg.Net = "tcp" cfg.Addr = s.Host + + if s.Port != 0 { + cfg.Addr = net.JoinHostPort(s.Host, strconv.Itoa(int(s.Port))) + } } else { cfg.Net = "unix" cfg.Addr = s.Host