From f15faa57fee8b031879802be19f293e70a290d1c Mon Sep 17 00:00:00 2001 From: Lexman Date: Tue, 5 Feb 2019 15:40:00 -0800 Subject: [PATCH] adds port parameter (#6145) --- physical/mssql/mssql.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/physical/mssql/mssql.go b/physical/mssql/mssql.go index 7de3423f10..d0029dd160 100644 --- a/physical/mssql/mssql.go +++ b/physical/mssql/mssql.go @@ -44,6 +44,11 @@ func NewMSSQLBackend(conf map[string]string, logger log.Logger) (physical.Backen return nil, fmt.Errorf("missing server") } + port, ok := conf["port"] + if !ok { + port = "" + } + maxParStr, ok := conf["max_parallel"] var maxParInt int var err error @@ -98,6 +103,10 @@ func NewMSSQLBackend(conf map[string]string, logger log.Logger) (physical.Backen connectionString += ";password=" + password } + if port != "" { + connectionString += ";port=" + port + } + db, err := sql.Open("mssql", connectionString) if err != nil { return nil, errwrap.Wrapf("failed to connect to mssql: {{err}}", err)