PMM-12551 Another fix for new connection string.

percona · Mar 21, 2024 · c7da376 · c7da376
1 parent 2d55e0b
commit c7da376
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/qan-api2/db.go b/qan-api2/db.go
@@ -78,11 +78,8 @@ func createDB(dsn string) error {
 	if err != nil {
 		return err
 	}
-	q := clickhouseURL.Query()
-	databaseName := q.Get("database")
-	q.Set("database", "default")
-
-	clickhouseURL.RawQuery = q.Encode()
+	databaseName := strings.Replace(clickhouseURL.Path, "/", "", 1)
+	clickhouseURL.Path = "/default"
 
 	defaultDB, err := sqlx.Connect("clickhouse", clickhouseURL.String())
 	if err != nil {

diff --git a/qan-api2/db_test.go b/qan-api2/db_test.go
@@ -120,6 +120,6 @@ func TestCreateDbIfNotExists(t *testing.T) {
 
 		db := createDB(dsn)
 
-		require.Equal(t, db, nil, "Check connection after we create database")
+		require.Equal(t, nil, db, "Check connection after we create database")
 	})
 }