From 4e3639b18fcd84b764925f8b21ab6b0f57ea6ef8 Mon Sep 17 00:00:00 2001 From: zhijian Date: Thu, 18 Apr 2024 18:45:36 +0800 Subject: [PATCH] postgres: fix postgres address parse (#4731) --- pkg/object/object_storage_test.go | 2 +- pkg/object/sql.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/object/object_storage_test.go b/pkg/object/object_storage_test.go index e16d4ec71d63..047b72247266 100644 --- a/pkg/object/object_storage_test.go +++ b/pkg/object/object_storage_test.go @@ -911,7 +911,7 @@ func TestPG(t *testing.T) { //skip mutate } func TestPGWithSearchPath(t *testing.T) { //skip mutate - _, err := newSQLStore("postgres", "localhost:5432/test?sslmode=disable&search_path=juicefs,public", "", "") + _, err := newSQLStore("postgres", "127.0.0.1:5432/test?sslmode=disable&search_path=juicefs,public", "", "") if !strings.Contains(err.Error(), "currently, only one schema is supported in search_path") { t.Fatalf("TestPGWithSearchPath error: %s", err) } diff --git a/pkg/object/sql.go b/pkg/object/sql.go index 21b7b1df1a3d..622f358eeeab 100644 --- a/pkg/object/sql.go +++ b/pkg/object/sql.go @@ -168,9 +168,9 @@ func newSQLStore(driver, addr, user, password string) (ObjectStorage, error) { uri = "postgres://" + uri driver = "pgx" - parse, err := url.Parse(addr) + parse, err := url.Parse(uri) if err != nil { - return nil, fmt.Errorf("parse url %s failed: %s", addr, err) + return nil, fmt.Errorf("parse url %s failed: %s", uri, err) } searchPath = parse.Query().Get("search_path") if searchPath != "" {