format dsn

pingcap · May 28, 2020 · 36e8103 · 36e8103
1 parent 2ad6fc6
commit 36e8103
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/conn/basedb.go b/pkg/conn/basedb.go
@@ -17,6 +17,7 @@ import (
 	"context"
 	"database/sql"
 	"fmt"
+	"net/url"
 	"sync"
 
 	"github.com/pingcap/dm/dm/config"
@@ -58,7 +59,7 @@ func (d *DefaultDBProviderImpl) Apply(config config.DBConfig) (*BaseDB, error) {
 	}
 
 	for key, val := range config.Session {
-		dsn += fmt.Sprintf("&%s=\"%s\"", key, val)
+		dsn += fmt.Sprintf("&%s='%s'", key, url.QueryEscape(val))
 	}
 
 	db, err := sql.Open("mysql", dsn)