Skip to content

Conversation

@chestnut-c
Copy link
Contributor

@chestnut-c chestnut-c commented Jul 22, 2025

Purpose of this pull request

  1. Optimize and extend each jdbc data source to rewrite getUpsertStatementByTableSchema to obtain specific field information of the table schema when generating upsert statements.
  2. Fix the problem that the vertica data source does not support the DUAL pseudo table like Oracle when rewriting,
  3. Fix the problem that the Vertica jdbc reports the [Vertica]VJDBC ERROR: Failed to find conversion function from unknown to int type inference exception by specifying the specific field type when writing with the MERGE INTO syntax.

close #9534
Refer to Vertica official documentation: https://docs.vertica.com/23.4.x/en/sql-reference/statements/merge/

Does this PR introduce any user-facing change?

No

How was this patch tested?

Abnormal before modification:
Clipboard_Screenshot_1753156454

Normal operation after modification:

Clipboard_Screenshot_1753164488 Clipboard_Screenshot_1753164506 Clipboard_Screenshot_1753164581

Check list

…e/seatunnel/connectors/seatunnel/jdbc/internal/dialect/vertica/VerticaDialect.java
Copy link
Member

@Hisoka-X Hisoka-X left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM if ci passes. Thanks @chestnut-c

Copy link
Contributor

@corgy-w corgy-w left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

TKS

@corgy-w corgy-w merged commit 7b4d051 into apache:dev Jul 23, 2025
5 checks passed
dybyte pushed a commit to dybyte/seatunnel that referenced this pull request Jul 23, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Bug] [Module Name] vertica sink 使用generate_sink_sql无法通过主键进行更新

3 participants