From ec5ecb560ee6396a5c53ebf559bf6291c8b09efb Mon Sep 17 00:00:00 2001 From: zhijian Date: Thu, 18 Apr 2024 17:47:57 +0800 Subject: [PATCH] postgres: fix postgres address parse --- 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 94375bc9c2a1..819528349161 100644 --- a/pkg/object/object_storage_test.go +++ b/pkg/object/object_storage_test.go @@ -926,7 +926,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 cdd51723dbf2..e17c73439f5b 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 != "" {