Skip to content

Commit f616dae

Browse files
committed
Clean up namespace handling (#65555)
1 parent aae059d commit f616dae

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

airbyte-integrations/connectors/source-postgres/src/main/kotlin/io/airbyte/integrations/source/postgres/config/PostgresSourceConfiguration.kt

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ import java.net.URLDecoder
2424
import java.net.URLEncoder
2525
import java.nio.charset.StandardCharsets
2626
import java.time.Duration
27-
import org.postgresql.PGProperty
2827

2928
private val log = KotlinLogging.logger {}
3029

@@ -156,8 +155,7 @@ constructor(
156155
var encodedDatabaseName = URLEncoder.encode(pojo.database, StandardCharsets.UTF_8.name())
157156

158157
// Build JDBC URL.
159-
// TODO: handle schemas correctly
160-
val jdbcUrlFmt = "jdbc:postgresql://%s:%d/$encodedDatabaseName?${PGProperty.CURRENT_SCHEMA}=public"
158+
val jdbcUrlFmt = "jdbc:postgresql://%s:%d/$encodedDatabaseName"
161159

162160
// Internal configuration settings.
163161
val checkpointTargetInterval: Duration =

airbyte-integrations/connectors/source-postgres/src/main/resources/application.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ airbyte:
1919
memory-capacity-ratio: 0.6
2020
estimated-record-overhead-bytes: 16
2121
estimated-field-overhead-bytes: 16
22-
namespace-kind: SCHEMA # TODO: should be CATALOG_AND_SCHEMA
22+
namespace-kind: SCHEMA
2323
include-pseudo-columns: false
2424
check:
2525
jdbc:

0 commit comments

Comments
 (0)