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)