diff --git a/source-postgres/.snapshots/TestConfigURI-Basic b/source-postgres/.snapshots/TestConfigURI-Basic index 916d2f44ec..6035dc435b 100644 --- a/source-postgres/.snapshots/TestConfigURI-Basic +++ b/source-postgres/.snapshots/TestConfigURI-Basic @@ -1,2 +1,2 @@ -postgres://will:secret1234@example.com:5432/somedb +postgres://will:secret1234@example.com:5432/somedb?application_name=estuary_flow config valid diff --git a/source-postgres/.snapshots/TestConfigURI-IncorrectSSL b/source-postgres/.snapshots/TestConfigURI-IncorrectSSL index 21d5381a60..2668daa1c1 100644 --- a/source-postgres/.snapshots/TestConfigURI-IncorrectSSL +++ b/source-postgres/.snapshots/TestConfigURI-IncorrectSSL @@ -1,2 +1,2 @@ -postgres://will:secret1234@example.com:5432/somedb?sslmode=whoops-this-isnt-right +postgres://will:secret1234@example.com:5432/somedb?application_name=estuary_flow&sslmode=whoops-this-isnt-right invalid 'sslmode' configuration: unknown setting "whoops-this-isnt-right" diff --git a/source-postgres/.snapshots/TestConfigURI-RequireSSL b/source-postgres/.snapshots/TestConfigURI-RequireSSL index 45ce8b198a..b181ea86e2 100644 --- a/source-postgres/.snapshots/TestConfigURI-RequireSSL +++ b/source-postgres/.snapshots/TestConfigURI-RequireSSL @@ -1,2 +1,2 @@ -postgres://will:secret1234@example.com:5432/somedb?sslmode=verify-full +postgres://will:secret1234@example.com:5432/somedb?application_name=estuary_flow&sslmode=verify-full config valid diff --git a/source-postgres/main.go b/source-postgres/main.go index 9502758025..6dad8cf025 100644 --- a/source-postgres/main.go +++ b/source-postgres/main.go @@ -227,6 +227,7 @@ func (c *Config) ToURI() string { uri.Path = "/" + c.Database } var params = make(url.Values) + params.Set("application_name", "estuary_flow") if c.Advanced.SSLMode != "" { params.Set("sslmode", c.Advanced.SSLMode) }