[
https://issues.apache.org/jira/browse/BEAM-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17531470#comment-17531470
]
Chamikara Madhusanka Jayalath commented on BEAM-14230:
------------------------------------------------------
More specifically, Python schema
[here|https://github.com/apache/beam/blob/2314da610c84a2c022bce6c77f44f67c1af05235/sdks/python/apache_beam/io/jdbc.py#L114]
currently need to have the same order as the Java schema
[here|https://github.com/apache/beam/blob/2314da610c84a2c022bce6c77f44f67c1af05235/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcSchemaIOProvider.java#L59].
> Python JDBC API don't recognize "statement" parameter
> -----------------------------------------------------
>
> Key: BEAM-14230
> URL: https://issues.apache.org/jira/browse/BEAM-14230
> Project: Beam
> Issue Type: Bug
> Components: cross-language
> Affects Versions: 2.35.0
> Reporter: Deepak Nagaraj
> Assignee: Pablo Estrada
> Priority: P2
> Fix For: 2.39.0
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> JDBC [write
> API|https://beam.apache.org/releases/pydoc/2.35.0/apache_beam.io.jdbc.html?highlight=jdbc#apache_beam.io.jdbc.WriteToJdbc]
> allow a "statement" parameter to pass custom INSERT statements (e.g.
> UPSERTs).
> However, when I pass a "statement" parameter in
> apache_beam.io.jdbc.WriteToJdbc(), I still see the usual INSERT coming in my
> Postgres logs.
> Additional context in this mailing list thread.
> https://lists.apache.org/thread/doy941o8f6lg5jq47vvftbcfg3849ztc
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
